| /external/libchrome/base/task/sequence_manager/ |
| D | work_queue.cc | 20 for (const TaskQueueImpl::Task& task : tasks_) { in AsValueInto()
31 if (tasks_.empty()) in GetFrontTask()
33 return &tasks_.front(); in GetFrontTask()
37 if (tasks_.empty()) in GetBackTask()
39 return &tasks_.back(); in GetBackTask()
49 return tasks_.empty() || tasks_.front().enqueue_order() >= fence_; in BlockedByFence()
53 if (tasks_.empty() || BlockedByFence()) in GetFrontTaskEnqueueOrder()
56 DCHECK_LE(tasks_.front().enqueue_order(), tasks_.back().enqueue_order()) in GetFrontTaskEnqueueOrder()
59 *enqueue_order = tasks_.front().enqueue_order(); in GetFrontTaskEnqueueOrder()
64 bool was_empty = tasks_.empty(); in Push()
[all …]
|
| D | work_queue.h | 49 bool Empty() const { return tasks_.empty(); } in Empty()
78 size_t Size() const { return tasks_.size(); } in Size()
136 TaskQueueImpl::TaskDeque tasks_; variable
|
| /external/libchrome/base/test/ |
| D | test_mock_time_task_runner.cc | 249 while (!tasks_.empty()) { in ClearPendingTasks()
251 tasks_.swap(cleanup_tasks); in ClearPendingTasks()
303 while (!tasks_.empty()) { in TakePendingTasks()
306 if (!tasks_.top().task.IsCancelled()) { in TakePendingTasks()
308 std::move(const_cast<TestOrderedPendingTask&>(tasks_.top()))); in TakePendingTasks()
310 tasks_.pop(); in TakePendingTasks()
318 while (!tasks_.empty() && tasks_.top().task.IsCancelled()) in HasPendingTask()
319 tasks_.pop(); in HasPendingTask()
320 return !tasks_.empty(); in HasPendingTask()
327 while (!tasks_.empty()) { in GetPendingTaskCount()
[all …]
|
| D | test_mock_time_task_runner.h | 275 TaskPriorityQueue tasks_; variable
|
| /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/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 | fake_message_loop.h | 72 std::map<MessageLoop::TaskId, ScheduledTask> 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/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/v8/src/heap/ |
| D | barrier.h | 34 OneshotBarrier() : tasks_(0), waiting_(0), done_(false) {} in OneshotBarrier()
38 tasks_++; in Start()
50 DCHECK_LE(waiting_, tasks_); in Wait()
52 if (waiting_ == tasks_) { in Wait()
69 int tasks_; variable
|
| D | item-parallel-job.cc | 62 DCHECK_GT(tasks_.size(), 0); in Run()
64 const size_t num_tasks = tasks_.size(); in Run()
79 const size_t num_tasks_processing_items = Min(num_items, tasks_.size()); in Run()
96 auto task = std::move(tasks_[i]); in Run()
|
| D | item-parallel-job.h | 130 void AddTask(Task* task) { tasks_.push_back(std::unique_ptr<Task>(task)); } in AddTask()
136 int NumberOfTasks() const { return static_cast<int>(tasks_.size()); } in NumberOfTasks()
144 std::vector<std::unique_ptr<Task>> tasks_; variable
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | bind_task_runner_unittest.cc | 47 tasks_.push(std::move(task)); in PostDelayedTask()
64 while (!tasks_.empty()) { in Run()
65 auto task = std::move(tasks_.front()); in Run()
66 tasks_.pop(); in Run()
92 if (!tasks_.empty()) { in RunOneTask()
93 auto task = std::move(tasks_.front()); in RunOneTask()
94 tasks_.pop(); in RunOneTask()
116 base::queue<base::OnceClosure> tasks_; member in mojo::test::__anona2eee2bc0111::TestTaskRunner
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 356 tasks_.clear(); in ~MultiplexRouter()
470 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in AttachEndpointClient()
589 bool processed = tasks_.empty() && ProcessIncomingMessage( in Accept()
596 tasks_.push_back(Task::CreateMessageTask(std::move(message_wrapper))); in Accept()
597 Task* task = tasks_.back().get(); in Accept()
606 } else if (!tasks_.empty()) { in Accept()
635 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint)); in OnPeerAssociatedEndpointClosed()
662 tasks_.push_back(Task::CreateNotifyErrorTask(endpoint.get())); in OnPipeConnectionError()
681 while (!tasks_.empty() && !paused_) { in ProcessTasks()
682 std::unique_ptr<Task> task(std::move(tasks_.front())); in ProcessTasks()
[all …]
|
| D | multiplex_router.h | 266 base::circular_deque<std::unique_ptr<Task>> tasks_; variable
|