| /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/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler.h | 126 std::vector<std::unique_ptr<TaskType>> tasks_ TF_GUARDED_BY(mu_);
219 tasks_.push_back(std::move(task)); in AddTask()
228 if (tasks_.empty()) { in RemoveTask()
231 std::unique_ptr<TaskType> task = std::move(tasks_.back()); in RemoveTask()
233 tasks_.pop_back(); in RemoveTask()
234 if (tasks_.empty()) { in RemoveTask()
245 return tasks_.size(); in num_tasks()
264 DCHECK_LT(i, tasks_.size()); in task()
265 return *tasks_[i].get(); in task()
274 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, std::move(task)}); in PostDelayedTask()
39 bool ret = tasks_.erase(task_id) > 0; in CancelTask()
55 const auto scheduled_task_ref = tasks_.find(task_ref.second); in RunOnce()
56 if (scheduled_task_ref == tasks_.end()) in RunOnce()
71 tasks_.erase(scheduled_task_ref); in RunOnce()
80 for (const auto& task : tasks_) { in PendingTasks()
84 return !tasks_.empty(); in PendingTasks()
|
| D | fake_message_loop.h | 59 std::map<MessageLoop::TaskId, ScheduledTask> tasks_; variable
|
| /external/zstd/contrib/pzstd/utils/ |
| D | ThreadPool.h | 23 WorkQueue<std::function<void()>> tasks_; variable
32 while (tasks_.pop(task)) { in ThreadPool()
41 tasks_.finish(); in ~ThreadPool()
55 tasks_.push(std::move(task)); in add()
|
| /external/openscreen/platform/impl/ |
| D | task_runner.cc | 48 tasks_.emplace_back(std::move(task)); in PostPackagedTask()
60 tasks_.emplace_back(std::move(task)); in PostPackagedTaskWithDelay()
149 tasks_.push_back(std::move(it->second)); in ScheduleDelayedTasks()
158 if (!tasks_.empty()) { in GrabMoreRunnableTasks()
159 running_tasks_.swap(tasks_); in GrabMoreRunnableTasks()
|
| D | task_runner.h | 127 std::vector<TaskWithMetadata> tasks_ GUARDED_BY(task_mutex_);
|
| /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::__anonb80a6cda0111::TestTaskRunner
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | data_service_dataset_op.cc | 248 for (const auto& task : tasks_) { in CancelThreads()
363 num_tasks = tasks_.size() - finished_tasks_; in GetTraceMeMetadata()
474 tasks_.push_back(std::make_shared<Task>(task_info, std::move(worker))); in AddTask()
521 for (int i = 0; i < tasks_.size(); ++i) { in UpdateTasks()
522 std::shared_ptr<Task> task = tasks_[i]; in UpdateTasks()
532 tasks_[i] = tasks_[tasks_.size() - 1]; in UpdateTasks()
533 tasks_.pop_back(); in UpdateTasks()
550 max_outstanding_requests_ = tasks_.size(); in UpdateTasks()
574 if (next_task_index_ >= tasks_.size()) { in AdvanceTaskIndex()
583 for (int i = 0; i < tasks_.size(); ++i) { in GetTaskToProcess()
[all …]
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | worker_impl.cc | 110 std::unique_ptr<Task>& task = tasks_[task_def.task_id()]; in ProcessTaskInternal()
193 auto it = tasks_.find(request->task_id()); in GetElement()
194 if (it == tasks_.end()) { in GetElement()
224 for (const auto& it : tasks_) { in GetWorkerTasks()
314 for (const auto& task : tasks_) { in Heartbeat()
334 tasks_.erase(task_id); in Heartbeat()
|
| D | dispatcher_state.cc | 153 auto& task = tasks_[task_id]; in CreatePendingTask()
188 auto& task = tasks_[task_id]; in CreateTask()
202 auto& task = tasks_[task_id]; in FinishTask()
310 auto it = tasks_.find(id); in TaskFromId()
311 if (it == tasks_.end()) { in TaskFromId()
|
| D | worker_impl.h | 90 absl::flat_hash_map<int64, std::unique_ptr<Task>> tasks_ TF_GUARDED_BY(mu_);
|
| D | dispatcher_state.h | 247 absl::flat_hash_map<int64, std::shared_ptr<Task>> tasks_; variable
|
| /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
|
| /external/openscreen/third_party/chromium_quic/demo/ |
| D | delegates.cc | 70 FakeTaskRunner::FakeTaskRunner(std::vector<FakeTask>* tasks) : tasks_(tasks) {} in FakeTaskRunner()
76 tasks_->push_back({whence, std::move(task), delay}); in PostDelayedTask()
|
| D | delegates.h | 93 std::vector<FakeTask>* tasks_; variable
|