| Index: media/remoting/courier_renderer.cc
|
| diff --git a/media/remoting/courier_renderer.cc b/media/remoting/courier_renderer.cc
|
| index b83c7f751440db55a06de12b25d0bc3524dd3521..ca0f5677f73b92f270d98002cbb6ca55cc6f950f 100644
|
| --- a/media/remoting/courier_renderer.cc
|
| +++ b/media/remoting/courier_renderer.cc
|
| @@ -19,7 +19,7 @@
|
| #include "base/time/time.h"
|
| #include "media/base/bind_to_current_loop.h"
|
| #include "media/base/buffering_state.h"
|
| -#include "media/base/demuxer_stream_provider.h"
|
| +#include "media/base/media_resource.h"
|
| #include "media/base/renderer_client.h"
|
| #include "media/remoting/demuxer_stream_adapter.h"
|
| #include "media/remoting/proto_enum_utils.h"
|
| @@ -65,7 +65,7 @@ CourierRenderer::CourierRenderer(
|
| : state_(STATE_UNINITIALIZED),
|
| main_task_runner_(base::ThreadTaskRunnerHandle::Get()),
|
| media_task_runner_(std::move(media_task_runner)),
|
| - demuxer_stream_provider_(nullptr),
|
| + media_resource_(nullptr),
|
| client_(nullptr),
|
| controller_(controller),
|
| rpc_broker_(controller_->GetRpcBroker()),
|
| @@ -106,12 +106,12 @@ CourierRenderer::~CourierRenderer() {
|
| rpc_broker_, rpc_handle_));
|
| }
|
|
|
| -void CourierRenderer::Initialize(DemuxerStreamProvider* demuxer_stream_provider,
|
| +void CourierRenderer::Initialize(MediaResource* media_resource,
|
| RendererClient* client,
|
| const PipelineStatusCB& init_cb) {
|
| VLOG(2) << __func__;
|
| DCHECK(media_task_runner_->BelongsToCurrentThread());
|
| - DCHECK(demuxer_stream_provider);
|
| + DCHECK(media_resource);
|
| DCHECK(client);
|
|
|
| if (state_ != STATE_UNINITIALIZED) {
|
| @@ -120,14 +120,15 @@ void CourierRenderer::Initialize(DemuxerStreamProvider* demuxer_stream_provider,
|
| return;
|
| }
|
|
|
| - demuxer_stream_provider_ = demuxer_stream_provider;
|
| + media_resource_ = media_resource;
|
| client_ = client;
|
| init_workflow_done_callback_ = init_cb;
|
|
|
| state_ = STATE_CREATE_PIPE;
|
| +
|
| // Create audio mojo data pipe handles if audio is available.
|
| DemuxerStream* audio_demuxer_stream =
|
| - demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO);
|
| + media_resource_->GetStream(DemuxerStream::AUDIO);
|
| std::unique_ptr<mojo::DataPipe> audio_data_pipe;
|
| if (audio_demuxer_stream) {
|
| audio_data_pipe = base::WrapUnique(DemuxerStreamAdapter::CreateDataPipe());
|
| @@ -135,7 +136,7 @@ void CourierRenderer::Initialize(DemuxerStreamProvider* demuxer_stream_provider,
|
|
|
| // Create video mojo data pipe handles if video is available.
|
| DemuxerStream* video_demuxer_stream =
|
| - demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO);
|
| + media_resource_->GetStream(DemuxerStream::VIDEO);
|
| std::unique_ptr<mojo::DataPipe> video_data_pipe;
|
| if (video_demuxer_stream) {
|
| video_data_pipe = base::WrapUnique(DemuxerStreamAdapter::CreateDataPipe());
|
| @@ -327,7 +328,7 @@ void CourierRenderer::OnDataPipeCreated(
|
|
|
| // Create audio demuxer stream adapter if audio is available.
|
| DemuxerStream* audio_demuxer_stream =
|
| - demuxer_stream_provider_->GetStream(DemuxerStream::AUDIO);
|
| + media_resource_->GetStream(DemuxerStream::AUDIO);
|
| if (audio_demuxer_stream && audio.is_valid() && audio_handle.is_valid() &&
|
| audio_rpc_handle != RpcBroker::kInvalidHandle) {
|
| VLOG(2) << "Initialize audio";
|
| @@ -340,7 +341,7 @@ void CourierRenderer::OnDataPipeCreated(
|
|
|
| // Create video demuxer stream adapter if video is available.
|
| DemuxerStream* video_demuxer_stream =
|
| - demuxer_stream_provider_->GetStream(DemuxerStream::VIDEO);
|
| + media_resource_->GetStream(DemuxerStream::VIDEO);
|
| if (video_demuxer_stream && video.is_valid() && video_handle.is_valid() &&
|
| video_rpc_handle != RpcBroker::kInvalidHandle) {
|
| VLOG(2) << "Initialize video";
|
|
|