| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/filters/decoder_selector.h" | 5 #include "media/filters/decoder_selector.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/callback_helpers.h" | 10 #include "base/callback_helpers.h" |
| (...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 61 ScopedVector<Decoder> decoders, | 61 ScopedVector<Decoder> decoders, |
| 62 const scoped_refptr<MediaLog>& media_log) | 62 const scoped_refptr<MediaLog>& media_log) |
| 63 : task_runner_(task_runner), | 63 : task_runner_(task_runner), |
| 64 decoders_(std::move(decoders)), | 64 decoders_(std::move(decoders)), |
| 65 media_log_(media_log), | 65 media_log_(media_log), |
| 66 input_stream_(nullptr), | 66 input_stream_(nullptr), |
| 67 weak_ptr_factory_(this) {} | 67 weak_ptr_factory_(this) {} |
| 68 | 68 |
| 69 template <DemuxerStream::Type StreamType> | 69 template <DemuxerStream::Type StreamType> |
| 70 DecoderSelector<StreamType>::~DecoderSelector() { | 70 DecoderSelector<StreamType>::~DecoderSelector() { |
| 71 DVLOG(2) << __FUNCTION__; | 71 DVLOG(2) << __func__; |
| 72 DCHECK(task_runner_->BelongsToCurrentThread()); | 72 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 73 | 73 |
| 74 if (!select_decoder_cb_.is_null()) | 74 if (!select_decoder_cb_.is_null()) |
| 75 ReturnNullDecoder(); | 75 ReturnNullDecoder(); |
| 76 | 76 |
| 77 decoder_.reset(); | 77 decoder_.reset(); |
| 78 decrypted_stream_.reset(); | 78 decrypted_stream_.reset(); |
| 79 } | 79 } |
| 80 | 80 |
| 81 template <DemuxerStream::Type StreamType> | 81 template <DemuxerStream::Type StreamType> |
| 82 void DecoderSelector<StreamType>::SelectDecoder( | 82 void DecoderSelector<StreamType>::SelectDecoder( |
| 83 StreamTraits* traits, | 83 StreamTraits* traits, |
| 84 DemuxerStream* stream, | 84 DemuxerStream* stream, |
| 85 CdmContext* cdm_context, | 85 CdmContext* cdm_context, |
| 86 const SelectDecoderCB& select_decoder_cb, | 86 const SelectDecoderCB& select_decoder_cb, |
| 87 const typename Decoder::OutputCB& output_cb, | 87 const typename Decoder::OutputCB& output_cb, |
| 88 const base::Closure& waiting_for_decryption_key_cb) { | 88 const base::Closure& waiting_for_decryption_key_cb) { |
| 89 DVLOG(2) << __FUNCTION__; | 89 DVLOG(2) << __func__; |
| 90 DCHECK(task_runner_->BelongsToCurrentThread()); | 90 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 91 DCHECK(traits); | 91 DCHECK(traits); |
| 92 DCHECK(stream); | 92 DCHECK(stream); |
| 93 DCHECK(select_decoder_cb_.is_null()); | 93 DCHECK(select_decoder_cb_.is_null()); |
| 94 | 94 |
| 95 cdm_context_ = cdm_context; | 95 cdm_context_ = cdm_context; |
| 96 waiting_for_decryption_key_cb_ = waiting_for_decryption_key_cb; | 96 waiting_for_decryption_key_cb_ = waiting_for_decryption_key_cb; |
| 97 | 97 |
| 98 // Make sure |select_decoder_cb| runs on a different execution stack. | 98 // Make sure |select_decoder_cb| runs on a different execution stack. |
| 99 select_decoder_cb_ = BindToCurrentLoop(select_decoder_cb); | 99 select_decoder_cb_ = BindToCurrentLoop(select_decoder_cb); |
| (...skipping 23 matching lines...) Expand all Loading... |
| 123 #if !defined(OS_ANDROID) | 123 #if !defined(OS_ANDROID) |
| 124 InitializeDecryptingDecoder(); | 124 InitializeDecryptingDecoder(); |
| 125 #else | 125 #else |
| 126 InitializeDecryptingDemuxerStream(); | 126 InitializeDecryptingDemuxerStream(); |
| 127 #endif | 127 #endif |
| 128 } | 128 } |
| 129 | 129 |
| 130 #if !defined(OS_ANDROID) | 130 #if !defined(OS_ANDROID) |
| 131 template <DemuxerStream::Type StreamType> | 131 template <DemuxerStream::Type StreamType> |
| 132 void DecoderSelector<StreamType>::InitializeDecryptingDecoder() { | 132 void DecoderSelector<StreamType>::InitializeDecryptingDecoder() { |
| 133 DVLOG(2) << __FUNCTION__; | 133 DVLOG(2) << __func__; |
| 134 decoder_.reset(new typename StreamTraits::DecryptingDecoderType( | 134 decoder_.reset(new typename StreamTraits::DecryptingDecoderType( |
| 135 task_runner_, media_log_, waiting_for_decryption_key_cb_)); | 135 task_runner_, media_log_, waiting_for_decryption_key_cb_)); |
| 136 | 136 |
| 137 traits_->InitializeDecoder( | 137 traits_->InitializeDecoder( |
| 138 decoder_.get(), input_stream_, cdm_context_, | 138 decoder_.get(), input_stream_, cdm_context_, |
| 139 base::Bind(&DecoderSelector<StreamType>::DecryptingDecoderInitDone, | 139 base::Bind(&DecoderSelector<StreamType>::DecryptingDecoderInitDone, |
| 140 weak_ptr_factory_.GetWeakPtr()), | 140 weak_ptr_factory_.GetWeakPtr()), |
| 141 output_cb_); | 141 output_cb_); |
| 142 } | 142 } |
| 143 | 143 |
| 144 template <DemuxerStream::Type StreamType> | 144 template <DemuxerStream::Type StreamType> |
| 145 void DecoderSelector<StreamType>::DecryptingDecoderInitDone(bool success) { | 145 void DecoderSelector<StreamType>::DecryptingDecoderInitDone(bool success) { |
| 146 DVLOG(2) << __FUNCTION__; | 146 DVLOG(2) << __func__; |
| 147 DCHECK(task_runner_->BelongsToCurrentThread()); | 147 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 148 | 148 |
| 149 if (success) { | 149 if (success) { |
| 150 base::ResetAndReturn(&select_decoder_cb_) | 150 base::ResetAndReturn(&select_decoder_cb_) |
| 151 .Run(std::move(decoder_), std::unique_ptr<DecryptingDemuxerStream>()); | 151 .Run(std::move(decoder_), std::unique_ptr<DecryptingDemuxerStream>()); |
| 152 return; | 152 return; |
| 153 } | 153 } |
| 154 | 154 |
| 155 decoder_.reset(); | 155 decoder_.reset(); |
| 156 | 156 |
| (...skipping 10 matching lines...) Expand all Loading... |
| 167 | 167 |
| 168 decrypted_stream_->Initialize( | 168 decrypted_stream_->Initialize( |
| 169 input_stream_, cdm_context_, | 169 input_stream_, cdm_context_, |
| 170 base::Bind(&DecoderSelector<StreamType>::DecryptingDemuxerStreamInitDone, | 170 base::Bind(&DecoderSelector<StreamType>::DecryptingDemuxerStreamInitDone, |
| 171 weak_ptr_factory_.GetWeakPtr())); | 171 weak_ptr_factory_.GetWeakPtr())); |
| 172 } | 172 } |
| 173 | 173 |
| 174 template <DemuxerStream::Type StreamType> | 174 template <DemuxerStream::Type StreamType> |
| 175 void DecoderSelector<StreamType>::DecryptingDemuxerStreamInitDone( | 175 void DecoderSelector<StreamType>::DecryptingDemuxerStreamInitDone( |
| 176 PipelineStatus status) { | 176 PipelineStatus status) { |
| 177 DVLOG(2) << __FUNCTION__; | 177 DVLOG(2) << __func__; |
| 178 DCHECK(task_runner_->BelongsToCurrentThread()); | 178 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 179 | 179 |
| 180 // If DecryptingDemuxerStream initialization succeeded, we'll use it to do | 180 // If DecryptingDemuxerStream initialization succeeded, we'll use it to do |
| 181 // decryption and use a decoder to decode the clear stream. Otherwise, we'll | 181 // decryption and use a decoder to decode the clear stream. Otherwise, we'll |
| 182 // try to see whether any decoder can decrypt-and-decode the encrypted stream | 182 // try to see whether any decoder can decrypt-and-decode the encrypted stream |
| 183 // directly. So in both cases, we'll initialize the decoders. | 183 // directly. So in both cases, we'll initialize the decoders. |
| 184 | 184 |
| 185 if (status == PIPELINE_OK) { | 185 if (status == PIPELINE_OK) { |
| 186 input_stream_ = decrypted_stream_.get(); | 186 input_stream_ = decrypted_stream_.get(); |
| 187 DCHECK(!IsStreamEncrypted(input_stream_)); | 187 DCHECK(!IsStreamEncrypted(input_stream_)); |
| 188 } else { | 188 } else { |
| 189 decrypted_stream_.reset(); | 189 decrypted_stream_.reset(); |
| 190 DCHECK(IsStreamEncrypted(input_stream_)); | 190 DCHECK(IsStreamEncrypted(input_stream_)); |
| 191 } | 191 } |
| 192 | 192 |
| 193 InitializeDecoder(); | 193 InitializeDecoder(); |
| 194 } | 194 } |
| 195 | 195 |
| 196 template <DemuxerStream::Type StreamType> | 196 template <DemuxerStream::Type StreamType> |
| 197 void DecoderSelector<StreamType>::InitializeDecoder() { | 197 void DecoderSelector<StreamType>::InitializeDecoder() { |
| 198 DVLOG(2) << __FUNCTION__; | 198 DVLOG(2) << __func__; |
| 199 DCHECK(task_runner_->BelongsToCurrentThread()); | 199 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 200 DCHECK(!decoder_); | 200 DCHECK(!decoder_); |
| 201 | 201 |
| 202 if (decoders_.empty()) { | 202 if (decoders_.empty()) { |
| 203 ReturnNullDecoder(); | 203 ReturnNullDecoder(); |
| 204 return; | 204 return; |
| 205 } | 205 } |
| 206 | 206 |
| 207 decoder_.reset(decoders_.front()); | 207 decoder_.reset(decoders_.front()); |
| 208 decoders_.weak_erase(decoders_.begin()); | 208 decoders_.weak_erase(decoders_.begin()); |
| 209 | 209 |
| 210 traits_->InitializeDecoder( | 210 traits_->InitializeDecoder( |
| 211 decoder_.get(), input_stream_, cdm_context_, | 211 decoder_.get(), input_stream_, cdm_context_, |
| 212 base::Bind(&DecoderSelector<StreamType>::DecoderInitDone, | 212 base::Bind(&DecoderSelector<StreamType>::DecoderInitDone, |
| 213 weak_ptr_factory_.GetWeakPtr()), | 213 weak_ptr_factory_.GetWeakPtr()), |
| 214 output_cb_); | 214 output_cb_); |
| 215 } | 215 } |
| 216 | 216 |
| 217 template <DemuxerStream::Type StreamType> | 217 template <DemuxerStream::Type StreamType> |
| 218 void DecoderSelector<StreamType>::DecoderInitDone(bool success) { | 218 void DecoderSelector<StreamType>::DecoderInitDone(bool success) { |
| 219 DVLOG(2) << __FUNCTION__; | 219 DVLOG(2) << __func__; |
| 220 DCHECK(task_runner_->BelongsToCurrentThread()); | 220 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 221 | 221 |
| 222 if (!success) { | 222 if (!success) { |
| 223 decoder_.reset(); | 223 decoder_.reset(); |
| 224 InitializeDecoder(); | 224 InitializeDecoder(); |
| 225 return; | 225 return; |
| 226 } | 226 } |
| 227 | 227 |
| 228 base::ResetAndReturn(&select_decoder_cb_) | 228 base::ResetAndReturn(&select_decoder_cb_) |
| 229 .Run(std::move(decoder_), std::move(decrypted_stream_)); | 229 .Run(std::move(decoder_), std::move(decrypted_stream_)); |
| 230 } | 230 } |
| 231 | 231 |
| 232 template <DemuxerStream::Type StreamType> | 232 template <DemuxerStream::Type StreamType> |
| 233 void DecoderSelector<StreamType>::ReturnNullDecoder() { | 233 void DecoderSelector<StreamType>::ReturnNullDecoder() { |
| 234 DVLOG(2) << __FUNCTION__; | 234 DVLOG(2) << __func__; |
| 235 DCHECK(task_runner_->BelongsToCurrentThread()); | 235 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 236 base::ResetAndReturn(&select_decoder_cb_) | 236 base::ResetAndReturn(&select_decoder_cb_) |
| 237 .Run(std::unique_ptr<Decoder>(), | 237 .Run(std::unique_ptr<Decoder>(), |
| 238 std::unique_ptr<DecryptingDemuxerStream>()); | 238 std::unique_ptr<DecryptingDemuxerStream>()); |
| 239 } | 239 } |
| 240 | 240 |
| 241 // These forward declarations tell the compiler that we will use | 241 // These forward declarations tell the compiler that we will use |
| 242 // DecoderSelector with these arguments, allowing us to keep these definitions | 242 // DecoderSelector with these arguments, allowing us to keep these definitions |
| 243 // in our .cc without causing linker errors. This also means if anyone tries to | 243 // in our .cc without causing linker errors. This also means if anyone tries to |
| 244 // instantiate a DecoderSelector with anything but these two specializations | 244 // instantiate a DecoderSelector with anything but these two specializations |
| 245 // they'll most likely get linker errors. | 245 // they'll most likely get linker errors. |
| 246 template class DecoderSelector<DemuxerStream::AUDIO>; | 246 template class DecoderSelector<DemuxerStream::AUDIO>; |
| 247 template class DecoderSelector<DemuxerStream::VIDEO>; | 247 template class DecoderSelector<DemuxerStream::VIDEO>; |
| 248 | 248 |
| 249 } // namespace media | 249 } // namespace media |
| OLD | NEW |