Home
last modified time | relevance | path

Searched refs:delayed_tasks_ (Results 1 – 16 of 16) sorted by relevance

/external/openscreen/platform/test/
Dfake_task_runner.cc30 const auto end_of_range = delayed_tasks_.upper_bound(current_time); in RunTasksUntilIdle()
31 for (auto it = delayed_tasks_.begin(); it != end_of_range; ++it) { in RunTasksUntilIdle()
34 delayed_tasks_.erase(delayed_tasks_.begin(), end_of_range); in RunTasksUntilIdle()
58 delayed_tasks_.emplace( in PostPackagedTaskWithDelay()
70 if (!delayed_tasks_.empty()) { in GetResumeTime()
71 return delayed_tasks_.begin()->first; in GetResumeTime()
Dfake_task_runner.h59 int delayed_task_count() const { return delayed_tasks_.size(); } in delayed_task_count()
69 std::multimap<Clock::time_point, Task> delayed_tasks_; variable
/external/webrtc/modules/utility/source/
Dprocess_thread_impl.cc54 while (!delayed_tasks_.empty()) { in ~ProcessThreadImpl()
55 delete delayed_tasks_.top().task; in ~ProcessThreadImpl()
56 delayed_tasks_.pop(); in ~ProcessThreadImpl()
136 delayed_tasks_.empty() || run_at_ms < delayed_tasks_.top().run_at_ms; in PostDelayedTask()
137 delayed_tasks_.emplace(run_at_ms, std::move(task)); in PostDelayedTask()
238 while (!delayed_tasks_.empty() && delayed_tasks_.top().run_at_ms <= now) { in Process()
239 queue_.push(delayed_tasks_.top().task); in Process()
240 delayed_tasks_.pop(); in Process()
243 if (!delayed_tasks_.empty()) { in Process()
245 std::min(next_checkpoint, delayed_tasks_.top().run_at_ms); in Process()
Dprocess_thread_impl.h105 std::priority_queue<DelayedTask> delayed_tasks_ RTC_GUARDED_BY(lock_);
/external/openscreen/platform/impl/
Dtask_runner.cc62 delayed_tasks_.emplace( in PostPackagedTaskWithDelay()
147 const auto end_of_range = delayed_tasks_.upper_bound(current_time); in ScheduleDelayedTasks()
148 for (auto it = delayed_tasks_.begin(); it != end_of_range; ++it) { in ScheduleDelayedTasks()
151 delayed_tasks_.erase(delayed_tasks_.begin(), end_of_range); in ScheduleDelayedTasks()
169 if (!delayed_tasks_.empty()) { in GrabMoreRunnableTasks()
171 delayed_tasks_.begin()->first - now_function_(); in GrabMoreRunnableTasks()
181 if (delayed_tasks_.empty()) { in GrabMoreRunnableTasks()
185 delayed_tasks_.begin()->first - now_function_()); in GrabMoreRunnableTasks()
Dtask_runner.h128 std::multimap<Clock::time_point, TaskWithMetadata> delayed_tasks_
/external/webrtc/test/time_controller/
Dsimulated_task_queue.cc37 delayed_tasks_.swap(delayed_tasks); in Delete()
46 for (auto it = delayed_tasks_.begin(); in RunReady()
47 it != delayed_tasks_.end() && it->first <= at_time; in RunReady()
48 it = delayed_tasks_.erase(it)) { in RunReady()
66 if (!delayed_tasks_.empty()) { in RunReady()
67 next_run_time_ = delayed_tasks_.begin()->first; in RunReady()
84 delayed_tasks_[target_time].push_back(std::move(task)); in PostDelayedTask()
Dsimulated_process_thread.cc56 for (auto it = delayed_tasks_.begin(); in RunReady()
57 it != delayed_tasks_.end() && it->first <= at_time; in RunReady()
58 it = delayed_tasks_.erase(it)) { in RunReady()
77 if (!delayed_tasks_.empty()) { in RunReady()
78 next_run_time_ = std::min(next_run_time_, delayed_tasks_.begin()->first); in RunReady()
178 delayed_tasks_[target_time].push_back(std::move(task)); in PostDelayedTask()
Dsimulated_task_queue.h53 std::map<Timestamp, std::vector<std::unique_ptr<QueuedTask>>> delayed_tasks_
Dsimulated_process_thread.h63 std::map<Timestamp, std::vector<std::unique_ptr<QueuedTask>>> delayed_tasks_
/external/libbrillo/brillo/message_loops/
Dbase_message_loop.cc66 for (const auto& delayed_task : delayed_tasks_) { in ~BaseMessageLoop()
95 delayed_tasks_.emplace(task_id, in PostDelayedTask()
103 auto delayed_task_it = delayed_tasks_.find(task_id); in CancelTask()
104 if (delayed_task_it == delayed_tasks_.end()) in CancelTask()
168 delayed_tasks_.find(res) != delayed_tasks_.end()); in NextTaskId()
173 auto task_it = delayed_tasks_.find(task_id); in OnRanPostedTask()
174 DCHECK(task_it != delayed_tasks_.end()); in OnRanPostedTask()
190 delayed_tasks_.erase(task_it); in OnRanPostedTask()
Dbase_message_loop.h90 std::map<MessageLoop::TaskId, DelayedTask> delayed_tasks_; variable
/external/perfetto/src/base/
Dunix_task_runner.cc140 if (!delayed_tasks_.empty()) { in RunImmediateAndDelayedTask()
141 auto it = delayed_tasks_.begin(); in RunImmediateAndDelayedTask()
144 delayed_tasks_.erase(it); in RunImmediateAndDelayedTask()
241 if (!delayed_tasks_.empty()) { in GetDelayMsToNextTaskLocked()
242 TimeMillis diff = delayed_tasks_.begin()->first - GetWallTimeMs(); in GetDelayMsToNextTaskLocked()
264 delayed_tasks_.insert(std::make_pair(runtime, std::move(task))); in PostDelayedTask()
/external/libchrome/base/message_loop/
Dincoming_task_queue.h111 Queue& delayed_tasks() { return delayed_tasks_; } in delayed_tasks()
117 return delayed_tasks_.HasPendingHighResolutionTasks(); in HasPendingHighResolutionTasks()
247 DelayedQueue delayed_tasks_; variable
Dincoming_task_queue.cc89 delayed_tasks_.Size()); in ReportMetricsOnIdle()
/external/perfetto/include/perfetto/ext/base/
Dunix_task_runner.h109 std::multimap<TimeMillis, std::function<void()>> delayed_tasks_; variable