Searched refs:MessageLoop (Results 1 – 21 of 21) sorted by relevance
31 using MessageLoop = brillo::MessageLoop; variable68 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};
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 …]
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()
65 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 …]
57 brillo::MessageLoop::TaskId manage_shares_id_{58 brillo::MessageLoop::kTaskIdNull};
48 timeout_id_(brillo::MessageLoop::kTaskIdNull), in MockHttpFetcher()142 brillo::MessageLoop::TaskId timeout_id_;
51 using brillo::MessageLoop;98 MessageLoop::current()->BreakLoop(); in ExpectedResults()109 MessageLoop::current()->BreakLoop(); in ExpectedEnvVars()130 MessageLoop::current()->BreakLoop(); in ExpectedDataOnPipe()
22 using brillo::MessageLoop;
39 using brillo::MessageLoop;
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()
79 brillo::MessageLoop::TaskId scheduled_task_{brillo::MessageLoop::kTaskIdNull};
141 return brillo::MessageLoop::current()->PostTask( in MarkBootSuccessfulAsync()143 brillo::MessageLoop::kTaskIdNull; in MarkBootSuccessfulAsync()
95 brillo::MessageLoop::current()->BreakLoop(); in SendPayloadApplicationComplete()
323 if (!brillo::MessageLoop::current()->PostTask(delayed_exit)) in ExitWhenIdle()
313 brillo::MessageLoop::current()->Run(); in ApplyPayload()
717 brillo::MessageLoop::current()->PostTask( in ScheduleProcessingStart()
47 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 …]
258 brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull};296 brillo::MessageLoop::TaskId retry_task_id_{brillo::MessageLoop::kTaskIdNull};
49 using brillo::MessageLoop;60 MessageLoop::current()->BreakLoop(); in ProcessingDone()64 MessageLoop::current()->BreakLoop(); in ProcessingStopped()
44 using brillo::MessageLoop;224 MessageLoop::current()->BreakLoop(); in ProcessingDone()227 MessageLoop::current()->BreakLoop(); in ProcessingStopped()
165 brillo::MessageLoop::current()->BreakLoop(); in ProcessingDone()169 brillo::MessageLoop::current()->BreakLoop(); in ProcessingStopped()