OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/interface_factory_impl.h" | 5 #include "media/mojo/services/interface_factory_impl.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/threading/thread_task_runner_handle.h" | 8 #include "base/threading/thread_task_runner_handle.h" |
9 #include "media/base/media_log.h" | 9 #include "media/base/media_log.h" |
10 #include "media/mojo/services/mojo_media_client.h" | 10 #include "media/mojo/services/mojo_media_client.h" |
(...skipping 50 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
61 scoped_refptr<base::SingleThreadTaskRunner> task_runner( | 61 scoped_refptr<base::SingleThreadTaskRunner> task_runner( |
62 base::ThreadTaskRunnerHandle::Get()); | 62 base::ThreadTaskRunnerHandle::Get()); |
63 | 63 |
64 std::unique_ptr<AudioDecoder> audio_decoder = | 64 std::unique_ptr<AudioDecoder> audio_decoder = |
65 mojo_media_client_->CreateAudioDecoder(task_runner); | 65 mojo_media_client_->CreateAudioDecoder(task_runner); |
66 if (!audio_decoder) { | 66 if (!audio_decoder) { |
67 LOG(ERROR) << "AudioDecoder creation failed."; | 67 LOG(ERROR) << "AudioDecoder creation failed."; |
68 return; | 68 return; |
69 } | 69 } |
70 | 70 |
71 mojo::MakeStrongBinding( | 71 audio_decoder_bindings_.AddBinding( |
72 base::MakeUnique<MojoAudioDecoderService>( | 72 base::MakeUnique<MojoAudioDecoderService>( |
73 cdm_service_context_.GetWeakPtr(), std::move(audio_decoder)), | 73 cdm_service_context_.GetWeakPtr(), std::move(audio_decoder)), |
74 std::move(request)); | 74 std::move(request)); |
75 #endif // defined(ENABLE_MOJO_AUDIO_DECODER) | 75 #endif // defined(ENABLE_MOJO_AUDIO_DECODER) |
76 } | 76 } |
77 | 77 |
78 void InterfaceFactoryImpl::CreateVideoDecoder( | 78 void InterfaceFactoryImpl::CreateVideoDecoder( |
79 mojom::VideoDecoderRequest request) { | 79 mojom::VideoDecoderRequest request) { |
80 #if defined(ENABLE_MOJO_VIDEO_DECODER) | 80 #if defined(ENABLE_MOJO_VIDEO_DECODER) |
81 mojo::MakeStrongBinding( | 81 video_decoder_bindings_.AddBinding( |
82 base::MakeUnique<MojoVideoDecoderService>(mojo_media_client_), | 82 base::MakeUnique<MojoVideoDecoderService>(mojo_media_client_), |
83 std::move(request)); | 83 std::move(request)); |
84 #endif // defined(ENABLE_MOJO_VIDEO_DECODER) | 84 #endif // defined(ENABLE_MOJO_VIDEO_DECODER) |
85 } | 85 } |
86 | 86 |
87 void InterfaceFactoryImpl::CreateRenderer( | 87 void InterfaceFactoryImpl::CreateRenderer( |
88 const std::string& audio_device_id, | 88 const std::string& audio_device_id, |
89 mojo::InterfaceRequest<mojom::Renderer> request) { | 89 mojo::InterfaceRequest<mojom::Renderer> request) { |
90 #if defined(ENABLE_MOJO_RENDERER) | 90 #if defined(ENABLE_MOJO_RENDERER) |
91 RendererFactory* renderer_factory = GetRendererFactory(); | 91 RendererFactory* renderer_factory = GetRendererFactory(); |
92 if (!renderer_factory) | 92 if (!renderer_factory) |
93 return; | 93 return; |
94 | 94 |
95 scoped_refptr<base::SingleThreadTaskRunner> task_runner( | 95 scoped_refptr<base::SingleThreadTaskRunner> task_runner( |
96 base::ThreadTaskRunnerHandle::Get()); | 96 base::ThreadTaskRunnerHandle::Get()); |
97 auto audio_sink = | 97 auto audio_sink = |
98 mojo_media_client_->CreateAudioRendererSink(audio_device_id); | 98 mojo_media_client_->CreateAudioRendererSink(audio_device_id); |
99 auto video_sink = mojo_media_client_->CreateVideoRendererSink(task_runner); | 99 auto video_sink = mojo_media_client_->CreateVideoRendererSink(task_runner); |
100 auto renderer = renderer_factory->CreateRenderer( | 100 auto renderer = renderer_factory->CreateRenderer( |
101 task_runner, task_runner, audio_sink.get(), video_sink.get(), | 101 task_runner, task_runner, audio_sink.get(), video_sink.get(), |
102 RequestSurfaceCB()); | 102 RequestSurfaceCB()); |
103 if (!renderer) { | 103 if (!renderer) { |
104 LOG(ERROR) << "Renderer creation failed."; | 104 LOG(ERROR) << "Renderer creation failed."; |
105 return; | 105 return; |
106 } | 106 } |
107 | 107 |
108 MojoRendererService::Create( | 108 renderer_bindings_.AddBinding( |
109 cdm_service_context_.GetWeakPtr(), std::move(audio_sink), | 109 base::MakeUnique<MojoRendererService>( |
110 std::move(video_sink), std::move(renderer), | 110 cdm_service_context_.GetWeakPtr(), std::move(audio_sink), |
111 MojoRendererService::InitiateSurfaceRequestCB(), std::move(request)); | 111 std::move(video_sink), std::move(renderer), |
| 112 MojoRendererService::InitiateSurfaceRequestCB()), |
| 113 std::move(request)); |
112 #endif // defined(ENABLE_MOJO_RENDERER) | 114 #endif // defined(ENABLE_MOJO_RENDERER) |
113 } | 115 } |
114 | 116 |
115 void InterfaceFactoryImpl::CreateCdm( | 117 void InterfaceFactoryImpl::CreateCdm( |
116 mojo::InterfaceRequest<mojom::ContentDecryptionModule> request) { | 118 mojo::InterfaceRequest<mojom::ContentDecryptionModule> request) { |
117 #if defined(ENABLE_MOJO_CDM) | 119 #if defined(ENABLE_MOJO_CDM) |
118 CdmFactory* cdm_factory = GetCdmFactory(); | 120 CdmFactory* cdm_factory = GetCdmFactory(); |
119 if (!cdm_factory) | 121 if (!cdm_factory) |
120 return; | 122 return; |
121 | 123 |
122 mojo::MakeStrongBinding(base::MakeUnique<MojoCdmService>( | 124 cdm_bindings_.AddBinding(base::MakeUnique<MojoCdmService>( |
123 cdm_service_context_.GetWeakPtr(), cdm_factory), | 125 cdm_service_context_.GetWeakPtr(), cdm_factory), |
124 std::move(request)); | 126 std::move(request)); |
125 #endif // defined(ENABLE_MOJO_CDM) | 127 #endif // defined(ENABLE_MOJO_CDM) |
126 } | 128 } |
127 | 129 |
128 #if defined(ENABLE_MOJO_RENDERER) | 130 #if defined(ENABLE_MOJO_RENDERER) |
129 RendererFactory* InterfaceFactoryImpl::GetRendererFactory() { | 131 RendererFactory* InterfaceFactoryImpl::GetRendererFactory() { |
130 if (!renderer_factory_) { | 132 if (!renderer_factory_) { |
131 renderer_factory_ = mojo_media_client_->CreateRendererFactory(media_log_); | 133 renderer_factory_ = mojo_media_client_->CreateRendererFactory(media_log_); |
132 LOG_IF(ERROR, !renderer_factory_) << "RendererFactory not available."; | 134 LOG_IF(ERROR, !renderer_factory_) << "RendererFactory not available."; |
133 } | 135 } |
134 return renderer_factory_.get(); | 136 return renderer_factory_.get(); |
135 } | 137 } |
136 #endif // defined(ENABLE_MOJO_RENDERER) | 138 #endif // defined(ENABLE_MOJO_RENDERER) |
137 | 139 |
138 #if defined(ENABLE_MOJO_CDM) | 140 #if defined(ENABLE_MOJO_CDM) |
139 CdmFactory* InterfaceFactoryImpl::GetCdmFactory() { | 141 CdmFactory* InterfaceFactoryImpl::GetCdmFactory() { |
140 if (!cdm_factory_) { | 142 if (!cdm_factory_) { |
141 cdm_factory_ = mojo_media_client_->CreateCdmFactory(interfaces_.get()); | 143 cdm_factory_ = mojo_media_client_->CreateCdmFactory(interfaces_.get()); |
142 LOG_IF(ERROR, !cdm_factory_) << "CdmFactory not available."; | 144 LOG_IF(ERROR, !cdm_factory_) << "CdmFactory not available."; |
143 } | 145 } |
144 return cdm_factory_.get(); | 146 return cdm_factory_.get(); |
145 } | 147 } |
146 #endif // defined(ENABLE_MOJO_CDM) | 148 #endif // defined(ENABLE_MOJO_CDM) |
147 | 149 |
148 } // namespace media | 150 } // namespace media |
OLD | NEW |