| /external/chromium_org/net/quic/congestion_control/ |
| 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_->OnIncomingQuicCongestionFeedbackFrame(feedback, clock_.Now()
[all...] |
| 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_->TimeUntilSend(clock_.Now()
[all...] |
| 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_->TimeUntilSend(now, transmission_type
[all...] |
| 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_.TimeUntilSend(send_clock_.Now()
[all...] |
| /external/chromium_org/content/child/appcache/ |
| 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_->Send(new AppCacheHostMsg_SwapCache(host_id, &result))
[all...] |
| 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/ |
| 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());
|
| power_monitor_message_broadcaster.h | 34 IPC::Sender* sender_; member in class:content::PowerMonitorMessageBroadcaster
|
| /external/chromium_org/content/browser/appcache/ |
| 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/ |
| window_proxy.cc | 31 if (!sender_->Send(new AutomationMsg_WindowViewBounds(
43 sender_->Send(new AutomationMsg_SetWindowBounds(handle_, bounds, &result));
|
| 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_->Send(new AutomationMsg_DomOperation(handle_, frame_xpath
[all...] |
| 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_->Send
[all...] |
| /external/chromium_org/content/child/ |
| 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_->Send(new BlobHostMsg_RevokePublicURL(url))
[all...] |
| /external/chromium_org/chrome/browser/drive/ |
| 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_.get()
[all...] |
| 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_->StartRequestWithRetry(request)
[all...] |
| /external/chromium_org/content/renderer/ |
| dom_automation_controller.h | 115 sender_ = sender;
119 IPC::Sender* sender_; member in class:content::DomAutomationController
|
| 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(
|
| 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(
|
| renderer_webcookiejar_impl.h | 18 : sender_(sender) {
39 RenderViewImpl* sender_; member in class:content::RendererWebCookieJarImpl
|
| /external/chromium_org/google_apis/drive/ |
| 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/ |
| 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_, Send
[all...] |
| /external/chromium_org/remoting/jingle_glue/ |
| 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/ |
| 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/ |
| 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/ |
| dom_storage_dispatcher.cc | 35 : pending_count_(0), sender_(sender) {}
38 void Shutdown() { sender_ = NULL; }
56 RenderThreadImpl* sender_; member in class:content::__anon10856::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_->AddFilter(throttling_filter_.get())
[all...] |
