Index: media/filters/video_decoder_selector.cc |
diff --git a/media/filters/video_decoder_selector.cc b/media/filters/video_decoder_selector.cc |
index e961a3164978bc226cf8c7fa058c9cf72356746c..525c0adde15baa0af5219fb75ad7435705546c05 100644 |
--- a/media/filters/video_decoder_selector.cc |
+++ b/media/filters/video_decoder_selector.cc |
@@ -7,7 +7,7 @@ |
#include "base/bind.h" |
#include "base/callback_helpers.h" |
#include "base/logging.h" |
-#include "base/message_loop/message_loop_proxy.h" |
+#include "base/single_thread_task_runner.h" |
#include "media/base/bind_to_loop.h" |
#include "media/base/demuxer_stream.h" |
#include "media/base/pipeline.h" |
@@ -18,10 +18,10 @@ |
namespace media { |
VideoDecoderSelector::VideoDecoderSelector( |
- const scoped_refptr<base::MessageLoopProxy>& message_loop, |
+ const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
ScopedVector<VideoDecoder> decoders, |
const SetDecryptorReadyCB& set_decryptor_ready_cb) |
- : message_loop_(message_loop), |
+ : task_runner_(task_runner), |
decoders_(decoders.Pass()), |
set_decryptor_ready_cb_(set_decryptor_ready_cb), |
input_stream_(NULL), |
@@ -37,7 +37,7 @@ void VideoDecoderSelector::SelectVideoDecoder( |
DemuxerStream* stream, |
const SelectDecoderCB& select_decoder_cb) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
DCHECK(stream); |
// Make sure |select_decoder_cb| runs on a different execution stack. |
@@ -64,7 +64,7 @@ void VideoDecoderSelector::SelectVideoDecoder( |
} |
video_decoder_.reset(new DecryptingVideoDecoder( |
- message_loop_, set_decryptor_ready_cb_)); |
+ task_runner_, set_decryptor_ready_cb_)); |
video_decoder_->Initialize( |
input_stream_->video_decoder_config(), |
@@ -74,7 +74,7 @@ void VideoDecoderSelector::SelectVideoDecoder( |
void VideoDecoderSelector::Abort() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
// This could happen when SelectVideoDecoder() was not called or when |
// |select_decoder_cb_| was already posted but not fired (e.g. in the |
@@ -108,7 +108,7 @@ void VideoDecoderSelector::Abort() { |
void VideoDecoderSelector::DecryptingVideoDecoderInitDone( |
PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status == PIPELINE_OK) { |
base::ResetAndReturn(&select_decoder_cb_).Run( |
@@ -119,7 +119,7 @@ void VideoDecoderSelector::DecryptingVideoDecoderInitDone( |
video_decoder_.reset(); |
decrypted_stream_.reset(new DecryptingDemuxerStream( |
- message_loop_, set_decryptor_ready_cb_)); |
+ task_runner_, set_decryptor_ready_cb_)); |
decrypted_stream_->Initialize( |
input_stream_, |
@@ -130,7 +130,7 @@ void VideoDecoderSelector::DecryptingVideoDecoderInitDone( |
void VideoDecoderSelector::DecryptingDemuxerStreamInitDone( |
PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status != PIPELINE_OK) { |
ReturnNullDecoder(); |
@@ -144,7 +144,7 @@ void VideoDecoderSelector::DecryptingDemuxerStreamInitDone( |
void VideoDecoderSelector::InitializeDecoder() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
DCHECK(!video_decoder_); |
if (decoders_.empty()) { |
@@ -162,7 +162,7 @@ void VideoDecoderSelector::InitializeDecoder() { |
void VideoDecoderSelector::DecoderInitDone(PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status != PIPELINE_OK) { |
video_decoder_.reset(); |
@@ -176,7 +176,7 @@ void VideoDecoderSelector::DecoderInitDone(PipelineStatus status) { |
void VideoDecoderSelector::ReturnNullDecoder() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
base::ResetAndReturn(&select_decoder_cb_).Run( |
scoped_ptr<VideoDecoder>(), scoped_ptr<DecryptingDemuxerStream>()); |
} |