Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1788)

Unified Diff: webrtc/video/video_receive_stream.cc

Issue 2997853002: Change ThreadChecker to SequencedTaskChecker in VideoReceiveStream (Closed)
Patch Set: Created 3 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « webrtc/video/video_receive_stream.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: webrtc/video/video_receive_stream.cc
diff --git a/webrtc/video/video_receive_stream.cc b/webrtc/video/video_receive_stream.cc
index 18cba03e21df11f9cf4e74ca5965729f310a9fb1..d9ccdc025112b61fd9f22fd2a7b4764e7769d610 100644
--- a/webrtc/video/video_receive_stream.cc
+++ b/webrtc/video/video_receive_stream.cc
@@ -205,7 +205,7 @@ VideoReceiveStream::VideoReceiveStream(
RTC_DCHECK(process_thread_);
RTC_DCHECK(call_stats_);
- module_process_thread_checker_.DetachFromThread();
+ module_process_sequence_checker_.Detach();
RTC_DCHECK(!config_.decoders.empty());
std::set<int> decoder_payload_types;
@@ -236,7 +236,7 @@ VideoReceiveStream::VideoReceiveStream(
}
VideoReceiveStream::~VideoReceiveStream() {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
LOG(LS_INFO) << "~VideoReceiveStream: " << config_.ToString();
Stop();
@@ -244,7 +244,7 @@ VideoReceiveStream::~VideoReceiveStream() {
}
void VideoReceiveStream::SignalNetworkState(NetworkState state) {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
rtp_video_stream_receiver_.SignalNetworkState(state);
}
@@ -253,12 +253,12 @@ bool VideoReceiveStream::DeliverRtcp(const uint8_t* packet, size_t length) {
}
void VideoReceiveStream::SetSync(Syncable* audio_syncable) {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
rtp_stream_sync_.ConfigureSync(audio_syncable);
}
void VideoReceiveStream::Start() {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
if (decode_thread_.IsRunning())
return;
@@ -313,7 +313,7 @@ void VideoReceiveStream::Start() {
}
void VideoReceiveStream::Stop() {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
rtp_video_stream_receiver_.StopReceive();
frame_buffer_->Stop();
@@ -450,12 +450,12 @@ void VideoReceiveStream::OnRttUpdate(int64_t avg_rtt_ms, int64_t max_rtt_ms) {
}
int VideoReceiveStream::id() const {
- RTC_DCHECK_RUN_ON(&worker_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&worker_sequence_checker_);
return config_.rtp.remote_ssrc;
}
rtc::Optional<Syncable::Info> VideoReceiveStream::GetInfo() const {
- RTC_DCHECK_RUN_ON(&module_process_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&module_process_sequence_checker_);
Syncable::Info info;
RtpReceiver* rtp_receiver = rtp_video_stream_receiver_.GetRtpReceiver();
@@ -485,7 +485,7 @@ uint32_t VideoReceiveStream::GetPlayoutTimestamp() const {
}
void VideoReceiveStream::SetMinimumPlayoutDelay(int delay_ms) {
- RTC_DCHECK_RUN_ON(&module_process_thread_checker_);
+ RTC_DCHECK_CALLED_SEQUENTIALLY(&module_process_sequence_checker_);
video_receiver_.SetMinimumPlayoutDelay(delay_ms);
}
« no previous file with comments | « webrtc/video/video_receive_stream.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698