Searched refs:decode_queue_ (Results 1 – 8 of 8) sorted by relevance
| /external/webrtc/video/ |
| D | video_receive_stream.h | 140 void StartNextDecode() RTC_RUN_ON(decode_queue_);
142 RTC_RUN_ON(decode_queue_);
143 void HandleFrameBufferTimeout() RTC_RUN_ON(decode_queue_);
146 void RequestKeyFrame(int64_t timestamp_ms) RTC_RUN_ON(decode_queue_);
148 RTC_RUN_ON(decode_queue_);
150 RTC_RUN_ON(decode_queue_);
169 bool decoder_stopped_ RTC_GUARDED_BY(decode_queue_) = true;
228 encoded_frame_buffer_function_ RTC_GUARDED_BY(decode_queue_);
230 bool keyframe_generation_requested_ RTC_GUARDED_BY(decode_queue_) = false;
233 rtc::TaskQueue decode_queue_; variable
|
| D | video_stream_decoder_impl.h | 83 VideoDecoder* GetDecoder(int payload_type) RTC_RUN_ON(decode_queue_);
86 RTC_RUN_ON(decode_queue_);
103 absl::optional<int> current_payload_type_ RTC_GUARDED_BY(decode_queue_);
104 VideoDecoderFactory* const decoder_factory_ RTC_PT_GUARDED_BY(decode_queue_);
106 RTC_GUARDED_BY(decode_queue_);
120 std::unique_ptr<VideoDecoder> decoder_ RTC_GUARDED_BY(decode_queue_);
121 rtc::TaskQueue decode_queue_; variable
|
| D | video_receive_stream2.h | 161 int64_t GetMaxWaitMs() const RTC_RUN_ON(decode_queue_);
162 void StartNextDecode() RTC_RUN_ON(decode_queue_);
164 RTC_RUN_ON(decode_queue_);
195 bool decoder_stopped_ RTC_GUARDED_BY(decode_queue_) = true;
223 bool keyframe_required_ RTC_GUARDED_BY(decode_queue_) = true;
226 bool frame_decoded_ RTC_GUARDED_BY(decode_queue_) = false;
228 int64_t last_keyframe_request_ms_ RTC_GUARDED_BY(decode_queue_) = 0;
256 encoded_frame_buffer_function_ RTC_GUARDED_BY(decode_queue_);
262 rtc::TaskQueue decode_queue_; variable
|
| D | video_receive_stream.cc | 228 decode_queue_(task_queue_factory_->CreateTaskQueue( in VideoReceiveStream()
395 decode_queue_.PostTask([this] { in Start()
396 RTC_DCHECK_RUN_ON(&decode_queue_); in Start()
411 decode_queue_.PostTask([this] { frame_buffer_->Stop(); }); in Stop()
417 decode_queue_.PostTask([this, &done] { in Stop()
418 RTC_DCHECK_RUN_ON(&decode_queue_); in Stop()
635 GetWaitMs(), keyframe_required_, &decode_queue_, in StartNextDecode()
640 decode_queue_.PostTask([this, frame = std::move(frame)]() mutable { in StartNextDecode()
641 RTC_DCHECK_RUN_ON(&decode_queue_); in StartNextDecode()
765 decode_queue_.PostTask([this, &event, &old_state, generate_key_frame, in SetAndGetRecordingState()
[all …]
|
| D | video_receive_stream2.cc | 226 decode_queue_(task_queue_factory_->CreateTaskQueue( in VideoReceiveStream2()
371 decode_queue_.PostTask([this] { in Start()
372 RTC_DCHECK_RUN_ON(&decode_queue_); in Start()
387 decode_queue_.PostTask([this] { frame_buffer_->Stop(); }); in Stop()
393 decode_queue_.PostTask([this, &done] { in Stop()
394 RTC_DCHECK_RUN_ON(&decode_queue_); in Stop()
531 decode_queue_.PostTask([this, timestamp_ms]() { in RequestKeyFrame()
532 RTC_DCHECK_RUN_ON(&decode_queue_); in RequestKeyFrame()
616 GetMaxWaitMs(), keyframe_required_, &decode_queue_, in StartNextDecode()
621 decode_queue_.PostTask([this, frame = std::move(frame)]() mutable { in StartNextDecode()
[all …]
|
| D | video_stream_decoder_impl.cc | 39 decode_queue_(task_queue_factory->CreateTaskQueue( in VideoStreamDecoderImpl()
165 decode_queue_.PostTask([this, frame = std::move(frame)]() mutable { in OnNextFrameCallback()
166 RTC_DCHECK_RUN_ON(&decode_queue_); in OnNextFrameCallback()
|
| D | receive_statistics_proxy2.cc | 140 decode_queue_.Detach(); in ReceiveStatisticsProxy()
705 RTC_DCHECK_RUN_ON(&decode_queue_); in OnIncomingPayloadType()
714 RTC_DCHECK_RUN_ON(&decode_queue_); in OnDecoderImplementationName()
729 RTC_DCHECK_RUN_ON(&decode_queue_); in OnFrameBufferTimingsUpdated()
757 RTC_DCHECK_RUN_ON(&decode_queue_); in OnTimingFrameInfoUpdated()
1014 RTC_DCHECK_RUN_ON(&decode_queue_); in OnPreDecode()
1047 decode_queue_.Detach(); in DecoderThreadStopped()
|
| D | receive_statistics_proxy2.h | 216 SequenceChecker decode_queue_; variable
|