Home
last modified time | relevance | path

Searched refs:task_queue (Results 1 – 25 of 146) sorted by relevance

123456

/external/webrtc/rtc_base/task_utils/
Drepeating_task_unittest.cc86 TaskQueueForTest task_queue("TestQueue"); in TEST() local
88 auto handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
97 task_queue.PostTask( in TEST()
115 TaskQueueForTest task_queue("TestQueue"); in TEST() local
116 RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
129 TaskQueueForTest task_queue("TestQueue"); in TEST() local
130 RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
148 TaskQueueForTest task_queue("queue"); in TEST() local
150 task_queue.Get(), TimeDelta::Millis(100), MoveOnlyClosure(&mock)); in TEST()
151 task_queue.PostTask( in TEST()
[all …]
Drepeating_task.h31 RepeatingTaskBase(TaskQueueBase* task_queue,
54 RepeatingTaskImpl(TaskQueueBase* task_queue, in RepeatingTaskImpl() argument
58 : RepeatingTaskBase(task_queue, first_delay, clock), in RepeatingTaskImpl()
97 static RepeatingTaskHandle Start(TaskQueueBase* task_queue,
102 task_queue, TimeDelta::Zero(), std::forward<Closure>(closure), clock);
104 task_queue->PostTask(std::move(repeating_task));
112 TaskQueueBase* task_queue,
118 task_queue, first_delay, std::forward<Closure>(closure), clock);
120 task_queue->PostDelayedTask(std::move(repeating_task), first_delay.ms());
/external/webrtc/test/time_controller/
Dsimulated_time_controller_unittest.cc41 rtc::TaskQueue task_queue( in TEST() local
45 auto handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
54 task_queue.PostTask( in TEST()
66 rtc::TaskQueue task_queue( in TEST() local
71 task_queue.PostTask([&] { in TEST()
72 handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
88 rtc::TaskQueue* task_queue) { in TEST() argument
89 *handle = RepeatingTaskHandle::Start(task_queue->Get(), [this] { in TEST()
96 rtc::TaskQueue task_queue( in TEST() local
102 object->StartPeriodicTask(&handle, &task_queue); in TEST()
[all …]
Dexternal_time_controller_unittest.cc91 rtc::TaskQueue task_queue( in TEST() local
95 auto handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
104 task_queue.PostTask( in TEST()
117 rtc::TaskQueue task_queue( in TEST() local
122 task_queue.PostTask([&] { in TEST()
123 handle = RepeatingTaskHandle::Start(task_queue.Get(), [&] { in TEST()
137 rtc::TaskQueue task_queue( in TEST() local
142 task_queue.PostTask([&] { event.Set(); }); in TEST()
150 rtc::TaskQueue task_queue( in TEST() local
157 task_queue.PostTask([&] { in TEST()
[all …]
/external/libchrome/base/task/sequence_manager/
Dsequence_manager_impl.cc157 std::unique_ptr<internal::TaskQueueImpl> task_queue = in CreateTaskQueueImpl() local
159 main_thread_only().active_queues.insert(task_queue.get()); in CreateTaskQueueImpl()
160 main_thread_only().selector.AddQueue(task_queue.get()); in CreateTaskQueueImpl()
161 return task_queue; in CreateTaskQueueImpl()
169 internal::TaskQueueImpl* task_queue, in AddToIncomingImmediateWorkList() argument
173 if (task_queue->immediate_work_list_storage()->queue) in AddToIncomingImmediateWorkList()
177 task_queue->immediate_work_list_storage()->queue = task_queue; in AddToIncomingImmediateWorkList()
178 task_queue->immediate_work_list_storage()->order = enqueue_order; in AddToIncomingImmediateWorkList()
179 task_queue->immediate_work_list_storage()->next = in AddToIncomingImmediateWorkList()
182 task_queue->immediate_work_list_storage(); in AddToIncomingImmediateWorkList()
[all …]
Dtask_queue_selector_unittest.cc137 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in PopTasks()
152 std::unique_ptr<TaskQueueImpl> task_queue = in SetUp() local
155 selector_.AddQueue(task_queue.get()); in SetUp()
156 task_queues_.push_back(std::move(task_queue)); in SetUp()
167 for (std::unique_ptr<TaskQueueImpl>& task_queue : task_queues_) { in TearDown()
171 selector_.RemoveQueue(task_queue.get()); in TearDown()
172 task_queue->UnregisterTaskQueue(); in TearDown()
373 EXPECT_EQ(task_queues_[3].get(), chosen_work_queue->task_queue()); in TEST_F()
390 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in TEST_F()
410 queue_to_index_map_.find(chosen_work_queue->task_queue())->second; in TEST_F()
[all …]
Dsequence_manager_impl.h134 std::unique_ptr<internal::TaskQueueImpl> task_queue);
175 internal::TaskQueueImpl* task_queue, in ExecutingTask()
178 task_queue(task_queue), in ExecutingTask()
182 internal::TaskQueueImpl* task_queue = nullptr; member
271 bool AddToIncomingImmediateWorkList(internal::TaskQueueImpl* task_queue,
273 void RemoveFromIncomingImmediateWorkList(internal::TaskQueueImpl* task_queue);
292 internal::TaskQueueImpl* task_queue);
/external/webrtc/video/end_to_end_tests/
Dprobing_tests.cc72 explicit InitialProbingTest(bool* success, TaskQueueBase* task_queue) argument
73 : ProbingTest(300000), success_(success), task_queue_(task_queue) {
104 InitialProbingTest test(&success, task_queue());
125 TriggerMidCallProbingTest(TaskQueueBase* task_queue, bool* success) argument
126 : ProbingTest(300000), success_(success), task_queue_(task_queue) {}
184 TriggerMidCallProbingTest test(task_queue(), &success);
203 ReconfigureTest(TaskQueueBase* task_queue, bool* success) argument
204 : ProbingTest(50000), task_queue_(task_queue), success_(success) {}
220 TaskQueueBase* task_queue, argument
226 task_queue, sender_call, this, test::PacketTransport::kSender,
[all …]
Dmulti_stream_tester.cc50 auto task_queue = task_queue_factory->CreateTaskQueue( in RunTest() local
70 SendTask(RTC_FROM_HERE, task_queue.get(), [&]() { in RunTest()
73 sender_transport = CreateSendTransport(task_queue.get(), sender_call.get()); in RunTest()
75 CreateReceiveTransport(task_queue.get(), receiver_call.get()); in RunTest()
131 SendTask(RTC_FROM_HERE, task_queue.get(), [&]() { in RunTest()
158 TaskQueueBase* task_queue, in CreateSendTransport() argument
161 task_queue, in CreateSendTransport()
169 MultiStreamTester::CreateReceiveTransport(TaskQueueBase* task_queue, in CreateReceiveTransport() argument
172 task_queue, in CreateReceiveTransport()
Dbandwidth_tests.cc87 BandwidthStatsTest(bool send_side_bwe, TaskQueueBase* task_queue) in BandwidthStatsTest() argument
93 task_queue_(task_queue) {} in BandwidthStatsTest()
179 BandwidthStatsTest test(true, task_queue()); in TEST_F()
184 BandwidthStatsTest test(false, task_queue()); in TEST_F()
196 explicit BweObserver(TaskQueueBase* task_queue) in TEST_F() argument
205 task_queue_(task_queue) {} in TEST_F()
215 TaskQueueBase* task_queue) override { in TEST_F() argument
217 task_queue, nullptr, this, test::PacketTransport::kReceiver, in TEST_F()
312 } test(task_queue()); in TEST_F()
327 explicit EncoderRateStatsTest(TaskQueueBase* task_queue) in TEST_F() argument
[all …]
Dcall_operation_tests.cc101 RTC_FROM_HERE, task_queue(), in TEST_F()
107 task_queue(), in TEST_F()
113 task_queue(), in TEST_F()
149 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
176 RTC_FROM_HERE, task_queue(), in TEST_F()
182 task_queue(), in TEST_F()
188 task_queue(), in TEST_F()
219 SendTask(RTC_FROM_HERE, task_queue(), in TEST_F()
Drtp_rtcp_tests.cc287 RTC_FROM_HERE, task_queue(), in TestRtpStatePreservation()
293 task_queue(), sender_call_.get(), &observer, in TestRtpStatePreservation()
300 task_queue(), nullptr, &observer, test::PacketTransport::kReceiver, in TestRtpStatePreservation()
339 SendTask(RTC_FROM_HERE, task_queue(), [&]() { in TestRtpStatePreservation()
361 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestRtpStatePreservation()
370 SendTask(RTC_FROM_HERE, task_queue(), [this, &one_stream]() { in TestRtpStatePreservation()
377 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TestRtpStatePreservation()
386 SendTask(RTC_FROM_HERE, task_queue(), in TestRtpStatePreservation()
487 SendTask(RTC_FROM_HERE, task_queue(), [&]() { in TEST_F()
495 task_queue(), sender_call_.get(), &observer, in TEST_F()
[all …]
/external/python/cpython3/Doc/includes/
Dmp_workers.py46 task_queue = Queue()
51 task_queue.put(task)
55 Process(target=worker, args=(task_queue, done_queue)).start()
64 task_queue.put(task)
72 task_queue.put('STOP')
/external/python/cpython2/Doc/includes/
Dmp_workers.py59 task_queue = Queue()
64 task_queue.put(task)
68 Process(target=worker, args=(task_queue, done_queue)).start()
77 task_queue.put(task)
85 task_queue.put('STOP')
/external/webrtc/rtc_base/
Dtask_queue_gcd.cc63 static void SetNotActive(void* task_queue);
64 static void DeleteQueue(void* task_queue);
129 void TaskQueueGcd::SetNotActive(void* task_queue) { in SetNotActive() argument
130 static_cast<TaskQueueGcd*>(task_queue)->is_active_ = false; in SetNotActive()
134 void TaskQueueGcd::DeleteQueue(void* task_queue) { in DeleteQueue() argument
135 delete static_cast<TaskQueueGcd*>(task_queue); in DeleteQueue()
Dtask_queue_for_test.h28 void SendTask(rtc::Location loc, TaskQueueBase* task_queue, Closure&& task) { argument
29 RTC_CHECK(!task_queue->IsCurrent())
32 task_queue->PostTask(
/external/webrtc/call/adaptation/
DBUILD.gn40 "../../api/task_queue:task_queue",
78 "../../api/task_queue:default_task_queue_factory",
79 "../../api/task_queue:task_queue",
113 "../../api/task_queue:task_queue",
/external/libabigail/tests/
Dtest-types-stability.cc119 queue task_queue(num_workers); in main() local
127 ABG_ASSERT(task_queue.schedule_task(t)); in main()
130 ABG_ASSERT(task_queue.schedule_task(t)); in main()
134 task_queue.wait_for_workers_to_complete(); in main()
140 task_queue.get_completed_tasks(); in main()
/external/llvm-project/clang-tools-extra/clang-tidy/tool/
Dclang-tidy-diff.py52 def run_tidy(task_queue, lock, timeout): argument
55 command = task_queue.get()
83 task_queue.task_done()
86 def start_workers(max_tasks, tidy_caller, task_queue, lock, timeout): argument
88 t = threading.Thread(target=tidy_caller, args=(task_queue, lock, timeout))
211 task_queue = queue.Queue(max_task_count)
216 start_workers(max_task_count, run_tidy, task_queue, lock, args.timeout)
251 task_queue.put(command)
254 task_queue.join()
/external/webrtc/call/
Dbitrate_estimator_tests.cc108 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in SetUp()
112 task_queue(), in SetUp()
119 task_queue(), in SetUp()
151 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TearDown()
254 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
265 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
278 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
287 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
299 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
309 SendTask(RTC_FROM_HERE, task_queue(), [this]() { in TEST_F()
[all …]
Drampup_tests.cc66 TaskQueueBase* task_queue) in RampUpTester() argument
88 task_queue_(task_queue) { in RampUpTester()
111 TaskQueueBase* task_queue, in CreateSendTransport() argument
116 task_queue, sender_call, this, test::PacketTransport::kSender, in CreateSendTransport()
423 TaskQueueBase* task_queue) in RampUpDownUpTester() argument
433 task_queue), in RampUpDownUpTester()
625 true, task_queue()); in TEST_F()
641 false, loss_rates, true, task_queue()); in TEST_F()
653 false, loss_rates, false, task_queue()); in TEST_F()
670 false, loss_rates, false, task_queue()); in TEST_F()
[all …]
/external/webrtc/api/task_queue/
Dtask_queue_base.cc30 TaskQueueBase* task_queue) in CurrentTaskQueueSetter() argument
32 current = task_queue; in CurrentTaskQueueSetter()
66 TaskQueueBase* task_queue) in CurrentTaskQueueSetter() argument
68 pthread_setspecific(GetQueuePtrTls(), task_queue); in CurrentTaskQueueSetter()
Dtask_queue_base.h63 explicit CurrentTaskQueueSetter(TaskQueueBase* task_queue);
78 void operator()(TaskQueueBase* task_queue) const { task_queue->Delete(); } in operator()
/external/webrtc/modules/rtp_rtcp/source/
Drtcp_transceiver_unittest.cc64 config.task_queue = queue.Get(); in TEST()
81 config.task_queue = queue.Get(); in TEST()
101 config.task_queue = queue.Get(); in TEST()
117 config.task_queue = queue.Get(); in TEST()
138 config.task_queue = queue.Get(); in TEST()
169 config.task_queue = queue.Get(); in TEST()
196 config.task_queue = queue.Get(); in TEST()
220 config.task_queue = queue.Get(); in TEST()
249 config.task_queue = queue.Get(); in TEST()
271 config.task_queue = queue.Get(); in TEST()
[all …]
/external/webrtc/modules/video_coding/codecs/test/
Dvideocodec_test_fixture_impl.h64 void SetUpAndInitObjects(TaskQueueForTest* task_queue,
67 void ReleaseAndCloseObjects(TaskQueueForTest* task_queue);
69 void ProcessAllFrames(TaskQueueForTest* task_queue,
85 void PrintSettings(TaskQueueForTest* task_queue) const;

123456