minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2016 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 | #include "modules/audio_coding/audio_network_adaptor/audio_network_adaptor_impl.h" |
minyue | 161b390 | 2016-09-22 14:16:55 -0700 | [diff] [blame] | 12 | |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 13 | #include <stdint.h> |
Jonas Olsson | a4d8737 | 2019-07-05 19:08:33 +0200 | [diff] [blame^] | 14 | |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 15 | #include <utility> |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 16 | #include <vector> |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 17 | |
Yves Gerey | 988cc08 | 2018-10-23 12:03:01 +0200 | [diff] [blame] | 18 | #include "modules/audio_coding/audio_network_adaptor/controller_manager.h" |
| 19 | #include "modules/audio_coding/audio_network_adaptor/debug_dump_writer.h" |
| 20 | #include "modules/audio_coding/audio_network_adaptor/event_log_writer.h" |
| 21 | #include "rtc_base/checks.h" |
Steve Anton | 10542f2 | 2019-01-11 09:11:00 -0800 | [diff] [blame] | 22 | #include "rtc_base/time_utils.h" |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 23 | #include "system_wrappers/include/field_trial.h" |
minyue | 4b7c952 | 2017-01-24 04:54:59 -0800 | [diff] [blame] | 24 | |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 25 | namespace webrtc { |
| 26 | |
minyue | 4b7c952 | 2017-01-24 04:54:59 -0800 | [diff] [blame] | 27 | namespace { |
| 28 | constexpr int kEventLogMinBitrateChangeBps = 5000; |
| 29 | constexpr float kEventLogMinBitrateChangeFraction = 0.25; |
| 30 | constexpr float kEventLogMinPacketLossChangeFraction = 0.5; |
| 31 | } // namespace |
| 32 | |
Nico Weber | 22f9925 | 2019-02-20 10:13:16 -0500 | [diff] [blame] | 33 | AudioNetworkAdaptorImpl::Config::Config() : event_log(nullptr) {} |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 34 | |
| 35 | AudioNetworkAdaptorImpl::Config::~Config() = default; |
| 36 | |
| 37 | AudioNetworkAdaptorImpl::AudioNetworkAdaptorImpl( |
| 38 | const Config& config, |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 39 | std::unique_ptr<ControllerManager> controller_manager, |
| 40 | std::unique_ptr<DebugDumpWriter> debug_dump_writer) |
| 41 | : config_(config), |
| 42 | controller_manager_(std::move(controller_manager)), |
minyue | 4b7c952 | 2017-01-24 04:54:59 -0800 | [diff] [blame] | 43 | debug_dump_writer_(std::move(debug_dump_writer)), |
| 44 | event_log_writer_( |
| 45 | config.event_log |
| 46 | ? new EventLogWriter(config.event_log, |
| 47 | kEventLogMinBitrateChangeBps, |
| 48 | kEventLogMinBitrateChangeFraction, |
| 49 | kEventLogMinPacketLossChangeFraction) |
Minyue Li | f40150d | 2018-11-21 21:39:54 +0100 | [diff] [blame] | 50 | : nullptr) { |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 51 | RTC_DCHECK(controller_manager_); |
| 52 | } |
| 53 | |
| 54 | AudioNetworkAdaptorImpl::~AudioNetworkAdaptorImpl() = default; |
| 55 | |
| 56 | void AudioNetworkAdaptorImpl::SetUplinkBandwidth(int uplink_bandwidth_bps) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 57 | last_metrics_.uplink_bandwidth_bps = uplink_bandwidth_bps; |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 58 | DumpNetworkMetrics(); |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 59 | |
| 60 | Controller::NetworkMetrics network_metrics; |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 61 | network_metrics.uplink_bandwidth_bps = uplink_bandwidth_bps; |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 62 | UpdateNetworkMetrics(network_metrics); |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 63 | } |
| 64 | |
| 65 | void AudioNetworkAdaptorImpl::SetUplinkPacketLossFraction( |
| 66 | float uplink_packet_loss_fraction) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 67 | last_metrics_.uplink_packet_loss_fraction = uplink_packet_loss_fraction; |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 68 | DumpNetworkMetrics(); |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 69 | |
| 70 | Controller::NetworkMetrics network_metrics; |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 71 | network_metrics.uplink_packet_loss_fraction = uplink_packet_loss_fraction; |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 72 | UpdateNetworkMetrics(network_metrics); |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 73 | } |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 74 | |
elad.alon | dadb4dc | 2017-03-23 15:29:50 -0700 | [diff] [blame] | 75 | void AudioNetworkAdaptorImpl::SetUplinkRecoverablePacketLossFraction( |
| 76 | float uplink_recoverable_packet_loss_fraction) { |
| 77 | last_metrics_.uplink_recoverable_packet_loss_fraction = |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 78 | uplink_recoverable_packet_loss_fraction; |
elad.alon | dadb4dc | 2017-03-23 15:29:50 -0700 | [diff] [blame] | 79 | DumpNetworkMetrics(); |
| 80 | |
| 81 | Controller::NetworkMetrics network_metrics; |
| 82 | network_metrics.uplink_recoverable_packet_loss_fraction = |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 83 | uplink_recoverable_packet_loss_fraction; |
elad.alon | dadb4dc | 2017-03-23 15:29:50 -0700 | [diff] [blame] | 84 | UpdateNetworkMetrics(network_metrics); |
| 85 | } |
| 86 | |
minyue | c9e80ee | 2016-11-29 13:00:28 -0800 | [diff] [blame] | 87 | void AudioNetworkAdaptorImpl::SetRtt(int rtt_ms) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 88 | last_metrics_.rtt_ms = rtt_ms; |
minyue | c9e80ee | 2016-11-29 13:00:28 -0800 | [diff] [blame] | 89 | DumpNetworkMetrics(); |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 90 | |
| 91 | Controller::NetworkMetrics network_metrics; |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 92 | network_metrics.rtt_ms = rtt_ms; |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 93 | UpdateNetworkMetrics(network_metrics); |
minyue | c9e80ee | 2016-11-29 13:00:28 -0800 | [diff] [blame] | 94 | } |
| 95 | |
minyue | e5e632f | 2016-09-27 12:54:19 -0700 | [diff] [blame] | 96 | void AudioNetworkAdaptorImpl::SetTargetAudioBitrate( |
| 97 | int target_audio_bitrate_bps) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 98 | last_metrics_.target_audio_bitrate_bps = target_audio_bitrate_bps; |
minyue | e5e632f | 2016-09-27 12:54:19 -0700 | [diff] [blame] | 99 | DumpNetworkMetrics(); |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 100 | |
| 101 | Controller::NetworkMetrics network_metrics; |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 102 | network_metrics.target_audio_bitrate_bps = target_audio_bitrate_bps; |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 103 | UpdateNetworkMetrics(network_metrics); |
minyue | e5e632f | 2016-09-27 12:54:19 -0700 | [diff] [blame] | 104 | } |
| 105 | |
minyue | c9e80ee | 2016-11-29 13:00:28 -0800 | [diff] [blame] | 106 | void AudioNetworkAdaptorImpl::SetOverhead(size_t overhead_bytes_per_packet) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 107 | last_metrics_.overhead_bytes_per_packet = overhead_bytes_per_packet; |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 108 | DumpNetworkMetrics(); |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 109 | |
| 110 | Controller::NetworkMetrics network_metrics; |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 111 | network_metrics.overhead_bytes_per_packet = overhead_bytes_per_packet; |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 112 | UpdateNetworkMetrics(network_metrics); |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 113 | } |
| 114 | |
michaelt | cde46b7 | 2017-04-06 05:59:10 -0700 | [diff] [blame] | 115 | AudioEncoderRuntimeConfig AudioNetworkAdaptorImpl::GetEncoderRuntimeConfig() { |
| 116 | AudioEncoderRuntimeConfig config; |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 117 | for (auto& controller : |
| 118 | controller_manager_->GetSortedControllers(last_metrics_)) |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 119 | controller->MakeDecision(&config); |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 120 | |
ivoc | 1728909 | 2017-09-09 08:45:40 -0700 | [diff] [blame] | 121 | // Update ANA stats. |
Danil Chapovalov | b602123 | 2018-06-19 13:26:36 +0200 | [diff] [blame] | 122 | auto increment_opt = [](absl::optional<uint32_t>& a) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 123 | a = a.value_or(0) + 1; |
ivoc | 1728909 | 2017-09-09 08:45:40 -0700 | [diff] [blame] | 124 | }; |
| 125 | if (prev_config_) { |
| 126 | if (config.bitrate_bps != prev_config_->bitrate_bps) { |
| 127 | increment_opt(stats_.bitrate_action_counter); |
| 128 | } |
| 129 | if (config.enable_dtx != prev_config_->enable_dtx) { |
| 130 | increment_opt(stats_.dtx_action_counter); |
| 131 | } |
| 132 | if (config.enable_fec != prev_config_->enable_fec) { |
| 133 | increment_opt(stats_.fec_action_counter); |
| 134 | } |
| 135 | if (config.frame_length_ms && prev_config_->frame_length_ms) { |
| 136 | if (*config.frame_length_ms > *prev_config_->frame_length_ms) { |
| 137 | increment_opt(stats_.frame_length_increase_counter); |
| 138 | } else if (*config.frame_length_ms < *prev_config_->frame_length_ms) { |
| 139 | increment_opt(stats_.frame_length_decrease_counter); |
| 140 | } |
| 141 | } |
| 142 | if (config.num_channels != prev_config_->num_channels) { |
| 143 | increment_opt(stats_.channel_action_counter); |
| 144 | } |
| 145 | if (config.uplink_packet_loss_fraction) { |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 146 | stats_.uplink_packet_loss_fraction = *config.uplink_packet_loss_fraction; |
ivoc | 1728909 | 2017-09-09 08:45:40 -0700 | [diff] [blame] | 147 | } |
| 148 | } |
Oskar Sundbom | 12ab00b | 2017-11-16 15:31:38 +0100 | [diff] [blame] | 149 | prev_config_ = config; |
ivoc | 1728909 | 2017-09-09 08:45:40 -0700 | [diff] [blame] | 150 | |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 151 | if (debug_dump_writer_) |
michaelt | 92aef17 | 2017-04-18 00:11:48 -0700 | [diff] [blame] | 152 | debug_dump_writer_->DumpEncoderRuntimeConfig(config, rtc::TimeMillis()); |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 153 | |
minyue | 4b7c952 | 2017-01-24 04:54:59 -0800 | [diff] [blame] | 154 | if (event_log_writer_) |
| 155 | event_log_writer_->MaybeLogEncoderConfig(config); |
| 156 | |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 157 | return config; |
| 158 | } |
| 159 | |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 160 | void AudioNetworkAdaptorImpl::StartDebugDump(FILE* file_handle) { |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 161 | debug_dump_writer_ = DebugDumpWriter::Create(file_handle); |
| 162 | } |
| 163 | |
| 164 | void AudioNetworkAdaptorImpl::StopDebugDump() { |
| 165 | debug_dump_writer_.reset(nullptr); |
| 166 | } |
| 167 | |
ivoc | e1198e0 | 2017-09-08 08:13:19 -0700 | [diff] [blame] | 168 | ANAStats AudioNetworkAdaptorImpl::GetStats() const { |
ivoc | 1728909 | 2017-09-09 08:45:40 -0700 | [diff] [blame] | 169 | return stats_; |
ivoc | e1198e0 | 2017-09-08 08:13:19 -0700 | [diff] [blame] | 170 | } |
| 171 | |
minyue | 25f6a39 | 2016-09-22 22:23:20 -0700 | [diff] [blame] | 172 | void AudioNetworkAdaptorImpl::DumpNetworkMetrics() { |
| 173 | if (debug_dump_writer_) |
michaelt | 92aef17 | 2017-04-18 00:11:48 -0700 | [diff] [blame] | 174 | debug_dump_writer_->DumpNetworkMetrics(last_metrics_, rtc::TimeMillis()); |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 175 | } |
| 176 | |
minyue | a6a6d65 | 2017-01-30 10:50:00 -0800 | [diff] [blame] | 177 | void AudioNetworkAdaptorImpl::UpdateNetworkMetrics( |
| 178 | const Controller::NetworkMetrics& network_metrics) { |
| 179 | for (auto& controller : controller_manager_->GetControllers()) |
| 180 | controller->UpdateNetworkMetrics(network_metrics); |
| 181 | } |
| 182 | |
minyue | caa9cb2 | 2016-09-13 13:34:15 -0700 | [diff] [blame] | 183 | } // namespace webrtc |