OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2004 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2004 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
11 #ifndef WEBRTC_PC_CHANNELMANAGER_H_ | 11 #ifndef WEBRTC_PC_CHANNELMANAGER_H_ |
12 #define WEBRTC_PC_CHANNELMANAGER_H_ | 12 #define WEBRTC_PC_CHANNELMANAGER_H_ |
13 | 13 |
14 #include <string> | 14 #include <string> |
15 #include <vector> | 15 #include <vector> |
16 | 16 |
17 #include "webrtc/base/criticalsection.h" | |
18 #include "webrtc/base/fileutils.h" | 17 #include "webrtc/base/fileutils.h" |
19 #include "webrtc/base/sigslotrepeater.h" | |
20 #include "webrtc/base/thread.h" | 18 #include "webrtc/base/thread.h" |
21 #include "webrtc/media/base/capturemanager.h" | |
22 #include "webrtc/media/base/mediaengine.h" | 19 #include "webrtc/media/base/mediaengine.h" |
23 #include "webrtc/pc/voicechannel.h" | 20 #include "webrtc/pc/voicechannel.h" |
24 | 21 |
25 namespace webrtc { | 22 namespace webrtc { |
26 class MediaControllerInterface; | 23 class MediaControllerInterface; |
27 } | 24 } |
28 namespace cricket { | 25 namespace cricket { |
29 | 26 |
30 class VoiceChannel; | 27 class VoiceChannel; |
31 | 28 |
32 // ChannelManager allows the MediaEngine to run on a separate thread, and takes | 29 // ChannelManager allows the MediaEngine to run on a separate thread, and takes |
33 // care of marshalling calls between threads. It also creates and keeps track of | 30 // care of marshalling calls between threads. It also creates and keeps track of |
34 // voice and video channels; by doing so, it can temporarily pause all the | 31 // voice and video channels; by doing so, it can temporarily pause all the |
35 // channels when a new audio or video device is chosen. The voice and video | 32 // channels when a new audio or video device is chosen. The voice and video |
36 // channels are stored in separate vectors, to easily allow operations on just | 33 // channels are stored in separate vectors, to easily allow operations on just |
37 // voice or just video channels. | 34 // voice or just video channels. |
38 // ChannelManager also allows the application to discover what devices it has | 35 // ChannelManager also allows the application to discover what devices it has |
39 // using device manager. | 36 // using device manager. |
40 class ChannelManager : public rtc::MessageHandler, | 37 class ChannelManager { |
41 public sigslot::has_slots<> { | |
42 public: | 38 public: |
43 // For testing purposes. Allows the media engine and data media | 39 // For testing purposes. Allows the media engine and data media |
44 // engine and dev manager to be mocks. The ChannelManager takes | 40 // engine and dev manager to be mocks. The ChannelManager takes |
45 // ownership of these objects. | 41 // ownership of these objects. |
46 ChannelManager(MediaEngineInterface* me, | 42 ChannelManager(MediaEngineInterface* me, |
47 DataEngineInterface* dme, | 43 DataEngineInterface* dme, |
48 CaptureManager* cm, | |
49 rtc::Thread* worker); | 44 rtc::Thread* worker); |
50 // Same as above, but gives an easier default DataEngine. | 45 // Same as above, but gives an easier default DataEngine. |
51 ChannelManager(MediaEngineInterface* me, | 46 ChannelManager(MediaEngineInterface* me, |
52 rtc::Thread* worker); | 47 rtc::Thread* worker); |
53 ~ChannelManager(); | 48 ~ChannelManager(); |
54 | 49 |
55 // Accessors for the worker thread, allowing it to be set after construction, | 50 // Accessors for the worker thread, allowing it to be set after construction, |
56 // but before Init. set_worker_thread will return false if called after Init. | 51 // but before Init. set_worker_thread will return false if called after Init. |
57 rtc::Thread* worker_thread() const { return worker_thread_; } | 52 rtc::Thread* worker_thread() const { return worker_thread_; } |
58 bool set_worker_thread(rtc::Thread* thread) { | 53 bool set_worker_thread(rtc::Thread* thread) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
112 | 107 |
113 bool GetOutputVolume(int* level); | 108 bool GetOutputVolume(int* level); |
114 bool SetOutputVolume(int level); | 109 bool SetOutputVolume(int level); |
115 // RTX will be enabled/disabled in engines that support it. The supporting | 110 // RTX will be enabled/disabled in engines that support it. The supporting |
116 // engines will start offering an RTX codec. Must be called before Init(). | 111 // engines will start offering an RTX codec. Must be called before Init(). |
117 bool SetVideoRtxEnabled(bool enable); | 112 bool SetVideoRtxEnabled(bool enable); |
118 | 113 |
119 // Starts/stops the local microphone and enables polling of the input level. | 114 // Starts/stops the local microphone and enables polling of the input level. |
120 bool capturing() const { return capturing_; } | 115 bool capturing() const { return capturing_; } |
121 | 116 |
122 // Gets capturer's supported formats in a thread safe manner | |
123 std::vector<cricket::VideoFormat> GetSupportedFormats( | |
124 VideoCapturer* capturer) const; | |
125 // The following are done in the new "CaptureManager" style that | |
126 // all local video capturers, processors, and managers should move to. | |
127 // TODO(pthatcher): Make methods nicer by having start return a handle that | |
128 // can be used for stop and restart, rather than needing to pass around | |
129 // formats a a pseudo-handle. | |
130 bool StartVideoCapture(VideoCapturer* video_capturer, | |
131 const VideoFormat& video_format); | |
132 bool StopVideoCapture(VideoCapturer* video_capturer, | |
133 const VideoFormat& video_format); | |
134 bool RestartVideoCapture(VideoCapturer* video_capturer, | |
135 const VideoFormat& previous_format, | |
136 const VideoFormat& desired_format, | |
137 CaptureManager::RestartOptions options); | |
138 | |
139 virtual void AddVideoSink(VideoCapturer* video_capturer, | |
140 rtc::VideoSinkInterface<VideoFrame>* sink); | |
141 virtual void RemoveVideoSink(VideoCapturer* video_capturer, | |
142 rtc::VideoSinkInterface<VideoFrame>* sink); | |
143 bool IsScreencastRunning() const; | |
144 | |
145 // The operations below occur on the main thread. | 117 // The operations below occur on the main thread. |
146 | 118 |
147 // Starts AEC dump using existing file, with a specified maximum file size in | 119 // Starts AEC dump using existing file, with a specified maximum file size in |
148 // bytes. When the limit is reached, logging will stop and the file will be | 120 // bytes. When the limit is reached, logging will stop and the file will be |
149 // closed. If max_size_bytes is set to <= 0, no limit will be used. | 121 // closed. If max_size_bytes is set to <= 0, no limit will be used. |
150 bool StartAecDump(rtc::PlatformFile file, int64_t max_size_bytes); | 122 bool StartAecDump(rtc::PlatformFile file, int64_t max_size_bytes); |
151 | 123 |
152 // Stops recording AEC dump. | 124 // Stops recording AEC dump. |
153 void StopAecDump(); | 125 void StopAecDump(); |
154 | 126 |
155 // Starts RtcEventLog using existing file. | 127 // Starts RtcEventLog using existing file. |
156 bool StartRtcEventLog(rtc::PlatformFile file); | 128 bool StartRtcEventLog(rtc::PlatformFile file); |
157 | 129 |
158 // Stops logging RtcEventLog. | 130 // Stops logging RtcEventLog. |
159 void StopRtcEventLog(); | 131 void StopRtcEventLog(); |
160 | 132 |
161 sigslot::signal2<VideoCapturer*, CaptureState> SignalVideoCaptureStateChange; | |
162 | |
163 private: | 133 private: |
164 typedef std::vector<VoiceChannel*> VoiceChannels; | 134 typedef std::vector<VoiceChannel*> VoiceChannels; |
165 typedef std::vector<VideoChannel*> VideoChannels; | 135 typedef std::vector<VideoChannel*> VideoChannels; |
166 typedef std::vector<DataChannel*> DataChannels; | 136 typedef std::vector<DataChannel*> DataChannels; |
167 | 137 |
168 void Construct(MediaEngineInterface* me, | 138 void Construct(MediaEngineInterface* me, |
169 DataEngineInterface* dme, | 139 DataEngineInterface* dme, |
170 CaptureManager* cm, | |
171 rtc::Thread* worker_thread); | 140 rtc::Thread* worker_thread); |
172 bool InitMediaEngine_w(); | 141 bool InitMediaEngine_w(); |
173 void DestructorDeletes_w(); | 142 void DestructorDeletes_w(); |
174 void Terminate_w(); | 143 void Terminate_w(); |
175 VoiceChannel* CreateVoiceChannel_w( | 144 VoiceChannel* CreateVoiceChannel_w( |
176 webrtc::MediaControllerInterface* media_controller, | 145 webrtc::MediaControllerInterface* media_controller, |
177 TransportController* transport_controller, | 146 TransportController* transport_controller, |
178 const std::string& content_name, | 147 const std::string& content_name, |
179 bool rtcp, | 148 bool rtcp, |
180 const AudioOptions& options); | 149 const AudioOptions& options); |
181 void DestroyVoiceChannel_w(VoiceChannel* voice_channel); | 150 void DestroyVoiceChannel_w(VoiceChannel* voice_channel); |
182 VideoChannel* CreateVideoChannel_w( | 151 VideoChannel* CreateVideoChannel_w( |
183 webrtc::MediaControllerInterface* media_controller, | 152 webrtc::MediaControllerInterface* media_controller, |
184 TransportController* transport_controller, | 153 TransportController* transport_controller, |
185 const std::string& content_name, | 154 const std::string& content_name, |
186 bool rtcp, | 155 bool rtcp, |
187 const VideoOptions& options); | 156 const VideoOptions& options); |
188 void DestroyVideoChannel_w(VideoChannel* video_channel); | 157 void DestroyVideoChannel_w(VideoChannel* video_channel); |
189 DataChannel* CreateDataChannel_w(TransportController* transport_controller, | 158 DataChannel* CreateDataChannel_w(TransportController* transport_controller, |
190 const std::string& content_name, | 159 const std::string& content_name, |
191 bool rtcp, | 160 bool rtcp, |
192 DataChannelType data_channel_type); | 161 DataChannelType data_channel_type); |
193 void DestroyDataChannel_w(DataChannel* data_channel); | 162 void DestroyDataChannel_w(DataChannel* data_channel); |
194 void OnVideoCaptureStateChange(VideoCapturer* capturer, | |
195 CaptureState result); | |
196 void GetSupportedFormats_w( | |
197 VideoCapturer* capturer, | |
198 std::vector<cricket::VideoFormat>* out_formats) const; | |
199 bool IsScreencastRunning_w() const; | |
200 virtual void OnMessage(rtc::Message *message); | |
201 | 163 |
202 rtc::scoped_ptr<MediaEngineInterface> media_engine_; | 164 rtc::scoped_ptr<MediaEngineInterface> media_engine_; |
203 rtc::scoped_ptr<DataEngineInterface> data_media_engine_; | 165 rtc::scoped_ptr<DataEngineInterface> data_media_engine_; |
204 rtc::scoped_ptr<CaptureManager> capture_manager_; | |
205 bool initialized_; | 166 bool initialized_; |
206 rtc::Thread* main_thread_; | 167 rtc::Thread* main_thread_; |
207 rtc::Thread* worker_thread_; | 168 rtc::Thread* worker_thread_; |
208 | 169 |
209 VoiceChannels voice_channels_; | 170 VoiceChannels voice_channels_; |
210 VideoChannels video_channels_; | 171 VideoChannels video_channels_; |
211 DataChannels data_channels_; | 172 DataChannels data_channels_; |
212 | 173 |
213 int audio_output_volume_; | 174 int audio_output_volume_; |
214 bool enable_rtx_; | 175 bool enable_rtx_; |
215 | 176 |
216 bool capturing_; | 177 bool capturing_; |
217 }; | 178 }; |
218 | 179 |
219 } // namespace cricket | 180 } // namespace cricket |
220 | 181 |
221 #endif // WEBRTC_PC_CHANNELMANAGER_H_ | 182 #endif // WEBRTC_PC_CHANNELMANAGER_H_ |
OLD | NEW |