| /system/update_engine/common/ |
| D | proxy_resolver.cc | 22 using brillo::MessageLoop;
29 const ProxyRequestId kProxyRequestIdNull = brillo::MessageLoop::kTaskIdNull;
32 if (idle_callback_id_ != MessageLoop::kTaskIdNull) { in ~DirectProxyResolver()
38 MessageLoop::current()->CancelTask(idle_callback_id_); in ~DirectProxyResolver()
39 idle_callback_id_ = MessageLoop::kTaskIdNull; in ~DirectProxyResolver()
45 idle_callback_id_ = MessageLoop::current()->PostTask( in GetProxiesForUrl()
54 return MessageLoop::current()->CancelTask(request); in CancelProxyRequest()
58 idle_callback_id_ = MessageLoop::kTaskIdNull; in ReturnCallback()
|
| D | scoped_task_id.h | 31 using MessageLoop = brillo::MessageLoop; variable
68 if (task_id_ != MessageLoop::kTaskIdNull) { in Cancel()
69 if (MessageLoop::current()->CancelTask(task_id_)) { in Cancel()
71 task_id_ = MessageLoop::kTaskIdNull; in Cancel()
79 return task_id_ != MessageLoop::kTaskIdNull; in IsScheduled()
97 if (task_id_ != MessageLoop::kTaskIdNull) { in PostTask()
102 task_id_ = MessageLoop::current()->PostDelayedTask( in PostTask()
108 return task_id_ != MessageLoop::kTaskIdNull; in PostTask()
112 task_id_ = MessageLoop::kTaskIdNull; in ExecuteTask()
119 MessageLoop::TaskId task_id_{MessageLoop::kTaskIdNull};
|
| D | mock_http_fetcher.cc | 30 using brillo::MessageLoop;
36 CHECK(timeout_id_ == MessageLoop::kTaskIdNull) in ~MockHttpFetcher()
64 if (timeout_id_ == MessageLoop::kTaskIdNull && delay_) { in SendData()
65 CHECK(MessageLoop::current()); in SendData()
66 timeout_id_ = MessageLoop::current()->PostDelayedTask( in SendData()
87 timeout_id_ = MessageLoop::kTaskIdNull; in TimeoutCallback()
99 if (timeout_id_ != MessageLoop::kTaskIdNull) { in TerminateTransfer()
100 MessageLoop::current()->CancelTask(timeout_id_); in TerminateTransfer()
101 timeout_id_ = MessageLoop::kTaskIdNull; in TerminateTransfer()
123 MessageLoop::current()->CancelTask(timeout_id_); in Pause()
[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;
54 no_resolver_idle_id_ = MessageLoop::current()->PostTask( in ResolveProxiesForUrl()
65 no_resolver_idle_id_ = MessageLoop::kTaskIdNull; in NoProxyResolverCallback()
82 if (no_resolver_idle_id_ != MessageLoop::kTaskIdNull) { in CancelProxyResolution()
83 ret = MessageLoop::current()->CancelTask(no_resolver_idle_id_); in CancelProxyResolution()
84 no_resolver_idle_id_ = MessageLoop::kTaskIdNull; in CancelProxyResolution()
|
| D | proxy_resolver.h | 43 typedef brillo::MessageLoop::TaskId ProxyRequestId;
84 brillo::MessageLoop::TaskId idle_callback_id_{
85 brillo::MessageLoop::kTaskIdNull};
|
| D | cpu_limiter.h | 57 brillo::MessageLoop::TaskId manage_shares_id_{
58 brillo::MessageLoop::kTaskIdNull};
|
| D | http_fetcher_unittest.cc | 65 using brillo::MessageLoop;
464 MessageLoop::current()->BreakLoop(); in TransferComplete()
472 MessageLoop::current()->BreakLoop(); in TransferTerminated()
607 MessageLoop::current()->BreakLoop(); in TransferComplete()
620 MessageLoop::TaskId* my_id) { in UnpausingTimeoutCallback()
624 *my_id = MessageLoop::current()->PostDelayedTask( in UnpausingTimeoutCallback()
641 MessageLoop::TaskId callback_id; in TYPED_TEST()
686 MessageLoop::current()->BreakLoop(); in TransferComplete()
702 void EndLoop() { MessageLoop::current()->BreakLoop(); } in EndLoop()
709 MessageLoop::TaskId* my_id) { in AbortingTimeoutCallback()
[all …]
|
| D | mock_http_fetcher.h | 50 timeout_id_(brillo::MessageLoop::kTaskIdNull), in MockHttpFetcher()
145 brillo::MessageLoop::TaskId timeout_id_;
|
| /system/update_engine/cros/ |
| D | dbus_test_utils.h | 46 if (callback_connected_task_ != brillo::MessageLoop::kTaskIdNull) in ~MockSignalHandler()
47 brillo::MessageLoop::current()->CancelTask(callback_connected_task_); in ~MockSignalHandler()
62 callback_connected_task_ = brillo::MessageLoop::current()->PostTask( in GrabCallbacks()
70 callback_connected_task_ = brillo::MessageLoop::kTaskIdNull; in OnCallbackConnected()
74 brillo::MessageLoop::TaskId callback_connected_task_{
75 brillo::MessageLoop::kTaskIdNull};
|
| /system/update_engine/update_manager/ |
| D | update_time_restrictions_monitor_unittest.cc | 32 using brillo::MessageLoop;
134 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in BuildMonitorAndVerify()
174 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
198 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
207 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
222 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
233 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
249 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
258 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
275 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
|
| D | update_time_restrictions_monitor.h | 71 return timeout_event_ != brillo::MessageLoop::kTaskIdNull; in IsMonitoringInterval()
98 brillo::MessageLoop::TaskId timeout_event_{brillo::MessageLoop::kTaskIdNull};
|
| D | update_time_restrictions_monitor.cc | 25 using brillo::MessageLoop;
106 timeout_event_ = MessageLoop::current()->PostDelayedTask( in WaitForRestrictedIntervalStarts()
114 timeout_event_ = MessageLoop::kTaskIdNull; in HandleRestrictedIntervalStarts()
120 MessageLoop::current()->CancelTask(timeout_event_); in StopMonitoring()
121 timeout_event_ = MessageLoop::kTaskIdNull; in StopMonitoring()
|
| D | generic_variables_unittest.cc | 29 using brillo::MessageLoop;
167 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
175 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
193 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
198 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
203 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
208 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
|
| D | evaluation_context_unittest.cc | 39 using brillo::MessageLoop;
228 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
235 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
250 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
262 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
264 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
279 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
281 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
306 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
325 MessageLoopRunUntil(MessageLoop::current(), in TEST_F()
[all …]
|
| D | update_manager_unittest.cc | 47 using brillo::MessageLoop;
263 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
280 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
287 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
310 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
319 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
327 MessageLoopRunMaxIterations(MessageLoop::current(), 10); in TEST_F()
|
| D | real_device_policy_provider.cc | 33 using brillo::MessageLoop;
49 MessageLoop::current()->CancelTask(scheduled_refresh_); in ~RealDevicePolicyProvider()
78 MessageLoop::current()->CancelTask(scheduled_refresh_); in OnPropertyChangedCompletedSignal()
79 scheduled_refresh_ = MessageLoop::kTaskIdNull; in OnPropertyChangedCompletedSignal()
99 scheduled_refresh_ = MessageLoop::current()->PostDelayedTask( in RefreshDevicePolicyAndReschedule()
|
| D | evaluation_context.cc | 37 using brillo::MessageLoop;
91 MessageLoop::current()->CancelTask(timeout_event_); in RemoveObserversAndTimeout()
92 timeout_event_ = MessageLoop::kTaskIdNull; in RemoveObserversAndTimeout()
119 timeout_event_ = MessageLoop::kTaskIdNull; in OnTimeout()
221 timeout_event_ = MessageLoop::current()->PostDelayedTask( in RunOnValueChangeOrTimeout()
|
| D | variable_unittest.cc | 27 using brillo::MessageLoop;
113 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
122 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
171 MessageLoopRunMaxIterations(MessageLoop::current(), 100); in TEST_F()
|
| D | evaluation_context.h | 162 brillo::MessageLoop::TaskId timeout_event_ = brillo::MessageLoop::kTaskIdNull;
|
| /system/bt/include/ |
| D | abstract_message_loop.h | 68 class AbstractMessageLoop : public base::MessageLoop {
71 return base::MessageLoop::current()->task_runner();
80 options.message_loop_type = base::MessageLoop::TYPE_IO;
|
| /system/update_engine/aosp/ |
| D | cleanup_previous_update_action.cc | 38 using brillo::MessageLoop;
111 if (scheduled_task_ != MessageLoop::kTaskIdNull) { in AcknowledgeTaskExecuted()
114 scheduled_task_ = MessageLoop::kTaskIdNull; in AcknowledgeTaskExecuted()
120 if (scheduled_task_ == MessageLoop::kTaskIdNull) { in CheckTaskScheduled()
133 if (scheduled_task_ != MessageLoop::kTaskIdNull) { in StopActionInternal()
134 if (MessageLoop::current()->CancelTask(scheduled_task_)) { in StopActionInternal()
142 scheduled_task_ = MessageLoop::kTaskIdNull; in StopActionInternal()
167 scheduled_task_ = MessageLoop::current()->PostDelayedTask( in ScheduleWaitBootCompleted()
195 scheduled_task_ = MessageLoop::current()->PostDelayedTask( in ScheduleWaitMarkBootSuccessful()
268 scheduled_task_ = MessageLoop::current()->PostDelayedTask( in ScheduleWaitForMerge()
|
| D | cleanup_previous_update_action.h | 79 brillo::MessageLoop::TaskId scheduled_task_{brillo::MessageLoop::kTaskIdNull};
|
| /system/update_engine/ |
| D | libcurl_http_fetcher.cc | 46 using brillo::MessageLoop;
466 MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
520 retry_task_id_ = MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
546 retry_task_id_ = MessageLoop::current()->PostTask( in CurlPerformOnce()
573 retry_task_id_ = MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
750 if (timeout_id_ == MessageLoop::kTaskIdNull) { in SetupMessageLoopSources()
752 timeout_id_ = MessageLoop::current()->PostDelayedTask( in SetupMessageLoopSources()
761 retry_task_id_ = MessageLoop::kTaskIdNull; in RetryTimeoutCallback()
774 timeout_id_ = MessageLoop::current()->PostDelayedTask( in TimeoutCallback()
786 MessageLoop::current()->CancelTask(retry_task_id_); in CleanUp()
[all …]
|
| D | libcurl_http_fetcher.h | 263 brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull};
301 brillo::MessageLoop::TaskId retry_task_id_{brillo::MessageLoop::kTaskIdNull};
|