Home
last modified time | relevance | path

Searched refs:worker_queue_ (Results 1 – 18 of 18) sorted by relevance

/external/webrtc/video/
Dvideo_send_stream_impl.cc210 worker_queue_(worker_queue), in VideoSendStreamImpl()
239 RTC_DCHECK_RUN_ON(worker_queue_); in VideoSendStreamImpl()
317 RTC_DCHECK_RUN_ON(worker_queue_); in ~VideoSendStreamImpl()
335 RTC_DCHECK(!worker_queue_->IsCurrent()); in DeliverRtcp()
341 RTC_DCHECK_RUN_ON(worker_queue_); in UpdateActiveSimulcastLayers()
354 RTC_DCHECK_RUN_ON(worker_queue_); in Start()
364 RTC_DCHECK_RUN_ON(worker_queue_); in StartupVideoSendStream()
373 worker_queue_->Get(), kEncoderTimeOut, [this] { in StartupVideoSendStream()
374 RTC_DCHECK_RUN_ON(worker_queue_); in StartupVideoSendStream()
394 RTC_DCHECK_RUN_ON(worker_queue_); in Stop()
[all …]
Dvideo_send_stream_impl.h141 void StopVideoSendStream() RTC_RUN_ON(worker_queue_);
148 RTC_RUN_ON(worker_queue_);
156 rtc::TaskQueue* const worker_queue_; variable
159 RTC_GUARDED_BY(worker_queue_);
162 bool timed_out_ RTC_GUARDED_BY(worker_queue_);
199 RTC_GUARDED_BY(worker_queue_);
Dvideo_send_stream.cc84 : worker_queue_(transport->GetWorkerQueue()), in VideoSendStream()
97 worker_queue_->PostTask(ToQueuedTask( in VideoSendStream()
102 clock, &stats_proxy_, worker_queue_, call_stats, transport, in VideoSendStream()
152 worker_queue_->PostTask([this, send_stream, active_layers] { in UpdateActiveSimulcastLayers()
164 worker_queue_->PostTask([this, send_stream] { in Start()
179 worker_queue_->PostTask([send_stream] { send_stream->Stop(); }); in Stop()
228 worker_queue_->PostTask([this, rtp_state_map, payload_state_map]() { in StopPermanentlyAndGetRtpStates()
Dvideo_send_stream.h101 rtc::TaskQueue* const worker_queue_; variable
/external/webrtc/audio/
Daudio_send_stream.h129 void ConfigureBitrateObserver() RTC_RUN_ON(worker_queue_);
135 RTC_RUN_ON(worker_queue_);
152 rtc::TaskQueue* worker_queue_; variable
176 RTC_GUARDED_BY(worker_queue_);
205 bool registered_with_allocator_ RTC_GUARDED_BY(worker_queue_) = false;
206 size_t total_packet_overhead_bytes_ RTC_GUARDED_BY(worker_queue_) = 0;
208 RTC_GUARDED_BY(worker_queue_);
Daudio_send_stream.cc145 worker_queue_(rtp_transport->GetWorkerQueue()), in AudioSendStream()
164 RTC_DCHECK(worker_queue_); in AudioSendStream()
185 worker_queue_->PostTask([&] { thread_sync_event.Set(); }); in ~AudioSendStream()
358 worker_queue_->PostTask( in ConfigureStream()
360 RTC_DCHECK_RUN_ON(worker_queue_); in ConfigureStream()
384 worker_queue_->PostTask([&] { in Start()
385 RTC_DCHECK_RUN_ON(worker_queue_); in Start()
513 worker_queue_->PostTask([&]() { in DeliverRtcp()
522 RTC_DCHECK_RUN_ON(worker_queue_); in OnBitrateUpdated()
557 RTC_DCHECK_RUN_ON(worker_queue_); in UpdateOverheadForEncoder()
[all …]
Daudio_send_stream_unittest.cc157 worker_queue_(task_queue_factory_->CreateTaskQueue( in ConfigHelper()
192 .WillRepeatedly(Return(&worker_queue_)); in CreateAudioSendStream()
322 TaskQueueForTest* worker() { return &worker_queue_; } in worker()
340 TaskQueueForTest worker_queue_; member
/external/webrtc/modules/rtp_rtcp/source/
Drtp_sender_egress.cc85 : worker_queue_(TaskQueueBase::Current()), in RtpSenderEgress()
122 RTC_DCHECK(worker_queue_);
125 update_task_ = RepeatingTaskHandle::DelayedStart(worker_queue_,
134 RTC_DCHECK_RUN_ON(worker_queue_); in ~RtpSenderEgress()
150 worker_queue_->PostTask( in SendPacket()
158 worker_queue_->PostTask(ToQueuedTask( in SendPacket()
164 RTC_DCHECK_RUN_ON(worker_queue_); in SendPacket()
287 worker_queue_->PostTask( in SendPacket()
290 RTC_DCHECK_RUN_ON(worker_queue_); in SendPacket()
339 RTC_DCHECK_RUN_ON(worker_queue_); in SetTimestampOffset()
[all …]
Drtp_sender_egress.h129 TaskQueueBase* const worker_queue_; variable
155 uint32_t timestamp_offset_ RTC_GUARDED_BY(worker_queue_);
174 RTC_GUARDED_BY(worker_queue_);
175 RepeatingTaskHandle update_task_ RTC_GUARDED_BY(worker_queue_);
Drtp_rtcp_impl2.cc56 : worker_queue_(TaskQueueBase::Current()), in ModuleRtpRtcpImpl2()
69 RTC_DCHECK(worker_queue_); in ModuleRtpRtcpImpl2()
86 worker_queue_, kRttUpdateInterval, [this]() { in ModuleRtpRtcpImpl2()
94 RTC_DCHECK_RUN_ON(worker_queue_); in ~ModuleRtpRtcpImpl2()
639 RTC_DCHECK_RUN_ON(worker_queue_); in BitrateSent()
650 RTC_DCHECK_RUN_ON(worker_queue_); in GetSendRates()
713 RTC_DCHECK_RUN_ON(worker_queue_); in set_rtt_ms()
742 RTC_DCHECK_RUN_ON(worker_queue_); in PeriodicUpdate()
Drtp_rtcp_impl2.h299 TaskQueueBase* const worker_queue_; variable
320 RepeatingTaskHandle rtt_update_task_ RTC_GUARDED_BY(worker_queue_);
/external/webrtc/modules/audio_processing/aec_dump/
Daec_dump_impl.cc63 worker_queue_(worker_queue), in AecDumpImpl()
69 worker_queue_->PostTask([&thread_sync_event] { thread_sync_event.Set(); }); in ~AecDumpImpl()
99 worker_queue_->PostTask(std::move(task)); in WriteInitMessage()
131 worker_queue_->PostTask(std::move(task)); in WriteCaptureStreamMessage()
146 worker_queue_->PostTask(std::move(task)); in WriteRenderStreamMessage()
163 worker_queue_->PostTask(std::move(task)); in WriteRenderStreamMessage()
172 worker_queue_->PostTask(std::move(task)); in WriteConfig()
224 worker_queue_->PostTask(std::move(task)); in WriteRuntimeSetting()
Daec_dump_impl.h83 rtc::TaskQueue* worker_queue_; variable
/external/webrtc/rtc_tools/network_tester/
Dpacket_sender.cc89 worker_queue_(task_queue_factory_->CreateTaskQueue( in PacketSender()
97 worker_queue_.PostTask([this]() { in StartSending()
101 worker_queue_.PostTask(std::make_unique<UpdateTestSettingTask>( in StartSending()
103 worker_queue_.PostTask(std::make_unique<SendPacketTask>(this)); in StartSending()
Dpacket_sender.h60 rtc::TaskQueue worker_queue_; variable
/external/webrtc/modules/audio_processing/test/
Ddebug_dump_test.cc114 TaskQueueForTest worker_queue_; member in webrtc::test::__anon9b6362310111::DebugDumpGenerator
143 worker_queue_("debug_dump_generator_worker_queue"), in DebugDumpGenerator()
204 AecDumpFactory::Create(dump_file_name_.c_str(), -1, &worker_queue_)); in StartRecording()
Daudio_processing_simulator.cc124 worker_queue_("file_writer_task_queue") { in AudioProcessingSimulator()
543 *settings_.aec_dump_output_filename, -1, &worker_queue_)); in ConfigureAudioProcessor()
Daudio_processing_simulator.h224 TaskQueueForTest worker_queue_; variable