Index: media/filters/decrypting_audio_decoder.cc |
diff --git a/media/filters/decrypting_audio_decoder.cc b/media/filters/decrypting_audio_decoder.cc |
index 92c0ae681858189235f5c5310b8268409f500d97..63c3c43912c9d5828bbb86bebb3eb410cde97485 100644 |
--- a/media/filters/decrypting_audio_decoder.cc |
+++ b/media/filters/decrypting_audio_decoder.cc |
@@ -120,7 +120,7 @@ |
DCHECK(init_cb_.is_null()); // No Reset() during pending initialization. |
DCHECK(reset_cb_.is_null()); |
- reset_cb_ = BindToCurrentLoop(closure); |
+ reset_cb_ = closure; |
decryptor_->ResetDecoder(Decryptor::kAudio); |
@@ -145,28 +145,6 @@ |
DoReset(); |
} |
-void DecryptingAudioDecoder::Stop(const base::Closure& closure) { |
- DVLOG(2) << "Stop() - state: " << state_; |
- DCHECK(task_runner_->BelongsToCurrentThread()); |
- |
- if (decryptor_) { |
- decryptor_->RegisterNewKeyCB(Decryptor::kAudio, Decryptor::NewKeyCB()); |
- decryptor_->DeinitializeDecoder(Decryptor::kAudio); |
- decryptor_ = NULL; |
- } |
- if (!set_decryptor_ready_cb_.is_null()) |
- base::ResetAndReturn(&set_decryptor_ready_cb_).Run(DecryptorReadyCB()); |
- pending_buffer_to_decode_ = NULL; |
- if (!init_cb_.is_null()) |
- base::ResetAndReturn(&init_cb_).Run(DECODER_ERROR_NOT_SUPPORTED); |
- if (!read_cb_.is_null()) |
- base::ResetAndReturn(&read_cb_).Run(kAborted, NULL); |
- if (!reset_cb_.is_null()) |
- base::ResetAndReturn(&reset_cb_).Run(); |
- state_ = kStopped; |
- task_runner_->PostTask(FROM_HERE, closure); |
-} |
- |
int DecryptingAudioDecoder::bits_per_channel() { |
DCHECK(task_runner_->BelongsToCurrentThread()); |
return bits_per_channel_; |
@@ -183,16 +161,11 @@ |
} |
DecryptingAudioDecoder::~DecryptingAudioDecoder() { |
- DCHECK(state_ == kUninitialized || state_ == kStopped) << state_; |
} |
void DecryptingAudioDecoder::SetDecryptor(Decryptor* decryptor) { |
DVLOG(2) << "SetDecryptor()"; |
DCHECK(task_runner_->BelongsToCurrentThread()); |
- |
- if (state_ == kStopped) |
- return; |
- |
DCHECK_EQ(state_, kDecryptorRequested) << state_; |
DCHECK(!init_cb_.is_null()); |
DCHECK(!set_decryptor_ready_cb_.is_null()); |
@@ -202,7 +175,7 @@ |
if (!decryptor) { |
base::ResetAndReturn(&init_cb_).Run(DECODER_ERROR_NOT_SUPPORTED); |
// TODO(xhwang): Add kError state. See http://crbug.com/251503 |
- state_ = kStopped; |
+ state_ = kDecodeFinished; |
return; |
} |
@@ -232,10 +205,6 @@ |
void DecryptingAudioDecoder::FinishInitialization(bool success) { |
DVLOG(2) << "FinishInitialization()"; |
DCHECK(task_runner_->BelongsToCurrentThread()); |
- |
- if (state_ == kStopped) |
- return; |
- |
DCHECK_EQ(state_, kPendingDecoderInit) << state_; |
DCHECK(!init_cb_.is_null()); |
DCHECK(reset_cb_.is_null()); // No Reset() before initialization finished. |
@@ -243,7 +212,7 @@ |
if (!success) { |
base::ResetAndReturn(&init_cb_).Run(DECODER_ERROR_NOT_SUPPORTED); |
- state_ = kStopped; |
+ state_ = kDecodeFinished; |
return; |
} |
@@ -375,10 +344,6 @@ |
const Decryptor::AudioBuffers& frames) { |
DVLOG(3) << "DeliverFrame() - status: " << status; |
DCHECK(task_runner_->BelongsToCurrentThread()); |
- |
- if (state_ == kStopped) |
- return; |
- |
DCHECK_EQ(state_, kPendingDecode) << state_; |
DCHECK(!read_cb_.is_null()); |
DCHECK(pending_buffer_to_decode_.get()); |