| /external/libchrome/base/ |
| D | pending_task.cc | 10 PendingTask::PendingTask(const Location& posted_from, in PendingTask() function in base::PendingTask
19 PendingTask::PendingTask(PendingTask&& other) = default;
21 PendingTask::~PendingTask() = default;
23 PendingTask& PendingTask::operator=(PendingTask&& other) = default;
25 bool PendingTask::operator<(const PendingTask& other) const { in operator <()
|
| D | pending_task.h | 25 struct BASE_EXPORT PendingTask { struct
26 PendingTask(const Location& posted_from,
30 PendingTask(PendingTask&& other);
31 ~PendingTask();
33 PendingTask& operator=(PendingTask&& other); argument
36 bool operator<(const PendingTask& other) const;
61 using TaskQueue = base::queue<PendingTask>; argument
64 using DelayedTaskQueue = std::priority_queue<base::PendingTask>;
|
| /external/libchrome/base/message_loop/ |
| D | incoming_task_queue.h | 39 virtual void WillQueueTask(PendingTask* task) = 0;
55 virtual const PendingTask& Peek() = 0;
58 virtual PendingTask Pop() = 0;
77 virtual void Push(PendingTask pending_task) = 0;
158 const PendingTask& Peek() override;
159 PendingTask Pop() override;
179 const PendingTask& Peek() override;
180 PendingTask Pop() override;
184 void Push(PendingTask pending_task) override;
208 const PendingTask& Peek() override;
[all …]
|
| D | incoming_task_queue.cc | 62 PendingTask pending_task(from_here, std::move(task), in AddToIncomingQueue()
97 const PendingTask& IncomingTaskQueue::TriageQueue::Peek() { in Peek()
104 PendingTask IncomingTaskQueue::TriageQueue::Pop() { in Pop()
108 PendingTask pending_task = std::move(queue_.front()); in Pop()
145 PendingTask pending_task = Pop(); in Clear()
166 void IncomingTaskQueue::DelayedQueue::Push(PendingTask pending_task) { in Push()
175 const PendingTask& IncomingTaskQueue::DelayedQueue::Peek() { in Peek()
181 PendingTask IncomingTaskQueue::DelayedQueue::Pop() { in Pop()
184 PendingTask delayed_task = std::move(const_cast<PendingTask&>(queue_.top())); in Pop()
220 void IncomingTaskQueue::DeferredQueue::Push(PendingTask pending_task) { in Push()
[all …]
|
| D | message_loop_task_runner_perftest.cc | 39 void WillQueueTask(PendingTask* task) override {} in WillQueueTask()
42 virtual void RunTask(PendingTask* task) { std::move(task->task).Run(); } in RunTask()
69 PendingTask t = std::move(loop_local_queue.front()); in Run()
116 void WillQueueTask(PendingTask* task) final { in WillQueueTask()
125 void RunTask(PendingTask* task) final { in RunTask()
|
| D | message_loop.cc | 83 void WillQueueTask(PendingTask* task) final;
130 void MessageLoop::Controller::WillQueueTask(PendingTask* task) { in WillQueueTask()
435 PendingTask pending_task = incoming_task_queue_->deferred_tasks().Pop(); in ProcessNextDelayedNonNestableTask()
445 void MessageLoop::RunTask(PendingTask* pending_task) { in RunTask()
463 bool MessageLoop::DeferOrRunPendingTask(PendingTask pending_task) { in DeferOrRunPendingTask()
511 PendingTask pending_task = incoming_task_queue_->triage_tasks().Pop(); in DoWork()
602 PendingTask pending_task = incoming_task_queue_->delayed_tasks().Pop(); in DoDelayedWork()
|
| D | message_loop_current.h | 108 virtual void WillProcessTask(const PendingTask& pending_task) = 0;
111 virtual void DidProcessTask(const PendingTask& pending_task) = 0;
|
| D | message_loop.h | 201 void RunTask(PendingTask* pending_task);
263 bool DeferOrRunPendingTask(PendingTask pending_task);
|
| /external/libchrome/base/debug/ |
| D | task_annotator.cc | 26 ThreadLocalPointer<const PendingTask>* GetTLSForCurrentPendingTask() { in GetTLSForCurrentPendingTask()
27 static NoDestructor<ThreadLocalPointer<const PendingTask>> in GetTLSForCurrentPendingTask()
39 PendingTask* pending_task) { in WillQueueTask()
52 const PendingTask* parent_task = GetTLSForCurrentPendingTask()->Get(); in WillQueueTask()
64 PendingTask* pending_task) { in RunTask()
93 ThreadLocalPointer<const PendingTask>* tls_for_current_pending_task = in RunTask()
95 const PendingTask* previous_pending_task = in RunTask()
106 uint64_t TaskAnnotator::GetTaskTraceID(const PendingTask& task) const { in GetTaskTraceID()
|
| D | task_annotator.h | 14 struct PendingTask;
26 virtual void BeforeRunTask(const PendingTask* pending_task) = 0;
37 void WillQueueTask(const char* queue_function, PendingTask* pending_task);
41 void RunTask(const char* queue_function, PendingTask* pending_task);
48 uint64_t GetTaskTraceID(const PendingTask& task) const;
|
| D | task_annotator_unittest.cc | 38 PendingTask pending_task(FROM_HERE, BindOnce(&TestTask, &result)); in TEST()
62 void BeforeRunTask(const PendingTask* pending_task) override { in BeforeRunTask()
|
| /external/libchrome/components/timers/ |
| D | alarm_timer_chromeos.h | 19 struct PendingTask;
72 std::unique_ptr<base::PendingTask> pending_task_;
|
| D | alarm_timer_chromeos.cc | 70 pending_task_ = std::make_unique<base::PendingTask>( in Reset()
|
| /external/libchrome/base/task/sequence_manager/ |
| D | thread_controller.h | 16 struct PendingTask;
38 virtual void WillQueueTask(PendingTask* pending_task) = 0;
|
| D | thread_controller_with_message_pump_impl.cc | 48 PendingTask* pending_task) { in WillQueueTask()
121 Optional<PendingTask> task = main_thread_only().task_source->TakeTask(); in DoWork()
|
| D | sequenced_task_source.h | 22 virtual Optional<PendingTask> TakeTask() = 0;
|
| D | thread_controller_impl.cc | 141 void ThreadControllerImpl::WillQueueTask(PendingTask* pending_task) { in WillQueueTask()
161 Optional<PendingTask> task = sequence_->TakeTask(); in DoWork()
|
| D | thread_controller_with_message_pump_impl.h | 33 void WillQueueTask(PendingTask* pending_task) override;
|
| D | thread_controller_impl.h | 38 void WillQueueTask(PendingTask* pending_task) override;
|
| D | task_queue_impl.h | 225 void NotifyWillProcessTask(const PendingTask& pending_task);
226 void NotifyDidProcessTask(const PendingTask& pending_task);
|
| /external/libchrome/base/task_scheduler/ |
| D | task.cc | 25 : PendingTask( in Task()
53 : PendingTask(std::move(other)), in Task()
|
| D | task.h | 24 struct BASE_EXPORT Task : public PendingTask {
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_state.h | 110 struct PendingTask { struct
111 explicit PendingTask(std::shared_ptr<Task> task, int64 target_round) in PendingTask() function
145 std::queue<PendingTask> pending_tasks;
|
| /external/libchrome/libchrome_tools/patch/ |
| D | task_annotator.patch | 12 virtual void BeforeRunTask(const PendingTask* pending_task) = 0;
|
| /external/libchrome/base/threading/ |
| D | thread_perftest.cc | 155 void WillProcessTask(const base::PendingTask& pending_task) override {} in WillProcessTask()
156 void DidProcessTask(const base::PendingTask& pending_task) override {} in DidProcessTask()
|