Index: media/filters/audio_decoder_selector.cc |
diff --git a/media/filters/audio_decoder_selector.cc b/media/filters/audio_decoder_selector.cc |
index cc5e5188a9aed1169a5574a39e649be190b9cafd..4f7889b2619f3793a85765522d7ec2a1d6f5d34a 100644 |
--- a/media/filters/audio_decoder_selector.cc |
+++ b/media/filters/audio_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/audio_decoder_config.h" |
#include "media/base/bind_to_loop.h" |
#include "media/base/demuxer_stream.h" |
@@ -18,10 +18,10 @@ |
namespace media { |
AudioDecoderSelector::AudioDecoderSelector( |
- const scoped_refptr<base::MessageLoopProxy>& message_loop, |
+ const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
ScopedVector<AudioDecoder> 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 AudioDecoderSelector::SelectAudioDecoder( |
const StatisticsCB& statistics_cb, |
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. |
@@ -65,7 +65,7 @@ void AudioDecoderSelector::SelectAudioDecoder( |
} |
audio_decoder_.reset(new DecryptingAudioDecoder( |
- message_loop_, set_decryptor_ready_cb_)); |
+ task_runner_, set_decryptor_ready_cb_)); |
audio_decoder_->Initialize( |
input_stream_, |
@@ -76,7 +76,7 @@ void AudioDecoderSelector::SelectAudioDecoder( |
void AudioDecoderSelector::Abort() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
// This could happen when SelectAudioDecoder() was not called or when |
// |select_decoder_cb_| was already posted but not fired (e.g. in the |
@@ -110,7 +110,7 @@ void AudioDecoderSelector::Abort() { |
void AudioDecoderSelector::DecryptingAudioDecoderInitDone( |
PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status == PIPELINE_OK) { |
base::ResetAndReturn(&select_decoder_cb_).Run( |
@@ -121,7 +121,7 @@ void AudioDecoderSelector::DecryptingAudioDecoderInitDone( |
audio_decoder_.reset(); |
decrypted_stream_.reset(new DecryptingDemuxerStream( |
- message_loop_, set_decryptor_ready_cb_)); |
+ task_runner_, set_decryptor_ready_cb_)); |
decrypted_stream_->Initialize( |
input_stream_, |
@@ -132,7 +132,7 @@ void AudioDecoderSelector::DecryptingAudioDecoderInitDone( |
void AudioDecoderSelector::DecryptingDemuxerStreamInitDone( |
PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status != PIPELINE_OK) { |
ReturnNullDecoder(); |
@@ -146,7 +146,7 @@ void AudioDecoderSelector::DecryptingDemuxerStreamInitDone( |
void AudioDecoderSelector::InitializeDecoder() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
DCHECK(!audio_decoder_); |
if (decoders_.empty()) { |
@@ -165,7 +165,7 @@ void AudioDecoderSelector::InitializeDecoder() { |
void AudioDecoderSelector::DecoderInitDone(PipelineStatus status) { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
if (status != PIPELINE_OK) { |
audio_decoder_.reset(); |
@@ -179,7 +179,7 @@ void AudioDecoderSelector::DecoderInitDone(PipelineStatus status) { |
void AudioDecoderSelector::ReturnNullDecoder() { |
DVLOG(2) << __FUNCTION__; |
- DCHECK(message_loop_->BelongsToCurrentThread()); |
+ DCHECK(task_runner_->BelongsToCurrentThread()); |
base::ResetAndReturn(&select_decoder_cb_).Run( |
scoped_ptr<AudioDecoder>(), scoped_ptr<DecryptingDemuxerStream>()); |
} |