Add CDM allocator interface.

webkit/media/crypto/ppapi/cdm_wrapper.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 <cstring>  // For memcpy.
+#include <cstring>
+#include <string>
 #include <vector>
 
-#include "base/compiler_specific.h"  // For OVERRIDE.
+#include "base/basictypes.h"
+#include "base/compiler_specific.h"
+#include "base/memory/linked_ptr.h"
 #include "ppapi/c/pp_errors.h"
 #include "ppapi/c/pp_stdint.h"
 #include "ppapi/c/private/pp_content_decryptor.h"
 #include "ppapi/cpp/completion_callback.h"
 #include "ppapi/cpp/core.h"
 #include "ppapi/cpp/instance.h"
 #include "ppapi/cpp/logging.h"
 #include "ppapi/cpp/module.h"
 #include "ppapi/cpp/pass_ref.h"
 #include "ppapi/cpp/resource.h"
@@ skipping 29 matching lines @@
   if (IsMainThread())
     cb.Run(PP_OK);
   else
     pp::Module::Get()->core()->CallOnMainThread(0, cb, PP_OK);
 }
 
 }  // namespace
 
 namespace webkit_media {
 
+// Provides access to memory owned by a pp::Buffer_Dev created by
+// PpbBufferAllocator::Allocate(). This class holds a reference to the
+// Buffer_Dev throughout its lifetime.
+class PpbBuffer : public cdm::Buffer {
+ public:
+  // cdm::Buffer methods.
+  uint8_t* buffer() OVERRIDE { return static_cast<uint8_t*>(buffer_.data()); }
+  int32_t size() const OVERRIDE { return buffer_.size(); }
+
+  pp::Buffer_Dev buffer_dev() const { return buffer_; }
+
+ private:
+  explicit PpbBuffer(pp::Buffer_Dev buffer) : buffer_(buffer) {}
+  virtual ~PpbBuffer() {}
+
+  pp::Buffer_Dev buffer_;
+
+  friend class PpbBufferAllocator;
+
+  DISALLOW_COPY_AND_ASSIGN(PpbBuffer);
+};
+
+class PpbBufferAllocator : public cdm::Allocator {
+ public:
+  explicit PpbBufferAllocator(pp::Instance* instance);
+  virtual ~PpbBufferAllocator();
+
+  // cdm::Allocator methods.
+  // Allocates a pp::Buffer_Dev of the specified size and wraps it in a
+  // PpbBuffer, which it returns. The caller own the returned buffer and must
+  // free it by calling ReleaseBuffer(). Returns NULL on failure.
+  virtual cdm::Buffer* Allocate(int32_t size) OVERRIDE;
+
+  // Deletes the cdm::Buffer*.
+  virtual void Release(cdm::Buffer* buffer) OVERRIDE;
+
+ private:
+  pp::Instance* const instance_;
+
+  DISALLOW_COPY_AND_ASSIGN(PpbBufferAllocator);
+};
+
+class KeyMessageImpl : public cdm::KeyMessage {
+ public:
+  explicit KeyMessageImpl(PpbBufferAllocator* allocator);
+  virtual ~KeyMessageImpl();
+
+  // cdm::KeyMessage methods.
+  virtual void set_session_id(const char* session_id, int32_t length) OVERRIDE;
+  virtual const char* session_id() const OVERRIDE;
+  virtual int32_t session_id_length() const OVERRIDE;
+
+  virtual void set_message(cdm::Buffer* message) OVERRIDE;
+  virtual cdm::Buffer* message() const OVERRIDE;
+
+  virtual void set_default_url(const char* default_url,
+                               int32_t length) OVERRIDE;
+  virtual const char* default_url() const OVERRIDE;
+  virtual int32_t default_url_length() const OVERRIDE;
+
+  std::string session_id_string() const { return session_id_; }
+  std::string default_url_string() const { return default_url_; }
+
+ private:
+  PpbBufferAllocator* const allocator_;
+  PpbBuffer* message_;
+  std::string session_id_;
+  std::string default_url_;
+
+  DISALLOW_COPY_AND_ASSIGN(KeyMessageImpl);
+};
+
+class OutputBufferImpl : public cdm::OutputBuffer {
+ public:
+  explicit OutputBufferImpl(PpbBufferAllocator* allocator);
+  virtual ~OutputBufferImpl();
+
+  virtual void set_buffer(cdm::Buffer* buffer) OVERRIDE;
+  virtual cdm::Buffer* buffer() const OVERRIDE;
+
+  virtual void set_timestamp(int64_t timestamp) OVERRIDE;
+  virtual int64_t timestamp() const OVERRIDE;
+
+ private:
+  PpbBufferAllocator* const allocator_;
+  PpbBuffer* buffer_;
+  int64_t timestamp_;
+
+  DISALLOW_COPY_AND_ASSIGN(OutputBufferImpl);
+};
+
+KeyMessageImpl::KeyMessageImpl(PpbBufferAllocator* allocator)
+    : allocator_(allocator),
+      message_(NULL) {
+  PP_DCHECK(allocator_);
+}
+
+KeyMessageImpl::~KeyMessageImpl() {
+  if (message_)
+    allocator_->Release(message_);
+}
+
+void KeyMessageImpl::set_session_id(const char* session_id, int32_t length) {
+  session_id_.assign(session_id, length);
+}
+
+const char* KeyMessageImpl::session_id() const {
+  return session_id_.c_str();
+}
+
+int32_t KeyMessageImpl::session_id_length() const {
+  return session_id_.length();
+}
+
+void KeyMessageImpl::set_message(cdm::Buffer* buffer) {
+  message_ = static_cast<PpbBuffer*>(buffer);
+}
+
+cdm::Buffer* KeyMessageImpl::message() const {
+  return message_;
+}
+
+void KeyMessageImpl::set_default_url(const char* default_url, int32_t length) {
+  default_url_.assign(default_url, length);
+}
+
+const char* KeyMessageImpl::default_url() const {
+  return default_url_.c_str();
+}
+
+int32_t KeyMessageImpl::default_url_length() const {
+  return default_url_.length();
+}
+
+OutputBufferImpl::OutputBufferImpl(PpbBufferAllocator* allocator)
+    : allocator_(allocator),
+      buffer_(NULL),
+      timestamp_(0) {
+  PP_DCHECK(allocator_);
+}
+
+OutputBufferImpl::~OutputBufferImpl() {
+  if (buffer_)
+    allocator_->Release(buffer_);
+}
+
+void OutputBufferImpl::set_buffer(cdm::Buffer* buffer) {
+  buffer_ = static_cast<PpbBuffer*>(buffer);
+}
+
+cdm::Buffer* OutputBufferImpl::buffer() const {
+  return buffer_;
+}
+
+void OutputBufferImpl::set_timestamp(int64_t timestamp) {
+  timestamp_ = timestamp;
+}
+
+int64_t OutputBufferImpl::timestamp() const {
+  return timestamp_;
+}
+
 // A wrapper class for abstracting away PPAPI interaction and threading for a
 // Content Decryption Module (CDM).
 class CdmWrapper : public pp::Instance,
                    public pp::ContentDecryptor_Private {
  public:
   CdmWrapper(PP_Instance instance, pp::Module* module);
   virtual ~CdmWrapper();
-
   virtual bool Init(uint32_t argc, const char* argn[], const char* argv[]) {
     return true;
   }
 
   // PPP_ContentDecryptor_Private methods
   // Note: As per comments in PPP_ContentDecryptor_Private, these calls should
   // return false if the call was not forwarded to the CDM and should return
   // true otherwise. Once the call reaches the CDM, the call result/status
   // should be reported through the PPB_ContentDecryptor_Private interface.
   virtual void GenerateKeyRequest(const std::string& key_system,
                                   pp::VarArrayBuffer init_data) OVERRIDE;
   virtual void AddKey(const std::string& session_id,
                       pp::VarArrayBuffer key,
                       pp::VarArrayBuffer init_data) OVERRIDE;
   virtual void CancelKeyRequest(const std::string& session_id) OVERRIDE;
   virtual void Decrypt(
       pp::Buffer_Dev encrypted_buffer,
       const PP_EncryptedBlockInfo& encrypted_block_info) OVERRIDE;
   virtual void DecryptAndDecode(
       pp::Buffer_Dev encrypted_buffer,
       const PP_EncryptedBlockInfo& encrypted_block_info) OVERRIDE;
 
  private:
-  // Creates a PP_Resource containing a PPB_Buffer_Impl, copies |data| into the
-  // buffer resource, and returns it. Returns a an invalid PP_Resource with an
-  // ID of 0 on failure. Upon success, the returned Buffer resource has a
-  // reference count of 1.
-  pp::Buffer_Dev MakeBufferResource(const uint8_t* data, uint32_t data_size);
+  typedef linked_ptr<KeyMessageImpl> LinkedKeyMessage;
+  typedef linked_ptr<OutputBufferImpl> LinkedOutputBuffer;
 
   // <code>PPB_ContentDecryptor_Private</code> dispatchers. These are passed to
   // <code>callback_factory_</code> to ensure that calls into
   // <code>PPP_ContentDecryptor_Private</code> are asynchronous.
   void KeyAdded(int32_t result, const std::string& session_id);
-  void KeyMessage(int32_t result, cdm::KeyMessage& key_message);
+  void KeyMessage(int32_t result, const LinkedKeyMessage& message);
   void KeyError(int32_t result, const std::string& session_id);
   void DeliverBlock(int32_t result,
                     const cdm::Status& status,
-                    cdm::OutputBuffer& output_buffer,
+                    const LinkedOutputBuffer& output_buffer,
                     const PP_DecryptTrackingInfo& tracking_info);
 
+  PpbBufferAllocator allocator_;
   pp::CompletionCallbackFactory<CdmWrapper> callback_factory_;
   cdm::ContentDecryptionModule* cdm_;
   std::string key_system_;
 };
 
+PpbBufferAllocator::PpbBufferAllocator(pp::Instance* instance)
+    : instance_(instance) {
+}
+
+PpbBufferAllocator::~PpbBufferAllocator() {
+}
+
+cdm::Buffer* PpbBufferAllocator::Allocate(int32_t size) {
+  PP_DCHECK(size > 0);
+
+  pp::Buffer_Dev buffer(instance_, size);
+  if (buffer.is_null())
+    return NULL;
+
+  return new PpbBuffer(buffer);
+}
+
+void PpbBufferAllocator::Release(cdm::Buffer* buffer) {
+  delete static_cast<PpbBuffer*>(buffer);

[ddorwin, 2012/09/18 01:26:08]

Why is this cast necessary? The destructor is virtual. Is it because Buffer's
destructor is now private?
Hmm. How about a pure virtual Destroy()/Release() method on Buffer. That would
move the deletion to the wrapper code. We probably don't even need this method
then.

[Tom Finegan, 2012/09/18 04:19:10]

Release is gone, now we have Buffer::Destroy.

+}
+
 CdmWrapper::CdmWrapper(PP_Instance instance, pp::Module* module)
     : pp::Instance(instance),
       pp::ContentDecryptor_Private(this),
+      allocator_(this),
       cdm_(NULL) {
   callback_factory_.Initialize(this);
 }
 
 CdmWrapper::~CdmWrapper() {
   if (cdm_)
     DestroyCdmInstance(cdm_);
 }
 
 void CdmWrapper::GenerateKeyRequest(const std::string& key_system,
                                     pp::VarArrayBuffer init_data) {
   PP_DCHECK(!key_system.empty());
 
   if (!cdm_) {
-    cdm_ = CreateCdmInstance();
+    cdm_ = CreateCdmInstance(&allocator_);
     if (!cdm_)
       return;
   }
 
-  cdm::KeyMessage key_request;
+  LinkedKeyMessage key_request(new KeyMessageImpl(&allocator_));
   cdm::Status status = cdm_->GenerateKeyRequest(
       reinterpret_cast<const uint8_t*>(init_data.Map()),
       init_data.ByteLength(),
-      &key_request);
+      key_request.get());
 
   if (status != cdm::kSuccess ||
-      !key_request.message ||
-      key_request.message_size == 0) {
+      !key_request->message() ||
+      key_request->message()->size() == 0) {
     CallOnMain(callback_factory_.NewCallback(&CdmWrapper::KeyError,
                                              std::string()));
     return;
   }
 
   // TODO(xhwang): Remove unnecessary CallOnMain calls here and below once we
   // only support out-of-process.
   // If running out-of-process, PPB calls will always behave asynchronously
   // since IPC is involved. In that case, if we are already on main thread,
   // we don't need to use CallOnMain to help us call PPB call on main thread,
@@ skipping 65 matching lines @@
       subsamples.push_back(cdm::SubsampleEntry(
           encrypted_block_info.subsamples[i].clear_bytes,
           encrypted_block_info.subsamples[i].cipher_bytes));
     }
 
     input_buffer.subsamples = &subsamples[0];
   }
 
   input_buffer.timestamp = encrypted_block_info.tracking_info.timestamp;
 
