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