| /system/update_engine/common/ |
| D | mock_http_fetcher.cc | 29 using brillo::MessageLoop;
35 CHECK(timeout_id_ == MessageLoop::kTaskIdNull) << in ~MockHttpFetcher()
56 return timeout_id_ != MessageLoop::kTaskIdNull; in SendData()
68 return timeout_id_ != MessageLoop::kTaskIdNull; in SendData()
81 return timeout_id_ != MessageLoop::kTaskIdNull; in SendData()
84 if (timeout_id_ != MessageLoop::kTaskIdNull) { in SendData()
89 timeout_id_ = MessageLoop::current()->PostDelayedTask( in SendData()
101 timeout_id_ = MessageLoop::current()->PostDelayedTask( in TimeoutCallback()
106 timeout_id_ = MessageLoop::kTaskIdNull; in TimeoutCallback()
116 MessageLoop::current()->CancelTask(timeout_id_); in TerminateTransfer()
[all …]
|
| D | cpu_limiter.cc | 44 if (manage_shares_id_ != brillo::MessageLoop::kTaskIdNull) { in StartLimiter()
48 manage_shares_id_ = brillo::MessageLoop::current()->PostDelayedTask( in StartLimiter()
56 if (manage_shares_id_ != brillo::MessageLoop::kTaskIdNull) { in StopLimiter()
59 brillo::MessageLoop::current()->CancelTask(manage_shares_id_); in StopLimiter()
60 manage_shares_id_ = brillo::MessageLoop::kTaskIdNull; in StopLimiter()
85 manage_shares_id_ = brillo::MessageLoop::kTaskIdNull; in StopLimiterCallback()
|
| D | http_fetcher.cc | 22 using brillo::MessageLoop;
29 if (no_resolver_idle_id_ != MessageLoop::kTaskIdNull) { in ~HttpFetcher()
30 MessageLoop::current()->CancelTask(no_resolver_idle_id_); in ~HttpFetcher()
31 no_resolver_idle_id_ = MessageLoop::kTaskIdNull; in ~HttpFetcher()
56 no_resolver_idle_id_ = MessageLoop::current()->PostTask( in ResolveProxiesForUrl()
72 no_resolver_idle_id_ = MessageLoop::kTaskIdNull; in ProxiesResolved()
|
| D | libcurl_http_fetcher.cc | 34 using brillo::MessageLoop;
392 MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
418 MessageLoop::current()->PostTask( in CurlPerformOnce()
443 MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
567 MessageLoop::WatchMode watch_modes[2] = { in SetupMessageLoopSources()
568 MessageLoop::WatchMode::kWatchRead, in SetupMessageLoopSources()
569 MessageLoop::WatchMode::kWatchWrite, in SetupMessageLoopSources()
579 MessageLoop::current()->CancelTask(fd_task_it->second); in SetupMessageLoopSources()
590 fd_task_maps_[t][fd] = MessageLoop::current()->WatchFileDescriptor( in SetupMessageLoopSources()
607 if (timeout_id_ == MessageLoop::kTaskIdNull) { in SetupMessageLoopSources()
[all …]
|
| D | http_fetcher_unittest.cc | 54 using brillo::MessageLoop;
388 MessageLoop::current()->BreakLoop(); in TransferComplete()
524 MessageLoop::current()->BreakLoop(); in TransferComplete()
539 MessageLoop::TaskId* my_id) { in UnpausingTimeoutCallback()
543 *my_id = MessageLoop::current()->PostDelayedTask( in UnpausingTimeoutCallback()
560 MessageLoop::TaskId callback_id; in TYPED_TEST()
605 MessageLoop::current()->BreakLoop(); in TransferComplete()
622 MessageLoop::current()->BreakLoop(); in EndLoop()
630 MessageLoop::TaskId* my_id) { in AbortingTimeoutCallback()
633 *my_id = MessageLoop::current()->PostTask( in AbortingTimeoutCallback()
[all …]
|
| D | subprocess.cc | 38 using brillo::MessageLoop;
129 MessageLoop::current()->CancelTask(record->stdout_task_id); in OnStdoutReady()
130 record->stdout_task_id = MessageLoop::kTaskIdNull; in OnStdoutReady()
145 MessageLoop::current()->CancelTask(record->stdout_task_id); in ChildExitedCallback()
146 record->stdout_task_id = MessageLoop::kTaskIdNull; in ChildExitedCallback()
200 record->stdout_task_id = MessageLoop::current()->WatchFileDescriptor( in ExecFlags()
203 MessageLoop::WatchMode::kWatchRead, in ExecFlags()
|
| D | cpu_limiter.h | 61 brillo::MessageLoop::TaskId manage_shares_id_{
62 brillo::MessageLoop::kTaskIdNull};
|
| D | subprocess_unittest.cc | 47 using brillo::MessageLoop;
85 MessageLoop::current()->BreakLoop(); in ExpectedResults()
96 MessageLoop::current()->BreakLoop(); in ExpectedEnvVars()
117 MessageLoop::current()->BreakLoop(); in ExpectedDataOnPipe()
248 MessageLoop::WatchMode::kWatchRead, in TEST_F()
|
| /system/update_engine/ |
| D | proxy_resolver.cc | 22 using brillo::MessageLoop;
31 if (idle_callback_id_ != MessageLoop::kTaskIdNull) { in ~DirectProxyResolver()
37 MessageLoop::current()->CancelTask(idle_callback_id_); in ~DirectProxyResolver()
38 idle_callback_id_ = MessageLoop::kTaskIdNull; in ~DirectProxyResolver()
45 idle_callback_id_ = MessageLoop::current()->PostTask( in GetProxiesForUrl()
57 idle_callback_id_ = MessageLoop::kTaskIdNull; in ReturnCallback()
|
| D | dbus_test_utils.h | 44 if (callback_connected_task_ != brillo::MessageLoop::kTaskIdNull) in ~MockSignalHandler()
45 brillo::MessageLoop::current()->CancelTask(callback_connected_task_); in ~MockSignalHandler()
60 callback_connected_task_ = brillo::MessageLoop::current()->PostTask( in GrabCallbacks()
68 callback_connected_task_ = brillo::MessageLoop::kTaskIdNull; in OnCallbackConnected()
72 brillo::MessageLoop::TaskId callback_connected_task_{
73 brillo::MessageLoop::kTaskIdNull};
|
| D | chrome_browser_proxy_resolver.cc | 34 using brillo::MessageLoop;
68 MessageLoop::current()->CancelTask(timer.second); in ~ChromeBrowserProxyResolver()
69 timer.second = MessageLoop::kTaskIdNull; in ~ChromeBrowserProxyResolver()
88 MessageLoop::TaskId timer = MessageLoop::current()->PostDelayedTask( in GetProxiesForUrl()
115 MessageLoop::current()->CancelTask(it->second); in DeleteUrlState()
|
| D | chrome_browser_proxy_resolver_unittest.cc | 36 using brillo::MessageLoop;
115 MessageLoop::current()->BreakLoop(); in CheckResponseResolved()
121 MessageLoop::current()->BreakLoop(); in CheckResponseNoReply()
144 MessageLoop::current()->PostDelayedTask( in RunTest()
155 MessageLoop::current()->Run(); in RunTest()
|
| D | real_system_state.cc | 36 using brillo::MessageLoop;
175 MessageLoop::current()->PostDelayedTask( in StartUpdater()
183 MessageLoop::current()->PostTask(FROM_HERE, base::Bind( in StartUpdater()
188 MessageLoop::current()->PostTask(FROM_HERE, base::Bind( in StartUpdater()
|
| D | proxy_resolver.h | 74 brillo::MessageLoop::TaskId idle_callback_id_{
75 brillo::MessageLoop::kTaskIdNull};
|
| /system/connectivity/dhcp_client/ |
| D | message_loop_event_dispatcher.cc | 29 if (!base::MessageLoop::current()) in PostTask()
31 base::MessageLoop::current()->PostTask(FROM_HERE, task); in PostTask()
37 if (!base::MessageLoop::current()) in PostDelayedTask()
39 base::MessageLoop::current()->PostDelayedTask( in PostDelayedTask()
|
| /system/connectivity/apmanager/ |
| D | event_dispatcher.cc | 40 if (!base::MessageLoop::current()) in PostTask()
42 base::MessageLoop::current()->PostTask(FROM_HERE, task); in PostTask()
48 if (!base::MessageLoop::current()) in PostDelayedTask()
50 base::MessageLoop::current()->PostDelayedTask( in PostDelayedTask()
|
| /system/update_engine/update_manager/ |
| D | generic_variables_unittest.cc | 29 using brillo::MessageLoop;
175 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
183 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
203 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
208 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
213 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
218 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
|
| D | real_device_policy_provider.cc | 31 using brillo::MessageLoop;
45 MessageLoop::current()->CancelTask(scheduled_refresh_); in ~RealDevicePolicyProvider()
72 MessageLoop::current()->CancelTask(scheduled_refresh_); in OnPropertyChangedCompletedSignal()
73 scheduled_refresh_ = MessageLoop::kTaskIdNull; in OnPropertyChangedCompletedSignal()
93 scheduled_refresh_ = MessageLoop::current()->PostDelayedTask( in RefreshDevicePolicyAndReschedule()
|
| D | evaluation_context_unittest.cc | 37 using brillo::MessageLoop;
221 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
228 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
243 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
255 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
257 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
272 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
274 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
299 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
318 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
[all …]
|
| D | update_manager_unittest.cc | 47 using brillo::MessageLoop;
257 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
274 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
281 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
302 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
311 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
319 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
|
| D | evaluation_context.cc | 35 using brillo::MessageLoop;
92 MessageLoop::current()->CancelTask(timeout_event_); in RemoveObserversAndTimeout()
93 timeout_event_ = MessageLoop::kTaskIdNull; in RemoveObserversAndTimeout()
118 timeout_event_ = MessageLoop::kTaskIdNull; in OnTimeout()
219 timeout_event_ = MessageLoop::current()->PostDelayedTask( in RunOnValueChangeOrTimeout()
|
| /system/update_engine/payload_consumer/ |
| D | postinstall_runner_action.cc | 50 using brillo::MessageLoop;
200 progress_task_ = MessageLoop::current()->WatchFileDescriptor( in PerformPartitionPostinstall()
203 MessageLoop::WatchMode::kWatchRead, in PerformPartitionPostinstall()
231 MessageLoop::current()->CancelTask(progress_task_); in OnProgressFdReady()
232 progress_task_ = MessageLoop::kTaskIdNull; in OnProgressFdReady()
275 if (progress_task_ != MessageLoop::kTaskIdNull) { in Cleanup()
276 MessageLoop::current()->CancelTask(progress_task_); in Cleanup()
277 progress_task_ = MessageLoop::kTaskIdNull; in Cleanup()
|
| /system/connectivity/shill/ |
| D | event_dispatcher.cc | 40 base::MessageLoop::current()->Run(); in DispatchForever()
48 base::MessageLoop::current()->PostTask(FROM_HERE, task); in PostTask()
52 base::MessageLoop::current()->PostDelayedTask( in PostDelayedTask()
|
| /system/media/brillo/audio/audioservice/ |
| D | audio_daemon.cpp | 46 MessageLoop* message_loop = MessageLoop::current(); in InitializeHandler()
54 message_loop->WatchFileDescriptor(fd, MessageLoop::kWatchRead, in InitializeHandler()
70 brillo::MessageLoop::current()->PostDelayedTask( in ConnectToAPS()
|
| /system/bt/service/ |
| D | daemon.cpp | 56 base::MessageLoop* GetMessageLoop() const override { in GetMessageLoop()
107 message_loop_.reset(new base::MessageLoop()); in Init()
135 std::unique_ptr<base::MessageLoop> message_loop_;
|