Update PluginInstance for decrypt-and-decode video.

webkit/media/crypto/ppapi_decryptor.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 "webkit/media/crypto/ppapi_decryptor.h"
 
 #include <string>
 
 #include "base/bind.h"
+#include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/message_loop.h"
 #include "base/message_loop_proxy.h"
 #include "media/base/decoder_buffer.h"
 #include "media/base/decryptor_client.h"
 #include "media/base/video_decoder_config.h"
 #include "media/base/video_frame.h"
 #include "webkit/media/crypto/key_systems.h"
 #include "webkit/plugins/ppapi/ppapi_plugin_instance.h"
@@ skipping 10 matching lines @@
   DCHECK(cdm_plugin_);
   cdm_plugin_->set_decrypt_client(client);
 }
 
 PpapiDecryptor::~PpapiDecryptor() {
 }
 
 bool PpapiDecryptor::GenerateKeyRequest(const std::string& key_system,
                                         const uint8* init_data,
                                         int init_data_length) {
-  DVLOG(1) << "GenerateKeyRequest()";
+  DVLOG(2) << "GenerateKeyRequest()";

[ddorwin, 2012/10/13 01:40:28]

Do we have level 1 logs in Proxydecryptor or something?

[xhwang, 2012/10/15 19:53:01]

We have a level 1 log in ReportFailureToCallPlugin. I use level 1 log for
abnormal situations. But I agree that we don't have consistent rule about the
use of log levels :)

   DCHECK(render_loop_proxy_->BelongsToCurrentThread());
   DCHECK(cdm_plugin_);
 
   // TODO(xhwang): Finalize the data type for |init_data| to avoid unnecessary
   // data type conversions.
   if (!cdm_plugin_->GenerateKeyRequest(
       key_system,
       std::string(reinterpret_cast<const char*>(init_data),
                   init_data_length))) {
     ReportFailureToCallPlugin(key_system, "");
     return false;
   }
 
   return true;
 }
 
 void PpapiDecryptor::AddKey(const std::string& key_system,
                             const uint8* key,
                             int key_length,
                             const uint8* init_data,
                             int init_data_length,
                             const std::string& session_id) {
-  DVLOG(1) << "AddKey()";
+  DVLOG(2) << "AddKey()";
   DCHECK(render_loop_proxy_->BelongsToCurrentThread());
   DCHECK(cdm_plugin_);
 
   if (!cdm_plugin_->AddKey(session_id,
                            std::string(reinterpret_cast<const char*>(key),
                                        key_length),
                            std::string(reinterpret_cast<const char*>(init_data),
                                        init_data_length))) {
     ReportFailureToCallPlugin(key_system, session_id);
   }
 
   if (!key_added_cb_.is_null())
     key_added_cb_.Run();
 }
 
 void PpapiDecryptor::CancelKeyRequest(const std::string& key_system,
                                       const std::string& session_id) {
-  DVLOG(1) << "CancelKeyRequest()";
+  DVLOG(2) << "CancelKeyRequest()";
   DCHECK(render_loop_proxy_->BelongsToCurrentThread());
   DCHECK(cdm_plugin_);
 
   if (!cdm_plugin_->CancelKeyRequest(session_id))
     ReportFailureToCallPlugin(key_system, session_id);
 }
 
 // TODO(xhwang): Remove Unretained in the following methods.
 
 void PpapiDecryptor::Decrypt(
     const scoped_refptr<media::DecoderBuffer>& encrypted,
     const DecryptCB& decrypt_cb) {
   if (!render_loop_proxy_->BelongsToCurrentThread()) {
     render_loop_proxy_->PostTask(
         FROM_HERE,
         base::Bind(&PpapiDecryptor::Decrypt, base::Unretained(this),
                    encrypted, decrypt_cb));
     return;
   }
 
-  DVLOG(1) << "Decrypt()";
+  DVLOG(3) << "Decrypt()";
   if (!cdm_plugin_->Decrypt(encrypted, decrypt_cb))
     decrypt_cb.Run(kError, NULL);
 }
 
 void PpapiDecryptor::CancelDecrypt() {
   // TODO(xhwang): Implement CancelDecrypt() in PluginInstance and call it here.
 }
 
 void PpapiDecryptor::InitializeVideoDecoder(
     scoped_ptr<media::VideoDecoderConfig> config,
     const DecoderInitCB& init_cb,
     const KeyAddedCB& key_added_cb) {
   if (!render_loop_proxy_->BelongsToCurrentThread()) {
     render_loop_proxy_->PostTask(
         FROM_HERE,
         base::Bind(&PpapiDecryptor::InitializeVideoDecoder,
                    base::Unretained(this), base::Passed(&config),
                    init_cb, key_added_cb));
     return;
   }
 
-  DVLOG(1) << "InitializeVideoDecoder()";
+  DVLOG(2) << "InitializeVideoDecoder()";
   DCHECK(config->is_encrypted());
   DCHECK(config->IsValidConfig());
 
+  video_decoder_init_cb_ = init_cb;
   key_added_cb_ = key_added_cb;
 
-  // TODO(xhwang): Enable this once PluginInstance is updated.
-  // if (!cdm_plugin_->InitializeVideoDecoder(video_config.Pass(), init_cb))
-  //   init_cb.Run(false);
-  init_cb.Run(false);
+  if (!cdm_plugin_->InitializeVideoDecoder(
+      *config,
+      base::Bind(&PpapiDecryptor::OnVideoDecoderInitialized,
+                 base::Unretained(this)))) {
+    key_added_cb_.Reset();
+    base::ResetAndReturn(&video_decoder_init_cb_).Run(false);
+    return;
+  }
 }
 
 void PpapiDecryptor::DecryptAndDecodeVideo(
     const scoped_refptr<media::DecoderBuffer>& encrypted,
     const VideoDecodeCB& video_decode_cb) {
   if (!render_loop_proxy_->BelongsToCurrentThread()) {
     render_loop_proxy_->PostTask(
         FROM_HERE,
         base::Bind(&PpapiDecryptor::DecryptAndDecodeVideo,
                    base::Unretained(this), encrypted, video_decode_cb));
     return;
   }
 
-  DVLOG(1) << "DecryptAndDecodeVideo()";
-  // TODO(xhwang): Enable this once PluginInstance is updated.
-  // if (!cdm_plugin_->DecryptAndDecodeVideo(encrypted, video_decode_cb))
-  //   video_decode_cb.Run(kError, NULL);
-  NOTIMPLEMENTED();
-  video_decode_cb.Run(kError, NULL);
+  DVLOG(3) << "DecryptAndDecodeVideo()";
+  if (!cdm_plugin_->DecryptAndDecode(encrypted, video_decode_cb))
+    video_decode_cb.Run(kError, NULL);
 }
 
 void PpapiDecryptor::CancelDecryptAndDecodeVideo() {

[ddorwin, 2012/10/13 01:40:28]

Should this be CancelVideoDecode() or eventually Cancel(type)?

[xhwang, 2012/10/15 19:53:01]

Yes, I plan to rename it to ResetDecoder(type) when I add audio support.

-  DVLOG(1) << "CancelDecryptAndDecodeVideo()";
-  // TODO(xhwang): Implement CancelDecryptAndDecodeVideo() in PluginInstance
-  // and call it here.
-  NOTIMPLEMENTED();
+  if (!render_loop_proxy_->BelongsToCurrentThread()) {
+    render_loop_proxy_->PostTask(
+        FROM_HERE,
+        base::Bind(&PpapiDecryptor::CancelDecryptAndDecodeVideo,
+                   base::Unretained(this)));
+    return;
+  }
+
+  DVLOG(2) << "CancelDecryptAndDecodeVideo()";
+  cdm_plugin_->ResetDecoder();

[ddorwin, 2012/10/13 01:40:28]

When we have audio, this will reset both. Is that what we want?

[xhwang, 2012/10/15 19:53:01]

ResetDecoder will take a StreamType param later.

 }
 
 void PpapiDecryptor::StopVideoDecoder() {

[ddorwin, 2012/10/13 01:40:28]

same here for both of the above.

[xhwang, 2012/10/15 19:53:01]

ditto

-  DVLOG(1) << "StopVideoDecoder()";
-  // TODO(xhwang): Implement StopVideoDecoder() in PluginInstance
-  // and call it here.
-  NOTIMPLEMENTED();
+  if (!render_loop_proxy_->BelongsToCurrentThread()) {
+    render_loop_proxy_->PostTask(
+        FROM_HERE,
+        base::Bind(&PpapiDecryptor::StopVideoDecoder, base::Unretained(this)));
+    return;
+  }
+
+  DVLOG(2) << "StopVideoDecoder()";
+  cdm_plugin_->DeinitializeDecoder();
 }
 
 void PpapiDecryptor::ReportFailureToCallPlugin(const std::string& key_system,
                                                const std::string& session_id) {
   DVLOG(1) << "Failed to call plugin.";
   client_->KeyError(key_system, session_id, kUnknownError, 0);
 }
 
+void PpapiDecryptor::OnVideoDecoderInitialized(bool success) {
+  DCHECK(!key_added_cb_.is_null());
+  DCHECK(!video_decoder_init_cb_.is_null());
+
+  if (!success)
+    key_added_cb_.Reset();
+
+  base::ResetAndReturn(&video_decoder_init_cb_).Run(success);
+}
+
 }  // namespace webkit_media