Home
last modified time | relevance | path

Searched refs:dispatcher_ (Results 1 – 25 of 166) sorted by relevance

1234567

/system/connectivity/shill/
Dresult_aggregator_unittest.cc66 &dispatcher_, kTimeoutMilliseconds); in InitializeResultAggregatorWithTimeout()
70 EventDispatcherForTest dispatcher_; member in shill::ResultAggregatorTestWithDispatcher
79 StrictMock<MockEventDispatcher> dispatcher_; member in shill::ResultAggregatorTestWithMockDispatcher
135 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kTimeoutMilliseconds)); in TEST_F()
137 Bind(&ResultAggregatorTest::ReportResult, Unretained(this)), &dispatcher_, in TEST_F()
146 dispatcher_.DispatchPendingEvents(); // Invoke timeout callback. in TEST_F()
156 dispatcher_.DispatchPendingEvents(); // Invoke timeout callback. in TEST_F()
165 &dispatcher_, kTimeoutMilliseconds)); in TEST_F()
177 dispatcher_.DispatchPendingEvents(); in TEST_F()
Ddaemon_task_unittest.cc69 void RunMessageLoop() { dispatcher_->DispatchForever(); } in RunMessageLoop()
73 dispatcher_->PostTask(base::MessageLoop::QuitWhenIdleClosure()); in Quit()
85 dispatcher_(new EventDispatcherForTest()), in DaemonTaskTest()
87 metrics_(new MockMetrics(dispatcher_)), in DaemonTaskTest()
88 manager_(new MockManager(control_, dispatcher_, metrics_)), in DaemonTaskTest()
92 device_info_(control_, dispatcher_, metrics_, manager_) { in DaemonTaskTest()
104 daemon_.dispatcher_.reset(dispatcher_); // Passes ownership in SetUp()
133 EventDispatcherForTest* dispatcher_; member in shill::DaemonTaskTest
194 dispatcher_->PostTask( in TEST_F()
Dpassive_link_monitor_unittest.cc87 link_monitor_(connection_, &dispatcher_, observer_.result_callback()), in PassiveLinkMonitorTest()
135 MockEventDispatcher dispatcher_; member in shill::PassiveLinkMonitorTest
153 EXPECT_CALL(dispatcher_, CreateReadyHandler(_, IOHandler::kModeInput, _)) in TEST_F()
155 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)).Times(1); in TEST_F()
230 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)).Times(0); in TEST_F()
231 EXPECT_CALL(dispatcher_, PostTask(_)).Times(1); in TEST_F()
243 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)).Times(1); in TEST_F()
244 EXPECT_CALL(dispatcher_, PostTask(_)).Times(0); in TEST_F()
258 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)).Times(0); in TEST_F()
259 EXPECT_CALL(dispatcher_, PostTask(_)).Times(1); in TEST_F()
Ddaemon_task.cc99 dispatcher_.reset(new EventDispatcher()); in Init()
101 control_.reset(new BinderControl(dispatcher_.get())); in Init()
103 control_.reset(new ChromeosDBusControl(dispatcher_.get())); in Init()
108 metrics_.reset(new Metrics(dispatcher_.get())); in Init()
117 manager_.reset(new Manager(control_.get(), dispatcher_.get(), metrics_.get(), in Init()
151 dispatcher_->PostTask( in TerminationActionsCompleted()
171 dhcp_provider_->Init(control_.get(), dispatcher_.get(), metrics_.get()); in Start()
172 process_manager_->Init(dispatcher_.get()); in Start()
Dpassive_link_monitor.cc50 dispatcher_(dispatcher), in PassiveLinkMonitor()
75 dispatcher_->PostDelayedTask(monitor_cycle_timeout_callback_.callback(), in Start()
95 dispatcher_->CreateReadyHandler( in StartArpClient()
136 dispatcher_->PostDelayedTask(monitor_cycle_timeout_callback_.callback(), in CycleTimeoutHandler()
149 dispatcher_->PostTask(monitor_completed_callback_.callback()); in CycleTimeoutHandler()
Dconnection_diagnostics.cc156 dispatcher_(dispatcher), in ConnectionDiagnostics()
164 connection_, dispatcher_, in ConnectionDiagnostics()
168 icmp_session_(new IcmpSession(dispatcher_)), in ConnectionDiagnostics()
220 dispatcher_->PostTask( in StartAfterPortalDetection()
317 dispatcher_->PostTask(Bind(&ConnectionDiagnostics::PingDNSServers, in StartAfterPortalDetectionInternal()
336 dispatcher_->PostTask( in StartAfterPortalDetectionInternal()
353 dispatcher_, Bind(&ConnectionDiagnostics::OnDNSResolutionComplete, in ResolveTargetServerIPAddress()
401 icmp_session_factory_->CreateIcmpSession(dispatcher_)))) in PingDNSServers()
459 dispatcher_->PostDelayedTask(route_query_timeout_callback_.callback(), in FindRouteToHost()
498 dispatcher_->PostTask(Bind(&ConnectionDiagnostics::CheckIpCollision, in FindArpTableEntry()
[all …]
Dvirtual_device_unittest.cc45 : metrics_(&dispatcher_), in VirtualDeviceTest()
46 manager_(&control_, &dispatcher_, &metrics_), in VirtualDeviceTest()
48 &dispatcher_, in VirtualDeviceTest()
63 EventDispatcher dispatcher_; member in shill::VirtualDeviceTest
Dicmp_session.cc51 dispatcher_(dispatcher), in IcmpSession()
69 if (!dispatcher_) { in Start()
80 echo_reply_handler_.reset(dispatcher_->CreateInputHandler( in Start()
86 dispatcher_->PostDelayedTask(timeout_callback_.callback(), in Start()
90 dispatcher_->PostTask(Bind(&IcmpSession::TransmitEchoRequestTask, in Start()
156 dispatcher_->PostDelayedTask( in TransmitEchoRequestTask()
Dicmp_session_unittest.cc71 IcmpSessionTest() : icmp_session_(&dispatcher_) {} in IcmpSessionTest()
95 EXPECT_CALL(dispatcher_, CreateInputHandler(icmp_->socket(), _, _)); in StartAndVerify()
96 EXPECT_CALL(dispatcher_, PostDelayedTask(_, GetTimeoutSeconds() * 1000)); in StartAndVerify()
97 EXPECT_CALL(dispatcher_, PostTask(_)); in StartAndVerify()
173 StrictMock<MockEventDispatcher> dispatcher_; member in shill::IcmpSessionTest
189 IcmpSession session(&dispatcher_); in TEST_F()
201 EXPECT_CALL(dispatcher_, CreateInputHandler(_, _, _)).Times(0); in TEST_F()
202 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)).Times(0); in TEST_F()
203 EXPECT_CALL(dispatcher_, PostTask(_)).Times(0); in TEST_F()
244 EXPECT_CALL(dispatcher_, in TEST_F()
[all …]
Ddns_client_unittest.cc129 &dispatcher_, in CreateClient()
168 EXPECT_CALL(dispatcher_, in StartValidRequest()
172 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kAresWaitMS)); in StartValidRequest()
208 EXPECT_CALL(dispatcher_, PostTask(_)); in ExpectPostCompletionTask()
232 StrictMock<MockEventDispatcher> dispatcher_; member in shill::DNSClientTest
310 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kAresWaitMS)); in TEST_F()
321 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kAresWaitMS)); in TEST_F()
332 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kAresWaitMS)); in TEST_F()
406 EXPECT_CALL(dispatcher_, in TEST_F()
409 EXPECT_CALL(dispatcher_, PostDelayedTask(_, kAresWaitMS)); in TEST_F()
[all …]
Dconnection_health_checker.cc89 dispatcher_(dispatcher), in ConnectionHealthChecker()
98 dispatcher_, in ConnectionHealthChecker()
157 dispatcher_, in AddRemoteURL()
213 dispatcher_, in SetConnection()
267 dispatcher_->PostTask(report_result_); in NextHealthCheckSample()
272 dispatcher_->PostTask(report_result_); in NextHealthCheckSample()
277 dispatcher_->PostTask(report_result_); in NextHealthCheckSample()
339 dispatcher_->PostDelayedTask(verify_sent_data_callback_.callback(), in OnConnectionComplete()
370 dispatcher_->PostDelayedTask(verify_sent_data_callback_.callback(), in VerifySentData()
Dconnection_health_checker_unittest.cc85 device_info_(&control_, &dispatcher_, nullptr, nullptr), in ConnectionHealthCheckerTest()
141 &dispatcher_, in SetUp()
244 EXPECT_EQ(&dispatcher_, health_checker_->dispatcher_); in ExpectReset()
318 EventDispatcherForTest dispatcher_; member in shill::ConnectionHealthCheckerTest
577 dispatcher_.DispatchPendingEvents(); in TEST_F()
587 dispatcher_.DispatchPendingEvents(); in TEST_F()
596 dispatcher_.DispatchPendingEvents(); in TEST_F()
624 dispatcher_.DispatchPendingEvents(); in TEST_F()
638 dispatcher_.DispatchPendingEvents(); in TEST_F()
653 dispatcher_.DispatchPendingEvents(); in TEST_F()
[all …]
Ddns_server_tester.cc52 dispatcher_(dispatcher), in DNSServerTester()
63 dispatcher_, in DNSServerTester()
80 dispatcher_->PostDelayedTask(start_attempt_.callback(), delay_ms); in StartAttempt()
/system/connectivity/shill/pppoe/
Dpppoe_service_unittest.cc53 : metrics_(&dispatcher_), in PPPoEServiceTest()
54 manager_(&control_interface_, &dispatcher_, &metrics_), in PPPoEServiceTest()
56 &dispatcher_, in PPPoEServiceTest()
63 &dispatcher_, in PPPoEServiceTest()
67 &dispatcher_, in PPPoEServiceTest()
78 dispatcher_.DispatchPendingEvents(); in ~PPPoEServiceTest()
92 EventDispatcherForTest dispatcher_; member in shill::PPPoEServiceTest
147 &control_interface_, &dispatcher_, &metrics_, &manager_, kLinkName, 0); in TEST_F()
195 &control_interface_, &dispatcher_, &metrics_, &manager_, "ppp0", 0); in TEST_F()
/system/connectivity/shill/cellular/
Dmodem_info_unittest.cc40 : metrics_(&dispatcher_), in ModemInfoTest()
41 manager_(&control_interface_, &dispatcher_, &metrics_), in ModemInfoTest()
42 modem_info_(&control_interface_, &dispatcher_, &metrics_, &manager_) {} in ModemInfoTest()
46 EventDispatcherForTest dispatcher_; member in shill::ModemInfoTest
Dactive_passive_out_of_credits_detector_unittest.cc52 : modem_info_(nullptr, &dispatcher_, &metrics_, &manager_), in ActivePassiveOutOfCreditsDetectorTest()
110 EventDispatcherForTest dispatcher_; member in shill::ActivePassiveOutOfCreditsDetectorTest
134 dispatcher_.DispatchPendingEvents(); in TEST_F()
139 dispatcher_.DispatchPendingEvents(); in TEST_F()
157 dispatcher_.DispatchPendingEvents(); in TEST_F()
162 dispatcher_.DispatchPendingEvents(); in TEST_F()
183 dispatcher_.DispatchPendingEvents(); in TEST_F()
195 dispatcher_.DispatchPendingEvents(); in TEST_F()
209 dispatcher_.DispatchPendingEvents(); in TEST_F()
222 dispatcher_.DispatchPendingEvents(); in TEST_F()
[all …]
Dmodem_info.h50 EventDispatcher* dispatcher() const { return dispatcher_; } in dispatcher()
63 dispatcher_ = dispatcher; in set_event_dispatcher()
86 EventDispatcher* dispatcher_; variable
/system/connectivity/shill/ethernet/
Dethernet_eap_service_unittest.cc43 : metrics_(&dispatcher_), in EthernetEapServiceTest()
44 manager_(&control_, &dispatcher_, &metrics_), in EthernetEapServiceTest()
46 &dispatcher_, in EthernetEapServiceTest()
57 MockEventDispatcher dispatcher_; member in shill::EthernetEapServiceTest
Dethernet_eap_provider_unittest.cc39 : metrics_(&dispatcher_), in EthernetEapProviderTest()
40 manager_(&control_, &dispatcher_, &metrics_), in EthernetEapProviderTest()
41 provider_(&control_, &dispatcher_, &metrics_, &manager_) {} in EthernetEapProviderTest()
53 MockEventDispatcher dispatcher_; member in shill::EthernetEapProviderTest
87 &dispatcher_, in TEST_F()
103 &dispatcher_, in TEST_F()
Dethernet_eap_provider.cc33 dispatcher_(dispatcher), in EthernetEapProvider()
61 dispatcher_, in CreateTemporaryService()
69 dispatcher_, in CreateTemporaryServiceFromProfile()
77 dispatcher_, in Start()
/system/connectivity/shill/dhcp/
Ddhcp_provider.cc68 dispatcher_(nullptr), in DHCPProvider()
87 dispatcher_ = dispatcher; in Init()
109 dispatcher_, in CreateIPv4Config()
123 dispatcher_, in CreateIPv6Config()
148 dispatcher_->PostDelayedTask(base::Bind(&DHCPProvider::RetireUnboundPID, in UnbindPID()
Ddhcp_provider_unittest.cc50 provider_->dispatcher_ = &dispatcher_; in DHCPProviderTest()
66 StrictMock<MockEventDispatcher> dispatcher_; member in shill::DHCPProviderTest
111 EXPECT_CALL(dispatcher_, PostDelayedTask(_, _)); // TODO(pstew): crbug/502320 in TEST_F()
/system/connectivity/shill/vpn/
Dthird_party_vpn_driver_unittest.cc44 : device_info_(&control_, &dispatcher_, &metrics_, &manager_), in ThirdPartyVpnDriverTest()
45 metrics_(&dispatcher_), in ThirdPartyVpnDriverTest()
46 manager_(&control_, &dispatcher_, &metrics_), in ThirdPartyVpnDriverTest()
47 driver_(new ThirdPartyVpnDriver(&control_, &dispatcher_, &metrics_, in ThirdPartyVpnDriverTest()
50 service_(new MockVPNService(&control_, &dispatcher_, &metrics_, in ThirdPartyVpnDriverTest()
52 device_(new MockVirtualDevice(&control_, &dispatcher_, &metrics_, in ThirdPartyVpnDriverTest()
76 MockEventDispatcher dispatcher_; member in shill::ThirdPartyVpnDriverTest
106 EXPECT_CALL(dispatcher_, CreateInputHandler(fd, _, _)) in TEST_F()
246 new MockVirtualDevice(&control_, &dispatcher_, &metrics_, &manager_, in TEST_F()
/system/connectivity/shill/binder/
Dbinder_control.cc62 dispatcher_(dispatcher), in BinderControl()
95 dispatcher_->PostTask(registration_done_callback); in RegisterManagerObject()
145 return new ChromeosSupplicantProcessProxy(dispatcher_, proxy_bus_, in CreateSupplicantProcessProxy()
172 return new ChromeosDHCPCDListener(proxy_bus_, dispatcher_, provider); in CreateDHCPCDListener()
/system/connectivity/shill/dbus/
Dchromeos_dbus_control.cc92 : dispatcher_(dispatcher), in ChromeosDBusControl()
212 return new ChromeosPowerManagerProxy(dispatcher_, in CreatePowerManagerProxy()
225 return new ChromeosSupplicantProcessProxy(dispatcher_, in CreateSupplicantProcessProxy()
256 return new ChromeosDHCPCDListener(proxy_bus_, dispatcher_, provider); in CreateDHCPCDListener()
293 return new ChromeosDBusObjectManagerProxy(dispatcher_, in CreateDBusObjectManagerProxy()
308 return new ChromeosModemManagerProxy(dispatcher_, in CreateModemManagerProxy()
396 return new ChromeosWiMaxManagerProxy(dispatcher_, in CreateWiMaxManagerProxy()

1234567