/external/chromium_org/net/quic/congestion_control/ |
H A D | tcp_cubic_sender_test.cc | 43 sender_(new TcpCubicSenderPeer(&clock_, true, 51 QuicByteCount bytes_to_send = sender_->AvailableSendWindow(); 54 sender_->OnPacketSent(clock_.Now(), sequence_number_++, bytes_in_packet, 58 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), NOT_RETRANSMISSION, 67 sender_->OnPacketAcked(acked_sequence_number_, kDefaultTCPMSS, rtt_); 76 scoped_ptr<TcpCubicSenderPeer> sender_; member in class:net::test::TcpCubicSenderTest 85 EXPECT_EQ(kDefaultWindowTCP, sender_->AvailableSendWindow()); 86 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); 88 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 92 sender_ [all...] |
H A D | fix_rate_test.cc | 33 sender_(new FixRateSender(&clock_)), 42 scoped_ptr<FixRateSender> sender_; member in class:net::test::FixRateTest 61 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback, clock_.Now(), 63 EXPECT_EQ(300000, sender_->BandwidthEstimate().ToBytesPerSecond()); 64 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 66 sender_->OnPacketSent(clock_.Now(), 1, kDefaultMaxPacketSize, 68 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(), 70 sender_->OnPacketSent(clock_.Now(), 2, kDefaultMaxPacketSize, 72 sender_->OnPacketSent(clock_.Now(), 3, 600, NOT_RETRANSMISSION, 75 sender_ [all...] |
H A D | pacing_sender.cc | 11 : sender_(sender), 22 sender_->SetMaxPacketSize(max_packet_size); 26 sender_->SetFromConfig(config, is_server); 33 sender_->OnIncomingQuicCongestionFeedbackFrame( 41 sender_->OnPacketAcked(acked_sequence_number, acked_bytes, rtt); 46 sender_->OnPacketLost(sequence_number, ack_receive_time); 66 return sender_->OnPacketSent(sent_time, sequence_number, bytes, 71 sender_->OnRetransmissionTimeout(); 76 sender_->OnPacketAbandoned(sequence_number, abandoned_bytes); 85 sender_ [all...] |
H A D | inter_arrival_sender_test.cc | 26 sender_(&send_clock_), 39 while (sender_.TimeUntilSend(send_clock_.Now(), 46 sender_.OnPacketSent(send_clock_.Now(), sequence_number_, bytes_in_packet, 50 EXPECT_FALSE(sender_.TimeUntilSend(send_clock_.Now(), 56 sender_.OnPacketAcked( 79 sender_.OnIncomingQuicCongestionFeedbackFrame(feedback, send_clock_.Now(), 101 sender_.OnIncomingQuicCongestionFeedbackFrame(feedback, send_clock_.Now(), 116 InterArrivalSender sender_; member in class:net::test::InterArrivalSenderTest 126 EXPECT_TRUE(sender_.TimeUntilSend(send_clock_.Now(), 132 send_clock_.AdvanceTime(sender_ [all...] |
/external/chromium_org/content/child/appcache/ |
H A D | appcache_backend_proxy.cc | 12 sender_->Send(new AppCacheHostMsg_RegisterHost(host_id)); 16 sender_->Send(new AppCacheHostMsg_UnregisterHost(host_id)); 21 sender_->Send(new AppCacheHostMsg_SetSpawningHostId( 30 sender_->Send(new AppCacheHostMsg_SelectCache( 38 sender_->Send(new AppCacheHostMsg_SelectCacheForWorker( 45 sender_->Send(new AppCacheHostMsg_SelectCacheForSharedWorker( 52 sender_->Send(new AppCacheHostMsg_MarkAsForeignEntry( 59 sender_->Send(new AppCacheHostMsg_GetStatus(host_id, &status)); 65 sender_->Send(new AppCacheHostMsg_StartUpdate(host_id, &result)); 71 sender_ [all...] |
H A D | appcache_backend_proxy.h | 18 explicit AppCacheBackendProxy(IPC::Sender* sender) : sender_(sender) {} 20 IPC::Sender* sender() const { return sender_; } 49 IPC::Sender* sender_; member in class:content::AppCacheBackendProxy
|
/external/chromium_org/content/browser/ |
H A D | power_monitor_message_broadcaster.cc | 15 : sender_(sender) { 28 sender_->Send(new PowerMonitorMsg_PowerStateChange(on_battery_power)); 32 sender_->Send(new PowerMonitorMsg_Suspend()); 36 sender_->Send(new PowerMonitorMsg_Resume());
|
H A D | power_monitor_message_broadcaster.h | 34 IPC::Sender* sender_; member in class:content::PowerMonitorMessageBroadcaster
|
/external/chromium_org/content/browser/appcache/ |
H A D | appcache_frontend_proxy.cc | 12 : sender_(sender) { 17 sender_->Send(new AppCacheMsg_CacheSelected(host_id, info)); 22 sender_->Send(new AppCacheMsg_StatusChanged(host_ids, status)); 28 sender_->Send(new AppCacheMsg_EventRaised(host_ids, event_id)); 34 sender_->Send(new AppCacheMsg_ProgressEventRaised( 41 sender_->Send(new AppCacheMsg_ErrorEventRaised( 48 sender_->Send(new AppCacheMsg_LogMessage(host_id, log_level, message)); 53 sender_->Send(new AppCacheMsg_ContentBlocked(host_id, manifest_url));
|
/external/chromium_org/chrome/test/automation/ |
H A D | window_proxy.cc | 31 if (!sender_->Send(new AutomationMsg_WindowViewBounds( 43 sender_->Send(new AutomationMsg_SetWindowBounds(handle_, bounds, &result));
|
H A D | tab_proxy.cc | 37 bool succeeded = sender_->Send( 51 return sender_->Send(new AutomationMsg_TabIndex(handle_, index)); 70 bool succeeded = sender_->Send(new AutomationMsg_Find(handle_, 95 sender_->Send(new AutomationMsg_NavigateToURLBlockUntilNavigationsComplete( 112 sender_->Send(new AutomationMsg_GoBackBlockUntilNavigationsComplete( 129 sender_->Send(new AutomationMsg_GoForwardBlockUntilNavigationsComplete( 140 sender_->Send(new AutomationMsg_Reload(handle_, &navigate_response)); 154 sender_->Send(new AutomationMsg_TabURL(handle_, &succeeded, url)); 163 sender_->Send(new AutomationMsg_NavigationAsync(handle_, 236 if (!sender_ [all...] |
H A D | browser_proxy.cc | 29 if (!sender_->Send(new AutomationMsg_ActivateTab( 46 if (!sender_->Send(new AutomationMsg_BringBrowserToFront( 60 sender_->Send(new AutomationMsg_AppendTab(handle_, tab_url, 76 if (!sender_->Send(new AutomationMsg_ActiveTabIndex( 95 sender_->Send(new AutomationMsg_Tab(handle_, tab_index, &tab_handle)); 101 tab = new TabProxy(sender_, tracker_, tab_handle); 129 if (!sender_->Send(new AutomationMsg_TabCount( 152 if (!sender_->Send(new AutomationMsg_Type(handle_, &type_as_int))) 165 if (!sender_->Send(new AutomationMsg_WaitForTabCountToBecome( 196 return sender_ [all...] |
/external/chromium_org/content/child/ |
H A D | webblobregistry_impl.cc | 36 : sender_(sender) { 46 sender_->Send(new BlobHostMsg_StartBuilding(uuid_str)); 65 sender_->Send( 76 sender_->Send( 90 sender_->Send( 98 sender_->Send(new BlobHostMsg_FinishBuilding( 103 sender_->Send(new BlobHostMsg_IncrementRefCount(uuid.utf8())); 107 sender_->Send(new BlobHostMsg_DecrementRefCount(uuid.utf8())); 112 sender_->Send(new BlobHostMsg_RegisterPublicURL(url, uuid.utf8())); 116 sender_ [all...] |
/external/chromium_org/chrome/browser/drive/ |
H A D | gdata_wapi_service.cc | 145 if (sender_.get()) 146 sender_->auth_service()->RemoveObserver(this); 158 sender_.reset(new RequestSender( 167 sender_->auth_service()->AddObserver(this); 201 return sender_->StartRequestWithRetry( 202 new GetResourceListRequest(sender_.get(), 218 return sender_->StartRequestWithRetry( 219 new GetResourceListRequest(sender_.get(), 235 return sender_->StartRequestWithRetry( 236 new GetResourceListRequest(sender_ [all...] |
H A D | drive_api_service.cc | 303 if (sender_.get()) 304 sender_->auth_service()->RemoveObserver(this); 318 sender_.reset(new RequestSender( 326 sender_->auth_service()->AddObserver(this); 357 sender_.get(), url_generator_, 363 return sender_->StartRequestWithRetry(request); 381 sender_.get(), url_generator_, 389 return sender_->StartRequestWithRetry(request); 400 sender_.get(), url_generator_, 406 return sender_ [all...] |
/external/chromium_org/content/renderer/ |
H A D | dom_automation_controller.h | 115 sender_ = sender; 119 IPC::Sender* sender_; member in class:content::DomAutomationController
|
H A D | dom_automation_controller.cc | 22 : sender_(NULL), 48 if (!sender_) { 96 bool succeeded = sender_->Send( 115 if (!sender_) { 127 result->Set(sender_->Send( 140 if (!sender_) { 151 result->Set(sender_->Send(
|
H A D | renderer_webcookiejar_impl.cc | 25 sender_->Send(new ViewHostMsg_SetCookie( 32 sender_->Send(new ViewHostMsg_GetCookies( 47 sender_->Send(new ViewHostMsg_GetRawCookies( 68 sender_->Send(new ViewHostMsg_DeleteCookie(url, cookie_name_utf8)); 75 sender_->Send(new ViewHostMsg_CookiesEnabled(
|
/external/chromium_org/google_apis/drive/ |
H A D | base_requests_unittest.cc | 82 sender_.reset(new RequestSender(new DummyAuthService, 104 scoped_ptr<RequestSender> sender_; member in class:google_apis::BaseRequestsTest 156 sender_->StartRequestWithRetry( 158 sender_.get(), 174 sender_->StartRequestWithRetry( 176 sender_.get(), 192 sender_->StartRequestWithRetry( 194 sender_.get(),
|
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_host_tcp_unittest.cc | 29 EXPECT_CALL(sender_, Send( 35 &sender_, 0, P2P_SOCKET_TCP_CLIENT, NULL)); 38 &sender_, 0, P2P_SOCKET_STUN_TCP_CLIENT, NULL)); 65 MockIPCSender sender_; member in class:content::P2PSocketHostTcpTestBase 90 EXPECT_CALL(sender_, Send( 121 EXPECT_CALL(sender_, Send( 146 EXPECT_CALL(sender_, Send(MatchPacketMessage(packet1))) 148 EXPECT_CALL(sender_, Send(MatchPacketMessage(packet2))) 150 EXPECT_CALL(sender_, Send(MatchPacketMessage(packet3))) 168 EXPECT_CALL(sender_, Sen [all...] |
H A D | socket_host_tcp_server_unittest.cc | 95 &sender_, 0, P2P_SOCKET_TCP_CLIENT)); 98 EXPECT_CALL(sender_, Send( 113 MockIPCSender sender_; member in class:content::P2PSocketHostTcpServerTest 125 EXPECT_CALL(sender_, Send(MatchIncomingSocketMessage(addr))) 149 EXPECT_CALL(sender_, Send(MatchIncomingSocketMessage(addr1))) 151 EXPECT_CALL(sender_, Send(MatchIncomingSocketMessage(addr2)))
|
/external/chromium_org/remoting/jingle_glue/ |
H A D | iq_sender_unittest.cc | 52 sender_.reset(new IqSender(&signal_strategy_)); 54 static_cast<SignalStrategy::Listener*>(sender_.get()))); 66 request_ = sender_->SendIq(kType, kTo, iq_body.Pass(), base::Bind( 83 scoped_ptr<IqSender> sender_; member in class:remoting::IqSenderTest 102 EXPECT_TRUE(sender_->OnSignalStrategyIncomingStanza(response.get())); 136 EXPECT_FALSE(sender_->OnSignalStrategyIncomingStanza(response.get())); 154 EXPECT_TRUE(sender_->OnSignalStrategyIncomingStanza(response.get()));
|
/external/chromium/chrome/browser/importer/ |
H A D | firefox_importer_unittest_utils_mac.cc | 70 : got_result(false), sender_(NULL) {} 73 sender_ = sender; 91 if (sender_) 92 sender_->Send(new Msg_Decryptor_Quit()); 118 IPC::Message::Sender* sender_; // weak member in class:FFDecryptorServerChannelListener 215 : sender_(NULL) {} 218 sender_ = sender; 223 sender_->Send(new Msg_Decryptor_InitReturnCode(ret)); 228 sender_->Send(new Msg_Decryptor_Response(unencrypted_str)); 252 IPC::Message::Sender* sender_; member in class:FFDecryptorClientChannelListener [all...] |
/external/chromium_org/chrome/utility/importer/ |
H A D | firefox_importer_unittest_utils_mac.cc | 77 : got_result(false), sender_(NULL) {} 80 sender_ = sender; 98 if (sender_) 99 sender_->Send(new Msg_Decryptor_Quit()); 125 IPC::Sender* sender_; // weak member in class:FFDecryptorServerChannelListener 226 : sender_(NULL) {} 229 sender_ = sender; 234 sender_->Send(new Msg_Decryptor_InitReturnCode(ret)); 239 sender_->Send(new Msg_Decryptor_Response(unencrypted_str)); 263 IPC::Sender* sender_; member in class:FFDecryptorClientChannelListener [all...] |
/external/chromium_org/content/renderer/dom_storage/ |
H A D | dom_storage_dispatcher.cc | 35 : pending_count_(0), sender_(sender) {} 38 void Shutdown() { sender_ = NULL; } 56 RenderThreadImpl* sender_; member in class:content::__anon8450::MessageThrottlingFilter 66 DCHECK(sender_); 67 if (!sender_) { 74 sender_->Send(message); 76 sender_->Send(new DOMStorageHostMsg_FlushMessages); 171 RenderThreadImpl* sender_; member in class:content::DomStorageDispatcher::ProxyImpl 178 : sender_(sender), 180 sender_ [all...] |