Decryptors can report kNoKey to WebMediaPlayer

media/filters/decrypting_demuxer_stream.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/filters/decrypting_demuxer_stream.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/logging.h"
@@ skipping 21 matching lines @@
     const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
     const SetDecryptorReadyCB& set_decryptor_ready_cb)
     : task_runner_(task_runner),
       state_(kUninitialized),
       demuxer_stream_(NULL),
       set_decryptor_ready_cb_(set_decryptor_ready_cb),
       decryptor_(NULL),
       key_added_while_decrypt_pending_(false),
       weak_factory_(this) {}
 
-void DecryptingDemuxerStream::Initialize(DemuxerStream* stream,
-                                         const PipelineStatusCB& status_cb) {
+void DecryptingDemuxerStream::Initialize(
+    DemuxerStream* stream,
+    const PipelineStatusCB& status_cb,
+    const base::Closure& waiting_for_encryption_key_cb) {
   DVLOG(2) << __FUNCTION__;
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK_EQ(state_, kUninitialized) << state_;
 
   DCHECK(!demuxer_stream_);
   weak_this_ = weak_factory_.GetWeakPtr();
   demuxer_stream_ = stream;
   init_cb_ = BindToCurrentLoop(status_cb);
+  waiting_for_encryption_key_cb_ = waiting_for_encryption_key_cb;
 
   InitializeDecoderConfig();
 
   state_ = kDecryptorRequested;
   set_decryptor_ready_cb_.Run(BindToCurrentLoop(
       base::Bind(&DecryptingDemuxerStream::SetDecryptor, weak_this_)));
 }
 
 void DecryptingDemuxerStream::Read(const ReadCB& read_cb) {
   DVLOG(3) << __FUNCTION__;
@@ skipping 242 matching lines @@
 
   if (status == Decryptor::kNoKey) {
     DVLOG(2) << "DoDeliverBuffer() - kNoKey";
     if (need_to_try_again_if_nokey) {
       // The |state_| is still kPendingDecrypt.
       DecryptPendingBuffer();
       return;
     }
 
     state_ = kWaitingForKey;
+    waiting_for_encryption_key_cb_.Run();
     return;
   }
 
   DCHECK_EQ(status, Decryptor::kSuccess);
 
   // Copy the key frame flag from the encrypted to decrypted buffer, assuming
   // that the decryptor initialized the flag to false.
   if (pending_buffer_to_decrypt_->is_key_frame())
     decrypted_buffer->set_is_key_frame(true);
 
@@ skipping 75 matching lines @@
       break;
     }
 
     default:
       NOTREACHED();
       return;
   }
 }
 
 }  // namespace media