-  cdm::OutputBuffer output_buffer;
-  cdm::Status status = cdm_->Decrypt(input_buffer, &output_buffer);
-
+  LinkedOutputBuffer output_buffer(new OutputBufferImpl(&allocator_));
+  cdm::Status status = cdm_->Decrypt(input_buffer, output_buffer.get());
+  PP_DCHECK(status == cdm::kSuccess);

[ddorwin, 2012/09/18 01:26:08]

We need to handle these errors. I think we should copy the code at 323.

[Tom Finegan, 2012/09/18 04:19:10]

Done.

+  PP_DCHECK(output_buffer->buffer());
   CallOnMain(callback_factory_.NewCallback(
       &CdmWrapper::DeliverBlock,
       status,
       output_buffer,
       encrypted_block_info.tracking_info));
 }
 
 void CdmWrapper::DecryptAndDecode(
     pp::Buffer_Dev encrypted_buffer,
     const PP_EncryptedBlockInfo& encrypted_block_info) {
 }
 
-pp::Buffer_Dev CdmWrapper::MakeBufferResource(const uint8_t* data,
-                                              uint32_t data_size) {
-  if (!data || !data_size)
-    return pp::Buffer_Dev();
-
-  pp::Buffer_Dev buffer(this, data_size);
-  if (!buffer.data())
-    return pp::Buffer_Dev();
-
-  memcpy(buffer.data(), data, data_size);
-  return buffer;
-}
-
 void CdmWrapper::KeyAdded(int32_t result, const std::string& session_id) {
   pp::ContentDecryptor_Private::KeyAdded(key_system_, session_id);
 }
 
 void CdmWrapper::KeyMessage(int32_t result,
-                            cdm::KeyMessage& key_message) {
-  pp::Buffer_Dev message_buffer(MakeBufferResource(key_message.message,
-                                                   key_message.message_size));
+                            const LinkedKeyMessage& key_message) {
+  pp::Buffer_Dev message_buffer =
+      static_cast<const PpbBuffer*>(key_message->message())->buffer_dev();
   pp::ContentDecryptor_Private::KeyMessage(
       key_system_,
-      std::string(key_message.session_id, key_message.session_id_size),
+      key_message->session_id_string(),
       message_buffer,
-      std::string(key_message.default_url, key_message.default_url_size));
-
-  // TODO(xhwang): Fix this. This is not always safe as the memory is allocated
-  // in another shared object.
-  delete [] key_message.session_id;
-  key_message.session_id = NULL;
-  delete [] key_message.message;
-  key_message.message = NULL;
-  delete [] key_message.default_url;
-  key_message.default_url = NULL;
+      key_message->default_url_string());
 }
 
 // TODO(xhwang): Support MediaKeyError (see spec: http://goo.gl/rbdnR) in CDM
 // interface and in this function.
 void CdmWrapper::KeyError(int32_t result, const std::string& session_id) {
   pp::ContentDecryptor_Private::KeyError(key_system_,
                                          session_id,
                                          kUnknownError,
                                          0);
 }
 
 void CdmWrapper::DeliverBlock(int32_t result,
                               const cdm::Status& status,
-                              cdm::OutputBuffer& output_buffer,
+                              const LinkedOutputBuffer& output_buffer,
                               const PP_DecryptTrackingInfo& tracking_info) {
-  pp::Buffer_Dev decrypted_buffer(MakeBufferResource(output_buffer.data,
-                                                     output_buffer.data_size));
   PP_DecryptedBlockInfo decrypted_block_info;
   decrypted_block_info.tracking_info.request_id = tracking_info.request_id;
-  decrypted_block_info.tracking_info.timestamp = output_buffer.timestamp;
+  decrypted_block_info.tracking_info.timestamp = output_buffer->timestamp();
 
   switch (status) {
     case cdm::kSuccess:
       decrypted_block_info.result = PP_DECRYPTRESULT_SUCCESS;
       break;
     case cdm::kNoKey:
       decrypted_block_info.result = PP_DECRYPTRESULT_DECRYPT_NOKEY;
       break;
     default:
       decrypted_block_info.result = PP_DECRYPTRESULT_DECRYPT_ERROR;
   }
 
-  pp::ContentDecryptor_Private::DeliverBlock(decrypted_buffer,
-                                             decrypted_block_info);
-
-  // TODO(xhwang): Fix this. This is not always safe as the memory is allocated
-  // in another shared object.
-  delete [] output_buffer.data;
-  output_buffer.data = NULL;
+  pp::ContentDecryptor_Private::DeliverBlock(
+      static_cast<PpbBuffer*>(output_buffer->buffer())->buffer_dev(),
+      decrypted_block_info);
 }
 
 // This object is the global object representing this plugin library as long
 // as it is loaded.
-class MyModule : public pp::Module {
+class CdmWrapperModule : public pp::Module {
  public:
-  MyModule() : pp::Module() {}
-  virtual ~MyModule() {}
+  CdmWrapperModule() : pp::Module() {}
+  virtual ~CdmWrapperModule() {}
 
   virtual pp::Instance* CreateInstance(PP_Instance instance) {
     return new CdmWrapper(instance, this);
   }
 };
 
 }  // namespace webkit_media
 
 namespace pp {
 
 // Factory function for your specialization of the Module object.
 Module* CreateModule() {
-  return new webkit_media::MyModule();
+  return new webkit_media::CdmWrapperModule();
 }
 
 }  // namespace pp