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"; |