Home
last modified time | relevance | path

Searched refs:encoder_queue_ (Results 1 – 16 of 16) sorted by relevance

/external/webrtc/video/
Dvideo_stream_encoder.h115 rtc::TaskQueue* encoder_queue() { return &encoder_queue_; } in encoder_queue()
174 void ReconfigureEncoder() RTC_RUN_ON(&encoder_queue_);
175 void OnEncoderSettingsChanged() RTC_RUN_ON(&encoder_queue_);
188 bool DropDueToSize(uint32_t pixel_count) const RTC_RUN_ON(&encoder_queue_);
206 const EncoderRateSettings& rate_settings) RTC_RUN_ON(&encoder_queue_);
208 uint32_t GetInputFramerateFps() RTC_RUN_ON(&encoder_queue_);
210 RTC_RUN_ON(&encoder_queue_);
216 bool HasInternalSource() const RTC_RUN_ON(&encoder_queue_);
217 void ReleaseEncoder() RTC_RUN_ON(&encoder_queue_);
221 RTC_RUN_ON(&encoder_queue_);
[all …]
Dvideo_stream_encoder.cc362 encoder_queue_(task_queue_factory->CreateTaskQueue(
368 stream_resource_manager_.Initialize(&encoder_queue_,
444 encoder_queue_.PostTask([this] { in Stop()
445 RTC_DCHECK_RUN_ON(&encoder_queue_); in Stop()
458 encoder_queue_.PostTask([this, bitrate_observer] { in SetBitrateAllocationObserver()
459 RTC_DCHECK_RUN_ON(&encoder_queue_); in SetBitrateAllocationObserver()
467 encoder_queue_.PostTask([this, fec_controller_override] { in SetFecControllerOverride()
468 RTC_DCHECK_RUN_ON(&encoder_queue_); in SetFecControllerOverride()
483 encoder_queue_.PostTask([this, resource, &map_resource_event] { in AddAdaptationResource()
484 RTC_DCHECK_RUN_ON(&encoder_queue_); in AddAdaptationResource()
[all …]
/external/webrtc/video/adaptation/
Dquality_scaler_resource_unittest.cc35 encoder_queue_(encoder_queue), in FakeQualityScalerQpUsageHandlerCallback()
45 ASSERT_TRUE(encoder_queue_->IsCurrent()); in OnQpUsageHandled()
59 rtc::TaskQueue* const encoder_queue_; member in webrtc::__anon383553a40111::FakeQualityScalerQpUsageHandlerCallback
83 encoder_queue_(task_queue_factory_->CreateTaskQueue( in QualityScalerResourceTest()
89 quality_scaler_resource_->RegisterEncoderTaskQueue(encoder_queue_.Get()); in QualityScalerResourceTest()
93 encoder_queue_.PostTask([this, &event] { in QualityScalerResourceTest()
103 encoder_queue_.PostTask([this, &event] { in ~QualityScalerResourceTest()
113 rtc::TaskQueue encoder_queue_; member in webrtc::QualityScalerResourceTest
120 new FakeQualityScalerQpUsageHandlerCallback(&encoder_queue_); in TEST_F()
121 encoder_queue_.PostTask([this, callback] { in TEST_F()
[all …]
Dvideo_stream_encoder_resource_manager.cc145 RTC_DCHECK_RUN_ON(manager_->encoder_queue_); in OnEncoderSettingsUpdated()
157 RTC_DCHECK_RUN_ON(manager_->encoder_queue_); in OnEncoderTargetBitrateUpdated()
220 RTC_DCHECK_RUN_ON(manager_->encoder_queue_); in OnEncoderTargetBitrateUpdated()
278 encoder_queue_(nullptr), in VideoStreamEncoderResourceManager()
306 RTC_DCHECK(!encoder_queue_); in Initialize()
310 encoder_queue_ = encoder_queue; in Initialize()
314 encode_usage_resource_->RegisterEncoderTaskQueue(encoder_queue_->Get()); in Initialize()
317 quality_scaler_resource_->RegisterEncoderTaskQueue(encoder_queue_->Get()); in Initialize()
332 RTC_DCHECK_RUN_ON(encoder_queue_); in SetDegradationPreferences()
339 RTC_DCHECK_RUN_ON(encoder_queue_); in degradation_preference()
[all …]
Dvideo_stream_encoder_resource_manager.h239 rtc::TaskQueue* encoder_queue_; variable
242 RTC_GUARDED_BY(encoder_queue_);
250 DegradationPreference degradation_preference_ RTC_GUARDED_BY(encoder_queue_);
252 RTC_GUARDED_BY(encoder_queue_);
255 Clock* clock_ RTC_GUARDED_BY(encoder_queue_);
256 const bool experiment_cpu_load_estimator_ RTC_GUARDED_BY(encoder_queue_);
258 RTC_GUARDED_BY(encoder_queue_);
259 const bool quality_scaling_experiment_enabled_ RTC_GUARDED_BY(encoder_queue_);
261 RTC_GUARDED_BY(encoder_queue_);
263 RTC_GUARDED_BY(encoder_queue_);
[all …]
Dvideo_stream_encoder_resource.cc21 encoder_queue_(nullptr), in VideoStreamEncoderResource()
33 RTC_DCHECK(!encoder_queue_); in RegisterEncoderTaskQueue()
35 encoder_queue_ = encoder_queue; in RegisterEncoderTaskQueue()
75 return encoder_queue_; in encoder_queue()
Dvideo_stream_encoder_resource.h73 TaskQueueBase* encoder_queue_; variable
/external/webrtc/audio/
Dchannel_send.cc171 RTC_RUN_ON(encoder_queue_);
200 uint32_t _timeStamp RTC_GUARDED_BY(encoder_queue_);
204 RmsLevel rms_level_ RTC_GUARDED_BY(encoder_queue_);
206 bool previous_frame_muted_ RTC_GUARDED_BY(encoder_queue_);
224 bool encoder_queue_is_active_ RTC_GUARDED_BY(encoder_queue_) = false;
228 RTC_GUARDED_BY(encoder_queue_);
236 frame_transformer_delegate_ RTC_GUARDED_BY(encoder_queue_);
243 rtc::TaskQueue encoder_queue_; member in webrtc::voe::__anonbb1b0d450111::ChannelSend
350 RTC_DCHECK_RUN_ON(&encoder_queue_); in SendData()
472 encoder_queue_(task_queue_factory->CreateTaskQueue( in ChannelSend()
[all …]
Dchannel_send_frame_transformer_delegate.cc69 encoder_queue_(encoder_queue) {} in ChannelSendFrameTransformerDelegate()
104 encoder_queue_->PostTask( in OnTransformedFrame()
113 RTC_DCHECK_RUN_ON(encoder_queue_); in SendFrame()
Dchannel_send_frame_transformer_delegate.h78 rtc::TaskQueue* encoder_queue_ RTC_GUARDED_BY(send_lock_);
/external/webrtc/audio/voip/
Daudio_egress.cc26 encoder_queue_(task_queue_factory->CreateTaskQueue( in AudioEgress()
71 encoder_queue_.PostTask( in SendAudioData()
73 RTC_DCHECK_RUN_ON(&encoder_queue_); in SendAudioData()
104 RTC_DCHECK_RUN_ON(&encoder_queue_); in SendData()
165 encoder_queue_.PostTask([this, mute] { in SetMute()
166 RTC_DCHECK_RUN_ON(&encoder_queue_); in SetMute()
Daudio_egress.h134 EncoderContext encoder_context_ RTC_GUARDED_BY(encoder_queue_);
138 rtc::TaskQueue encoder_queue_; variable
/external/webrtc/modules/rtp_rtcp/source/
Drtp_sender_video_frame_transformer_delegate.cc114 if (!encoder_queue_) { in TransformFrame()
120 encoder_queue_ = current ? current : send_transport_queue_; in TransformFrame()
137 encoder_queue_->PostTask(ToQueuedTask( in OnTransformedFrame()
145 RTC_CHECK(encoder_queue_->IsCurrent()); in SendVideo()
Drtp_sender_video_frame_transformer_delegate.h71 TaskQueueBase* encoder_queue_ = nullptr; variable
/external/webrtc/media/engine/
Dsimulcast_encoder_adapter.cc159 encoder_queue_.Detach(); in SimulcastEncoderAdapter()
175 RTC_DCHECK_RUN_ON(&encoder_queue_); in Release()
190 encoder_queue_.Detach(); in Release()
201 RTC_DCHECK_RUN_ON(&encoder_queue_); in InitEncode()
352 RTC_DCHECK_RUN_ON(&encoder_queue_); in Encode()
464 RTC_DCHECK_RUN_ON(&encoder_queue_); in RegisterEncodeCompleteCallback()
474 RTC_DCHECK_RUN_ON(&encoder_queue_); in SetRates()
Dsimulcast_encoder_adapter.h128 SequenceChecker encoder_queue_; variable