| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/mojo/services/mojo_renderer_service.h" | 5 #include "media/mojo/services/mojo_renderer_service.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "media/base/media_keys.h" | 10 #include "media/base/media_keys.h" |
| 11 #include "media/base/renderer.h" | 11 #include "media/base/renderer.h" |
| 12 #include "media/mojo/services/demuxer_stream_provider_shim.h" | 12 #include "media/mojo/services/demuxer_stream_provider_shim.h" |
| 13 #include "media/mojo/services/mojo_cdm_service_context.h" | 13 #include "media/mojo/services/mojo_cdm_service_context.h" |
| 14 | 14 |
| 15 namespace media { | 15 namespace media { |
| 16 | 16 |
| 17 // Time interval to update media time. | 17 // Time interval to update media time. |
| 18 const int kTimeUpdateIntervalMs = 50; | 18 const int kTimeUpdateIntervalMs = 50; |
| 19 | 19 |
| 20 MojoRendererService::MojoRendererService( | 20 MojoRendererService::MojoRendererService( |
| 21 base::WeakPtr<MojoCdmServiceContext> mojo_cdm_service_context, | 21 base::WeakPtr<MojoCdmServiceContext> mojo_cdm_service_context, |
| 22 std::unique_ptr<media::Renderer> renderer, | 22 std::unique_ptr<media::Renderer> renderer, |
| 23 mojo::InterfaceRequest<interfaces::Renderer> request) | 23 mojo::InterfaceRequest<mojom::Renderer> request) |
| 24 : binding_(this, std::move(request)), | 24 : binding_(this, std::move(request)), |
| 25 mojo_cdm_service_context_(mojo_cdm_service_context), | 25 mojo_cdm_service_context_(mojo_cdm_service_context), |
| 26 state_(STATE_UNINITIALIZED), | 26 state_(STATE_UNINITIALIZED), |
| 27 last_media_time_usec_(0), | 27 last_media_time_usec_(0), |
| 28 renderer_(std::move(renderer)), | 28 renderer_(std::move(renderer)), |
| 29 weak_factory_(this) { | 29 weak_factory_(this) { |
| 30 DVLOG(1) << __FUNCTION__; | 30 DVLOG(1) << __FUNCTION__; |
| 31 DCHECK(renderer_); | 31 DCHECK(renderer_); |
| 32 | 32 |
| 33 weak_this_ = weak_factory_.GetWeakPtr(); | 33 weak_this_ = weak_factory_.GetWeakPtr(); |
| 34 } | 34 } |
| 35 | 35 |
| 36 MojoRendererService::~MojoRendererService() { | 36 MojoRendererService::~MojoRendererService() { |
| 37 } | 37 } |
| 38 | 38 |
| 39 void MojoRendererService::Initialize( | 39 void MojoRendererService::Initialize( |
| 40 interfaces::RendererClientPtr client, | 40 mojom::RendererClientPtr client, |
| 41 interfaces::DemuxerStreamPtr audio, | 41 mojom::DemuxerStreamPtr audio, |
| 42 interfaces::DemuxerStreamPtr video, | 42 mojom::DemuxerStreamPtr video, |
| 43 const mojo::Callback<void(bool)>& callback) { | 43 const mojo::Callback<void(bool)>& callback) { |
| 44 DVLOG(1) << __FUNCTION__; | 44 DVLOG(1) << __FUNCTION__; |
| 45 DCHECK_EQ(state_, STATE_UNINITIALIZED); | 45 DCHECK_EQ(state_, STATE_UNINITIALIZED); |
| 46 client_ = std::move(client); | 46 client_ = std::move(client); |
| 47 state_ = STATE_INITIALIZING; | 47 state_ = STATE_INITIALIZING; |
| 48 stream_provider_.reset(new DemuxerStreamProviderShim( | 48 stream_provider_.reset(new DemuxerStreamProviderShim( |
| 49 std::move(audio), std::move(video), | 49 std::move(audio), std::move(video), |
| 50 base::Bind(&MojoRendererService::OnStreamReady, weak_this_, callback))); | 50 base::Bind(&MojoRendererService::OnStreamReady, weak_this_, callback))); |
| 51 } | 51 } |
| 52 | 52 |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 109 client_->OnError(); | 109 client_->OnError(); |
| 110 } | 110 } |
| 111 | 111 |
| 112 void MojoRendererService::OnEnded() { | 112 void MojoRendererService::OnEnded() { |
| 113 DVLOG(1) << __FUNCTION__; | 113 DVLOG(1) << __FUNCTION__; |
| 114 CancelPeriodicMediaTimeUpdates(); | 114 CancelPeriodicMediaTimeUpdates(); |
| 115 client_->OnEnded(); | 115 client_->OnEnded(); |
| 116 } | 116 } |
| 117 | 117 |
| 118 void MojoRendererService::OnStatisticsUpdate(const PipelineStatistics& stats) { | 118 void MojoRendererService::OnStatisticsUpdate(const PipelineStatistics& stats) { |
| 119 // TODO(alokp): Plumb the event to interfaces::RendererClient. crbug/585287 | 119 // TODO(alokp): Plumb the event to mojom::RendererClient. crbug/585287 |
| 120 } | 120 } |
| 121 | 121 |
| 122 void MojoRendererService::OnBufferingStateChange(BufferingState state) { | 122 void MojoRendererService::OnBufferingStateChange(BufferingState state) { |
| 123 DVLOG(2) << __FUNCTION__ << "(" << state << ")"; | 123 DVLOG(2) << __FUNCTION__ << "(" << state << ")"; |
| 124 client_->OnBufferingStateChange( | 124 client_->OnBufferingStateChange(static_cast<mojom::BufferingState>(state)); |
| 125 static_cast<interfaces::BufferingState>(state)); | |
| 126 } | 125 } |
| 127 | 126 |
| 128 void MojoRendererService::OnWaitingForDecryptionKey() { | 127 void MojoRendererService::OnWaitingForDecryptionKey() { |
| 129 // TODO(alokp): Plumb the event to interfaces::RendererClient. crbug/585287 | 128 // TODO(alokp): Plumb the event to mojom::RendererClient. crbug/585287 |
| 130 } | 129 } |
| 131 | 130 |
| 132 void MojoRendererService::OnStreamReady( | 131 void MojoRendererService::OnStreamReady( |
| 133 const mojo::Callback<void(bool)>& callback) { | 132 const mojo::Callback<void(bool)>& callback) { |
| 134 DCHECK_EQ(state_, STATE_INITIALIZING); | 133 DCHECK_EQ(state_, STATE_INITIALIZING); |
| 135 | 134 |
| 136 renderer_->Initialize( | 135 renderer_->Initialize( |
| 137 stream_provider_.get(), this, | 136 stream_provider_.get(), this, |
| 138 base::Bind(&MojoRendererService::OnRendererInitializeDone, weak_this_, | 137 base::Bind(&MojoRendererService::OnRendererInitializeDone, weak_this_, |
| 139 callback)); | 138 callback)); |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 192 bool success) { | 191 bool success) { |
| 193 DVLOG(1) << __FUNCTION__ << "(" << success << ")"; | 192 DVLOG(1) << __FUNCTION__ << "(" << success << ")"; |
| 194 | 193 |
| 195 if (success) | 194 if (success) |
| 196 cdm_ = cdm; | 195 cdm_ = cdm; |
| 197 | 196 |
| 198 callback.Run(success); | 197 callback.Run(success); |
| 199 } | 198 } |
| 200 | 199 |
| 201 } // namespace media | 200 } // namespace media |
| OLD | NEW |