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/decryptor.h"
 #include "media/base/media_log.h"
 #include "media/base/video_renderer.h"
 #include "media/filters/audio_renderer_impl.h"
 #include "media/filters/renderer_impl.h"
 #include "media/filters/video_renderer_impl.h"
 #include "media/mojo/services/demuxer_stream_provider_shim.h"
+#include "media/mojo/services/mojo_cdm_service_context.h"
 #include "media/mojo/services/mojo_demuxer_stream_adapter.h"
 #include "media/mojo/services/renderer_config.h"
 
 namespace media {
 
 // Time interval to update media time.
 const int kTimeUpdateIntervalMs = 50;
 
 static void LogMediaSourceError(const scoped_refptr<MediaLog>& media_log,
                                 const std::string& error) {
   media_log->AddEvent(media_log->CreateMediaSourceErrorEvent(error));
 }
 
 static void PaintNothing(const scoped_refptr<VideoFrame>& frame) {
 }
 
-MojoRendererService::MojoRendererService()
-    : state_(STATE_UNINITIALIZED),
+MojoRendererService::MojoRendererService(
+    MojoCdmServiceContext* cdm_service_context)
+    : cdm_service_context_(cdm_service_context),
+      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();
   audio_renderer_sink_ = renderer_config->GetAudioRendererSink();
@@ skipping 54 matching lines @@
 void MojoRendererService::SetPlaybackRate(float 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) {
+  CdmContext* cdm_context = cdm_service_context_->GetCdmContext(cdm_id);
+  if (!cdm_context) {
+    DVLOG(1) << __FUNCTION__ << ": No CDM for " << cdm_id << " found.";
+    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(&PaintNothing),
@@ skipping 59 matching lines @@
   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__;
+  callback.Run(success);
+}
+
 }  // namespace media