OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "chromecast/media/service/cast_renderer.h" | 5 #include "chromecast/media/service/cast_renderer.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/single_thread_task_runner.h" | 8 #include "base/single_thread_task_runner.h" |
9 #include "chromecast/base/task_runner_impl.h" | 9 #include "chromecast/base/task_runner_impl.h" |
10 #include "chromecast/media/base/video_mode_switcher.h" | 10 #include "chromecast/media/base/video_mode_switcher.h" |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
98 // Create pipeline. | 98 // Create pipeline. |
99 MediaPipelineClient pipeline_client; | 99 MediaPipelineClient pipeline_client; |
100 pipeline_client.error_cb = | 100 pipeline_client.error_cb = |
101 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); | 101 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); |
102 pipeline_client.buffering_state_cb = base::Bind( | 102 pipeline_client.buffering_state_cb = base::Bind( |
103 &CastRenderer::OnBufferingStateChange, weak_factory_.GetWeakPtr()); | 103 &CastRenderer::OnBufferingStateChange, weak_factory_.GetWeakPtr()); |
104 pipeline_.reset(new MediaPipelineImpl()); | 104 pipeline_.reset(new MediaPipelineImpl()); |
105 pipeline_->SetClient(pipeline_client); | 105 pipeline_->SetClient(pipeline_client); |
106 pipeline_->Initialize(load_type, std::move(backend)); | 106 pipeline_->Initialize(load_type, std::move(backend)); |
107 | 107 |
| 108 // TODO(servolk): Implement support for multiple streams. For now use the |
| 109 // first enabled audio and video streams to preserve the existing behavior. |
| 110 ::media::DemuxerStream* audio_stream = |
| 111 media_resource->GetFirstStream(::media::DemuxerStream::AUDIO); |
| 112 ::media::DemuxerStream* video_stream = |
| 113 media_resource->GetFirstStream(::media::DemuxerStream::VIDEO); |
| 114 |
108 // Initialize audio. | 115 // Initialize audio. |
109 ::media::DemuxerStream* audio_stream = | |
110 media_resource->GetStream(::media::DemuxerStream::AUDIO); | |
111 if (audio_stream) { | 116 if (audio_stream) { |
112 AvPipelineClient audio_client; | 117 AvPipelineClient audio_client; |
113 audio_client.wait_for_key_cb = base::Bind( | 118 audio_client.wait_for_key_cb = base::Bind( |
114 &CastRenderer::OnWaitingForDecryptionKey, weak_factory_.GetWeakPtr()); | 119 &CastRenderer::OnWaitingForDecryptionKey, weak_factory_.GetWeakPtr()); |
115 audio_client.eos_cb = base::Bind(&CastRenderer::OnEnded, | 120 audio_client.eos_cb = base::Bind(&CastRenderer::OnEnded, |
116 weak_factory_.GetWeakPtr(), STREAM_AUDIO); | 121 weak_factory_.GetWeakPtr(), STREAM_AUDIO); |
117 audio_client.playback_error_cb = | 122 audio_client.playback_error_cb = |
118 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); | 123 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); |
119 audio_client.statistics_cb = base::Bind(&CastRenderer::OnStatisticsUpdate, | 124 audio_client.statistics_cb = base::Bind(&CastRenderer::OnStatisticsUpdate, |
120 weak_factory_.GetWeakPtr()); | 125 weak_factory_.GetWeakPtr()); |
121 std::unique_ptr<CodedFrameProvider> frame_provider(new DemuxerStreamAdapter( | 126 std::unique_ptr<CodedFrameProvider> frame_provider(new DemuxerStreamAdapter( |
122 task_runner_, media_task_runner_factory_, audio_stream)); | 127 task_runner_, media_task_runner_factory_, audio_stream)); |
123 | 128 |
124 ::media::PipelineStatus status = | 129 ::media::PipelineStatus status = |
125 pipeline_->InitializeAudio(audio_stream->audio_decoder_config(), | 130 pipeline_->InitializeAudio(audio_stream->audio_decoder_config(), |
126 audio_client, std::move(frame_provider)); | 131 audio_client, std::move(frame_provider)); |
127 if (status != ::media::PIPELINE_OK) { | 132 if (status != ::media::PIPELINE_OK) { |
128 init_cb.Run(status); | 133 init_cb.Run(status); |
129 return; | 134 return; |
130 } | 135 } |
131 audio_stream->EnableBitstreamConverter(); | 136 audio_stream->EnableBitstreamConverter(); |
132 } | 137 } |
133 | 138 |
134 // Initialize video. | 139 // Initialize video. |
135 ::media::DemuxerStream* video_stream = | |
136 media_resource->GetStream(::media::DemuxerStream::VIDEO); | |
137 if (video_stream) { | 140 if (video_stream) { |
138 VideoPipelineClient video_client; | 141 VideoPipelineClient video_client; |
139 video_client.av_pipeline_client.wait_for_key_cb = base::Bind( | 142 video_client.av_pipeline_client.wait_for_key_cb = base::Bind( |
140 &CastRenderer::OnWaitingForDecryptionKey, weak_factory_.GetWeakPtr()); | 143 &CastRenderer::OnWaitingForDecryptionKey, weak_factory_.GetWeakPtr()); |
141 video_client.av_pipeline_client.eos_cb = base::Bind( | 144 video_client.av_pipeline_client.eos_cb = base::Bind( |
142 &CastRenderer::OnEnded, weak_factory_.GetWeakPtr(), STREAM_VIDEO); | 145 &CastRenderer::OnEnded, weak_factory_.GetWeakPtr(), STREAM_VIDEO); |
143 video_client.av_pipeline_client.playback_error_cb = | 146 video_client.av_pipeline_client.playback_error_cb = |
144 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); | 147 base::Bind(&CastRenderer::OnError, weak_factory_.GetWeakPtr()); |
145 video_client.av_pipeline_client.statistics_cb = base::Bind( | 148 video_client.av_pipeline_client.statistics_cb = base::Bind( |
146 &CastRenderer::OnStatisticsUpdate, weak_factory_.GetWeakPtr()); | 149 &CastRenderer::OnStatisticsUpdate, weak_factory_.GetWeakPtr()); |
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
295 } | 298 } |
296 | 299 |
297 void CastRenderer::OnVideoOpacityChange(bool opaque) { | 300 void CastRenderer::OnVideoOpacityChange(bool opaque) { |
298 DCHECK(task_runner_->BelongsToCurrentThread()); | 301 DCHECK(task_runner_->BelongsToCurrentThread()); |
299 DCHECK(opaque); | 302 DCHECK(opaque); |
300 client_->OnVideoOpacityChange(opaque); | 303 client_->OnVideoOpacityChange(opaque); |
301 } | 304 } |
302 | 305 |
303 } // namespace media | 306 } // namespace media |
304 } // namespace chromecast | 307 } // namespace chromecast |
OLD | NEW |