Chromium Code Reviews| 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/clients/mojo_renderer.h" | 5 #include "media/mojo/clients/mojo_renderer.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/callback_helpers.h" | 10 #include "base/callback_helpers.h" |
| (...skipping 10 matching lines...) Expand all Loading... | |
| 21 | 21 |
| 22 MojoRenderer::MojoRenderer( | 22 MojoRenderer::MojoRenderer( |
| 23 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, | 23 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
| 24 std::unique_ptr<VideoOverlayFactory> video_overlay_factory, | 24 std::unique_ptr<VideoOverlayFactory> video_overlay_factory, |
| 25 VideoRendererSink* video_renderer_sink, | 25 VideoRendererSink* video_renderer_sink, |
| 26 mojom::RendererPtr remote_renderer) | 26 mojom::RendererPtr remote_renderer) |
| 27 : task_runner_(task_runner), | 27 : task_runner_(task_runner), |
| 28 video_overlay_factory_(std::move(video_overlay_factory)), | 28 video_overlay_factory_(std::move(video_overlay_factory)), |
| 29 video_renderer_sink_(video_renderer_sink), | 29 video_renderer_sink_(video_renderer_sink), |
| 30 remote_renderer_info_(remote_renderer.PassInterface()), | 30 remote_renderer_info_(remote_renderer.PassInterface()), |
| 31 binding_(this), | 31 client_binding_(this), |
| 32 media_time_interpolator_(&media_clock_) { | 32 media_time_interpolator_(&media_clock_) { |
| 33 DVLOG(1) << __FUNCTION__; | 33 DVLOG(1) << __FUNCTION__; |
| 34 } | 34 } |
| 35 | 35 |
| 36 MojoRenderer::~MojoRenderer() { | 36 MojoRenderer::~MojoRenderer() { |
| 37 DVLOG(1) << __FUNCTION__; | 37 DVLOG(1) << __FUNCTION__; |
| 38 DCHECK(task_runner_->BelongsToCurrentThread()); | 38 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 39 | 39 |
| 40 CancelPendingCallbacks(); | 40 CancelPendingCallbacks(); |
| 41 } | 41 } |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 97 // Using base::Unretained(this) is safe because |this| owns | 97 // Using base::Unretained(this) is safe because |this| owns |
| 98 // |video_stream_|, and the error handler can't be invoked once | 98 // |video_stream_|, and the error handler can't be invoked once |
| 99 // |video_stream_| is destroyed. | 99 // |video_stream_| is destroyed. |
| 100 video_stream_->set_connection_error_handler( | 100 video_stream_->set_connection_error_handler( |
| 101 base::Bind(&MojoRenderer::OnDemuxerStreamConnectionError, | 101 base::Bind(&MojoRenderer::OnDemuxerStreamConnectionError, |
| 102 base::Unretained(this), DemuxerStream::VIDEO)); | 102 base::Unretained(this), DemuxerStream::VIDEO)); |
| 103 } | 103 } |
| 104 | 104 |
| 105 BindRemoteRendererIfNeeded(); | 105 BindRemoteRendererIfNeeded(); |
| 106 | 106 |
| 107 mojom::RendererClientAssociatedPtrInfo client_ptr_info; | |
|
alokp
2016/09/22 17:30:08
move these two lines into BindRemoteRendererIfNeed
xhwang
2016/09/22 18:11:57
I see the benefit of less code duplication. But re
alokp
2016/09/22 18:17:24
Acknowledged.
| |
| 108 client_binding_.Bind(&client_ptr_info, remote_renderer_.associated_group()); | |
| 109 | |
| 107 // Using base::Unretained(this) is safe because |this| owns | 110 // Using base::Unretained(this) is safe because |this| owns |
| 108 // |remote_renderer_|, and the callback won't be dispatched if | 111 // |remote_renderer_|, and the callback won't be dispatched if |
| 109 // |remote_renderer_| is destroyed. | 112 // |remote_renderer_| is destroyed. |
| 110 remote_renderer_->Initialize( | 113 remote_renderer_->Initialize( |
| 111 binding_.CreateInterfacePtrAndBind(), std::move(audio_stream), | 114 std::move(client_ptr_info), std::move(audio_stream), |
| 112 std::move(video_stream), base::nullopt, | 115 std::move(video_stream), base::nullopt, |
| 113 base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client)); | 116 base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client)); |
| 114 } | 117 } |
| 115 | 118 |
| 116 void MojoRenderer::InitializeRendererFromUrl(media::RendererClient* client) { | 119 void MojoRenderer::InitializeRendererFromUrl(media::RendererClient* client) { |
| 117 DVLOG(2) << __FUNCTION__; | 120 DVLOG(2) << __FUNCTION__; |
| 118 DCHECK(task_runner_->BelongsToCurrentThread()); | 121 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 119 | 122 |
| 120 BindRemoteRendererIfNeeded(); | 123 BindRemoteRendererIfNeeded(); |
| 121 | 124 |
| 125 mojom::RendererClientAssociatedPtrInfo client_ptr_info; | |
| 126 client_binding_.Bind(&client_ptr_info, remote_renderer_.associated_group()); | |
| 127 | |
| 122 // Using base::Unretained(this) is safe because |this| owns | 128 // Using base::Unretained(this) is safe because |this| owns |
| 123 // |remote_renderer_|, and the callback won't be dispatched if | 129 // |remote_renderer_|, and the callback won't be dispatched if |
| 124 // |remote_renderer_| is destroyed. | 130 // |remote_renderer_| is destroyed. |
| 125 remote_renderer_->Initialize( | 131 remote_renderer_->Initialize( |
| 126 binding_.CreateInterfacePtrAndBind(), mojom::DemuxerStreamPtr(), | 132 std::move(client_ptr_info), mojom::DemuxerStreamPtr(), |
| 127 mojom::DemuxerStreamPtr(), demuxer_stream_provider_->GetUrl(), | 133 mojom::DemuxerStreamPtr(), demuxer_stream_provider_->GetUrl(), |
| 128 base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client)); | 134 base::Bind(&MojoRenderer::OnInitialized, base::Unretained(this), client)); |
| 129 } | 135 } |
| 130 | 136 |
| 131 void MojoRenderer::SetCdm(CdmContext* cdm_context, | 137 void MojoRenderer::SetCdm(CdmContext* cdm_context, |
| 132 const CdmAttachedCB& cdm_attached_cb) { | 138 const CdmAttachedCB& cdm_attached_cb) { |
| 133 DVLOG(1) << __FUNCTION__; | 139 DVLOG(1) << __FUNCTION__; |
| 134 DCHECK(task_runner_->BelongsToCurrentThread()); | 140 DCHECK(task_runner_->BelongsToCurrentThread()); |
| 135 DCHECK(cdm_context); | 141 DCHECK(cdm_context); |
| 136 DCHECK(!cdm_attached_cb.is_null()); | 142 DCHECK(!cdm_attached_cb.is_null()); |
| (...skipping 258 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 395 base::ResetAndReturn(&init_cb_).Run(PIPELINE_ERROR_INITIALIZATION_FAILED); | 401 base::ResetAndReturn(&init_cb_).Run(PIPELINE_ERROR_INITIALIZATION_FAILED); |
| 396 | 402 |
| 397 if (!flush_cb_.is_null()) | 403 if (!flush_cb_.is_null()) |
| 398 base::ResetAndReturn(&flush_cb_).Run(); | 404 base::ResetAndReturn(&flush_cb_).Run(); |
| 399 | 405 |
| 400 if (!cdm_attached_cb_.is_null()) | 406 if (!cdm_attached_cb_.is_null()) |
| 401 base::ResetAndReturn(&cdm_attached_cb_).Run(false); | 407 base::ResetAndReturn(&cdm_attached_cb_).Run(false); |
| 402 } | 408 } |
| 403 | 409 |
| 404 } // namespace media | 410 } // namespace media |
| OLD | NEW |