Home
last modified time | relevance | path

Searched refs:MessageLoop (Results 1 – 21 of 21) sorted by relevance

/system/update_engine/common/
Dscoped_task_id.h31 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};
Dmock_http_fetcher.cc30 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 …]
Dcpu_limiter.cc44 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()
Dhttp_fetcher_unittest.cc65 using brillo::MessageLoop;
450 MessageLoop::current()->BreakLoop(); in TransferComplete()
458 MessageLoop::current()->BreakLoop(); in TransferTerminated()
591 MessageLoop::current()->BreakLoop(); in TransferComplete()
604 MessageLoop::TaskId* my_id) { in UnpausingTimeoutCallback()
608 *my_id = MessageLoop::current()->PostDelayedTask( in UnpausingTimeoutCallback()
624 MessageLoop::TaskId callback_id{}; in TYPED_TEST()
661 MessageLoop::current()->BreakLoop(); in TransferComplete()
677 void EndLoop() { MessageLoop::current()->BreakLoop(); } in EndLoop()
684 MessageLoop::TaskId* my_id) { in AbortingTimeoutCallback()
[all …]
Dcpu_limiter.h57 brillo::MessageLoop::TaskId manage_shares_id_{
58 brillo::MessageLoop::kTaskIdNull};
Dmock_http_fetcher.h48 timeout_id_(brillo::MessageLoop::kTaskIdNull), in MockHttpFetcher()
142 brillo::MessageLoop::TaskId timeout_id_;
Dsubprocess_unittest.cc51 using brillo::MessageLoop;
98 MessageLoop::current()->BreakLoop(); in ExpectedResults()
109 MessageLoop::current()->BreakLoop(); in ExpectedEnvVars()
130 MessageLoop::current()->BreakLoop(); in ExpectedDataOnPipe()
Dhttp_fetcher.cc22 using brillo::MessageLoop;
Dsubprocess.cc39 using brillo::MessageLoop;
/system/update_engine/aosp/
Dcleanup_previous_update_action.cc38 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()
Dcleanup_previous_update_action.h79 brillo::MessageLoop::TaskId scheduled_task_{brillo::MessageLoop::kTaskIdNull};
Dboot_control_android.cc141 return brillo::MessageLoop::current()->PostTask( in MarkBootSuccessfulAsync()
143 brillo::MessageLoop::kTaskIdNull; in MarkBootSuccessfulAsync()
Dsideload_main.cc95 brillo::MessageLoop::current()->BreakLoop(); in SendPayloadApplicationComplete()
Dupdate_engine_client_android.cc323 if (!brillo::MessageLoop::current()->PostTask(delayed_exit)) in ExitWhenIdle()
Dupdate_attempter_android_integration_test.cc313 brillo::MessageLoop::current()->Run(); in ApplyPayload()
Dupdate_attempter_android.cc717 brillo::MessageLoop::current()->PostTask( in ScheduleProcessingStart()
/system/update_engine/
Dlibcurl_http_fetcher.cc47 using brillo::MessageLoop;
459 MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
513 retry_task_id_ = MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
539 retry_task_id_ = MessageLoop::current()->PostTask( in CurlPerformOnce()
566 retry_task_id_ = MessageLoop::current()->PostDelayedTask( in CurlPerformOnce()
743 if (timeout_id_ == MessageLoop::kTaskIdNull) { in SetupMessageLoopSources()
745 timeout_id_ = MessageLoop::current()->PostDelayedTask( in SetupMessageLoopSources()
754 retry_task_id_ = MessageLoop::kTaskIdNull; in RetryTimeoutCallback()
767 timeout_id_ = MessageLoop::current()->PostDelayedTask( in TimeoutCallback()
779 MessageLoop::current()->CancelTask(retry_task_id_); in CleanUp()
[all …]
Dlibcurl_http_fetcher.h258 brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull};
296 brillo::MessageLoop::TaskId retry_task_id_{brillo::MessageLoop::kTaskIdNull};
/system/update_engine/payload_consumer/
Dpostinstall_runner_action_unittest.cc49 using brillo::MessageLoop;
60 MessageLoop::current()->BreakLoop(); in ProcessingDone()
64 MessageLoop::current()->BreakLoop(); in ProcessingStopped()
Dfilesystem_verifier_action_unittest.cc44 using brillo::MessageLoop;
224 MessageLoop::current()->BreakLoop(); in ProcessingDone()
227 MessageLoop::current()->BreakLoop(); in ProcessingStopped()
/system/update_engine/payload_generator/
Dgenerate_delta_main.cc165 brillo::MessageLoop::current()->BreakLoop(); in ProcessingDone()
169 brillo::MessageLoop::current()->BreakLoop(); in ProcessingStopped()