| /external/webrtc/rtc_base/ |
| D | task_queue_libevent.cc | 113 void PostTask(std::unique_ptr<QueuedTask> task) override;
114 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
134 absl::InlinedVector<std::unique_ptr<QueuedTask>, 4> pending_
141 TimerEvent(TaskQueueLibevent* task_queue, std::unique_ptr<QueuedTask> task) in TimerEvent()
147 std::unique_ptr<QueuedTask> task;
150 class TaskQueueLibevent::SetTimerTask : public QueuedTask {
152 SetTimerTask(std::unique_ptr<QueuedTask> task, uint32_t milliseconds) in SetTimerTask()
168 std::unique_ptr<QueuedTask> task_;
217 void TaskQueueLibevent::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
240 void TaskQueueLibevent::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
[all …]
|
| D | task_queue_stdlib.cc | 56 void PostTask(std::unique_ptr<QueuedTask> task) override;
57 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
75 std::unique_ptr<QueuedTask> run_task_;
111 std::queue<std::pair<OrderId, std::unique_ptr<QueuedTask>>> pending_queue_
120 std::map<DelayedEntryTimeout, std::unique_ptr<QueuedTask>> delayed_queue_
149 void TaskQueueStdlib::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
154 pending_queue_.push(std::pair<OrderId, std::unique_ptr<QueuedTask>>( in PostTask()
161 void TaskQueueStdlib::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
240 QueuedTask* release_ptr = task.run_task_.release(); in ProcessTasks()
|
| D | task_queue_gcd.cc | 48 void PostTask(std::unique_ptr<QueuedTask> task) override;
49 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
54 TaskContext(TaskQueueGcd* queue, std::unique_ptr<QueuedTask> task) in TaskContext()
58 std::unique_ptr<QueuedTask> task;
100 void TaskQueueGcd::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
105 void TaskQueueGcd::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
|
| D | task_queue_win.cc | 84 DelayedTaskInfo(uint32_t milliseconds, std::unique_ptr<QueuedTask> task) in DelayedTaskInfo()
114 mutable std::unique_ptr<QueuedTask> task_;
163 void PostTask(std::unique_ptr<QueuedTask> task) override;
164 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
209 std::queue<std::unique_ptr<QueuedTask>> pending_
237 void TaskQueueWin::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
243 void TaskQueueWin::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
263 std::unique_ptr<QueuedTask> task; in RunPendingTasks()
327 QueuedTask* task = reinterpret_cast<QueuedTask*>(msg.lParam); in ProcessQueuedMessages()
|
| D | task_queue.h | 95 void PostTask(std::unique_ptr<webrtc::QueuedTask> task);
102 void PostDelayedTask(std::unique_ptr<webrtc::QueuedTask> task,
111 std::unique_ptr<webrtc::QueuedTask>>::value>::type* = nullptr>
120 std::unique_ptr<webrtc::QueuedTask>>::value>::type* = nullptr>
|
| D | task_queue.cc | 32 void TaskQueue::PostTask(std::unique_ptr<webrtc::QueuedTask> task) { in PostTask()
36 void TaskQueue::PostDelayedTask(std::unique_ptr<webrtc::QueuedTask> task, in PostDelayedTask()
|
| D | thread.cc | 967 auto* data = static_cast<ScopedMessageData<webrtc::QueuedTask>*>(msg->pdata); in PreRun()
968 std::unique_ptr<webrtc::QueuedTask> task = std::move(data->data()); in PreRun()
1023 void Thread::PostTask(std::unique_ptr<webrtc::QueuedTask> task) { in PreRun()
1027 /*id=*/0, new ScopedMessageData<webrtc::QueuedTask>(std::move(task))); in PreRun()
1030 void Thread::PostDelayedTask(std::unique_ptr<webrtc::QueuedTask> task, in PreRun()
1036 new ScopedMessageData<webrtc::QueuedTask>(std::move(task))); in PreRun()
|
| /external/webrtc/rtc_base/task_utils/ |
| D | to_queued_task.h | 25 class ClosureTask : public QueuedTask {
40 class SafetyClosureTask : public QueuedTask {
78 std::unique_ptr<QueuedTask> ToQueuedTask(Closure&& closure) { in ToQueuedTask()
84 std::unique_ptr<QueuedTask> ToQueuedTask( in ToQueuedTask()
92 std::unique_ptr<QueuedTask> ToQueuedTask(const ScopedTaskSafety& safety, in ToQueuedTask()
103 std::unique_ptr<QueuedTask> ToQueuedTask(Closure&& closure, Cleanup&& cleanup) { in ToQueuedTask()
|
| D | to_queued_task_unittest.cc | 26 void RunTask(std::unique_ptr<QueuedTask> task) { in RunTask()
28 QueuedTask* raw = task.release(); in RunTask()
35 std::unique_ptr<QueuedTask> task = ToQueuedTask([&run] { run = true; }); in TEST()
68 std::unique_ptr<QueuedTask> task; in TEST()
|
| D | repeating_task_unittest.cc | 52 MOCK_METHOD(void, PostTask, (std::unique_ptr<QueuedTask> task), (override));
55 (std::unique_ptr<QueuedTask> task, uint32_t milliseconds),
247 std::unique_ptr<QueuedTask> delayed_task; in TEST()
254 Invoke([&delayed_task, &expected_ms](std::unique_ptr<QueuedTask> task, in TEST()
272 QueuedTask* task_to_run = delayed_task.release(); in TEST()
|
| /external/webrtc/modules/utility/source/ |
| D | process_thread_impl.h | 40 void PostTask(std::unique_ptr<QueuedTask> task) override;
41 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
70 DelayedTask(int64_t run_at_ms, std::unique_ptr<QueuedTask> task) in DelayedTask()
83 QueuedTask* task;
104 std::queue<QueuedTask*> queue_;
|
| D | process_thread_impl.cc | 120 void ProcessThreadImpl::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
129 void ProcessThreadImpl::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
249 QueuedTask* task = queue_.front(); in Process()
|
| /external/webrtc/test/time_controller/ |
| D | simulated_task_queue.cc | 32 std::deque<std::unique_ptr<QueuedTask>> ready_tasks; in Delete()
33 std::map<Timestamp, std::vector<std::unique_ptr<QueuedTask>>> delayed_tasks; in Delete()
55 std::unique_ptr<QueuedTask> ready = std::move(ready_tasks_.front()); in RunReady()
73 void SimulatedTaskQueue::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
79 void SimulatedTaskQueue::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
|
| D | simulated_task_queue.h | 41 void PostTask(std::unique_ptr<QueuedTask> task) override;
42 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
52 std::deque<std::unique_ptr<QueuedTask>> ready_tasks_ RTC_GUARDED_BY(lock_);
53 std::map<Timestamp, std::vector<std::unique_ptr<QueuedTask>>> delayed_tasks_
|
| D | simulated_process_thread.h | 45 void PostTask(std::unique_ptr<QueuedTask> task) override;
46 void PostDelayedTask(std::unique_ptr<QueuedTask> task,
62 std::deque<std::unique_ptr<QueuedTask>> queue_;
63 std::map<Timestamp, std::vector<std::unique_ptr<QueuedTask>>> delayed_tasks_
|
| D | external_time_controller.cc | 58 void PostTask(std::unique_ptr<QueuedTask> task) override { in PostTask()
64 void PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
134 void PostTask(std::unique_ptr<QueuedTask> task) override { in PostTask()
140 void PostDelayedTask(std::unique_ptr<QueuedTask> task, uint32_t ms) override { in PostDelayedTask()
150 class TaskWrapper : public QueuedTask {
152 TaskWrapper(std::unique_ptr<QueuedTask> task, TaskQueueWrapper* queue) in TaskWrapper()
166 std::unique_ptr<QueuedTask> task_;
|
| D | simulated_process_thread.cc | 64 std::unique_ptr<QueuedTask> task = std::move(queue_.front()); in RunReady()
167 void SimulatedProcessThread::PostTask(std::unique_ptr<QueuedTask> task) { in PostTask()
173 void SimulatedProcessThread::PostDelayedTask(std::unique_ptr<QueuedTask> task, in PostDelayedTask()
|
| D | simulated_time_controller.h | 113 void PostTask(std::unique_ptr<QueuedTask> /*task*/) override { in PostTask() argument
116 void PostDelayedTask(std::unique_ptr<QueuedTask> /*task*/, in PostDelayedTask() argument
|
| /external/webrtc/rtc_tools/network_tester/ |
| D | packet_sender.cc | 30 class SendPacketTask : public QueuedTask {
43 std::unique_ptr<QueuedTask>(this), delay_ms); in Run()
53 class UpdateTestSettingTask : public QueuedTask {
67 std::unique_ptr<QueuedTask>(this), (*config).execution_time_ms); in Run()
|
| /external/webrtc/api/task_queue/ |
| D | queued_task.h | 18 class QueuedTask {
20 virtual ~QueuedTask() = default;
|
| D | task_queue_base.h | 46 virtual void PostTask(std::unique_ptr<QueuedTask> task) = 0;
52 virtual void PostDelayedTask(std::unique_ptr<QueuedTask> task,
|
| /external/webrtc/modules/utility/include/mock/ |
| D | mock_process_thread.h | 28 MOCK_METHOD(void, PostTask, (std::unique_ptr<QueuedTask>), (override));
31 (std::unique_ptr<QueuedTask>, uint32_t),
|
| /external/webrtc/audio/test/ |
| D | audio_bwe_integration_test.cc | 87 class StatsPollTask : public QueuedTask {
96 TaskQueueBase::Current()->PostDelayedTask(std::unique_ptr<QueuedTask>(this), in Run()
|
| /external/webrtc/video/end_to_end_tests/ |
| D | retransmission_tests.cc | 207 class KeyframeRequestObserver : public test::EndToEndTest, public QueuedTask { in TEST_F()
224 task_queue_->PostTask(std::unique_ptr<QueuedTask>(this)); in TEST_F()
232 task_queue_->PostDelayedTask(std::unique_ptr<QueuedTask>(this), 100); in TEST_F()
240 task_queue_->PostTask(std::unique_ptr<QueuedTask>(this)); in TEST_F()
|
| /external/webrtc/modules/audio_processing/aec_dump/ |
| D | write_to_file_task.h | 35 class WriteToFileTask : public QueuedTask { in RTC_POP_IGNORING_WUNDEF()
|