pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2013 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 | |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 11 | #ifndef VIDEO_VIDEO_SEND_STREAM_H_ |
| 12 | #define VIDEO_VIDEO_SEND_STREAM_H_ |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 13 | |
pbos@webrtc.org | 2bb1bda | 2014-07-07 13:06:48 +0000 | [diff] [blame] | 14 | #include <map> |
kwiberg | bfefb03 | 2016-05-01 14:53:46 -0700 | [diff] [blame] | 15 | #include <memory> |
pbos@webrtc.org | dde16f1 | 2014-08-05 23:35:43 +0000 | [diff] [blame] | 16 | #include <vector> |
pbos@webrtc.org | 2bb1bda | 2014-07-07 13:06:48 +0000 | [diff] [blame] | 17 | |
Ying Wang | 3b790f3 | 2018-01-19 17:58:57 +0100 | [diff] [blame] | 18 | #include "api/fec_controller.h" |
Niels Möller | 213618e | 2018-07-24 09:29:58 +0200 | [diff] [blame] | 19 | #include "api/video/video_stream_encoder_interface.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 20 | #include "call/bitrate_allocator.h" |
| 21 | #include "call/video_receive_stream.h" |
| 22 | #include "call/video_send_stream.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 23 | #include "rtc_base/critical_section.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 24 | #include "rtc_base/event.h" |
| 25 | #include "rtc_base/task_queue.h" |
Sebastian Jansson | df5e4e0 | 2019-03-29 10:34:45 +0100 | [diff] [blame] | 26 | #include "rtc_base/thread_checker.h" |
Yves Gerey | 665174f | 2018-06-19 15:03:05 +0200 | [diff] [blame] | 27 | #include "video/send_delay_stats.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 28 | #include "video/send_statistics_proxy.h" |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 29 | |
| 30 | namespace webrtc { |
Sebastian Jansson | a45c8da | 2018-01-16 10:55:29 +0100 | [diff] [blame] | 31 | namespace test { |
| 32 | class VideoSendStreamPeer; |
| 33 | } // namespace test |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 34 | |
mflodman | e378702 | 2015-10-21 13:24:28 +0200 | [diff] [blame] | 35 | class CallStats; |
perkj | 600246e | 2016-05-04 11:26:51 -0700 | [diff] [blame] | 36 | class IvfFileWriter; |
Peter Boström | f16fcbe | 2015-04-30 12:16:05 +0200 | [diff] [blame] | 37 | class ProcessThread; |
Niels Möller | 213618e | 2018-07-24 09:29:58 +0200 | [diff] [blame] | 38 | class RateLimiter; |
Peter Boström | 723ead8 | 2016-02-22 15:14:01 +0100 | [diff] [blame] | 39 | class RtpRtcp; |
nisse | b8f9a32 | 2017-03-27 05:36:15 -0700 | [diff] [blame] | 40 | class RtpTransportControllerSendInterface; |
terelius | adafe0b | 2016-05-26 01:58:40 -0700 | [diff] [blame] | 41 | class RtcEventLog; |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 42 | |
| 43 | namespace internal { |
mflodman@webrtc.org | 6879c8a | 2013-07-23 11:35:00 +0000 | [diff] [blame] | 44 | |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 45 | class VideoSendStreamImpl; |
| 46 | |
| 47 | // VideoSendStream implements webrtc::VideoSendStream. |
| 48 | // Internally, it delegates all public methods to VideoSendStreamImpl and / or |
mflodman | cc3d442 | 2017-08-03 08:27:51 -0700 | [diff] [blame] | 49 | // VideoStreamEncoder. VideoSendStreamInternal is created and deleted on |
| 50 | // |worker_queue|. |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 51 | class VideoSendStream : public webrtc::VideoSendStream { |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 52 | public: |
Stefan Holmer | dbdb3a0 | 2018-07-17 16:03:46 +0200 | [diff] [blame] | 53 | using RtpStateMap = std::map<uint32_t, RtpState>; |
| 54 | using RtpPayloadStateMap = std::map<uint32_t, RtpPayloadState>; |
| 55 | |
Åsa Persson | 4bece9a | 2017-10-06 10:04:04 +0200 | [diff] [blame] | 56 | VideoSendStream( |
Sebastian Jansson | 572c60f | 2019-03-04 18:30:41 +0100 | [diff] [blame] | 57 | Clock* clock, |
Åsa Persson | 4bece9a | 2017-10-06 10:04:04 +0200 | [diff] [blame] | 58 | int num_cpu_cores, |
| 59 | ProcessThread* module_process_thread, |
Sebastian Jansson | 74682c1 | 2019-03-01 11:50:20 +0100 | [diff] [blame] | 60 | TaskQueueFactory* task_queue_factory, |
Åsa Persson | 4bece9a | 2017-10-06 10:04:04 +0200 | [diff] [blame] | 61 | CallStats* call_stats, |
| 62 | RtpTransportControllerSendInterface* transport, |
Niels Möller | 67b011d | 2018-10-22 13:00:40 +0200 | [diff] [blame] | 63 | BitrateAllocatorInterface* bitrate_allocator, |
Åsa Persson | 4bece9a | 2017-10-06 10:04:04 +0200 | [diff] [blame] | 64 | SendDelayStats* send_delay_stats, |
| 65 | RtcEventLog* event_log, |
| 66 | VideoSendStream::Config config, |
| 67 | VideoEncoderConfig encoder_config, |
| 68 | const std::map<uint32_t, RtpState>& suspended_ssrcs, |
Ying Wang | 3b790f3 | 2018-01-19 17:58:57 +0100 | [diff] [blame] | 69 | const std::map<uint32_t, RtpPayloadState>& suspended_payload_states, |
Stefan Holmer | dbdb3a0 | 2018-07-17 16:03:46 +0200 | [diff] [blame] | 70 | std::unique_ptr<FecController> fec_controller); |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 71 | |
Jelena Marusic | cd67022 | 2015-07-16 09:30:09 +0200 | [diff] [blame] | 72 | ~VideoSendStream() override; |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 73 | |
Niels Möller | 8fb1a6a | 2019-03-05 14:29:42 +0100 | [diff] [blame] | 74 | void DeliverRtcp(const uint8_t* packet, size_t length); |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 75 | |
Jelena Marusic | cd67022 | 2015-07-16 09:30:09 +0200 | [diff] [blame] | 76 | // webrtc::VideoSendStream implementation. |
Seth Hampson | cc7125f | 2018-02-02 08:46:16 -0800 | [diff] [blame] | 77 | void UpdateActiveSimulcastLayers( |
| 78 | const std::vector<bool> active_layers) override; |
pbos | 1ba8d39 | 2016-05-01 20:18:34 -0700 | [diff] [blame] | 79 | void Start() override; |
| 80 | void Stop() override; |
perkj | a49cbd3 | 2016-09-16 07:53:41 -0700 | [diff] [blame] | 81 | |
perkj | 803d97f | 2016-11-01 11:45:46 -0700 | [diff] [blame] | 82 | void SetSource(rtc::VideoSourceInterface<webrtc::VideoFrame>* source, |
| 83 | const DegradationPreference& degradation_preference) override; |
perkj | a49cbd3 | 2016-09-16 07:53:41 -0700 | [diff] [blame] | 84 | |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 85 | void ReconfigureVideoEncoder(VideoEncoderConfig) override; |
kjellander@webrtc.org | 14665ff | 2015-03-04 12:58:35 +0000 | [diff] [blame] | 86 | Stats GetStats() override; |
sprang@webrtc.org | ccd4284 | 2014-01-07 09:54:34 +0000 | [diff] [blame] | 87 | |
Åsa Persson | 4bece9a | 2017-10-06 10:04:04 +0200 | [diff] [blame] | 88 | void StopPermanentlyAndGetRtpStates(RtpStateMap* rtp_state_map, |
| 89 | RtpPayloadStateMap* payload_state_map); |
Per | 83d0910 | 2016-04-15 14:59:13 +0200 | [diff] [blame] | 90 | |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 91 | private: |
Sebastian Jansson | a45c8da | 2018-01-16 10:55:29 +0100 | [diff] [blame] | 92 | friend class test::VideoSendStreamPeer; |
| 93 | |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 94 | class ConstructionTask; |
perkj | bc75d97 | 2016-05-02 06:31:25 -0700 | [diff] [blame] | 95 | |
Danil Chapovalov | b9b146c | 2018-06-15 12:28:07 +0200 | [diff] [blame] | 96 | absl::optional<float> GetPacingFactorOverride() const; |
Sebastian Jansson | a45c8da | 2018-01-16 10:55:29 +0100 | [diff] [blame] | 97 | |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 98 | rtc::ThreadChecker thread_checker_; |
| 99 | rtc::TaskQueue* const worker_queue_; |
| 100 | rtc::Event thread_sync_event_; |
Peter Boström | 373284d | 2015-11-03 13:53:06 +0100 | [diff] [blame] | 101 | |
| 102 | SendStatisticsProxy stats_proxy_; |
pbos@webrtc.org | 6ae48c6 | 2014-06-06 10:49:19 +0000 | [diff] [blame] | 103 | const VideoSendStream::Config config_; |
sprang | f24a064 | 2017-02-28 13:23:26 -0800 | [diff] [blame] | 104 | const VideoEncoderConfig::ContentType content_type_; |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 105 | std::unique_ptr<VideoSendStreamImpl> send_stream_; |
Niels Möller | 213618e | 2018-07-24 09:29:58 +0200 | [diff] [blame] | 106 | std::unique_ptr<VideoStreamEncoderInterface> video_stream_encoder_; |
perkj | 8eb37a3 | 2016-08-16 02:40:55 -0700 | [diff] [blame] | 107 | }; |
perkj | 26091b1 | 2016-09-01 01:17:40 -0700 | [diff] [blame] | 108 | |
pbos@webrtc.org | 29d5839 | 2013-05-16 12:08:03 +0000 | [diff] [blame] | 109 | } // namespace internal |
| 110 | } // namespace webrtc |
| 111 | |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 112 | #endif // VIDEO_VIDEO_SEND_STREAM_H_ |