media: Support creation and SetCdm() for mojo based CDM.

media/mojo/services/mojo_renderer_service.cc

 // Copyright 2014 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/mojo/services/mojo_renderer_service.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/memory/scoped_vector.h"
 #include "base/message_loop/message_loop.h"
 #include "media/base/audio_decoder.h"
 #include "media/base/audio_renderer.h"
 #include "media/base/audio_renderer_sink.h"
+#include "media/base/cdm_context.h"
 #include "media/base/decryptor.h"
 #include "media/base/media_log.h"
 #include "media/base/video_renderer.h"
 #include "media/base/video_renderer_sink.h"
 #include "media/mojo/services/demuxer_stream_provider_shim.h"
 #include "media/mojo/services/renderer_config.h"
 #include "media/renderers/audio_renderer_impl.h"
 #include "media/renderers/renderer_impl.h"
 #include "media/renderers/video_renderer_impl.h"
 
 namespace media {
 
 // Time interval to update media time.
 const int kTimeUpdateIntervalMs = 50;
 
 MojoRendererService::MojoRendererService(
+    CdmContextProvider* cdm_context_provider,
     mojo::InterfaceRequest<mojo::MediaRenderer> request)
     : binding_(this, request.Pass()),
+      cdm_context_provider_(cdm_context_provider),
       state_(STATE_UNINITIALIZED),
       last_media_time_usec_(0),
       weak_factory_(this) {
   weak_this_ = weak_factory_.GetWeakPtr();
   DVLOG(1) << __FUNCTION__;
 
   scoped_refptr<base::SingleThreadTaskRunner> task_runner(
       base::MessageLoop::current()->task_runner());
   scoped_refptr<MediaLog> media_log(new MediaLog());
   RendererConfig* renderer_config = RendererConfig::Get();
@@ skipping 56 matching lines @@
 void MojoRendererService::SetPlaybackRate(double playback_rate) {
   DVLOG(2) << __FUNCTION__ << ": " << playback_rate;
   DCHECK_EQ(state_, STATE_PLAYING);
   renderer_->SetPlaybackRate(playback_rate);
 }
 
 void MojoRendererService::SetVolume(float volume) {
   renderer_->SetVolume(volume);
 }
 
+void MojoRendererService::SetCdm(int32_t cdm_id,
+                                 const mojo::Callback<void(bool)>& callback) {
+  if (!cdm_context_provider_) {
+    LOG(ERROR) << "CDM context provider not available.";
+    callback.Run(false);
+    return;
+  }
+
+  CdmContext* cdm_context = cdm_context_provider_->GetCdmContext(cdm_id);
+  if (!cdm_context) {
+    LOG(ERROR) << "CDM context not found: " << cdm_id;
+    callback.Run(false);
+    return;
+  }
+
+  renderer_->SetCdm(cdm_context, base::Bind(&MojoRendererService::OnCdmAttached,
+                                            weak_this_, callback));
+}
+
 void MojoRendererService::OnStreamReady(const mojo::Closure& callback) {
   DCHECK_EQ(state_, STATE_INITIALIZING);
 
   renderer_->Initialize(
       stream_provider_.get(),
       base::Bind(
           &MojoRendererService::OnRendererInitializeDone, weak_this_, callback),
       base::Bind(&MojoRendererService::OnUpdateStatistics, weak_this_),
       base::Bind(&MojoRendererService::OnBufferingStateChanged, weak_this_),
       base::Bind(&MojoRendererService::OnRendererEnded, weak_this_),
@@ skipping 38 matching lines @@
 void MojoRendererService::SchedulePeriodicMediaTimeUpdates() {
   UpdateMediaTime(true);
   time_update_timer_.Start(
       FROM_HERE,
       base::TimeDelta::FromMilliseconds(kTimeUpdateIntervalMs),
       base::Bind(&MojoRendererService::UpdateMediaTime, weak_this_, false));
 }
 
 void MojoRendererService::OnBufferingStateChanged(
     BufferingState new_buffering_state) {
-  DVLOG(2) << __FUNCTION__ << "(" << new_buffering_state << ") ";
+  DVLOG(2) << __FUNCTION__ << "(" << new_buffering_state << ")";
   client_->OnBufferingStateChange(
       static_cast<mojo::BufferingState>(new_buffering_state));
 }
 
 void MojoRendererService::OnRendererEnded() {
   DVLOG(1) << __FUNCTION__;
   CancelPeriodicMediaTimeUpdates();
   client_->OnEnded();
 }
 
 void MojoRendererService::OnError(PipelineStatus error) {
-  DVLOG(1) << __FUNCTION__;
+  DVLOG(1) << __FUNCTION__ << "(" << error << ")";
   state_ = STATE_ERROR;
   client_->OnError();
 }
 
 void MojoRendererService::OnFlushCompleted(const mojo::Closure& callback) {
   DVLOG(1) << __FUNCTION__;
   DCHECK_EQ(state_, STATE_FLUSHING);
   state_ = STATE_PLAYING;
   callback.Run();
 }
 
+void MojoRendererService::OnCdmAttached(
+    const mojo::Callback<void(bool)>& callback,
+    bool success) {
+  DVLOG(1) << __FUNCTION__ << "(" << success << ")";
+  callback.Run(success);
+}
+
 }  // namespace media