| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 67 worker_queue = @ready_workers.pop
69 fail 'worker already has a task waiting' unless worker_queue.empty?
70 worker_queue << [blk, args]
99 worker_queue = @ready_workers.pop
100 worker_queue << [proc { throw :exit }, []]
134 def loop_execute_jobs(worker_queue) argument
137 blk, args = worker_queue.pop
144 fail('received a task while busy') unless worker_queue.empty?
147 @ready_workers << worker_queue
|
| /external/webrtc/modules/audio_processing/aec_dump/ |
| D | aec_dump_impl.cc | 60 rtc::TaskQueue* worker_queue) in AecDumpImpl() argument
63 worker_queue_(worker_queue), in AecDumpImpl()
234 rtc::TaskQueue* worker_queue) { in Create() argument
235 RTC_DCHECK(worker_queue); in Create()
240 worker_queue); in Create()
245 rtc::TaskQueue* worker_queue) { in Create() argument
247 max_log_size_bytes, worker_queue); in Create()
252 rtc::TaskQueue* worker_queue) { in Create() argument
253 return Create(FileWrapper(handle), max_log_size_bytes, worker_queue); in Create()
|
| D | null_aec_dump_factory.cc | 18 rtc::TaskQueue* worker_queue) { in Create() argument
24 rtc::TaskQueue* worker_queue) { in Create() argument
30 rtc::TaskQueue* worker_queue) { in Create() argument
|
| D | aec_dump_factory.h | 37 rtc::TaskQueue* worker_queue);
40 rtc::TaskQueue* worker_queue);
43 rtc::TaskQueue* worker_queue);
|
| D | aec_dump_impl.h | 49 rtc::TaskQueue* worker_queue);
|
| /external/webrtc/test/fuzzers/ |
| D | audio_processing_configs_fuzzer.cc | 39 rtc::TaskQueue* worker_queue) { in CreateApm() argument
117 apm->AttachAecDump(AecDumpFactory::Create("/dev/null", -1, worker_queue)); in CreateApm()
166 rtc::TaskQueue worker_queue(GetTaskQueueFactory()->CreateTaskQueue( in FuzzOneInput() local
168 auto apm = CreateApm(&fuzz_data, &field_trial_string, &worker_queue); in FuzzOneInput()
|
| /external/webrtc/modules/audio_processing/include/ |
| D | mock_audio_processing.h | 148 rtc::TaskQueue* worker_queue),
154 rtc::TaskQueue* worker_queue),
|
| D | audio_processing.h | 619 rtc::TaskQueue* worker_queue) = 0;
622 rtc::TaskQueue* worker_queue) = 0;
|
| /external/webrtc/video/ |
| D | video_send_stream_impl.h | 76 rtc::TaskQueue* worker_queue,
|
| D | video_send_stream_impl.cc | 190 rtc::TaskQueue* worker_queue, in VideoSendStreamImpl() argument
210 worker_queue_(worker_queue), in VideoSendStreamImpl()
|
| /external/webrtc/modules/audio_processing/ |
| D | audio_processing_impl.h | 78 rtc::TaskQueue* worker_queue) override;
81 rtc::TaskQueue* worker_queue) override;
|
| D | audio_processing_unittest.cc | 1356 TaskQueueForTest worker_queue("ApmTest_worker_queue"); in ProcessDebugDump() local
1381 AecDumpFactory::Create(out_filename, max_size_bytes, &worker_queue); in ProcessDebugDump()
1518 TaskQueueForTest worker_queue("ApmTest_worker_queue"); in TEST_F() local
1522 auto aec_dump = AecDumpFactory::Create("", -1, &worker_queue); in TEST_F()
1530 auto aec_dump = AecDumpFactory::Create(filename, -1, &worker_queue); in TEST_F()
1562 TaskQueueForTest worker_queue("ApmTest_worker_queue"); in TEST_F() local
1573 auto aec_dump = AecDumpFactory::Create(std::move(f), -1, &worker_queue); in TEST_F()
|
| D | audio_processing_impl.cc | 1546 rtc::TaskQueue* worker_queue) { in CreateAndAttachAecDump() argument
1548 AecDumpFactory::Create(file_name, max_log_size_bytes, worker_queue); in CreateAndAttachAecDump()
1559 rtc::TaskQueue* worker_queue) { in CreateAndAttachAecDump() argument
1561 AecDumpFactory::Create(handle, max_log_size_bytes, worker_queue); in CreateAndAttachAecDump()
|