| /external/webrtc/webrtc/base/ |
| D | taskrunner.cc | 40 tasks_.push_back(task); in StartTask()
73 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()
74 while (!tasks_[i]->Blocked()) { in InternalRunTasks()
75 tasks_[i]->Step(); in InternalRunTasks()
82 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()
83 if (tasks_[i]->IsDone()) { in InternalRunTasks()
84 Task* task = tasks_[i]; in InternalRunTasks()
98 tasks_[i] = NULL; in InternalRunTasks()
103 it = std::remove(tasks_.begin(), in InternalRunTasks()
104 tasks_.end(), in InternalRunTasks()
[all …]
|
| D | taskrunner.h | 87 std::vector<Task *> tasks_; variable
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler.h | 120 std::vector<std::unique_ptr<TaskType>> tasks_ GUARDED_BY(mu_);
201 tasks_.push_back(std::move(task)); in AddTask()
209 if (tasks_.empty()) { in RemoveTask()
212 std::unique_ptr<TaskType> task = std::move(tasks_.back()); in RemoveTask()
214 tasks_.pop_back(); in RemoveTask()
223 return tasks_.size(); in num_tasks()
231 return tasks_.empty(); in empty()
240 DCHECK_LT(i, tasks_.size()); in task()
241 return *tasks_[i].get(); in task()
250 DCHECK_LT(i, tasks_.size()); in mutable_task()
[all …]
|
| /external/libbrillo/brillo/message_loops/ |
| D | fake_message_loop.cc | 28 tasks_.emplace(current_id, ScheduledTask{from_here, false, task}); in PostDelayedTask()
45 tasks_.emplace(current_id, ScheduledTask{from_here, persistent, task}); in WatchFileDescriptor()
53 bool ret = tasks_.erase(task_id) > 0; in CancelTask()
68 const auto& scheduled_task_ref = tasks_.find(fd_watched->second); in RunOnce()
69 if (scheduled_task_ref == tasks_.end()) { in RunOnce()
84 tasks_.erase(scheduled_task_ref); in RunOnce()
99 const auto scheduled_task_ref = tasks_.find(task_ref.second); in RunOnce()
100 if (scheduled_task_ref == tasks_.end()) in RunOnce()
115 tasks_.erase(scheduled_task_ref); in RunOnce()
133 for (const auto& task : tasks_) { in PendingTasks()
[all …]
|
| D | glib_message_loop.cc | 22 for (const auto& task : tasks_) { in ~GlibMessageLoop()
49 tasks_[task_id] = scheduled_task; in PostDelayedTask()
120 tasks_[task_id] = scheduled_task; in WatchFileDescriptor()
127 const auto task = tasks_.find(task_id); in CancelTask()
129 if (task == tasks_.end()) in CancelTask()
136 tasks_.erase(task); in CancelTask()
157 } while (!res || tasks_.find(res) != tasks_.end()); in NextTaskId()
168 scheduled_task->loop->tasks_.erase(scheduled_task->task_id); in OnRanPostedTask()
184 scheduled_task->loop->tasks_.erase(scheduled_task->task_id); in OnWatchedFdReady()
|
| D | glib_message_loop.h | 74 std::map<MessageLoop::TaskId, ScheduledTask*> tasks_; variable
|
| D | fake_message_loop.h | 72 std::map<MessageLoop::TaskId, ScheduledTask> tasks_; variable
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner.cc | 181 while (!tasks_.empty()) in ClearPendingTasks()
182 tasks_.pop(); in ClearPendingTasks()
208 while (!tasks_.empty()) { in TakePendingTasks()
212 std::move(const_cast<TestOrderedPendingTask&>(tasks_.top()))); in TakePendingTasks()
213 tasks_.pop(); in TakePendingTasks()
220 return !tasks_.empty(); in HasPendingTask()
225 return tasks_.size(); in GetPendingTaskCount()
230 return tasks_.empty() ? TimeDelta::Max() in NextPendingTaskDelay()
231 : tasks_.top().GetTimeToRun() - now_ticks_; in NextPendingTaskDelay()
246 tasks_.push(TestOrderedPendingTask(from_here, std::move(task), now_ticks_, in PostDelayedTask()
[all …]
|
| D | test_mock_time_task_runner.h | 211 TaskPriorityQueue tasks_; variable
|
| /external/webrtc/webrtc/libjingle/xmpp/ |
| D | fakexmppclient.h | 74 tasks_.push_back(task); in AddXmppTask()
78 std::remove(tasks_.begin(), tasks_.end(), task); in RemoveXmppTask()
88 for (std::vector<XmppTask*>::iterator task = tasks_.begin(); in HandleStanza()
89 task != tasks_.end(); ++task) { in HandleStanza()
100 std::vector<XmppTask*> tasks_; variable
|
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| D | bind_task_runner_unittest.cc | 45 tasks_.push(task); in PostDelayedTask()
62 while (!tasks_.empty()) { in Run()
63 auto task = tasks_.front(); in Run()
64 tasks_.pop(); in Run()
90 if (!tasks_.empty()) { in RunOneTask()
91 auto task = tasks_.front(); in RunOneTask()
92 tasks_.pop(); in RunOneTask()
114 std::queue<base::Closure> tasks_; member in mojo::test::__anonbcb860870111::TestTaskRunner
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 395 tasks_.clear(); in ~MultiplexRouter()
529 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in AttachEndpointClient()
633 tasks_.empty() && ProcessIncomingMessage(message, client_call_behavior, in Accept()
639 tasks_.push_back( in Accept()
641 Task* task = tasks_.back().get(); in Accept()
650 } else if (!tasks_.empty()) { in Accept()
681 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in OnPeerAssociatedEndpointClosed()
705 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in OnPipeConnectionError()
724 while (!tasks_.empty() && !paused_) { in ProcessTasks()
725 std::unique_ptr<Task> task(std::move(tasks_.front())); in ProcessTasks()
[all …]
|
| D | multiplex_router.h | 256 std::deque<std::unique_ptr<Task>> tasks_; in NON_EXPORTED_BASE() local
|