Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2018 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 | #ifndef CALL_DEGRADED_CALL_H_ |
| 12 | #define CALL_DEGRADED_CALL_H_ |
| 13 | |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 14 | #include <stddef.h> |
| 15 | #include <stdint.h> |
Jonas Olsson | a4d8737 | 2019-07-05 19:08:33 +0200 | [diff] [blame] | 16 | |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 17 | #include <map> |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 18 | #include <memory> |
| 19 | |
Danil Chapovalov | b9b146c | 2018-06-15 12:28:07 +0200 | [diff] [blame] | 20 | #include "absl/types/optional.h" |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 21 | #include "api/call/transport.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 22 | #include "api/fec_controller.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 23 | #include "api/media_types.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 24 | #include "api/rtp_headers.h" |
Artem Titov | 3229d65 | 2018-08-17 13:00:54 +0200 | [diff] [blame] | 25 | #include "api/test/simulated_network.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 26 | #include "api/video_codecs/video_encoder_config.h" |
| 27 | #include "call/audio_receive_stream.h" |
| 28 | #include "call/audio_send_stream.h" |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 29 | #include "call/call.h" |
| 30 | #include "call/fake_network_pipe.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 31 | #include "call/flexfec_receive_stream.h" |
| 32 | #include "call/packet_receiver.h" |
| 33 | #include "call/rtp_transport_controller_send_interface.h" |
Artem Titov | 3229d65 | 2018-08-17 13:00:54 +0200 | [diff] [blame] | 34 | #include "call/simulated_network.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 35 | #include "call/video_receive_stream.h" |
| 36 | #include "call/video_send_stream.h" |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 37 | #include "modules/utility/include/process_thread.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 38 | #include "rtc_base/copy_on_write_buffer.h" |
Yves Gerey | 3e70781 | 2018-11-28 16:47:49 +0100 | [diff] [blame] | 39 | #include "rtc_base/network/sent_packet.h" |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 40 | #include "rtc_base/task_queue.h" |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 41 | #include "system_wrappers/include/clock.h" |
| 42 | |
| 43 | namespace webrtc { |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 44 | class DegradedCall : public Call, private PacketReceiver { |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 45 | public: |
Artem Titov | 3229d65 | 2018-08-17 13:00:54 +0200 | [diff] [blame] | 46 | explicit DegradedCall( |
| 47 | std::unique_ptr<Call> call, |
Artem Titov | 75e3647 | 2018-10-08 12:28:56 +0200 | [diff] [blame] | 48 | absl::optional<BuiltInNetworkBehaviorConfig> send_config, |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 49 | absl::optional<BuiltInNetworkBehaviorConfig> receive_config, |
| 50 | TaskQueueFactory* task_queue_factory); |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 51 | ~DegradedCall() override; |
| 52 | |
| 53 | // Implements Call. |
| 54 | AudioSendStream* CreateAudioSendStream( |
| 55 | const AudioSendStream::Config& config) override; |
| 56 | void DestroyAudioSendStream(AudioSendStream* send_stream) override; |
| 57 | |
| 58 | AudioReceiveStream* CreateAudioReceiveStream( |
| 59 | const AudioReceiveStream::Config& config) override; |
| 60 | void DestroyAudioReceiveStream(AudioReceiveStream* receive_stream) override; |
| 61 | |
| 62 | VideoSendStream* CreateVideoSendStream( |
| 63 | VideoSendStream::Config config, |
| 64 | VideoEncoderConfig encoder_config) override; |
| 65 | VideoSendStream* CreateVideoSendStream( |
| 66 | VideoSendStream::Config config, |
| 67 | VideoEncoderConfig encoder_config, |
| 68 | std::unique_ptr<FecController> fec_controller) override; |
| 69 | void DestroyVideoSendStream(VideoSendStream* send_stream) override; |
| 70 | |
| 71 | VideoReceiveStream* CreateVideoReceiveStream( |
| 72 | VideoReceiveStream::Config configuration) override; |
| 73 | void DestroyVideoReceiveStream(VideoReceiveStream* receive_stream) override; |
| 74 | |
| 75 | FlexfecReceiveStream* CreateFlexfecReceiveStream( |
| 76 | const FlexfecReceiveStream::Config& config) override; |
| 77 | void DestroyFlexfecReceiveStream( |
| 78 | FlexfecReceiveStream* receive_stream) override; |
| 79 | |
| 80 | PacketReceiver* Receiver() override; |
| 81 | |
| 82 | RtpTransportControllerSendInterface* GetTransportControllerSend() override; |
| 83 | |
| 84 | Stats GetStats() const override; |
| 85 | |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 86 | void SignalChannelNetworkState(MediaType media, NetworkState state) override; |
Stefan Holmer | 64be7fa | 2018-10-04 15:21:55 +0200 | [diff] [blame] | 87 | void OnAudioTransportOverheadChanged( |
| 88 | int transport_overhead_per_packet) override; |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 89 | void OnSentPacket(const rtc::SentPacket& sent_packet) override; |
| 90 | |
| 91 | protected: |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 92 | // Implements PacketReceiver. |
| 93 | DeliveryStatus DeliverPacket(MediaType media_type, |
| 94 | rtc::CopyOnWriteBuffer packet, |
Niels Möller | 7008287 | 2018-08-07 11:03:12 +0200 | [diff] [blame] | 95 | int64_t packet_time_us) override; |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 96 | |
| 97 | private: |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 98 | class FakeNetworkPipeOnTaskQueue { |
| 99 | public: |
| 100 | FakeNetworkPipeOnTaskQueue( |
| 101 | TaskQueueFactory* task_queue_factory, |
| 102 | Clock* clock, |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 103 | std::unique_ptr<NetworkBehaviorInterface> network_behavior); |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 104 | |
| 105 | void SendRtp(const uint8_t* packet, |
| 106 | size_t length, |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 107 | const PacketOptions& options, |
| 108 | Transport* transport); |
| 109 | void SendRtcp(const uint8_t* packet, size_t length, Transport* transport); |
| 110 | |
| 111 | void AddActiveTransport(Transport* transport); |
| 112 | void RemoveActiveTransport(Transport* transport); |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 113 | |
| 114 | private: |
| 115 | // Try to process packets on the fake network queue. |
| 116 | // Returns true if call resulted in a delayed process, false if queue empty. |
| 117 | bool Process(); |
| 118 | |
| 119 | Clock* const clock_; |
| 120 | rtc::TaskQueue task_queue_; |
| 121 | FakeNetworkPipe pipe_; |
| 122 | absl::optional<int64_t> next_process_ms_ RTC_GUARDED_BY(&task_queue_); |
| 123 | }; |
| 124 | |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 125 | // For audio/video send stream, a TransportAdapter instance is used to |
| 126 | // intercept packets to be sent, and put them into a common FakeNetworkPipe |
| 127 | // in such as way that they will eventually (unless dropped) be forwarded to |
| 128 | // the correct Transport for that stream. |
| 129 | class FakeNetworkPipeTransportAdapter : public Transport { |
| 130 | public: |
| 131 | FakeNetworkPipeTransportAdapter(FakeNetworkPipeOnTaskQueue* fake_network, |
| 132 | Call* call, |
| 133 | Clock* clock, |
| 134 | Transport* real_transport); |
| 135 | ~FakeNetworkPipeTransportAdapter(); |
| 136 | |
| 137 | bool SendRtp(const uint8_t* packet, |
| 138 | size_t length, |
| 139 | const PacketOptions& options) override; |
| 140 | bool SendRtcp(const uint8_t* packet, size_t length) override; |
| 141 | |
| 142 | private: |
| 143 | FakeNetworkPipeOnTaskQueue* const network_pipe_; |
| 144 | Call* const call_; |
| 145 | Clock* const clock_; |
| 146 | Transport* const real_transport_; |
| 147 | }; |
| 148 | |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 149 | Clock* const clock_; |
| 150 | const std::unique_ptr<Call> call_; |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 151 | TaskQueueFactory* const task_queue_factory_; |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 152 | |
Piotr (Peter) Slatala | 7fbfaa4 | 2019-03-18 10:31:54 -0700 | [diff] [blame] | 153 | void SetClientBitratePreferences( |
| 154 | const webrtc::BitrateSettings& preferences) override {} |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 155 | |
Artem Titov | 75e3647 | 2018-10-08 12:28:56 +0200 | [diff] [blame] | 156 | const absl::optional<BuiltInNetworkBehaviorConfig> send_config_; |
Artem Titov | 3229d65 | 2018-08-17 13:00:54 +0200 | [diff] [blame] | 157 | SimulatedNetwork* send_simulated_network_; |
Erik Språng | c648819 | 2019-08-06 15:54:23 +0200 | [diff] [blame] | 158 | std::unique_ptr<FakeNetworkPipeOnTaskQueue> send_pipe_; |
Erik Språng | eea605d | 2019-08-12 15:56:51 +0200 | [diff] [blame] | 159 | std::map<AudioSendStream*, std::unique_ptr<FakeNetworkPipeTransportAdapter>> |
| 160 | audio_send_transport_adapters_; |
| 161 | std::map<VideoSendStream*, std::unique_ptr<FakeNetworkPipeTransportAdapter>> |
| 162 | video_send_transport_adapters_; |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 163 | |
Artem Titov | 75e3647 | 2018-10-08 12:28:56 +0200 | [diff] [blame] | 164 | const absl::optional<BuiltInNetworkBehaviorConfig> receive_config_; |
Artem Titov | 3229d65 | 2018-08-17 13:00:54 +0200 | [diff] [blame] | 165 | SimulatedNetwork* receive_simulated_network_; |
Erik Språng | 0970851 | 2018-03-14 15:16:50 +0100 | [diff] [blame] | 166 | std::unique_ptr<FakeNetworkPipe> receive_pipe_; |
| 167 | }; |
| 168 | |
| 169 | } // namespace webrtc |
| 170 | |
| 171 | #endif // CALL_DEGRADED_CALL_H_ |