[DO NOT COMMIT] MediaPlayerRenderer using StreamTextures.

media/mojo/clients/mojo_renderer.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/clients/mojo_renderer.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/location.h"
 #include "base/single_thread_task_runner.h"
 #include "media/base/demuxer_stream_provider.h"
 #include "media/base/pipeline_status.h"
 #include "media/base/renderer_client.h"
 #include "media/base/video_renderer_sink.h"
+#include "media/media_features.h"
 #include "media/mojo/clients/mojo_demuxer_stream_impl.h"
 #include "media/renderers/video_overlay_factory.h"
 
 namespace media {
 
 MojoRenderer::MojoRenderer(
     const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
     std::unique_ptr<VideoOverlayFactory> video_overlay_factory,
     VideoRendererSink* video_renderer_sink,
     mojom::RendererPtr remote_renderer)
@@ skipping 21 matching lines @@
 
   if (encountered_error_) {
     task_runner_->PostTask(
         FROM_HERE, base::Bind(init_cb, PIPELINE_ERROR_INITIALIZATION_FAILED));
     return;
   }
 
   demuxer_stream_provider_ = demuxer_stream_provider;
   init_cb_ = init_cb;
 
+  switch (demuxer_stream_provider_->GetType()) {
+    case DemuxerStreamProvider::Type::STREAM:
+      InitializeRendererFromStreams(client);
+      break;
+    case DemuxerStreamProvider::Type::URL:
+      InitializeRendererFromUrl(client);
+      break;
+  }
+}
+
+void MojoRenderer::InitializeRendererFromStreams(
+    media::RendererClient* client) {
+  DVLOG(1) << __FUNCTION__;
+  DCHECK(task_runner_->BelongsToCurrentThread());
+
   // Create audio and video mojom::DemuxerStream and bind its lifetime to
   // the pipe.
   DemuxerStream* const audio =
       demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO);
   DemuxerStream* const video =
       demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO);
 
   mojom::DemuxerStreamPtr audio_stream;
   if (audio) {
     audio_stream_.reset(
@@ skipping 18 matching lines @@
                    base::Unretained(this), DemuxerStream::VIDEO));
   }
 
   BindRemoteRendererIfNeeded();
 
   // Using base::Unretained(this) is safe because |this| owns
   // |remote_renderer_|, and the callback won't be dispatched if
   // |remote_renderer_| is destroyed.
   remote_renderer_->Initialize(
       binding_.CreateInterfacePtrAndBind(), std::move(audio_stream),
-      std::move(video_stream),
+      std::move(video_stream), mojo::String(), -1,
       base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client));
 }
 
+void MojoRenderer::InitializeRendererFromUrl(media::RendererClient* client) {
+  DVLOG(2) << __FUNCTION__;
+  DCHECK(task_runner_->BelongsToCurrentThread());
+
+  BindRemoteRendererIfNeeded();
+
+  // TODO(tguilbert): Register and Send the proper surface ID. See
+  // crbug.com/627658
+  const int kFakeSurfaceId = 123;
+
+  // Using base::Unretained(this) is safe because |this| owns
+  // |remote_renderer_|, and the callback won't be dispatched if
+  // |remote_renderer_| is destroyed.
+  remote_renderer_->Initialize(
+      binding_.CreateInterfacePtrAndBind(), mojom::DemuxerStreamPtr(),
+      mojom::DemuxerStreamPtr(),
+      mojo::String::From(demuxer_stream_provider_->GetUrl().spec()),
+      kFakeSurfaceId,
+      base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client));
+}
+
 void MojoRenderer::SetCdm(CdmContext* cdm_context,
                           const CdmAttachedCB& cdm_attached_cb) {
   DVLOG(1) << __FUNCTION__;
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK(cdm_context);
   DCHECK(!cdm_attached_cb.is_null());
   DCHECK(cdm_attached_cb_.is_null());
 
   if (encountered_error_) {
     task_runner_->PostTask(FROM_HERE, base::Bind(cdm_attached_cb, false));
@@ skipping 65 matching lines @@
   base::AutoLock auto_lock(lock_);
   DVLOG(3) << __FUNCTION__ << ": " << time_.InMilliseconds() << " ms";
   return time_;
 }
 
 bool MojoRenderer::HasAudio() {
   DVLOG(1) << __FUNCTION__;
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK(remote_renderer_.is_bound());
 
+  // TODO(tguilbert): Update for the URL case.
   return !!demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO);
 }
 
 bool MojoRenderer::HasVideo() {
   DVLOG(1) << __FUNCTION__;
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK(remote_renderer_.is_bound());
 
+  // TODO(tguilbert): Update for the URL case.
   return !!demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO);
 }
 
 void MojoRenderer::OnTimeUpdate(int64_t time_usec, int64_t max_time_usec) {
   DVLOG(3) << __FUNCTION__ << ": " << time_usec << ", " << max_time_usec;
   DCHECK(task_runner_->BelongsToCurrentThread());
 
   base::AutoLock auto_lock(lock_);
   time_ = base::TimeDelta::FromMicroseconds(time_usec);
 }
@@ skipping 19 matching lines @@
 
   // TODO(tim): Should we plumb error code from remote renderer?
   // http://crbug.com/410451.
   client_->OnError(PIPELINE_ERROR_DECODE);
 }
 
 void MojoRenderer::OnVideoNaturalSizeChange(const gfx::Size& size) {
   DVLOG(2) << __FUNCTION__ << ": " << size.ToString();
   DCHECK(task_runner_->BelongsToCurrentThread());
 
+#if !BUILDFLAG(FORCE_MOJO_MEDIA_PLAYER_RENDERER)
+  // TODO(tguilbert): Investigate why this line crashes when using the
+  // MediaPlayerRenderer.
   video_renderer_sink_->PaintSingleFrame(
       video_overlay_factory_->CreateFrame(size));
+#endif
+
   client_->OnVideoNaturalSizeChange(size);
 }
 
+void MojoRenderer::OnDurationChange(int64_t duration_usec) {
+  DVLOG(2) << __FUNCTION__ << ": duration" << duration_usec;
+  client_->OnDurationChange(base::TimeDelta::FromMicroseconds(duration_usec));
+}
+
 void MojoRenderer::OnVideoOpacityChange(bool opaque) {
   DVLOG(2) << __FUNCTION__ << ": " << opaque;
   DCHECK(task_runner_->BelongsToCurrentThread());
   client_->OnVideoOpacityChange(opaque);
 }
 
 void MojoRenderer::OnStatisticsUpdate(const PipelineStatistics& stats) {
   DVLOG(3) << __FUNCTION__;
   DCHECK(task_runner_->BelongsToCurrentThread());
   client_->OnStatisticsUpdate(stats);
@@ skipping 88 matching lines @@
     base::ResetAndReturn(&init_cb_).Run(PIPELINE_ERROR_INITIALIZATION_FAILED);
 
   if (!flush_cb_.is_null())
     base::ResetAndReturn(&flush_cb_).Run();
 
   if (!cdm_attached_cb_.is_null())
     base::ResetAndReturn(&cdm_attached_cb_).Run(false);
 }
 
 }  // namespace media