Searched refs:sender_ (Results 1 - 25 of 67) sorted by relevance

123

/external/chromium_org/net/quic/congestion_control/
H A Dtcp_cubic_sender_test.cc43 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 Dfix_rate_test.cc33 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 Dpacing_sender.cc11 : 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 Dinter_arrival_sender_test.cc26 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 Dappcache_backend_proxy.cc12 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 Dappcache_backend_proxy.h18 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 Dpower_monitor_message_broadcaster.cc15 : 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 Dpower_monitor_message_broadcaster.h34 IPC::Sender* sender_; member in class:content::PowerMonitorMessageBroadcaster
/external/chromium_org/content/browser/appcache/
H A Dappcache_frontend_proxy.cc12 : 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 Dwindow_proxy.cc31 if (!sender_->Send(new AutomationMsg_WindowViewBounds(
43 sender_->Send(new AutomationMsg_SetWindowBounds(handle_, bounds, &result));
H A Dtab_proxy.cc37 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 Dbrowser_proxy.cc29 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 Dwebblobregistry_impl.cc36 : 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 Dgdata_wapi_service.cc145 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 Ddrive_api_service.cc303 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 Ddom_automation_controller.h115 sender_ = sender;
119 IPC::Sender* sender_; member in class:content::DomAutomationController
H A Ddom_automation_controller.cc22 : 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 Drenderer_webcookiejar_impl.cc25 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 Dbase_requests_unittest.cc82 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 Dsocket_host_tcp_unittest.cc29 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 Dsocket_host_tcp_server_unittest.cc95 &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 Diq_sender_unittest.cc52 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 Dfirefox_importer_unittest_utils_mac.cc70 : 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 Dfirefox_importer_unittest_utils_mac.cc77 : 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 Ddom_storage_dispatcher.cc35 : 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...]

Completed in 2144 milliseconds

123