OLD | NEW |
---|---|
(Empty) | |
1 /* | |
2 * Copyright 2017 The WebRTC project authors. All Rights Reserved. | |
3 * | |
4 * Use of this source code is governed by a BSD-style license | |
5 * that can be found in the LICENSE file in the root of the source | |
6 * tree. An additional intellectual property rights grant can be found | |
7 * in the file PATENTS. All contributing project authors may | |
8 * be found in the AUTHORS file in the root of the source tree. | |
9 */ | |
10 | |
11 #include "webrtc/api/audio_codecs/builtin_audio_decoder_factory.h" | |
12 #include "webrtc/api/audio_codecs/builtin_audio_encoder_factory.h" | |
13 #include "webrtc/api/peerconnectioninterface.h" | |
14 #include "webrtc/base/bind.h" | |
15 #include "webrtc/base/scoped_ref_ptr.h" | |
16 #include "webrtc/base/thread.h" | |
17 #include "webrtc/call/callfactoryinterface.h" | |
18 #include "webrtc/logging/rtc_event_log/rtc_event_log_factory_interface.h" | |
19 #include "webrtc/media/engine/webrtcmediaengine.h" | |
20 | |
21 namespace webrtc { | |
22 | |
23 class MediaEngineCreator { | |
Taylor Brandstetter
2017/06/14 01:54:16
Is this just because "rtc::Bind" requires a class?
Zhi Huang
2017/06/14 06:57:01
I just wanna have something work here.
Maybe we c
Taylor Brandstetter
2017/06/15 00:35:02
Acknowledged.
| |
24 public: | |
25 std::unique_ptr<cricket::MediaEngineInterface> CreateMediaEngine_w( | |
26 AudioDeviceModule* default_adm, | |
27 rtc::scoped_refptr<AudioEncoderFactory> audio_encoder_factory, | |
28 rtc::scoped_refptr<AudioDecoderFactory> audio_decoder_factory, | |
29 cricket::WebRtcVideoEncoderFactory* video_encoder_factory, | |
30 cricket::WebRtcVideoDecoderFactory* video_decoder_factory, | |
31 rtc::scoped_refptr<AudioMixer> audio_mixer) { | |
32 return std::unique_ptr<cricket::MediaEngineInterface>( | |
33 cricket::WebRtcMediaEngineFactory::Create( | |
34 default_adm, audio_encoder_factory, audio_decoder_factory, | |
35 video_encoder_factory, video_decoder_factory, audio_mixer)); | |
36 } | |
37 }; | |
38 | |
39 rtc::scoped_refptr<PeerConnectionFactoryInterface> CreatePeerConnectionFactory( | |
40 rtc::scoped_refptr<AudioEncoderFactory> audio_encoder_factory, | |
41 rtc::scoped_refptr<AudioDecoderFactory> audio_decoder_factory) { | |
42 // Create and start the worker thread to create the MediaEngine. | |
43 std::unique_ptr<rtc::Thread> worker_thread = rtc::Thread::Create(); | |
44 worker_thread->Start(); | |
45 | |
46 MediaEngineCreator media_engine_creator; | |
47 std::unique_ptr<cricket::MediaEngineInterface> media_engine = | |
48 worker_thread->Invoke<std::unique_ptr<cricket::MediaEngineInterface>>( | |
49 RTC_FROM_HERE, | |
50 rtc::Bind( | |
51 &MediaEngineCreator::CreateMediaEngine_w, &media_engine_creator, | |
52 nullptr /*default_adm*/, audio_encoder_factory, | |
53 audio_decoder_factory, nullptr /*video_encoder_factory*/, | |
54 nullptr /*video_decoder_factory*/, nullptr /*audio_mixer*/)); | |
55 | |
56 std::unique_ptr<CallFactoryInterface> call_factory = CreateCallFactory(); | |
57 | |
58 std::unique_ptr<RtcEventLogFactoryInterface> event_log_factory = | |
59 CreateRtcEventLogFactory(); | |
60 | |
61 // The PeerConnectionFactory would create the network thread and signaling | |
62 // thread internally and own all the threads. | |
63 return CreateModularPeerConnectionFactory( | |
64 nullptr, /*network_thread*/ | |
65 worker_thread.release(), nullptr /*signaling_thread*/, | |
Taylor Brandstetter
2017/06/14 01:54:16
So, this results in ownership of |worker_thread| b
Zhi Huang
2017/06/14 06:57:01
Again, I think this won't be an issue once your CL
| |
66 nullptr /*default_adm*/, audio_encoder_factory, audio_decoder_factory, | |
67 nullptr /*video_encoder_factory*/, nullptr /*video_decoder_factory*/, | |
68 nullptr /*audio_mixer*/, std::move(media_engine), std::move(call_factory), | |
69 std::move(event_log_factory)); | |
70 } | |
71 | |
72 rtc::scoped_refptr<PeerConnectionFactoryInterface> | |
73 CreatePeerConnectionFactory() { | |
74 return CreatePeerConnectionFactory(CreateBuiltinAudioEncoderFactory(), | |
75 CreateBuiltinAudioDecoderFactory()); | |
76 } | |
77 | |
78 rtc::scoped_refptr<PeerConnectionFactoryInterface> | |
79 CreatePeerConnectionFactoryWithAudioMixer( | |
80 rtc::Thread* network_thread, | |
81 rtc::Thread* worker_thread, | |
82 rtc::Thread* signaling_thread, | |
83 AudioDeviceModule* default_adm, | |
84 rtc::scoped_refptr<AudioEncoderFactory> audio_encoder_factory, | |
85 rtc::scoped_refptr<AudioDecoderFactory> audio_decoder_factory, | |
86 cricket::WebRtcVideoEncoderFactory* video_encoder_factory, | |
87 cricket::WebRtcVideoDecoderFactory* video_decoder_factory, | |
88 rtc::scoped_refptr<AudioMixer> audio_mixer) { | |
89 MediaEngineCreator media_engine_creator; | |
90 std::unique_ptr<cricket::MediaEngineInterface> media_engine = | |
91 worker_thread->Invoke<std::unique_ptr<cricket::MediaEngineInterface>>( | |
92 RTC_FROM_HERE, | |
93 rtc::Bind(&MediaEngineCreator::CreateMediaEngine_w, | |
94 &media_engine_creator, default_adm, audio_encoder_factory, | |
95 audio_decoder_factory, video_encoder_factory, | |
96 video_decoder_factory, audio_mixer)); | |
97 | |
98 std::unique_ptr<CallFactoryInterface> call_factory = CreateCallFactory(); | |
99 | |
100 std::unique_ptr<RtcEventLogFactoryInterface> event_log_factory = | |
101 CreateRtcEventLogFactory(); | |
102 | |
103 return CreateModularPeerConnectionFactory( | |
104 network_thread, worker_thread, signaling_thread, default_adm, | |
105 audio_encoder_factory, audio_decoder_factory, video_encoder_factory, | |
106 video_decoder_factory, audio_mixer, std::move(media_engine), | |
107 std::move(call_factory), std::move(event_log_factory)); | |
108 } | |
109 | |
110 rtc::scoped_refptr<PeerConnectionFactoryInterface> | |
111 CreatePeerConnectionFactoryWithAudioMixer( | |
112 rtc::Thread* network_thread, | |
113 rtc::Thread* worker_thread, | |
114 rtc::Thread* signaling_thread, | |
115 AudioDeviceModule* default_adm, | |
116 cricket::WebRtcVideoEncoderFactory* encoder_factory, | |
117 cricket::WebRtcVideoDecoderFactory* decoder_factory, | |
118 rtc::scoped_refptr<AudioMixer> audio_mixer) { | |
119 return CreatePeerConnectionFactoryWithAudioMixer( | |
120 network_thread, worker_thread, signaling_thread, default_adm, | |
121 CreateBuiltinAudioEncoderFactory(), CreateBuiltinAudioDecoderFactory(), | |
122 encoder_factory, decoder_factory, audio_mixer); | |
123 } | |
124 | |
125 rtc::scoped_refptr<PeerConnectionFactoryInterface> CreatePeerConnectionFactory( | |
126 rtc::Thread* network_thread, | |
127 rtc::Thread* worker_thread, | |
128 rtc::Thread* signaling_thread, | |
129 AudioDeviceModule* default_adm, | |
130 cricket::WebRtcVideoEncoderFactory* encoder_factory, | |
131 cricket::WebRtcVideoDecoderFactory* decoder_factory) { | |
132 return CreatePeerConnectionFactoryWithAudioMixer( | |
133 network_thread, worker_thread, signaling_thread, default_adm, | |
134 encoder_factory, decoder_factory, nullptr); | |
135 } | |
136 | |
137 rtc::scoped_refptr<PeerConnectionFactoryInterface> CreatePeerConnectionFactory( | |
138 rtc::Thread* network_thread, | |
139 rtc::Thread* worker_thread, | |
140 rtc::Thread* signaling_thread, | |
141 AudioDeviceModule* default_adm, | |
142 rtc::scoped_refptr<AudioEncoderFactory> audio_encoder_factory, | |
143 rtc::scoped_refptr<AudioDecoderFactory> audio_decoder_factory, | |
144 cricket::WebRtcVideoEncoderFactory* video_encoder_factory, | |
145 cricket::WebRtcVideoDecoderFactory* video_decoder_factory) { | |
146 return CreatePeerConnectionFactoryWithAudioMixer( | |
147 network_thread, worker_thread, signaling_thread, default_adm, | |
148 audio_encoder_factory, audio_decoder_factory, video_encoder_factory, | |
149 video_decoder_factory, nullptr); | |
150 } | |
151 | |
152 } // namespace webrtc | |
OLD | NEW |