blob: fe4b0dc460e61bf89b5945fc899cf51db176ee80 [file] [log] [blame]
niklase@google.com470e71d2011-07-07 08:21:25 +00001/*
andrew@webrtc.org648af742012-02-08 01:57:29 +00002 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
niklase@google.com470e71d2011-07-07 08:21:25 +00003 *
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 Bonadei92ea95e2017-09-15 06:47:31 +020011#ifndef MODULES_AUDIO_PROCESSING_INCLUDE_AUDIO_PROCESSING_H_
12#define MODULES_AUDIO_PROCESSING_INCLUDE_AUDIO_PROCESSING_H_
niklase@google.com470e71d2011-07-07 08:21:25 +000013
Alejandro Luebscb3f9bd2015-10-29 18:21:34 -070014// MSVC++ requires this to be set before any other includes to get M_PI.
Patrik Höglund3ff90f12017-12-12 14:41:53 +010015#ifndef _USE_MATH_DEFINES
Alejandro Luebscb3f9bd2015-10-29 18:21:34 -070016#define _USE_MATH_DEFINES
Patrik Höglund3ff90f12017-12-12 14:41:53 +010017#endif
Alejandro Luebscb3f9bd2015-10-29 18:21:34 -070018
19#include <math.h>
andrew@webrtc.orgd72b3d62012-11-15 21:46:06 +000020#include <stddef.h> // size_t
Yves Gerey665174f2018-06-19 15:03:05 +020021#include <stdio.h> // FILE
peah8cee56f2017-08-24 22:36:53 -070022#include <string.h>
Jonas Olssona4d87372019-07-05 19:08:33 +020023
aluebs@webrtc.orgfb7a0392015-01-05 21:58:58 +000024#include <vector>
ajm@google.com22e65152011-07-18 18:03:01 +000025
Danil Chapovalovdb9f7ab2018-06-19 10:50:11 +020026#include "absl/types/optional.h"
Gustaf Ullbergbffa3002018-02-14 15:12:00 +010027#include "api/audio/echo_canceller3_config.h"
Gustaf Ullbergfd4ce502018-02-15 10:09:09 +010028#include "api/audio/echo_control.h"
Mirko Bonadeid9708072019-01-25 20:26:48 +010029#include "api/scoped_refptr.h"
Sam Zackrisson4d364492018-03-02 16:03:21 +010030#include "modules/audio_processing/include/audio_generator.h"
Ivo Creusen56d46092017-11-24 17:29:59 +010031#include "modules/audio_processing/include/audio_processing_statistics.h"
Mirko Bonadei92ea95e2017-09-15 06:47:31 +020032#include "modules/audio_processing/include/config.h"
33#include "rtc_base/arraysize.h"
Sam Zackrisson0beac582017-09-25 12:04:02 +020034#include "rtc_base/deprecation.h"
Steve Anton10542f22019-01-11 09:11:00 -080035#include "rtc_base/ref_count.h"
Mirko Bonadei3d255302018-10-11 10:50:45 +020036#include "rtc_base/system/rtc_export.h"
niklase@google.com470e71d2011-07-07 08:21:25 +000037
38namespace webrtc {
39
aleloi868f32f2017-05-23 07:20:05 -070040class AecDump;
Sam Zackrisson0beac582017-09-25 12:04:02 +020041class AudioBuffer;
niklase@google.com470e71d2011-07-07 08:21:25 +000042class AudioFrame;
Michael Graczykdfa36052015-03-25 16:37:27 -070043
Michael Graczyk86c6d332015-07-23 11:41:39 -070044class StreamConfig;
45class ProcessingConfig;
46
Ivo Creusen09fa4b02018-01-11 16:08:54 +010047class EchoDetector;
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +020048class CustomAudioAnalyzer;
Alex Loiko5825aa62017-12-18 16:02:40 +010049class CustomProcessing;
niklase@google.com470e71d2011-07-07 08:21:25 +000050
Bjorn Volckeradc46c42015-04-15 11:42:40 +020051// Use to enable experimental gain control (AGC). At startup the experimental
52// AGC moves the microphone volume up to |startup_min_volume| if the current
53// microphone volume is set too low. The value is clamped to its operating range
54// [12, 255]. Here, 255 maps to 100%.
55//
Ivo Creusen62337e52018-01-09 14:17:33 +010056// Must be provided through AudioProcessingBuilder().Create(config).
Bjorn Volckerfb494512015-04-22 06:39:58 +020057#if defined(WEBRTC_CHROMIUM_BUILD)
Bjorn Volckeradc46c42015-04-15 11:42:40 +020058static const int kAgcStartupMinVolume = 85;
Bjorn Volckerfb494512015-04-22 06:39:58 +020059#else
60static const int kAgcStartupMinVolume = 0;
61#endif // defined(WEBRTC_CHROMIUM_BUILD)
Henrik Lundine3a4da92017-11-06 11:42:21 +010062static constexpr int kClippedLevelMin = 70;
andrew@webrtc.orgc7c7a532014-01-29 04:57:25 +000063struct ExperimentalAgc {
henrik.lundinbd681b92016-12-05 09:08:42 -080064 ExperimentalAgc() = default;
65 explicit ExperimentalAgc(bool enabled) : enabled(enabled) {}
Alex Loiko64cb83b2018-07-02 13:38:19 +020066 ExperimentalAgc(bool enabled,
67 bool enabled_agc2_level_estimator,
Per Åhgrenb8c1be52019-11-07 20:35:50 +010068 bool digital_adaptive_disabled)
69 : enabled(enabled),
70 enabled_agc2_level_estimator(enabled_agc2_level_estimator),
71 digital_adaptive_disabled(digital_adaptive_disabled) {}
72 // Deprecated constructor: will be removed.
73 ExperimentalAgc(bool enabled,
74 bool enabled_agc2_level_estimator,
Alex Loikod9342442018-09-10 13:59:41 +020075 bool digital_adaptive_disabled,
76 bool analyze_before_aec)
Alex Loiko64cb83b2018-07-02 13:38:19 +020077 : enabled(enabled),
78 enabled_agc2_level_estimator(enabled_agc2_level_estimator),
Per Åhgrenb8c1be52019-11-07 20:35:50 +010079 digital_adaptive_disabled(digital_adaptive_disabled) {}
Bjorn Volckeradc46c42015-04-15 11:42:40 +020080 ExperimentalAgc(bool enabled, int startup_min_volume)
81 : enabled(enabled), startup_min_volume(startup_min_volume) {}
henrik.lundinbd681b92016-12-05 09:08:42 -080082 ExperimentalAgc(bool enabled, int startup_min_volume, int clipped_level_min)
83 : enabled(enabled),
84 startup_min_volume(startup_min_volume),
85 clipped_level_min(clipped_level_min) {}
aluebs688e3082016-01-14 04:32:46 -080086 static const ConfigOptionID identifier = ConfigOptionID::kExperimentalAgc;
henrik.lundinbd681b92016-12-05 09:08:42 -080087 bool enabled = true;
88 int startup_min_volume = kAgcStartupMinVolume;
89 // Lowest microphone level that will be applied in response to clipping.
90 int clipped_level_min = kClippedLevelMin;
Alex Loiko64cb83b2018-07-02 13:38:19 +020091 bool enabled_agc2_level_estimator = false;
Alex Loiko9489c3a2018-08-09 15:04:24 +020092 bool digital_adaptive_disabled = false;
andrew@webrtc.org6b1e2192013-09-25 23:46:20 +000093};
94
Per Åhgrenc0734712020-01-02 15:15:36 +010095// To be deprecated: Please instead use the flag in the
96// AudioProcessing::Config::TransientSuppression.
97//
aluebs@webrtc.org9825afc2014-06-30 17:39:53 +000098// Use to enable experimental noise suppression. It can be set in the
99// constructor or using AudioProcessing::SetExtraOptions().
Per Åhgrenc0734712020-01-02 15:15:36 +0100100// TODO(webrtc:5298): Remove.
aluebs@webrtc.org9825afc2014-06-30 17:39:53 +0000101struct ExperimentalNs {
102 ExperimentalNs() : enabled(false) {}
103 explicit ExperimentalNs(bool enabled) : enabled(enabled) {}
aluebs688e3082016-01-14 04:32:46 -0800104 static const ConfigOptionID identifier = ConfigOptionID::kExperimentalNs;
aluebs@webrtc.org9825afc2014-06-30 17:39:53 +0000105 bool enabled;
106};
107
niklase@google.com470e71d2011-07-07 08:21:25 +0000108// The Audio Processing Module (APM) provides a collection of voice processing
109// components designed for real-time communications software.
110//
111// APM operates on two audio streams on a frame-by-frame basis. Frames of the
112// primary stream, on which all processing is applied, are passed to
aluebsb0319552016-03-17 20:39:53 -0700113// |ProcessStream()|. Frames of the reverse direction stream are passed to
114// |ProcessReverseStream()|. On the client-side, this will typically be the
115// near-end (capture) and far-end (render) streams, respectively. APM should be
116// placed in the signal chain as close to the audio hardware abstraction layer
117// (HAL) as possible.
niklase@google.com470e71d2011-07-07 08:21:25 +0000118//
119// On the server-side, the reverse stream will normally not be used, with
120// processing occurring on each incoming stream.
121//
122// Component interfaces follow a similar pattern and are accessed through
123// corresponding getters in APM. All components are disabled at create-time,
124// with default settings that are recommended for most situations. New settings
125// can be applied without enabling a component. Enabling a component triggers
126// memory allocation and initialization to allow it to start processing the
127// streams.
128//
129// Thread safety is provided with the following assumptions to reduce locking
130// overhead:
131// 1. The stream getters and setters are called from the same thread as
132// ProcessStream(). More precisely, stream functions are never called
133// concurrently with ProcessStream().
134// 2. Parameter getters are never called concurrently with the corresponding
135// setter.
136//
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000137// APM accepts only linear PCM audio data in chunks of 10 ms. The int16
138// interfaces use interleaved data, while the float interfaces use deinterleaved
139// data.
niklase@google.com470e71d2011-07-07 08:21:25 +0000140//
141// Usage example, omitting error checking:
Ivo Creusen62337e52018-01-09 14:17:33 +0100142// AudioProcessing* apm = AudioProcessingBuilder().Create();
niklase@google.com470e71d2011-07-07 08:21:25 +0000143//
peah88ac8532016-09-12 16:47:25 -0700144// AudioProcessing::Config config;
Sam Zackrissoncdf0e6d2018-09-17 11:05:17 +0200145// config.echo_canceller.enabled = true;
146// config.echo_canceller.mobile_mode = false;
Sam Zackrisson41478c72019-10-15 10:10:26 +0200147//
148// config.gain_controller1.enabled = true;
149// config.gain_controller1.mode =
150// AudioProcessing::Config::GainController1::kAdaptiveAnalog;
151// config.gain_controller1.analog_level_minimum = 0;
152// config.gain_controller1.analog_level_maximum = 255;
153//
Sam Zackrissonab1aee02018-03-05 15:59:06 +0100154// config.gain_controller2.enabled = true;
Sam Zackrisson41478c72019-10-15 10:10:26 +0200155//
156// config.high_pass_filter.enabled = true;
157//
158// config.voice_detection.enabled = true;
159//
peah88ac8532016-09-12 16:47:25 -0700160// apm->ApplyConfig(config)
161//
niklase@google.com470e71d2011-07-07 08:21:25 +0000162// apm->noise_reduction()->set_level(kHighSuppression);
163// apm->noise_reduction()->Enable(true);
164//
niklase@google.com470e71d2011-07-07 08:21:25 +0000165// // Start a voice call...
166//
167// // ... Render frame arrives bound for the audio HAL ...
aluebsb0319552016-03-17 20:39:53 -0700168// apm->ProcessReverseStream(render_frame);
niklase@google.com470e71d2011-07-07 08:21:25 +0000169//
170// // ... Capture frame arrives from the audio HAL ...
171// // Call required set_stream_ functions.
172// apm->set_stream_delay_ms(delay_ms);
Sam Zackrisson41478c72019-10-15 10:10:26 +0200173// apm->set_stream_analog_level(analog_level);
niklase@google.com470e71d2011-07-07 08:21:25 +0000174//
175// apm->ProcessStream(capture_frame);
176//
177// // Call required stream_ functions.
Sam Zackrisson41478c72019-10-15 10:10:26 +0200178// analog_level = apm->recommended_stream_analog_level();
niklase@google.com470e71d2011-07-07 08:21:25 +0000179// has_voice = apm->stream_has_voice();
180//
181// // Repeate render and capture processing for the duration of the call...
182// // Start a new call...
183// apm->Initialize();
184//
185// // Close the application...
andrew@webrtc.orgf3930e92013-09-18 22:37:32 +0000186// delete apm;
niklase@google.com470e71d2011-07-07 08:21:25 +0000187//
Mirko Bonadei35214fc2019-09-23 14:54:28 +0200188class RTC_EXPORT AudioProcessing : public rtc::RefCountInterface {
niklase@google.com470e71d2011-07-07 08:21:25 +0000189 public:
peah88ac8532016-09-12 16:47:25 -0700190 // The struct below constitutes the new parameter scheme for the audio
191 // processing. It is being introduced gradually and until it is fully
192 // introduced, it is prone to change.
193 // TODO(peah): Remove this comment once the new config scheme is fully rolled
194 // out.
195 //
196 // The parameters and behavior of the audio processing module are controlled
197 // by changing the default values in the AudioProcessing::Config struct.
198 // The config is applied by passing the struct to the ApplyConfig method.
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100199 //
200 // This config is intended to be used during setup, and to enable/disable
201 // top-level processing effects. Use during processing may cause undesired
202 // submodule resets, affecting the audio quality. Use the RuntimeSetting
203 // construct for runtime configuration.
Mirko Bonadeid4002a72019-11-12 20:11:48 +0100204 struct RTC_EXPORT Config {
Per Åhgren25126042019-12-05 07:32:32 +0100205
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200206 // Sets the properties of the audio processing pipeline.
Mirko Bonadeid4002a72019-11-12 20:11:48 +0100207 struct RTC_EXPORT Pipeline {
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200208 Pipeline();
209
210 // Maximum allowed processing rate used internally. May only be set to
211 // 32000 or 48000 and any differing values will be treated as 48000. The
212 // default rate is currently selected based on the CPU architecture, but
213 // that logic may change.
214 int maximum_internal_processing_rate;
Per Åhgrene14cb992019-11-27 09:34:22 +0100215 // Allow multi-channel processing of render audio.
216 bool multi_channel_render = false;
217 // Allow multi-channel processing of capture audio when AEC3 is active
218 // or a custom AEC is injected..
219 bool multi_channel_capture = false;
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200220 } pipeline;
221
Sam Zackrisson23513132019-01-11 15:10:32 +0100222 // Enabled the pre-amplifier. It amplifies the capture signal
223 // before any other processing is done.
224 struct PreAmplifier {
225 bool enabled = false;
226 float fixed_gain_factor = 1.f;
227 } pre_amplifier;
228
229 struct HighPassFilter {
230 bool enabled = false;
Per Åhgrenc0424252019-12-10 13:04:15 +0100231 bool apply_in_full_band = true;
Sam Zackrisson23513132019-01-11 15:10:32 +0100232 } high_pass_filter;
233
Sam Zackrisson8b5d2cc2018-07-27 13:27:23 +0200234 struct EchoCanceller {
235 bool enabled = false;
236 bool mobile_mode = false;
Per Åhgrenc20a19c2019-11-13 11:12:29 +0100237 bool export_linear_aec_output = false;
Per Åhgrenb8106462019-12-04 08:34:12 +0100238 // Enforce the highpass filter to be on (has no effect for the mobile
239 // mode).
Per Åhgrenbcce4532019-12-03 13:52:40 +0100240 bool enforce_high_pass_filtering = true;
Sam Zackrisson8b5d2cc2018-07-27 13:27:23 +0200241 } echo_canceller;
242
Sam Zackrisson23513132019-01-11 15:10:32 +0100243 // Enables background noise suppression.
244 struct NoiseSuppression {
peah8271d042016-11-22 07:24:52 -0800245 bool enabled = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100246 enum Level { kLow, kModerate, kHigh, kVeryHigh };
247 Level level = kModerate;
Per Åhgren2e8e1c62019-12-20 00:42:22 +0100248 bool analyze_linear_aec_output_when_available = false;
Per Åhgren0cbb58e2019-10-29 22:59:44 +0100249 // Recommended not to use. Will be removed in the future.
250 bool use_legacy_ns = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100251 } noise_suppression;
peahe0eae3c2016-12-14 01:16:23 -0800252
Per Åhgrenc0734712020-01-02 15:15:36 +0100253 // Enables transient suppression.
254 struct TransientSuppression {
255 bool enabled = false;
256 } transient_suppression;
257
Sam Zackrisson0824c6f2019-10-07 14:03:56 +0200258 // Enables reporting of |voice_detected| in webrtc::AudioProcessingStats.
259 // In addition to |voice_detected|, VAD decision is provided through the
260 // |AudioFrame| passed to |ProcessStream()|. The |vad_activity_| member will
261 // be modified to reflect the current decision.
Sam Zackrisson23513132019-01-11 15:10:32 +0100262 struct VoiceDetection {
Alex Loiko5feb30e2018-04-16 13:52:32 +0200263 bool enabled = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100264 } voice_detection;
Alex Loiko5feb30e2018-04-16 13:52:32 +0200265
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100266 // Enables automatic gain control (AGC) functionality.
267 // The automatic gain control (AGC) component brings the signal to an
268 // appropriate range. This is done by applying a digital gain directly and,
269 // in the analog mode, prescribing an analog gain to be applied at the audio
270 // HAL.
271 // Recommended to be enabled on the client-side.
272 struct GainController1 {
273 bool enabled = false;
274 enum Mode {
275 // Adaptive mode intended for use if an analog volume control is
276 // available on the capture device. It will require the user to provide
277 // coupling between the OS mixer controls and AGC through the
278 // stream_analog_level() functions.
279 // It consists of an analog gain prescription for the audio device and a
280 // digital compression stage.
281 kAdaptiveAnalog,
282 // Adaptive mode intended for situations in which an analog volume
283 // control is unavailable. It operates in a similar fashion to the
284 // adaptive analog mode, but with scaling instead applied in the digital
285 // domain. As with the analog mode, it additionally uses a digital
286 // compression stage.
287 kAdaptiveDigital,
288 // Fixed mode which enables only the digital compression stage also used
289 // by the two adaptive modes.
290 // It is distinguished from the adaptive modes by considering only a
291 // short time-window of the input signal. It applies a fixed gain
292 // through most of the input level range, and compresses (gradually
293 // reduces gain with increasing level) the input signal at higher
294 // levels. This mode is preferred on embedded devices where the capture
295 // signal level is predictable, so that a known gain can be applied.
296 kFixedDigital
297 };
298 Mode mode = kAdaptiveAnalog;
299 // Sets the target peak level (or envelope) of the AGC in dBFs (decibels
300 // from digital full-scale). The convention is to use positive values. For
301 // instance, passing in a value of 3 corresponds to -3 dBFs, or a target
302 // level 3 dB below full-scale. Limited to [0, 31].
303 int target_level_dbfs = 3;
304 // Sets the maximum gain the digital compression stage may apply, in dB. A
305 // higher number corresponds to greater compression, while a value of 0
306 // will leave the signal uncompressed. Limited to [0, 90].
307 // For updates after APM setup, use a RuntimeSetting instead.
308 int compression_gain_db = 9;
309 // When enabled, the compression stage will hard limit the signal to the
310 // target level. Otherwise, the signal will be compressed but not limited
311 // above the target level.
312 bool enable_limiter = true;
313 // Sets the minimum and maximum analog levels of the audio capture device.
314 // Must be set if an analog mode is used. Limited to [0, 65535].
315 int analog_level_minimum = 0;
316 int analog_level_maximum = 255;
317 } gain_controller1;
318
Alex Loikoe5831742018-08-24 11:28:36 +0200319 // Enables the next generation AGC functionality. This feature replaces the
320 // standard methods of gain control in the previous AGC. Enabling this
321 // submodule enables an adaptive digital AGC followed by a limiter. By
322 // setting |fixed_gain_db|, the limiter can be turned into a compressor that
323 // first applies a fixed gain. The adaptive digital AGC can be turned off by
324 // setting |adaptive_digital_mode=false|.
alessiob3ec96df2017-05-22 06:57:06 -0700325 struct GainController2 {
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100326 enum LevelEstimator { kRms, kPeak };
alessiob3ec96df2017-05-22 06:57:06 -0700327 bool enabled = false;
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100328 struct {
329 float gain_db = 0.f;
330 } fixed_digital;
331 struct {
Alessio Bazzica8da7b352018-11-21 10:50:58 +0100332 bool enabled = false;
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100333 LevelEstimator level_estimator = kRms;
334 bool use_saturation_protector = true;
335 float extra_saturation_margin_db = 2.f;
336 } adaptive_digital;
alessiob3ec96df2017-05-22 06:57:06 -0700337 } gain_controller2;
peah8cee56f2017-08-24 22:36:53 -0700338
Sam Zackrisson23513132019-01-11 15:10:32 +0100339 struct ResidualEchoDetector {
340 bool enabled = true;
341 } residual_echo_detector;
342
Sam Zackrissonb24c00f2018-11-26 16:18:25 +0100343 // Enables reporting of |output_rms_dbfs| in webrtc::AudioProcessingStats.
344 struct LevelEstimation {
345 bool enabled = false;
346 } level_estimation;
347
Artem Titov59bbd652019-08-02 11:31:37 +0200348 std::string ToString() const;
peah88ac8532016-09-12 16:47:25 -0700349 };
350
Michael Graczyk86c6d332015-07-23 11:41:39 -0700351 // TODO(mgraczyk): Remove once all methods that use ChannelLayout are gone.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000352 enum ChannelLayout {
353 kMono,
354 // Left, right.
355 kStereo,
peah88ac8532016-09-12 16:47:25 -0700356 // Mono, keyboard, and mic.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000357 kMonoAndKeyboard,
peah88ac8532016-09-12 16:47:25 -0700358 // Left, right, keyboard, and mic.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000359 kStereoAndKeyboard
360 };
361
Alessio Bazzicac054e782018-04-16 12:10:09 +0200362 // Specifies the properties of a setting to be passed to AudioProcessing at
363 // runtime.
364 class RuntimeSetting {
365 public:
Alex Loiko73ec0192018-05-15 10:52:28 +0200366 enum class Type {
367 kNotSpecified,
368 kCapturePreGain,
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100369 kCaptureCompressionGain,
Per Åhgren6ee75fd2019-04-26 11:33:37 +0200370 kCaptureFixedPostGain,
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200371 kPlayoutVolumeChange,
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100372 kCustomRenderProcessingRuntimeSetting,
373 kPlayoutAudioDeviceChange
374 };
375
376 // Play-out audio device properties.
377 struct PlayoutAudioDeviceInfo {
378 int id; // Identifies the audio device.
379 int max_volume; // Maximum play-out volume.
Alex Loiko73ec0192018-05-15 10:52:28 +0200380 };
Alessio Bazzicac054e782018-04-16 12:10:09 +0200381
382 RuntimeSetting() : type_(Type::kNotSpecified), value_(0.f) {}
383 ~RuntimeSetting() = default;
384
385 static RuntimeSetting CreateCapturePreGain(float gain) {
386 RTC_DCHECK_GE(gain, 1.f) << "Attenuation is not allowed.";
387 return {Type::kCapturePreGain, gain};
388 }
389
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100390 // Corresponds to Config::GainController1::compression_gain_db, but for
391 // runtime configuration.
392 static RuntimeSetting CreateCompressionGainDb(int gain_db) {
393 RTC_DCHECK_GE(gain_db, 0);
394 RTC_DCHECK_LE(gain_db, 90);
395 return {Type::kCaptureCompressionGain, static_cast<float>(gain_db)};
396 }
397
Per Åhgren6ee75fd2019-04-26 11:33:37 +0200398 // Corresponds to Config::GainController2::fixed_digital::gain_db, but for
399 // runtime configuration.
400 static RuntimeSetting CreateCaptureFixedPostGain(float gain_db) {
401 RTC_DCHECK_GE(gain_db, 0.f);
402 RTC_DCHECK_LE(gain_db, 90.f);
403 return {Type::kCaptureFixedPostGain, gain_db};
404 }
405
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100406 // Creates a runtime setting to notify play-out (aka render) audio device
407 // changes.
408 static RuntimeSetting CreatePlayoutAudioDeviceChange(
409 PlayoutAudioDeviceInfo audio_device) {
410 return {Type::kPlayoutAudioDeviceChange, audio_device};
411 }
412
413 // Creates a runtime setting to notify play-out (aka render) volume changes.
414 // |volume| is the unnormalized volume, the maximum of which
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200415 static RuntimeSetting CreatePlayoutVolumeChange(int volume) {
416 return {Type::kPlayoutVolumeChange, volume};
417 }
418
Alex Loiko73ec0192018-05-15 10:52:28 +0200419 static RuntimeSetting CreateCustomRenderSetting(float payload) {
420 return {Type::kCustomRenderProcessingRuntimeSetting, payload};
421 }
422
Alessio Bazzicac054e782018-04-16 12:10:09 +0200423 Type type() const { return type_; }
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100424 // Getters do not return a value but instead modify the argument to protect
425 // from implicit casting.
Alessio Bazzicac054e782018-04-16 12:10:09 +0200426 void GetFloat(float* value) const {
427 RTC_DCHECK(value);
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200428 *value = value_.float_value;
429 }
430 void GetInt(int* value) const {
431 RTC_DCHECK(value);
432 *value = value_.int_value;
Alessio Bazzicac054e782018-04-16 12:10:09 +0200433 }
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100434 void GetPlayoutAudioDeviceInfo(PlayoutAudioDeviceInfo* value) const {
435 RTC_DCHECK(value);
436 *value = value_.playout_audio_device_info;
437 }
Alessio Bazzicac054e782018-04-16 12:10:09 +0200438
439 private:
440 RuntimeSetting(Type id, float value) : type_(id), value_(value) {}
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200441 RuntimeSetting(Type id, int value) : type_(id), value_(value) {}
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100442 RuntimeSetting(Type id, PlayoutAudioDeviceInfo value)
443 : type_(id), value_(value) {}
Alessio Bazzicac054e782018-04-16 12:10:09 +0200444 Type type_;
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200445 union U {
446 U() {}
447 U(int value) : int_value(value) {}
448 U(float value) : float_value(value) {}
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100449 U(PlayoutAudioDeviceInfo value) : playout_audio_device_info(value) {}
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200450 float float_value;
451 int int_value;
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100452 PlayoutAudioDeviceInfo playout_audio_device_info;
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200453 } value_;
Alessio Bazzicac054e782018-04-16 12:10:09 +0200454 };
455
peaha9cc40b2017-06-29 08:32:09 -0700456 ~AudioProcessing() override {}
niklase@google.com470e71d2011-07-07 08:21:25 +0000457
niklase@google.com470e71d2011-07-07 08:21:25 +0000458 // Initializes internal states, while retaining all user settings. This
459 // should be called before beginning to process a new audio stream. However,
460 // it is not necessary to call before processing the first stream after
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000461 // creation.
462 //
463 // It is also not necessary to call if the audio parameters (sample
andrew@webrtc.org60730cf2014-01-07 17:45:09 +0000464 // rate and number of channels) have changed. Passing updated parameters
aluebsb0319552016-03-17 20:39:53 -0700465 // directly to |ProcessStream()| and |ProcessReverseStream()| is permissible.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000466 // If the parameters are known at init-time though, they may be provided.
niklase@google.com470e71d2011-07-07 08:21:25 +0000467 virtual int Initialize() = 0;
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000468
469 // The int16 interfaces require:
470 // - only |NativeRate|s be used
471 // - that the input, output and reverse rates must match
Michael Graczyk86c6d332015-07-23 11:41:39 -0700472 // - that |processing_config.output_stream()| matches
473 // |processing_config.input_stream()|.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000474 //
Michael Graczyk86c6d332015-07-23 11:41:39 -0700475 // The float interfaces accept arbitrary rates and support differing input and
476 // output layouts, but the output must have either one channel or the same
477 // number of channels as the input.
478 virtual int Initialize(const ProcessingConfig& processing_config) = 0;
479
480 // Initialize with unpacked parameters. See Initialize() above for details.
481 //
482 // TODO(mgraczyk): Remove once clients are updated to use the new interface.
peahde65ddc2016-09-16 15:02:15 -0700483 virtual int Initialize(int capture_input_sample_rate_hz,
484 int capture_output_sample_rate_hz,
485 int render_sample_rate_hz,
486 ChannelLayout capture_input_layout,
487 ChannelLayout capture_output_layout,
488 ChannelLayout render_input_layout) = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000489
peah88ac8532016-09-12 16:47:25 -0700490 // TODO(peah): This method is a temporary solution used to take control
491 // over the parameters in the audio processing module and is likely to change.
492 virtual void ApplyConfig(const Config& config) = 0;
493
andrew@webrtc.org61e596f2013-07-25 18:28:29 +0000494 // Pass down additional options which don't have explicit setters. This
495 // ensures the options are applied immediately.
peah88ac8532016-09-12 16:47:25 -0700496 virtual void SetExtraOptions(const webrtc::Config& config) = 0;
andrew@webrtc.org61e596f2013-07-25 18:28:29 +0000497
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000498 // TODO(ajm): Only intended for internal use. Make private and friend the
499 // necessary classes?
500 virtual int proc_sample_rate_hz() const = 0;
501 virtual int proc_split_sample_rate_hz() const = 0;
Peter Kasting69558702016-01-12 16:26:35 -0800502 virtual size_t num_input_channels() const = 0;
503 virtual size_t num_proc_channels() const = 0;
504 virtual size_t num_output_channels() const = 0;
505 virtual size_t num_reverse_channels() const = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000506
andrew@webrtc.org17342e52014-02-12 22:28:31 +0000507 // Set to true when the output of AudioProcessing will be muted or in some
508 // other way not used. Ideally, the captured audio would still be processed,
509 // but some components may change behavior based on this information.
510 // Default false.
511 virtual void set_output_will_be_muted(bool muted) = 0;
andrew@webrtc.org17342e52014-02-12 22:28:31 +0000512
Alessio Bazzicac054e782018-04-16 12:10:09 +0200513 // Enqueue a runtime setting.
514 virtual void SetRuntimeSetting(RuntimeSetting setting) = 0;
515
niklase@google.com470e71d2011-07-07 08:21:25 +0000516 // Processes a 10 ms |frame| of the primary audio stream. On the client-side,
517 // this is the near-end (or captured) audio.
518 //
519 // If needed for enabled functionality, any function with the set_stream_ tag
520 // must be called prior to processing the current frame. Any getter function
521 // with the stream_ tag which is needed should be called after processing.
522 //
andrew@webrtc.org63a50982012-05-02 23:56:37 +0000523 // The |sample_rate_hz_|, |num_channels_|, and |samples_per_channel_|
andrew@webrtc.org60730cf2014-01-07 17:45:09 +0000524 // members of |frame| must be valid. If changed from the previous call to this
525 // method, it will trigger an initialization.
niklase@google.com470e71d2011-07-07 08:21:25 +0000526 virtual int ProcessStream(AudioFrame* frame) = 0;
527
Michael Graczyk86c6d332015-07-23 11:41:39 -0700528 // Accepts deinterleaved float audio with the range [-1, 1]. Each element of
529 // |src| points to a channel buffer, arranged according to |input_stream|. At
530 // output, the channels will be arranged according to |output_stream| in
531 // |dest|.
532 //
533 // The output must have one channel or as many channels as the input. |src|
534 // and |dest| may use the same memory, if desired.
535 virtual int ProcessStream(const float* const* src,
536 const StreamConfig& input_config,
537 const StreamConfig& output_config,
538 float* const* dest) = 0;
539
aluebsb0319552016-03-17 20:39:53 -0700540 // Processes a 10 ms |frame| of the reverse direction audio stream. The frame
541 // may be modified. On the client-side, this is the far-end (or to be
niklase@google.com470e71d2011-07-07 08:21:25 +0000542 // rendered) audio.
543 //
aluebsb0319552016-03-17 20:39:53 -0700544 // It is necessary to provide this if echo processing is enabled, as the
niklase@google.com470e71d2011-07-07 08:21:25 +0000545 // reverse stream forms the echo reference signal. It is recommended, but not
546 // necessary, to provide if gain control is enabled. On the server-side this
547 // typically will not be used. If you're not sure what to pass in here,
548 // chances are you don't need to use it.
549 //
andrew@webrtc.org63a50982012-05-02 23:56:37 +0000550 // The |sample_rate_hz_|, |num_channels_|, and |samples_per_channel_|
aluebsda116c42016-03-17 16:43:29 -0700551 // members of |frame| must be valid.
ekmeyerson60d9b332015-08-14 10:35:55 -0700552 virtual int ProcessReverseStream(AudioFrame* frame) = 0;
553
Michael Graczyk86c6d332015-07-23 11:41:39 -0700554 // Accepts deinterleaved float audio with the range [-1, 1]. Each element of
555 // |data| points to a channel buffer, arranged according to |reverse_config|.
ekmeyerson60d9b332015-08-14 10:35:55 -0700556 virtual int ProcessReverseStream(const float* const* src,
peahde65ddc2016-09-16 15:02:15 -0700557 const StreamConfig& input_config,
558 const StreamConfig& output_config,
ekmeyerson60d9b332015-08-14 10:35:55 -0700559 float* const* dest) = 0;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700560
Gustaf Ullbergcb307262019-10-29 09:30:44 +0100561 // Accepts deinterleaved float audio with the range [-1, 1]. Each element
562 // of |data| points to a channel buffer, arranged according to
563 // |reverse_config|.
564 virtual int AnalyzeReverseStream(const float* const* data,
565 const StreamConfig& reverse_config) = 0;
566
Per Åhgrenc20a19c2019-11-13 11:12:29 +0100567 // Returns the most recently produced 10 ms of the linear AEC output at a rate
568 // of 16 kHz. If there is more than one capture channel, a mono representation
569 // of the input is returned. Returns true/false to indicate whether an output
570 // returned.
571 virtual bool GetLinearAecOutput(
572 rtc::ArrayView<std::array<float, 160>> linear_output) const = 0;
573
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100574 // This must be called prior to ProcessStream() if and only if adaptive analog
575 // gain control is enabled, to pass the current analog level from the audio
576 // HAL. Must be within the range provided in Config::GainController1.
577 virtual void set_stream_analog_level(int level) = 0;
578
579 // When an analog mode is set, this should be called after ProcessStream()
580 // to obtain the recommended new analog level for the audio HAL. It is the
581 // user's responsibility to apply this level.
582 virtual int recommended_stream_analog_level() const = 0;
583
niklase@google.com470e71d2011-07-07 08:21:25 +0000584 // This must be called if and only if echo processing is enabled.
585 //
aluebsb0319552016-03-17 20:39:53 -0700586 // Sets the |delay| in ms between ProcessReverseStream() receiving a far-end
niklase@google.com470e71d2011-07-07 08:21:25 +0000587 // frame and ProcessStream() receiving a near-end frame containing the
588 // corresponding echo. On the client-side this can be expressed as
589 // delay = (t_render - t_analyze) + (t_process - t_capture)
590 // where,
aluebsb0319552016-03-17 20:39:53 -0700591 // - t_analyze is the time a frame is passed to ProcessReverseStream() and
niklase@google.com470e71d2011-07-07 08:21:25 +0000592 // t_render is the time the first sample of the same frame is rendered by
593 // the audio hardware.
594 // - t_capture is the time the first sample of a frame is captured by the
alessiob13fc1802017-04-19 05:35:51 -0700595 // audio hardware and t_process is the time the same frame is passed to
niklase@google.com470e71d2011-07-07 08:21:25 +0000596 // ProcessStream().
597 virtual int set_stream_delay_ms(int delay) = 0;
598 virtual int stream_delay_ms() const = 0;
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000599 virtual bool was_stream_delay_set() const = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000600
andrew@webrtc.org75dd2882014-02-11 20:52:30 +0000601 // Call to signal that a key press occurred (true) or did not occur (false)
602 // with this chunk of audio.
603 virtual void set_stream_key_pressed(bool key_pressed) = 0;
andrew@webrtc.org75dd2882014-02-11 20:52:30 +0000604
andrew@webrtc.org6f9f8172012-03-06 19:03:39 +0000605 // Sets a delay |offset| in ms to add to the values passed in through
606 // set_stream_delay_ms(). May be positive or negative.
607 //
608 // Note that this could cause an otherwise valid value passed to
609 // set_stream_delay_ms() to return an error.
610 virtual void set_delay_offset_ms(int offset) = 0;
611 virtual int delay_offset_ms() const = 0;
612
aleloi868f32f2017-05-23 07:20:05 -0700613 // Attaches provided webrtc::AecDump for recording debugging
614 // information. Log file and maximum file size logic is supposed to
615 // be handled by implementing instance of AecDump. Calling this
616 // method when another AecDump is attached resets the active AecDump
617 // with a new one. This causes the d-tor of the earlier AecDump to
618 // be called. The d-tor call may block until all pending logging
619 // tasks are completed.
Alex Loikobe767e02017-06-08 09:45:03 +0200620 virtual void AttachAecDump(std::unique_ptr<AecDump> aec_dump) = 0;
aleloi868f32f2017-05-23 07:20:05 -0700621
622 // If no AecDump is attached, this has no effect. If an AecDump is
623 // attached, it's destructor is called. The d-tor may block until
624 // all pending logging tasks are completed.
Alex Loikobe767e02017-06-08 09:45:03 +0200625 virtual void DetachAecDump() = 0;
aleloi868f32f2017-05-23 07:20:05 -0700626
Sam Zackrisson4d364492018-03-02 16:03:21 +0100627 // Attaches provided webrtc::AudioGenerator for modifying playout audio.
628 // Calling this method when another AudioGenerator is attached replaces the
629 // active AudioGenerator with a new one.
630 virtual void AttachPlayoutAudioGenerator(
631 std::unique_ptr<AudioGenerator> audio_generator) = 0;
632
633 // If no AudioGenerator is attached, this has no effect. If an AecDump is
634 // attached, its destructor is called.
635 virtual void DetachPlayoutAudioGenerator() = 0;
636
Bjorn Volcker4e7aa432015-07-07 11:50:05 +0200637 // Use to send UMA histograms at end of a call. Note that all histogram
638 // specific member variables are reset.
Per Åhgrenea4c5df2019-05-03 09:00:08 +0200639 // Deprecated. This method is deprecated and will be removed.
640 // TODO(peah): Remove this method.
Bjorn Volcker4e7aa432015-07-07 11:50:05 +0200641 virtual void UpdateHistogramsOnCallEnd() = 0;
642
Per Åhgrencf4c8722019-12-30 14:32:14 +0100643 // Get audio processing statistics.
644 virtual AudioProcessingStats GetStatistics() = 0;
645 // TODO(webrtc:5298) Deprecated variant. The |has_remote_tracks| argument
646 // should be set if there are active remote tracks (this would usually be true
647 // during a call). If there are no remote tracks some of the stats will not be
648 // set by AudioProcessing, because they only make sense if there is at least
649 // one remote track.
650 virtual AudioProcessingStats GetStatistics(bool has_remote_tracks) = 0;
Ivo Creusenae026092017-11-20 13:07:16 +0100651
henrik.lundinadf06352017-04-05 05:48:24 -0700652 // Returns the last applied configuration.
henrik.lundin77492862017-04-06 23:28:09 -0700653 virtual AudioProcessing::Config GetConfig() const = 0;
henrik.lundinadf06352017-04-05 05:48:24 -0700654
andrew@webrtc.org648af742012-02-08 01:57:29 +0000655 enum Error {
656 // Fatal errors.
niklase@google.com470e71d2011-07-07 08:21:25 +0000657 kNoError = 0,
658 kUnspecifiedError = -1,
659 kCreationFailedError = -2,
660 kUnsupportedComponentError = -3,
661 kUnsupportedFunctionError = -4,
662 kNullPointerError = -5,
663 kBadParameterError = -6,
664 kBadSampleRateError = -7,
665 kBadDataLengthError = -8,
666 kBadNumberChannelsError = -9,
667 kFileError = -10,
668 kStreamParameterNotSetError = -11,
andrew@webrtc.org648af742012-02-08 01:57:29 +0000669 kNotEnabledError = -12,
niklase@google.com470e71d2011-07-07 08:21:25 +0000670
andrew@webrtc.org648af742012-02-08 01:57:29 +0000671 // Warnings are non-fatal.
niklase@google.com470e71d2011-07-07 08:21:25 +0000672 // This results when a set_stream_ parameter is out of range. Processing
673 // will continue, but the parameter may have been truncated.
andrew@webrtc.org648af742012-02-08 01:57:29 +0000674 kBadStreamParameterWarning = -13
niklase@google.com470e71d2011-07-07 08:21:25 +0000675 };
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000676
Per Åhgrenc8626b62019-08-23 15:49:51 +0200677 // Native rates supported by the AudioFrame interfaces.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000678 enum NativeRate {
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000679 kSampleRate8kHz = 8000,
680 kSampleRate16kHz = 16000,
aluebs@webrtc.org087da132014-11-17 23:01:23 +0000681 kSampleRate32kHz = 32000,
682 kSampleRate48kHz = 48000
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000683 };
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000684
kwibergd59d3bb2016-09-13 07:49:33 -0700685 // TODO(kwiberg): We currently need to support a compiler (Visual C++) that
686 // complains if we don't explicitly state the size of the array here. Remove
687 // the size when that's no longer the case.
688 static constexpr int kNativeSampleRatesHz[4] = {
689 kSampleRate8kHz, kSampleRate16kHz, kSampleRate32kHz, kSampleRate48kHz};
690 static constexpr size_t kNumNativeSampleRates =
691 arraysize(kNativeSampleRatesHz);
692 static constexpr int kMaxNativeSampleRateHz =
693 kNativeSampleRatesHz[kNumNativeSampleRates - 1];
Alejandro Luebscdfe20b2015-09-23 12:49:12 -0700694
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000695 static const int kChunkSizeMs = 10;
niklase@google.com470e71d2011-07-07 08:21:25 +0000696};
697
Mirko Bonadei3d255302018-10-11 10:50:45 +0200698class RTC_EXPORT AudioProcessingBuilder {
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100699 public:
700 AudioProcessingBuilder();
701 ~AudioProcessingBuilder();
702 // The AudioProcessingBuilder takes ownership of the echo_control_factory.
703 AudioProcessingBuilder& SetEchoControlFactory(
704 std::unique_ptr<EchoControlFactory> echo_control_factory);
705 // The AudioProcessingBuilder takes ownership of the capture_post_processing.
706 AudioProcessingBuilder& SetCapturePostProcessing(
707 std::unique_ptr<CustomProcessing> capture_post_processing);
708 // The AudioProcessingBuilder takes ownership of the render_pre_processing.
709 AudioProcessingBuilder& SetRenderPreProcessing(
710 std::unique_ptr<CustomProcessing> render_pre_processing);
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100711 // The AudioProcessingBuilder takes ownership of the echo_detector.
712 AudioProcessingBuilder& SetEchoDetector(
Ivo Creusend1f970d2018-06-14 11:02:03 +0200713 rtc::scoped_refptr<EchoDetector> echo_detector);
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200714 // The AudioProcessingBuilder takes ownership of the capture_analyzer.
715 AudioProcessingBuilder& SetCaptureAnalyzer(
716 std::unique_ptr<CustomAudioAnalyzer> capture_analyzer);
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100717 // This creates an APM instance using the previously set components. Calling
718 // the Create function resets the AudioProcessingBuilder to its initial state.
719 AudioProcessing* Create();
720 AudioProcessing* Create(const webrtc::Config& config);
721
722 private:
723 std::unique_ptr<EchoControlFactory> echo_control_factory_;
724 std::unique_ptr<CustomProcessing> capture_post_processing_;
725 std::unique_ptr<CustomProcessing> render_pre_processing_;
Ivo Creusend1f970d2018-06-14 11:02:03 +0200726 rtc::scoped_refptr<EchoDetector> echo_detector_;
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200727 std::unique_ptr<CustomAudioAnalyzer> capture_analyzer_;
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100728 RTC_DISALLOW_COPY_AND_ASSIGN(AudioProcessingBuilder);
729};
730
Michael Graczyk86c6d332015-07-23 11:41:39 -0700731class StreamConfig {
732 public:
733 // sample_rate_hz: The sampling rate of the stream.
734 //
735 // num_channels: The number of audio channels in the stream, excluding the
736 // keyboard channel if it is present. When passing a
737 // StreamConfig with an array of arrays T*[N],
738 //
739 // N == {num_channels + 1 if has_keyboard
740 // {num_channels if !has_keyboard
741 //
742 // has_keyboard: True if the stream has a keyboard channel. When has_keyboard
743 // is true, the last channel in any corresponding list of
744 // channels is the keyboard channel.
745 StreamConfig(int sample_rate_hz = 0,
Peter Kasting69558702016-01-12 16:26:35 -0800746 size_t num_channels = 0,
Michael Graczyk86c6d332015-07-23 11:41:39 -0700747 bool has_keyboard = false)
748 : sample_rate_hz_(sample_rate_hz),
749 num_channels_(num_channels),
750 has_keyboard_(has_keyboard),
751 num_frames_(calculate_frames(sample_rate_hz)) {}
752
753 void set_sample_rate_hz(int value) {
754 sample_rate_hz_ = value;
755 num_frames_ = calculate_frames(value);
756 }
Peter Kasting69558702016-01-12 16:26:35 -0800757 void set_num_channels(size_t value) { num_channels_ = value; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700758 void set_has_keyboard(bool value) { has_keyboard_ = value; }
759
760 int sample_rate_hz() const { return sample_rate_hz_; }
761
762 // The number of channels in the stream, not including the keyboard channel if
763 // present.
Peter Kasting69558702016-01-12 16:26:35 -0800764 size_t num_channels() const { return num_channels_; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700765
766 bool has_keyboard() const { return has_keyboard_; }
Peter Kastingdce40cf2015-08-24 14:52:23 -0700767 size_t num_frames() const { return num_frames_; }
768 size_t num_samples() const { return num_channels_ * num_frames_; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700769
770 bool operator==(const StreamConfig& other) const {
771 return sample_rate_hz_ == other.sample_rate_hz_ &&
772 num_channels_ == other.num_channels_ &&
773 has_keyboard_ == other.has_keyboard_;
774 }
775
776 bool operator!=(const StreamConfig& other) const { return !(*this == other); }
777
778 private:
Peter Kastingdce40cf2015-08-24 14:52:23 -0700779 static size_t calculate_frames(int sample_rate_hz) {
Yves Gerey665174f2018-06-19 15:03:05 +0200780 return static_cast<size_t>(AudioProcessing::kChunkSizeMs * sample_rate_hz /
781 1000);
Michael Graczyk86c6d332015-07-23 11:41:39 -0700782 }
783
784 int sample_rate_hz_;
Peter Kasting69558702016-01-12 16:26:35 -0800785 size_t num_channels_;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700786 bool has_keyboard_;
Peter Kastingdce40cf2015-08-24 14:52:23 -0700787 size_t num_frames_;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700788};
789
790class ProcessingConfig {
791 public:
792 enum StreamName {
793 kInputStream,
794 kOutputStream,
ekmeyerson60d9b332015-08-14 10:35:55 -0700795 kReverseInputStream,
796 kReverseOutputStream,
Michael Graczyk86c6d332015-07-23 11:41:39 -0700797 kNumStreamNames,
798 };
799
800 const StreamConfig& input_stream() const {
801 return streams[StreamName::kInputStream];
802 }
803 const StreamConfig& output_stream() const {
804 return streams[StreamName::kOutputStream];
805 }
ekmeyerson60d9b332015-08-14 10:35:55 -0700806 const StreamConfig& reverse_input_stream() const {
807 return streams[StreamName::kReverseInputStream];
808 }
809 const StreamConfig& reverse_output_stream() const {
810 return streams[StreamName::kReverseOutputStream];
Michael Graczyk86c6d332015-07-23 11:41:39 -0700811 }
812
813 StreamConfig& input_stream() { return streams[StreamName::kInputStream]; }
814 StreamConfig& output_stream() { return streams[StreamName::kOutputStream]; }
ekmeyerson60d9b332015-08-14 10:35:55 -0700815 StreamConfig& reverse_input_stream() {
816 return streams[StreamName::kReverseInputStream];
817 }
818 StreamConfig& reverse_output_stream() {
819 return streams[StreamName::kReverseOutputStream];
820 }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700821
822 bool operator==(const ProcessingConfig& other) const {
823 for (int i = 0; i < StreamName::kNumStreamNames; ++i) {
824 if (this->streams[i] != other.streams[i]) {
825 return false;
826 }
827 }
828 return true;
829 }
830
831 bool operator!=(const ProcessingConfig& other) const {
832 return !(*this == other);
833 }
834
835 StreamConfig streams[StreamName::kNumStreamNames];
836};
837
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200838// Experimental interface for a custom analysis submodule.
839class CustomAudioAnalyzer {
840 public:
841 // (Re-) Initializes the submodule.
842 virtual void Initialize(int sample_rate_hz, int num_channels) = 0;
843 // Analyzes the given capture or render signal.
844 virtual void Analyze(const AudioBuffer* audio) = 0;
845 // Returns a string representation of the module state.
846 virtual std::string ToString() const = 0;
847
848 virtual ~CustomAudioAnalyzer() {}
849};
850
Alex Loiko5825aa62017-12-18 16:02:40 +0100851// Interface for a custom processing submodule.
852class CustomProcessing {
Sam Zackrisson0beac582017-09-25 12:04:02 +0200853 public:
854 // (Re-)Initializes the submodule.
855 virtual void Initialize(int sample_rate_hz, int num_channels) = 0;
856 // Processes the given capture or render signal.
857 virtual void Process(AudioBuffer* audio) = 0;
858 // Returns a string representation of the module state.
859 virtual std::string ToString() const = 0;
Alex Loiko73ec0192018-05-15 10:52:28 +0200860 // Handles RuntimeSettings. TODO(webrtc:9262): make pure virtual
861 // after updating dependencies.
862 virtual void SetRuntimeSetting(AudioProcessing::RuntimeSetting setting);
Sam Zackrisson0beac582017-09-25 12:04:02 +0200863
Alex Loiko5825aa62017-12-18 16:02:40 +0100864 virtual ~CustomProcessing() {}
Sam Zackrisson0beac582017-09-25 12:04:02 +0200865};
866
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100867// Interface for an echo detector submodule.
Ivo Creusend1f970d2018-06-14 11:02:03 +0200868class EchoDetector : public rtc::RefCountInterface {
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100869 public:
870 // (Re-)Initializes the submodule.
Ivo Creusen647ef092018-03-14 17:13:48 +0100871 virtual void Initialize(int capture_sample_rate_hz,
872 int num_capture_channels,
873 int render_sample_rate_hz,
874 int num_render_channels) = 0;
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100875
876 // Analysis (not changing) of the render signal.
877 virtual void AnalyzeRenderAudio(rtc::ArrayView<const float> render_audio) = 0;
878
879 // Analysis (not changing) of the capture signal.
880 virtual void AnalyzeCaptureAudio(
881 rtc::ArrayView<const float> capture_audio) = 0;
882
883 // Pack an AudioBuffer into a vector<float>.
884 static void PackRenderAudioBuffer(AudioBuffer* audio,
885 std::vector<float>* packed_buffer);
886
887 struct Metrics {
888 double echo_likelihood;
889 double echo_likelihood_recent_max;
890 };
891
892 // Collect current metrics from the echo detector.
893 virtual Metrics GetMetrics() const = 0;
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100894};
895
niklase@google.com470e71d2011-07-07 08:21:25 +0000896} // namespace webrtc
897
Mirko Bonadei92ea95e2017-09-15 06:47:31 +0200898#endif // MODULES_AUDIO_PROCESSING_INCLUDE_AUDIO_PROCESSING_H_