henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 1 | /* |
kjellander | 65c7f67 | 2016-02-12 00:05:01 -0800 | [diff] [blame] | 2 | * Copyright 2004 The WebRTC project authors. All Rights Reserved. |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 3 | * |
kjellander | 65c7f67 | 2016-02-12 00:05:01 -0800 | [diff] [blame] | 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. |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 9 | */ |
| 10 | |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 11 | #ifndef PC_CHANNEL_MANAGER_H_ |
| 12 | #define PC_CHANNEL_MANAGER_H_ |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 13 | |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 14 | #include <stdint.h> |
Anton Sukhanov | 4f08faa | 2019-05-21 11:12:57 -0700 | [diff] [blame] | 15 | |
kwiberg | 3102294 | 2016-03-11 14:18:21 -0800 | [diff] [blame] | 16 | #include <memory> |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 17 | #include <string> |
| 18 | #include <vector> |
| 19 | |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 20 | #include "api/audio_options.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 21 | #include "api/crypto/crypto_options.h" |
Niels Möller | 65f17ca | 2019-09-12 13:59:36 +0200 | [diff] [blame] | 22 | #include "api/transport/media/media_transport_config.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 23 | #include "call/call.h" |
| 24 | #include "media/base/codec.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 25 | #include "media/base/media_channel.h" |
| 26 | #include "media/base/media_config.h" |
| 27 | #include "media/base/media_engine.h" |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 28 | #include "pc/channel.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 29 | #include "pc/rtp_transport_internal.h" |
| 30 | #include "pc/session_description.h" |
Niels Möller | e8e4dc4 | 2019-06-11 14:04:16 +0200 | [diff] [blame] | 31 | #include "rtc_base/system/file_wrapper.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 32 | #include "rtc_base/thread.h" |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 33 | |
| 34 | namespace cricket { |
| 35 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 36 | // ChannelManager allows the MediaEngine to run on a separate thread, and takes |
| 37 | // care of marshalling calls between threads. It also creates and keeps track of |
| 38 | // voice and video channels; by doing so, it can temporarily pause all the |
| 39 | // channels when a new audio or video device is chosen. The voice and video |
| 40 | // channels are stored in separate vectors, to easily allow operations on just |
| 41 | // voice or just video channels. |
| 42 | // ChannelManager also allows the application to discover what devices it has |
| 43 | // using device manager. |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 44 | class ChannelManager final { |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 45 | public: |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 46 | // Construct a ChannelManager with the specified media engine and data engine. |
| 47 | ChannelManager(std::unique_ptr<MediaEngineInterface> media_engine, |
| 48 | std::unique_ptr<DataEngineInterface> data_engine, |
| 49 | rtc::Thread* worker_thread, |
| 50 | rtc::Thread* network_thread); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 51 | ~ChannelManager(); |
| 52 | |
| 53 | // Accessors for the worker thread, allowing it to be set after construction, |
| 54 | // but before Init. set_worker_thread will return false if called after Init. |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 55 | rtc::Thread* worker_thread() const { return worker_thread_; } |
| 56 | bool set_worker_thread(rtc::Thread* thread) { |
Danil Chapovalov | 33b01f2 | 2016-05-11 19:55:27 +0200 | [diff] [blame] | 57 | if (initialized_) { |
| 58 | return false; |
| 59 | } |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 60 | worker_thread_ = thread; |
| 61 | return true; |
| 62 | } |
Danil Chapovalov | 33b01f2 | 2016-05-11 19:55:27 +0200 | [diff] [blame] | 63 | rtc::Thread* network_thread() const { return network_thread_; } |
| 64 | bool set_network_thread(rtc::Thread* thread) { |
| 65 | if (initialized_) { |
| 66 | return false; |
| 67 | } |
| 68 | network_thread_ = thread; |
| 69 | return true; |
| 70 | } |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 71 | |
Fredrik Solenberg | 709ed67 | 2015-09-15 12:26:33 +0200 | [diff] [blame] | 72 | MediaEngineInterface* media_engine() { return media_engine_.get(); } |
| 73 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 74 | // Retrieves the list of supported audio & video codec types. |
| 75 | // Can be called before starting the media engine. |
ossu | dedfd28 | 2016-06-14 07:12:39 -0700 | [diff] [blame] | 76 | void GetSupportedAudioSendCodecs(std::vector<AudioCodec>* codecs) const; |
| 77 | void GetSupportedAudioReceiveCodecs(std::vector<AudioCodec>* codecs) const; |
Johannes Kron | 8e8b36a | 2020-02-07 14:23:45 +0000 | [diff] [blame] | 78 | void GetSupportedVideoCodecs(std::vector<VideoCodec>* codecs) const; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 79 | void GetSupportedDataCodecs(std::vector<DataCodec>* codecs) const; |
Markus Handell | 0357b3e | 2020-03-16 13:40:51 +0100 | [diff] [blame] | 80 | RtpHeaderExtensions GetDefaultEnabledAudioRtpHeaderExtensions() const; |
| 81 | std::vector<webrtc::RtpHeaderExtensionCapability> |
| 82 | GetSupportedAudioRtpHeaderExtensions() const; |
| 83 | RtpHeaderExtensions GetDefaultEnabledVideoRtpHeaderExtensions() const; |
| 84 | std::vector<webrtc::RtpHeaderExtensionCapability> |
| 85 | GetSupportedVideoRtpHeaderExtensions() const; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 86 | |
| 87 | // Indicates whether the media engine is started. |
| 88 | bool initialized() const { return initialized_; } |
| 89 | // Starts up the media engine. |
| 90 | bool Init(); |
| 91 | // Shuts down the media engine. |
| 92 | void Terminate(); |
| 93 | |
| 94 | // The operations below all occur on the worker thread. |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 95 | // ChannelManager retains ownership of the created channels, so clients should |
| 96 | // call the appropriate Destroy*Channel method when done. |
| 97 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 98 | // Creates a voice channel, to be associated with the specified session. |
Anton Sukhanov | 98a462c | 2018-10-17 13:15:42 -0700 | [diff] [blame] | 99 | VoiceChannel* CreateVoiceChannel( |
| 100 | webrtc::Call* call, |
| 101 | const cricket::MediaConfig& media_config, |
| 102 | webrtc::RtpTransportInternal* rtp_transport, |
Anton Sukhanov | 4f08faa | 2019-05-21 11:12:57 -0700 | [diff] [blame] | 103 | const webrtc::MediaTransportConfig& media_transport_config, |
Anton Sukhanov | 98a462c | 2018-10-17 13:15:42 -0700 | [diff] [blame] | 104 | rtc::Thread* signaling_thread, |
| 105 | const std::string& content_name, |
| 106 | bool srtp_required, |
| 107 | const webrtc::CryptoOptions& crypto_options, |
Amit Hilbuch | bcd39d4 | 2019-01-25 17:13:56 -0800 | [diff] [blame] | 108 | rtc::UniqueRandomIdGenerator* ssrc_generator, |
Anton Sukhanov | 98a462c | 2018-10-17 13:15:42 -0700 | [diff] [blame] | 109 | const AudioOptions& options); |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 110 | // Destroys a voice channel created by CreateVoiceChannel. |
Fredrik Solenberg | 709ed67 | 2015-09-15 12:26:33 +0200 | [diff] [blame] | 111 | void DestroyVoiceChannel(VoiceChannel* voice_channel); |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 112 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 113 | // Creates a video channel, synced with the specified voice channel, and |
| 114 | // associated with the specified session. |
deadbeef | e814a0d | 2017-02-25 18:15:09 -0800 | [diff] [blame] | 115 | // Version of the above that takes PacketTransportInternal. |
Niels Möller | 4687915 | 2019-01-07 15:54:47 +0100 | [diff] [blame] | 116 | VideoChannel* CreateVideoChannel( |
| 117 | webrtc::Call* call, |
| 118 | const cricket::MediaConfig& media_config, |
| 119 | webrtc::RtpTransportInternal* rtp_transport, |
Anton Sukhanov | 4f08faa | 2019-05-21 11:12:57 -0700 | [diff] [blame] | 120 | const webrtc::MediaTransportConfig& media_transport_config, |
Niels Möller | 4687915 | 2019-01-07 15:54:47 +0100 | [diff] [blame] | 121 | rtc::Thread* signaling_thread, |
| 122 | const std::string& content_name, |
| 123 | bool srtp_required, |
| 124 | const webrtc::CryptoOptions& crypto_options, |
Amit Hilbuch | bcd39d4 | 2019-01-25 17:13:56 -0800 | [diff] [blame] | 125 | rtc::UniqueRandomIdGenerator* ssrc_generator, |
Jonas Oreland | a3aa9bd | 2019-04-17 07:38:40 +0200 | [diff] [blame] | 126 | const VideoOptions& options, |
| 127 | webrtc::VideoBitrateAllocatorFactory* video_bitrate_allocator_factory); |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 128 | // Destroys a video channel created by CreateVideoChannel. |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 129 | void DestroyVideoChannel(VideoChannel* video_channel); |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 130 | |
Zhi Huang | 2dfc42d | 2017-12-04 13:38:48 -0800 | [diff] [blame] | 131 | RtpDataChannel* CreateRtpDataChannel( |
| 132 | const cricket::MediaConfig& media_config, |
| 133 | webrtc::RtpTransportInternal* rtp_transport, |
| 134 | rtc::Thread* signaling_thread, |
| 135 | const std::string& content_name, |
Zhi Huang | e830e68 | 2018-03-30 10:48:35 -0700 | [diff] [blame] | 136 | bool srtp_required, |
Amit Hilbuch | bcd39d4 | 2019-01-25 17:13:56 -0800 | [diff] [blame] | 137 | const webrtc::CryptoOptions& crypto_options, |
| 138 | rtc::UniqueRandomIdGenerator* ssrc_generator); |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 139 | // Destroys a data channel created by CreateRtpDataChannel. |
deadbeef | 953c2ce | 2017-01-09 14:53:41 -0800 | [diff] [blame] | 140 | void DestroyRtpDataChannel(RtpDataChannel* data_channel); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 141 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 142 | // Indicates whether any channels exist. |
| 143 | bool has_channels() const { |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 144 | return (!voice_channels_.empty() || !video_channels_.empty() || |
| 145 | !data_channels_.empty()); |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 146 | } |
| 147 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 148 | // RTX will be enabled/disabled in engines that support it. The supporting |
| 149 | // engines will start offering an RTX codec. Must be called before Init(). |
| 150 | bool SetVideoRtxEnabled(bool enable); |
| 151 | |
| 152 | // Starts/stops the local microphone and enables polling of the input level. |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 153 | bool capturing() const { return capturing_; } |
| 154 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 155 | // The operations below occur on the main thread. |
| 156 | |
ivoc | d66b44d | 2016-01-15 03:06:36 -0800 | [diff] [blame] | 157 | // Starts AEC dump using existing file, with a specified maximum file size in |
| 158 | // bytes. When the limit is reached, logging will stop and the file will be |
| 159 | // closed. If max_size_bytes is set to <= 0, no limit will be used. |
Niels Möller | e8e4dc4 | 2019-06-11 14:04:16 +0200 | [diff] [blame] | 160 | bool StartAecDump(webrtc::FileWrapper file, int64_t max_size_bytes); |
wu@webrtc.org | a989080 | 2013-12-13 00:21:03 +0000 | [diff] [blame] | 161 | |
ivoc | 797ef12 | 2015-10-22 03:25:41 -0700 | [diff] [blame] | 162 | // Stops recording AEC dump. |
| 163 | void StopAecDump(); |
| 164 | |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 165 | private: |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 166 | std::unique_ptr<MediaEngineInterface> media_engine_; // Nullable. |
| 167 | std::unique_ptr<DataEngineInterface> data_engine_; // Non-null. |
| 168 | bool initialized_ = false; |
buildbot@webrtc.org | d4e598d | 2014-07-29 17:36:52 +0000 | [diff] [blame] | 169 | rtc::Thread* main_thread_; |
| 170 | rtc::Thread* worker_thread_; |
Danil Chapovalov | 33b01f2 | 2016-05-11 19:55:27 +0200 | [diff] [blame] | 171 | rtc::Thread* network_thread_; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 172 | |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 173 | // Vector contents are non-null. |
Steve Anton | 774115c | 2017-08-30 10:48:46 -0700 | [diff] [blame] | 174 | std::vector<std::unique_ptr<VoiceChannel>> voice_channels_; |
| 175 | std::vector<std::unique_ptr<VideoChannel>> video_channels_; |
| 176 | std::vector<std::unique_ptr<RtpDataChannel>> data_channels_; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 177 | |
Steve Anton | c9e1560 | 2017-11-06 15:40:09 -0800 | [diff] [blame] | 178 | bool enable_rtx_ = false; |
| 179 | bool capturing_ = false; |
henrike@webrtc.org | 28e2075 | 2013-07-10 00:45:36 +0000 | [diff] [blame] | 180 | }; |
| 181 | |
| 182 | } // namespace cricket |
| 183 | |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 184 | #endif // PC_CHANNEL_MANAGER_H_ |