Index: content/renderer/media/video_track_adapter.cc |
diff --git a/content/renderer/media/video_track_adapter.cc b/content/renderer/media/video_track_adapter.cc |
index 453e10c6edec630aed82567f67f1ded3d5d97470..aa4e40188a8868e0db2313ee44b97d2874f1d4c6 100644 |
--- a/content/renderer/media/video_track_adapter.cc |
+++ b/content/renderer/media/video_track_adapter.cc |
@@ -358,14 +358,14 @@ bool VideoTrackAdapter::VideoFrameResolutionAdapter::MaybeDropFrame( |
} |
VideoTrackAdapter::VideoTrackAdapter( |
- const scoped_refptr<base::MessageLoopProxy>& io_message_loop) |
- : io_message_loop_(io_message_loop), |
- renderer_task_runner_(base::MessageLoopProxy::current()), |
+ scoped_refptr<base::SingleThreadTaskRunner> io_task_runner) |
+ : io_task_runner_(io_task_runner), |
+ renderer_task_runner_(base::ThreadTaskRunnerHandle::Get()), |
monitoring_frame_rate_(false), |
muted_state_(false), |
frame_counter_(0), |
source_frame_rate_(0.0f) { |
- DCHECK(io_message_loop_.get()); |
+ DCHECK(io_task_runner); |
} |
VideoTrackAdapter::~VideoTrackAdapter() { |
@@ -381,11 +381,11 @@ void VideoTrackAdapter::AddTrack(const MediaStreamVideoTrack* track, |
double max_frame_rate) { |
DCHECK(thread_checker_.CalledOnValidThread()); |
- io_message_loop_->PostTask( |
+ io_task_runner_->PostTask( |
FROM_HERE, |
- base::Bind(&VideoTrackAdapter::AddTrackOnIO, |
- this, track, frame_callback, gfx::Size(max_width, max_height), |
- min_aspect_ratio, max_aspect_ratio, max_frame_rate)); |
+ base::Bind(&VideoTrackAdapter::AddTrackOnIO, this, track, frame_callback, |
+ gfx::Size(max_width, max_height), min_aspect_ratio, |
+ max_aspect_ratio, max_frame_rate)); |
} |
void VideoTrackAdapter::AddTrackOnIO(const MediaStreamVideoTrack* track, |
@@ -394,7 +394,7 @@ void VideoTrackAdapter::AddTrackOnIO(const MediaStreamVideoTrack* track, |
double min_aspect_ratio, |
double max_aspect_ratio, |
double max_frame_rate) { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
scoped_refptr<VideoFrameResolutionAdapter> adapter; |
for (const auto& frame_adapter : adapters_) { |
if (frame_adapter->ConstraintsMatch(max_frame_size, min_aspect_ratio, |
@@ -417,9 +417,8 @@ void VideoTrackAdapter::AddTrackOnIO(const MediaStreamVideoTrack* track, |
void VideoTrackAdapter::RemoveTrack(const MediaStreamVideoTrack* track) { |
DCHECK(thread_checker_.CalledOnValidThread()); |
- io_message_loop_->PostTask( |
- FROM_HERE, |
- base::Bind(&VideoTrackAdapter::RemoveTrackOnIO, this, track)); |
+ io_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&VideoTrackAdapter::RemoveTrackOnIO, this, track)); |
} |
void VideoTrackAdapter::StartFrameMonitoring( |
@@ -430,23 +429,21 @@ void VideoTrackAdapter::StartFrameMonitoring( |
VideoTrackAdapter::OnMutedCallback bound_on_muted_callback = |
media::BindToCurrentLoop(on_muted_callback); |
- io_message_loop_->PostTask( |
- FROM_HERE, |
- base::Bind(&VideoTrackAdapter::StartFrameMonitoringOnIO, |
- this, bound_on_muted_callback, source_frame_rate)); |
+ io_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&VideoTrackAdapter::StartFrameMonitoringOnIO, this, |
+ bound_on_muted_callback, source_frame_rate)); |
} |
void VideoTrackAdapter::StopFrameMonitoring() { |
DCHECK(thread_checker_.CalledOnValidThread()); |
- io_message_loop_->PostTask( |
- FROM_HERE, |
- base::Bind(&VideoTrackAdapter::StopFrameMonitoringOnIO, this)); |
+ io_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&VideoTrackAdapter::StopFrameMonitoringOnIO, this)); |
} |
void VideoTrackAdapter::StartFrameMonitoringOnIO( |
const OnMutedCallback& on_muted_callback, |
double source_frame_rate) { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
DCHECK(!monitoring_frame_rate_); |
monitoring_frame_rate_ = true; |
@@ -457,20 +454,20 @@ void VideoTrackAdapter::StartFrameMonitoringOnIO( |
source_frame_rate_ = source_frame_rate; |
DVLOG(1) << "Monitoring frame creation, first (large) delay: " |
<< (kFirstFrameTimeoutInFrameIntervals / source_frame_rate_) << "s"; |
- io_message_loop_->PostDelayedTask(FROM_HERE, |
- base::Bind(&VideoTrackAdapter::CheckFramesReceivedOnIO, this, |
- on_muted_callback, frame_counter_), |
- base::TimeDelta::FromSecondsD(kFirstFrameTimeoutInFrameIntervals / |
- source_frame_rate_)); |
+ io_task_runner_->PostDelayedTask( |
+ FROM_HERE, base::Bind(&VideoTrackAdapter::CheckFramesReceivedOnIO, this, |
+ on_muted_callback, frame_counter_), |
+ base::TimeDelta::FromSecondsD(kFirstFrameTimeoutInFrameIntervals / |
+ source_frame_rate_)); |
} |
void VideoTrackAdapter::StopFrameMonitoringOnIO() { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
monitoring_frame_rate_ = false; |
} |
void VideoTrackAdapter::RemoveTrackOnIO(const MediaStreamVideoTrack* track) { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
for (FrameAdapters::iterator it = adapters_.begin(); |
it != adapters_.end(); ++it) { |
(*it)->RemoveCallback(track); |
@@ -484,7 +481,7 @@ void VideoTrackAdapter::RemoveTrackOnIO(const MediaStreamVideoTrack* track) { |
void VideoTrackAdapter::DeliverFrameOnIO( |
const scoped_refptr<media::VideoFrame>& frame, |
const base::TimeTicks& estimated_capture_time) { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
TRACE_EVENT0("video", "VideoTrackAdapter::DeliverFrameOnIO"); |
++frame_counter_; |
for (const auto& adapter : adapters_) |
@@ -494,7 +491,7 @@ void VideoTrackAdapter::DeliverFrameOnIO( |
void VideoTrackAdapter::CheckFramesReceivedOnIO( |
const OnMutedCallback& set_muted_state_callback, |
uint64 old_frame_counter_snapshot) { |
- DCHECK(io_message_loop_->BelongsToCurrentThread()); |
+ DCHECK(io_task_runner_->BelongsToCurrentThread()); |
if (!monitoring_frame_rate_) |
return; |
@@ -508,9 +505,9 @@ void VideoTrackAdapter::CheckFramesReceivedOnIO( |
muted_state_ = muted_state; |
} |
- io_message_loop_->PostDelayedTask(FROM_HERE, |
- base::Bind(&VideoTrackAdapter::CheckFramesReceivedOnIO, this, |
- set_muted_state_callback, frame_counter_), |
+ io_task_runner_->PostDelayedTask( |
+ FROM_HERE, base::Bind(&VideoTrackAdapter::CheckFramesReceivedOnIO, this, |
+ set_muted_state_callback, frame_counter_), |
base::TimeDelta::FromSecondsD(kNormalFrameTimeoutInFrameIntervals / |
source_frame_rate_)); |
} |