| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/decrypting_demuxer_stream.h" | 5 #include "media/filters/decrypting_demuxer_stream.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/callback_helpers.h" | 8 #include "base/callback_helpers.h" |
| 9 #include "base/location.h" | 9 #include "base/location.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 stream->audio_decoder_config().is_encrypted()) || | 25 stream->audio_decoder_config().is_encrypted()) || |
| 26 (stream->type() == DemuxerStream::VIDEO && | 26 (stream->type() == DemuxerStream::VIDEO && |
| 27 stream->video_decoder_config().IsValidConfig() && | 27 stream->video_decoder_config().IsValidConfig() && |
| 28 stream->video_decoder_config().is_encrypted())); | 28 stream->video_decoder_config().is_encrypted())); |
| 29 } | 29 } |
| 30 | 30 |
| 31 DecryptingDemuxerStream::DecryptingDemuxerStream( | 31 DecryptingDemuxerStream::DecryptingDemuxerStream( |
| 32 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, | 32 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
| 33 const SetDecryptorReadyCB& set_decryptor_ready_cb) | 33 const SetDecryptorReadyCB& set_decryptor_ready_cb) |
| 34 : task_runner_(task_runner), | 34 : task_runner_(task_runner), |
| 35 weak_factory_(this), | |
| 36 state_(kUninitialized), | 35 state_(kUninitialized), |
| 37 demuxer_stream_(NULL), | 36 demuxer_stream_(NULL), |
| 38 set_decryptor_ready_cb_(set_decryptor_ready_cb), | 37 set_decryptor_ready_cb_(set_decryptor_ready_cb), |
| 39 decryptor_(NULL), | 38 decryptor_(NULL), |
| 40 key_added_while_decrypt_pending_(false) { | 39 key_added_while_decrypt_pending_(false), |
| 41 } | 40 weak_factory_(this) {} |
| 42 | 41 |
| 43 void DecryptingDemuxerStream::Initialize(DemuxerStream* stream, | 42 void DecryptingDemuxerStream::Initialize(DemuxerStream* stream, |
| 44 const PipelineStatusCB& status_cb) { | 43 const PipelineStatusCB& status_cb) { |
| 45 DVLOG(2) << __FUNCTION__; | 44 DVLOG(2) << __FUNCTION__; |
| 46 DCHECK(task_runner_->BelongsToCurrentThread()); | 45 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 47 DCHECK_EQ(state_, kUninitialized) << state_; | 46 DCHECK_EQ(state_, kUninitialized) << state_; |
| 48 | 47 |
| 49 DCHECK(!demuxer_stream_); | 48 DCHECK(!demuxer_stream_); |
| 50 weak_this_ = weak_factory_.GetWeakPtr(); | 49 weak_this_ = weak_factory_.GetWeakPtr(); |
| 51 demuxer_stream_ = stream; | 50 demuxer_stream_ = stream; |
| (...skipping 335 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 387 break; | 386 break; |
| 388 } | 387 } |
| 389 | 388 |
| 390 default: | 389 default: |
| 391 NOTREACHED(); | 390 NOTREACHED(); |
| 392 return; | 391 return; |
| 393 } | 392 } |
| 394 } | 393 } |
| 395 | 394 |
| 396 } // namespace media | 395 } // namespace media |
| OLD | NEW |