Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(202)

Side by Side Diff: media/mojo/services/service_factory_impl.cc

Issue 2326913003: Privatize StrongBinding lifetime management (Closed)
Patch Set: rebase Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « media/mojo/services/service_factory_impl.h ('k') | mojo/public/cpp/bindings/strong_binding.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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/service_factory_impl.h" 5 #include "media/mojo/services/service_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"
11 #include "mojo/public/cpp/bindings/strong_binding.h"
11 #include "services/shell/public/interfaces/interface_provider.mojom.h" 12 #include "services/shell/public/interfaces/interface_provider.mojom.h"
12 13
13 #if defined(ENABLE_MOJO_AUDIO_DECODER) 14 #if defined(ENABLE_MOJO_AUDIO_DECODER)
14 #include "media/mojo/services/mojo_audio_decoder_service.h" 15 #include "media/mojo/services/mojo_audio_decoder_service.h"
15 #endif // defined(ENABLE_MOJO_AUDIO_DECODER) 16 #endif // defined(ENABLE_MOJO_AUDIO_DECODER)
16 17
17 #if defined(ENABLE_MOJO_VIDEO_DECODER) 18 #if defined(ENABLE_MOJO_VIDEO_DECODER)
18 #include "media/mojo/services/mojo_video_decoder_service.h" 19 #include "media/mojo/services/mojo_video_decoder_service.h"
19 #endif // defined(ENABLE_MOJO_VIDEO_DECODER) 20 #endif // defined(ENABLE_MOJO_VIDEO_DECODER)
20 21
21 #if defined(ENABLE_MOJO_RENDERER) 22 #if defined(ENABLE_MOJO_RENDERER)
22 #include "media/base/audio_renderer_sink.h" 23 #include "media/base/audio_renderer_sink.h"
23 #include "media/base/renderer_factory.h" 24 #include "media/base/renderer_factory.h"
24 #include "media/base/video_renderer_sink.h" 25 #include "media/base/video_renderer_sink.h"
25 #include "media/mojo/services/mojo_renderer_service.h" 26 #include "media/mojo/services/mojo_renderer_service.h"
26 #endif // defined(ENABLE_MOJO_RENDERER) 27 #endif // defined(ENABLE_MOJO_RENDERER)
27 28
28 #if defined(ENABLE_MOJO_CDM) 29 #if defined(ENABLE_MOJO_CDM)
29 #include "media/base/cdm_factory.h" 30 #include "media/base/cdm_factory.h"
30 #include "media/mojo/services/mojo_cdm_service.h" 31 #include "media/mojo/services/mojo_cdm_service.h"
31 #endif // defined(ENABLE_MOJO_CDM) 32 #endif // defined(ENABLE_MOJO_CDM)
32 33
33 namespace media { 34 namespace media {
34 35
35 ServiceFactoryImpl::ServiceFactoryImpl( 36 ServiceFactoryImpl::ServiceFactoryImpl(
36 mojo::InterfaceRequest<mojom::ServiceFactory> request,
37 shell::mojom::InterfaceProviderPtr interfaces, 37 shell::mojom::InterfaceProviderPtr interfaces,
38 scoped_refptr<MediaLog> media_log, 38 scoped_refptr<MediaLog> media_log,
39 std::unique_ptr<shell::ServiceContextRef> connection_ref, 39 std::unique_ptr<shell::ServiceContextRef> connection_ref,
40 MojoMediaClient* mojo_media_client) 40 MojoMediaClient* mojo_media_client)
41 : binding_(this, std::move(request)), 41 :
42 #if defined(ENABLE_MOJO_CDM) 42 #if defined(ENABLE_MOJO_CDM)
43 interfaces_(std::move(interfaces)), 43 interfaces_(std::move(interfaces)),
44 #endif 44 #endif
45 media_log_(media_log), 45 media_log_(media_log),
46 connection_ref_(std::move(connection_ref)), 46 connection_ref_(std::move(connection_ref)),
47 mojo_media_client_(mojo_media_client) { 47 mojo_media_client_(mojo_media_client) {
48 DVLOG(1) << __FUNCTION__; 48 DVLOG(1) << __FUNCTION__;
49 DCHECK(mojo_media_client_); 49 DCHECK(mojo_media_client_);
50 } 50 }
51 51
52 ServiceFactoryImpl::~ServiceFactoryImpl() { 52 ServiceFactoryImpl::~ServiceFactoryImpl() {
53 DVLOG(1) << __FUNCTION__; 53 DVLOG(1) << __FUNCTION__;
54 } 54 }
55 55
56 // mojom::ServiceFactory implementation. 56 // mojom::ServiceFactory implementation.
57 57
58 void ServiceFactoryImpl::CreateAudioDecoder( 58 void ServiceFactoryImpl::CreateAudioDecoder(
59 mojo::InterfaceRequest<mojom::AudioDecoder> request) { 59 mojo::InterfaceRequest<mojom::AudioDecoder> request) {
60 #if defined(ENABLE_MOJO_AUDIO_DECODER) 60 #if defined(ENABLE_MOJO_AUDIO_DECODER)
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 new MojoAudioDecoderService(cdm_service_context_.GetWeakPtr(), 71 mojo::MakeStrongBinding(
72 std::move(audio_decoder), std::move(request)); 72 base::MakeUnique<MojoAudioDecoderService>(
73 cdm_service_context_.GetWeakPtr(), std::move(audio_decoder)),
74 std::move(request));
73 #endif // defined(ENABLE_MOJO_AUDIO_DECODER) 75 #endif // defined(ENABLE_MOJO_AUDIO_DECODER)
74 } 76 }
75 77
76 void ServiceFactoryImpl::CreateVideoDecoder( 78 void ServiceFactoryImpl::CreateVideoDecoder(
77 mojom::VideoDecoderRequest request) { 79 mojom::VideoDecoderRequest request) {
78 #if defined(ENABLE_MOJO_VIDEO_DECODER) 80 #if defined(ENABLE_MOJO_VIDEO_DECODER)
79 new MojoVideoDecoderService(std::move(request), mojo_media_client_); 81 mojo::MakeStrongBinding(
82 base::MakeUnique<MojoVideoDecoderService>(mojo_media_client_),
83 std::move(request));
80 #endif // defined(ENABLE_MOJO_VIDEO_DECODER) 84 #endif // defined(ENABLE_MOJO_VIDEO_DECODER)
81 } 85 }
82 86
83 void ServiceFactoryImpl::CreateRenderer( 87 void ServiceFactoryImpl::CreateRenderer(
84 const mojo::String& audio_device_id, 88 const mojo::String& audio_device_id,
85 mojo::InterfaceRequest<mojom::Renderer> request) { 89 mojo::InterfaceRequest<mojom::Renderer> request) {
86 #if defined(ENABLE_MOJO_RENDERER) 90 #if defined(ENABLE_MOJO_RENDERER)
87 RendererFactory* renderer_factory = GetRendererFactory(); 91 RendererFactory* renderer_factory = GetRendererFactory();
88 if (!renderer_factory) 92 if (!renderer_factory)
89 return; 93 return;
90 94
91 scoped_refptr<base::SingleThreadTaskRunner> task_runner( 95 scoped_refptr<base::SingleThreadTaskRunner> task_runner(
92 base::ThreadTaskRunnerHandle::Get()); 96 base::ThreadTaskRunnerHandle::Get());
93 auto audio_sink = 97 auto audio_sink =
94 mojo_media_client_->CreateAudioRendererSink(audio_device_id); 98 mojo_media_client_->CreateAudioRendererSink(audio_device_id);
95 auto video_sink = mojo_media_client_->CreateVideoRendererSink(task_runner); 99 auto video_sink = mojo_media_client_->CreateVideoRendererSink(task_runner);
96 auto renderer = renderer_factory->CreateRenderer( 100 auto renderer = renderer_factory->CreateRenderer(
97 task_runner, task_runner, audio_sink.get(), video_sink.get(), 101 task_runner, task_runner, audio_sink.get(), video_sink.get(),
98 RequestSurfaceCB()); 102 RequestSurfaceCB());
99 if (!renderer) { 103 if (!renderer) {
100 LOG(ERROR) << "Renderer creation failed."; 104 LOG(ERROR) << "Renderer creation failed.";
101 return; 105 return;
102 } 106 }
103 107
104 // The created object is owned by the pipe. 108 mojo::MakeStrongBinding(
105 new MojoRendererService(cdm_service_context_.GetWeakPtr(), 109 base::MakeUnique<MojoRendererService>(
106 std::move(audio_sink), std::move(video_sink), 110 cdm_service_context_.GetWeakPtr(), std::move(audio_sink),
107 std::move(renderer), std::move(request)); 111 std::move(video_sink), std::move(renderer)),
112 std::move(request));
108 #endif // defined(ENABLE_MOJO_RENDERER) 113 #endif // defined(ENABLE_MOJO_RENDERER)
109 } 114 }
110 115
111 void ServiceFactoryImpl::CreateCdm( 116 void ServiceFactoryImpl::CreateCdm(
112 mojo::InterfaceRequest<mojom::ContentDecryptionModule> request) { 117 mojo::InterfaceRequest<mojom::ContentDecryptionModule> request) {
113 #if defined(ENABLE_MOJO_CDM) 118 #if defined(ENABLE_MOJO_CDM)
114 CdmFactory* cdm_factory = GetCdmFactory(); 119 CdmFactory* cdm_factory = GetCdmFactory();
115 if (!cdm_factory) 120 if (!cdm_factory)
116 return; 121 return;
117 122
118 // The created object is owned by the pipe. 123 mojo::MakeStrongBinding(base::MakeUnique<MojoCdmService>(
119 new MojoCdmService(cdm_service_context_.GetWeakPtr(), cdm_factory, 124 cdm_service_context_.GetWeakPtr(), cdm_factory),
120 std::move(request)); 125 std::move(request));
121 #endif // defined(ENABLE_MOJO_CDM) 126 #endif // defined(ENABLE_MOJO_CDM)
122 } 127 }
123 128
124 #if defined(ENABLE_MOJO_RENDERER) 129 #if defined(ENABLE_MOJO_RENDERER)
125 RendererFactory* ServiceFactoryImpl::GetRendererFactory() { 130 RendererFactory* ServiceFactoryImpl::GetRendererFactory() {
126 if (!renderer_factory_) { 131 if (!renderer_factory_) {
127 renderer_factory_ = mojo_media_client_->CreateRendererFactory(media_log_); 132 renderer_factory_ = mojo_media_client_->CreateRendererFactory(media_log_);
128 LOG_IF(ERROR, !renderer_factory_) << "RendererFactory not available."; 133 LOG_IF(ERROR, !renderer_factory_) << "RendererFactory not available.";
129 } 134 }
130 return renderer_factory_.get(); 135 return renderer_factory_.get();
131 } 136 }
132 #endif // defined(ENABLE_MOJO_RENDERER) 137 #endif // defined(ENABLE_MOJO_RENDERER)
133 138
134 #if defined(ENABLE_MOJO_CDM) 139 #if defined(ENABLE_MOJO_CDM)
135 CdmFactory* ServiceFactoryImpl::GetCdmFactory() { 140 CdmFactory* ServiceFactoryImpl::GetCdmFactory() {
136 if (!cdm_factory_) { 141 if (!cdm_factory_) {
137 cdm_factory_ = mojo_media_client_->CreateCdmFactory(interfaces_.get()); 142 cdm_factory_ = mojo_media_client_->CreateCdmFactory(interfaces_.get());
138 LOG_IF(ERROR, !cdm_factory_) << "CdmFactory not available."; 143 LOG_IF(ERROR, !cdm_factory_) << "CdmFactory not available.";
139 } 144 }
140 return cdm_factory_.get(); 145 return cdm_factory_.get();
141 } 146 }
142 #endif // defined(ENABLE_MOJO_CDM) 147 #endif // defined(ENABLE_MOJO_CDM)
143 148
144 } // namespace media 149 } // namespace media
OLDNEW
« no previous file with comments | « media/mojo/services/service_factory_impl.h ('k') | mojo/public/cpp/bindings/strong_binding.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698