blob: 5ab591bc7f3ad37dcd8992247414a466b0da548b [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
aluebs@webrtc.org9825afc2014-06-30 17:39:53 +000095// Use to enable experimental noise suppression. It can be set in the
96// constructor or using AudioProcessing::SetExtraOptions().
97struct ExperimentalNs {
98 ExperimentalNs() : enabled(false) {}
99 explicit ExperimentalNs(bool enabled) : enabled(enabled) {}
aluebs688e3082016-01-14 04:32:46 -0800100 static const ConfigOptionID identifier = ConfigOptionID::kExperimentalNs;
aluebs@webrtc.org9825afc2014-06-30 17:39:53 +0000101 bool enabled;
102};
103
niklase@google.com470e71d2011-07-07 08:21:25 +0000104// The Audio Processing Module (APM) provides a collection of voice processing
105// components designed for real-time communications software.
106//
107// APM operates on two audio streams on a frame-by-frame basis. Frames of the
108// primary stream, on which all processing is applied, are passed to
aluebsb0319552016-03-17 20:39:53 -0700109// |ProcessStream()|. Frames of the reverse direction stream are passed to
110// |ProcessReverseStream()|. On the client-side, this will typically be the
111// near-end (capture) and far-end (render) streams, respectively. APM should be
112// placed in the signal chain as close to the audio hardware abstraction layer
113// (HAL) as possible.
niklase@google.com470e71d2011-07-07 08:21:25 +0000114//
115// On the server-side, the reverse stream will normally not be used, with
116// processing occurring on each incoming stream.
117//
118// Component interfaces follow a similar pattern and are accessed through
119// corresponding getters in APM. All components are disabled at create-time,
120// with default settings that are recommended for most situations. New settings
121// can be applied without enabling a component. Enabling a component triggers
122// memory allocation and initialization to allow it to start processing the
123// streams.
124//
125// Thread safety is provided with the following assumptions to reduce locking
126// overhead:
127// 1. The stream getters and setters are called from the same thread as
128// ProcessStream(). More precisely, stream functions are never called
129// concurrently with ProcessStream().
130// 2. Parameter getters are never called concurrently with the corresponding
131// setter.
132//
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000133// APM accepts only linear PCM audio data in chunks of 10 ms. The int16
134// interfaces use interleaved data, while the float interfaces use deinterleaved
135// data.
niklase@google.com470e71d2011-07-07 08:21:25 +0000136//
137// Usage example, omitting error checking:
Ivo Creusen62337e52018-01-09 14:17:33 +0100138// AudioProcessing* apm = AudioProcessingBuilder().Create();
niklase@google.com470e71d2011-07-07 08:21:25 +0000139//
peah88ac8532016-09-12 16:47:25 -0700140// AudioProcessing::Config config;
Sam Zackrissoncdf0e6d2018-09-17 11:05:17 +0200141// config.echo_canceller.enabled = true;
142// config.echo_canceller.mobile_mode = false;
Sam Zackrisson41478c72019-10-15 10:10:26 +0200143//
144// config.gain_controller1.enabled = true;
145// config.gain_controller1.mode =
146// AudioProcessing::Config::GainController1::kAdaptiveAnalog;
147// config.gain_controller1.analog_level_minimum = 0;
148// config.gain_controller1.analog_level_maximum = 255;
149//
Sam Zackrissonab1aee02018-03-05 15:59:06 +0100150// config.gain_controller2.enabled = true;
Sam Zackrisson41478c72019-10-15 10:10:26 +0200151//
152// config.high_pass_filter.enabled = true;
153//
154// config.voice_detection.enabled = true;
155//
peah88ac8532016-09-12 16:47:25 -0700156// apm->ApplyConfig(config)
157//
niklase@google.com470e71d2011-07-07 08:21:25 +0000158// apm->noise_reduction()->set_level(kHighSuppression);
159// apm->noise_reduction()->Enable(true);
160//
niklase@google.com470e71d2011-07-07 08:21:25 +0000161// // Start a voice call...
162//
163// // ... Render frame arrives bound for the audio HAL ...
aluebsb0319552016-03-17 20:39:53 -0700164// apm->ProcessReverseStream(render_frame);
niklase@google.com470e71d2011-07-07 08:21:25 +0000165//
166// // ... Capture frame arrives from the audio HAL ...
167// // Call required set_stream_ functions.
168// apm->set_stream_delay_ms(delay_ms);
Sam Zackrisson41478c72019-10-15 10:10:26 +0200169// apm->set_stream_analog_level(analog_level);
niklase@google.com470e71d2011-07-07 08:21:25 +0000170//
171// apm->ProcessStream(capture_frame);
172//
173// // Call required stream_ functions.
Sam Zackrisson41478c72019-10-15 10:10:26 +0200174// analog_level = apm->recommended_stream_analog_level();
niklase@google.com470e71d2011-07-07 08:21:25 +0000175// has_voice = apm->stream_has_voice();
176//
177// // Repeate render and capture processing for the duration of the call...
178// // Start a new call...
179// apm->Initialize();
180//
181// // Close the application...
andrew@webrtc.orgf3930e92013-09-18 22:37:32 +0000182// delete apm;
niklase@google.com470e71d2011-07-07 08:21:25 +0000183//
Mirko Bonadei35214fc2019-09-23 14:54:28 +0200184class RTC_EXPORT AudioProcessing : public rtc::RefCountInterface {
niklase@google.com470e71d2011-07-07 08:21:25 +0000185 public:
peah88ac8532016-09-12 16:47:25 -0700186 // The struct below constitutes the new parameter scheme for the audio
187 // processing. It is being introduced gradually and until it is fully
188 // introduced, it is prone to change.
189 // TODO(peah): Remove this comment once the new config scheme is fully rolled
190 // out.
191 //
192 // The parameters and behavior of the audio processing module are controlled
193 // by changing the default values in the AudioProcessing::Config struct.
194 // The config is applied by passing the struct to the ApplyConfig method.
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100195 //
196 // This config is intended to be used during setup, and to enable/disable
197 // top-level processing effects. Use during processing may cause undesired
198 // submodule resets, affecting the audio quality. Use the RuntimeSetting
199 // construct for runtime configuration.
Mirko Bonadeid4002a72019-11-12 20:11:48 +0100200 struct RTC_EXPORT Config {
Per Åhgren25126042019-12-05 07:32:32 +0100201
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200202 // Sets the properties of the audio processing pipeline.
Mirko Bonadeid4002a72019-11-12 20:11:48 +0100203 struct RTC_EXPORT Pipeline {
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200204 Pipeline();
205
206 // Maximum allowed processing rate used internally. May only be set to
207 // 32000 or 48000 and any differing values will be treated as 48000. The
208 // default rate is currently selected based on the CPU architecture, but
209 // that logic may change.
210 int maximum_internal_processing_rate;
Per Åhgrene14cb992019-11-27 09:34:22 +0100211 // Allow multi-channel processing of render audio.
212 bool multi_channel_render = false;
213 // Allow multi-channel processing of capture audio when AEC3 is active
214 // or a custom AEC is injected..
215 bool multi_channel_capture = false;
Per Åhgrenfcbe4072019-09-15 00:27:58 +0200216 } pipeline;
217
Sam Zackrisson23513132019-01-11 15:10:32 +0100218 // Enabled the pre-amplifier. It amplifies the capture signal
219 // before any other processing is done.
220 struct PreAmplifier {
221 bool enabled = false;
222 float fixed_gain_factor = 1.f;
223 } pre_amplifier;
224
225 struct HighPassFilter {
226 bool enabled = false;
Per Åhgrenc0424252019-12-10 13:04:15 +0100227 bool apply_in_full_band = true;
Sam Zackrisson23513132019-01-11 15:10:32 +0100228 } high_pass_filter;
229
Sam Zackrisson8b5d2cc2018-07-27 13:27:23 +0200230 struct EchoCanceller {
231 bool enabled = false;
232 bool mobile_mode = false;
Per Åhgrenc20a19c2019-11-13 11:12:29 +0100233 bool export_linear_aec_output = false;
Per Åhgrenb8106462019-12-04 08:34:12 +0100234 // Enforce the highpass filter to be on (has no effect for the mobile
235 // mode).
Per Åhgrenbcce4532019-12-03 13:52:40 +0100236 bool enforce_high_pass_filtering = true;
Sam Zackrisson8b5d2cc2018-07-27 13:27:23 +0200237 } echo_canceller;
238
Sam Zackrisson23513132019-01-11 15:10:32 +0100239 // Enables background noise suppression.
240 struct NoiseSuppression {
peah8271d042016-11-22 07:24:52 -0800241 bool enabled = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100242 enum Level { kLow, kModerate, kHigh, kVeryHigh };
243 Level level = kModerate;
Per Åhgren0cbb58e2019-10-29 22:59:44 +0100244 // Recommended not to use. Will be removed in the future.
245 bool use_legacy_ns = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100246 } noise_suppression;
peahe0eae3c2016-12-14 01:16:23 -0800247
Sam Zackrisson0824c6f2019-10-07 14:03:56 +0200248 // Enables reporting of |voice_detected| in webrtc::AudioProcessingStats.
249 // In addition to |voice_detected|, VAD decision is provided through the
250 // |AudioFrame| passed to |ProcessStream()|. The |vad_activity_| member will
251 // be modified to reflect the current decision.
Sam Zackrisson23513132019-01-11 15:10:32 +0100252 struct VoiceDetection {
Alex Loiko5feb30e2018-04-16 13:52:32 +0200253 bool enabled = false;
Sam Zackrisson23513132019-01-11 15:10:32 +0100254 } voice_detection;
Alex Loiko5feb30e2018-04-16 13:52:32 +0200255
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100256 // Enables automatic gain control (AGC) functionality.
257 // The automatic gain control (AGC) component brings the signal to an
258 // appropriate range. This is done by applying a digital gain directly and,
259 // in the analog mode, prescribing an analog gain to be applied at the audio
260 // HAL.
261 // Recommended to be enabled on the client-side.
262 struct GainController1 {
263 bool enabled = false;
264 enum Mode {
265 // Adaptive mode intended for use if an analog volume control is
266 // available on the capture device. It will require the user to provide
267 // coupling between the OS mixer controls and AGC through the
268 // stream_analog_level() functions.
269 // It consists of an analog gain prescription for the audio device and a
270 // digital compression stage.
271 kAdaptiveAnalog,
272 // Adaptive mode intended for situations in which an analog volume
273 // control is unavailable. It operates in a similar fashion to the
274 // adaptive analog mode, but with scaling instead applied in the digital
275 // domain. As with the analog mode, it additionally uses a digital
276 // compression stage.
277 kAdaptiveDigital,
278 // Fixed mode which enables only the digital compression stage also used
279 // by the two adaptive modes.
280 // It is distinguished from the adaptive modes by considering only a
281 // short time-window of the input signal. It applies a fixed gain
282 // through most of the input level range, and compresses (gradually
283 // reduces gain with increasing level) the input signal at higher
284 // levels. This mode is preferred on embedded devices where the capture
285 // signal level is predictable, so that a known gain can be applied.
286 kFixedDigital
287 };
288 Mode mode = kAdaptiveAnalog;
289 // Sets the target peak level (or envelope) of the AGC in dBFs (decibels
290 // from digital full-scale). The convention is to use positive values. For
291 // instance, passing in a value of 3 corresponds to -3 dBFs, or a target
292 // level 3 dB below full-scale. Limited to [0, 31].
293 int target_level_dbfs = 3;
294 // Sets the maximum gain the digital compression stage may apply, in dB. A
295 // higher number corresponds to greater compression, while a value of 0
296 // will leave the signal uncompressed. Limited to [0, 90].
297 // For updates after APM setup, use a RuntimeSetting instead.
298 int compression_gain_db = 9;
299 // When enabled, the compression stage will hard limit the signal to the
300 // target level. Otherwise, the signal will be compressed but not limited
301 // above the target level.
302 bool enable_limiter = true;
303 // Sets the minimum and maximum analog levels of the audio capture device.
304 // Must be set if an analog mode is used. Limited to [0, 65535].
305 int analog_level_minimum = 0;
306 int analog_level_maximum = 255;
307 } gain_controller1;
308
Alex Loikoe5831742018-08-24 11:28:36 +0200309 // Enables the next generation AGC functionality. This feature replaces the
310 // standard methods of gain control in the previous AGC. Enabling this
311 // submodule enables an adaptive digital AGC followed by a limiter. By
312 // setting |fixed_gain_db|, the limiter can be turned into a compressor that
313 // first applies a fixed gain. The adaptive digital AGC can be turned off by
314 // setting |adaptive_digital_mode=false|.
alessiob3ec96df2017-05-22 06:57:06 -0700315 struct GainController2 {
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100316 enum LevelEstimator { kRms, kPeak };
alessiob3ec96df2017-05-22 06:57:06 -0700317 bool enabled = false;
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100318 struct {
319 float gain_db = 0.f;
320 } fixed_digital;
321 struct {
Alessio Bazzica8da7b352018-11-21 10:50:58 +0100322 bool enabled = false;
Alessio Bazzica1e2542f2018-11-13 14:44:15 +0100323 LevelEstimator level_estimator = kRms;
324 bool use_saturation_protector = true;
325 float extra_saturation_margin_db = 2.f;
326 } adaptive_digital;
alessiob3ec96df2017-05-22 06:57:06 -0700327 } gain_controller2;
peah8cee56f2017-08-24 22:36:53 -0700328
Sam Zackrisson23513132019-01-11 15:10:32 +0100329 struct ResidualEchoDetector {
330 bool enabled = true;
331 } residual_echo_detector;
332
Sam Zackrissonb24c00f2018-11-26 16:18:25 +0100333 // Enables reporting of |output_rms_dbfs| in webrtc::AudioProcessingStats.
334 struct LevelEstimation {
335 bool enabled = false;
336 } level_estimation;
337
Artem Titov59bbd652019-08-02 11:31:37 +0200338 std::string ToString() const;
peah88ac8532016-09-12 16:47:25 -0700339 };
340
Michael Graczyk86c6d332015-07-23 11:41:39 -0700341 // TODO(mgraczyk): Remove once all methods that use ChannelLayout are gone.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000342 enum ChannelLayout {
343 kMono,
344 // Left, right.
345 kStereo,
peah88ac8532016-09-12 16:47:25 -0700346 // Mono, keyboard, and mic.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000347 kMonoAndKeyboard,
peah88ac8532016-09-12 16:47:25 -0700348 // Left, right, keyboard, and mic.
andrew@webrtc.org17e40642014-03-04 20:58:13 +0000349 kStereoAndKeyboard
350 };
351
Alessio Bazzicac054e782018-04-16 12:10:09 +0200352 // Specifies the properties of a setting to be passed to AudioProcessing at
353 // runtime.
354 class RuntimeSetting {
355 public:
Alex Loiko73ec0192018-05-15 10:52:28 +0200356 enum class Type {
357 kNotSpecified,
358 kCapturePreGain,
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100359 kCaptureCompressionGain,
Per Åhgren6ee75fd2019-04-26 11:33:37 +0200360 kCaptureFixedPostGain,
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200361 kPlayoutVolumeChange,
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100362 kCustomRenderProcessingRuntimeSetting,
363 kPlayoutAudioDeviceChange
364 };
365
366 // Play-out audio device properties.
367 struct PlayoutAudioDeviceInfo {
368 int id; // Identifies the audio device.
369 int max_volume; // Maximum play-out volume.
Alex Loiko73ec0192018-05-15 10:52:28 +0200370 };
Alessio Bazzicac054e782018-04-16 12:10:09 +0200371
372 RuntimeSetting() : type_(Type::kNotSpecified), value_(0.f) {}
373 ~RuntimeSetting() = default;
374
375 static RuntimeSetting CreateCapturePreGain(float gain) {
376 RTC_DCHECK_GE(gain, 1.f) << "Attenuation is not allowed.";
377 return {Type::kCapturePreGain, gain};
378 }
379
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100380 // Corresponds to Config::GainController1::compression_gain_db, but for
381 // runtime configuration.
382 static RuntimeSetting CreateCompressionGainDb(int gain_db) {
383 RTC_DCHECK_GE(gain_db, 0);
384 RTC_DCHECK_LE(gain_db, 90);
385 return {Type::kCaptureCompressionGain, static_cast<float>(gain_db)};
386 }
387
Per Åhgren6ee75fd2019-04-26 11:33:37 +0200388 // Corresponds to Config::GainController2::fixed_digital::gain_db, but for
389 // runtime configuration.
390 static RuntimeSetting CreateCaptureFixedPostGain(float gain_db) {
391 RTC_DCHECK_GE(gain_db, 0.f);
392 RTC_DCHECK_LE(gain_db, 90.f);
393 return {Type::kCaptureFixedPostGain, gain_db};
394 }
395
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100396 // Creates a runtime setting to notify play-out (aka render) audio device
397 // changes.
398 static RuntimeSetting CreatePlayoutAudioDeviceChange(
399 PlayoutAudioDeviceInfo audio_device) {
400 return {Type::kPlayoutAudioDeviceChange, audio_device};
401 }
402
403 // Creates a runtime setting to notify play-out (aka render) volume changes.
404 // |volume| is the unnormalized volume, the maximum of which
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200405 static RuntimeSetting CreatePlayoutVolumeChange(int volume) {
406 return {Type::kPlayoutVolumeChange, volume};
407 }
408
Alex Loiko73ec0192018-05-15 10:52:28 +0200409 static RuntimeSetting CreateCustomRenderSetting(float payload) {
410 return {Type::kCustomRenderProcessingRuntimeSetting, payload};
411 }
412
Alessio Bazzicac054e782018-04-16 12:10:09 +0200413 Type type() const { return type_; }
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100414 // Getters do not return a value but instead modify the argument to protect
415 // from implicit casting.
Alessio Bazzicac054e782018-04-16 12:10:09 +0200416 void GetFloat(float* value) const {
417 RTC_DCHECK(value);
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200418 *value = value_.float_value;
419 }
420 void GetInt(int* value) const {
421 RTC_DCHECK(value);
422 *value = value_.int_value;
Alessio Bazzicac054e782018-04-16 12:10:09 +0200423 }
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100424 void GetPlayoutAudioDeviceInfo(PlayoutAudioDeviceInfo* value) const {
425 RTC_DCHECK(value);
426 *value = value_.playout_audio_device_info;
427 }
Alessio Bazzicac054e782018-04-16 12:10:09 +0200428
429 private:
430 RuntimeSetting(Type id, float value) : type_(id), value_(value) {}
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200431 RuntimeSetting(Type id, int value) : type_(id), value_(value) {}
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100432 RuntimeSetting(Type id, PlayoutAudioDeviceInfo value)
433 : type_(id), value_(value) {}
Alessio Bazzicac054e782018-04-16 12:10:09 +0200434 Type type_;
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200435 union U {
436 U() {}
437 U(int value) : int_value(value) {}
438 U(float value) : float_value(value) {}
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100439 U(PlayoutAudioDeviceInfo value) : playout_audio_device_info(value) {}
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200440 float float_value;
441 int int_value;
Alessio Bazzica7c19a702019-11-07 13:22:00 +0100442 PlayoutAudioDeviceInfo playout_audio_device_info;
Fredrik Hernqvistca362852019-05-10 15:50:02 +0200443 } value_;
Alessio Bazzicac054e782018-04-16 12:10:09 +0200444 };
445
peaha9cc40b2017-06-29 08:32:09 -0700446 ~AudioProcessing() override {}
niklase@google.com470e71d2011-07-07 08:21:25 +0000447
niklase@google.com470e71d2011-07-07 08:21:25 +0000448 // Initializes internal states, while retaining all user settings. This
449 // should be called before beginning to process a new audio stream. However,
450 // it is not necessary to call before processing the first stream after
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000451 // creation.
452 //
453 // It is also not necessary to call if the audio parameters (sample
andrew@webrtc.org60730cf2014-01-07 17:45:09 +0000454 // rate and number of channels) have changed. Passing updated parameters
aluebsb0319552016-03-17 20:39:53 -0700455 // directly to |ProcessStream()| and |ProcessReverseStream()| is permissible.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000456 // If the parameters are known at init-time though, they may be provided.
niklase@google.com470e71d2011-07-07 08:21:25 +0000457 virtual int Initialize() = 0;
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000458
459 // The int16 interfaces require:
460 // - only |NativeRate|s be used
461 // - that the input, output and reverse rates must match
Michael Graczyk86c6d332015-07-23 11:41:39 -0700462 // - that |processing_config.output_stream()| matches
463 // |processing_config.input_stream()|.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000464 //
Michael Graczyk86c6d332015-07-23 11:41:39 -0700465 // The float interfaces accept arbitrary rates and support differing input and
466 // output layouts, but the output must have either one channel or the same
467 // number of channels as the input.
468 virtual int Initialize(const ProcessingConfig& processing_config) = 0;
469
470 // Initialize with unpacked parameters. See Initialize() above for details.
471 //
472 // TODO(mgraczyk): Remove once clients are updated to use the new interface.
peahde65ddc2016-09-16 15:02:15 -0700473 virtual int Initialize(int capture_input_sample_rate_hz,
474 int capture_output_sample_rate_hz,
475 int render_sample_rate_hz,
476 ChannelLayout capture_input_layout,
477 ChannelLayout capture_output_layout,
478 ChannelLayout render_input_layout) = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000479
peah88ac8532016-09-12 16:47:25 -0700480 // TODO(peah): This method is a temporary solution used to take control
481 // over the parameters in the audio processing module and is likely to change.
482 virtual void ApplyConfig(const Config& config) = 0;
483
andrew@webrtc.org61e596f2013-07-25 18:28:29 +0000484 // Pass down additional options which don't have explicit setters. This
485 // ensures the options are applied immediately.
peah88ac8532016-09-12 16:47:25 -0700486 virtual void SetExtraOptions(const webrtc::Config& config) = 0;
andrew@webrtc.org61e596f2013-07-25 18:28:29 +0000487
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000488 // TODO(ajm): Only intended for internal use. Make private and friend the
489 // necessary classes?
490 virtual int proc_sample_rate_hz() const = 0;
491 virtual int proc_split_sample_rate_hz() const = 0;
Peter Kasting69558702016-01-12 16:26:35 -0800492 virtual size_t num_input_channels() const = 0;
493 virtual size_t num_proc_channels() const = 0;
494 virtual size_t num_output_channels() const = 0;
495 virtual size_t num_reverse_channels() const = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000496
andrew@webrtc.org17342e52014-02-12 22:28:31 +0000497 // Set to true when the output of AudioProcessing will be muted or in some
498 // other way not used. Ideally, the captured audio would still be processed,
499 // but some components may change behavior based on this information.
500 // Default false.
501 virtual void set_output_will_be_muted(bool muted) = 0;
andrew@webrtc.org17342e52014-02-12 22:28:31 +0000502
Alessio Bazzicac054e782018-04-16 12:10:09 +0200503 // Enqueue a runtime setting.
504 virtual void SetRuntimeSetting(RuntimeSetting setting) = 0;
505
niklase@google.com470e71d2011-07-07 08:21:25 +0000506 // Processes a 10 ms |frame| of the primary audio stream. On the client-side,
507 // this is the near-end (or captured) audio.
508 //
509 // If needed for enabled functionality, any function with the set_stream_ tag
510 // must be called prior to processing the current frame. Any getter function
511 // with the stream_ tag which is needed should be called after processing.
512 //
andrew@webrtc.org63a50982012-05-02 23:56:37 +0000513 // The |sample_rate_hz_|, |num_channels_|, and |samples_per_channel_|
andrew@webrtc.org60730cf2014-01-07 17:45:09 +0000514 // members of |frame| must be valid. If changed from the previous call to this
515 // method, it will trigger an initialization.
niklase@google.com470e71d2011-07-07 08:21:25 +0000516 virtual int ProcessStream(AudioFrame* frame) = 0;
517
Michael Graczyk86c6d332015-07-23 11:41:39 -0700518 // Accepts deinterleaved float audio with the range [-1, 1]. Each element of
519 // |src| points to a channel buffer, arranged according to |input_stream|. At
520 // output, the channels will be arranged according to |output_stream| in
521 // |dest|.
522 //
523 // The output must have one channel or as many channels as the input. |src|
524 // and |dest| may use the same memory, if desired.
525 virtual int ProcessStream(const float* const* src,
526 const StreamConfig& input_config,
527 const StreamConfig& output_config,
528 float* const* dest) = 0;
529
aluebsb0319552016-03-17 20:39:53 -0700530 // Processes a 10 ms |frame| of the reverse direction audio stream. The frame
531 // may be modified. On the client-side, this is the far-end (or to be
niklase@google.com470e71d2011-07-07 08:21:25 +0000532 // rendered) audio.
533 //
aluebsb0319552016-03-17 20:39:53 -0700534 // It is necessary to provide this if echo processing is enabled, as the
niklase@google.com470e71d2011-07-07 08:21:25 +0000535 // reverse stream forms the echo reference signal. It is recommended, but not
536 // necessary, to provide if gain control is enabled. On the server-side this
537 // typically will not be used. If you're not sure what to pass in here,
538 // chances are you don't need to use it.
539 //
andrew@webrtc.org63a50982012-05-02 23:56:37 +0000540 // The |sample_rate_hz_|, |num_channels_|, and |samples_per_channel_|
aluebsda116c42016-03-17 16:43:29 -0700541 // members of |frame| must be valid.
ekmeyerson60d9b332015-08-14 10:35:55 -0700542 virtual int ProcessReverseStream(AudioFrame* frame) = 0;
543
Michael Graczyk86c6d332015-07-23 11:41:39 -0700544 // Accepts deinterleaved float audio with the range [-1, 1]. Each element of
545 // |data| points to a channel buffer, arranged according to |reverse_config|.
ekmeyerson60d9b332015-08-14 10:35:55 -0700546 virtual int ProcessReverseStream(const float* const* src,
peahde65ddc2016-09-16 15:02:15 -0700547 const StreamConfig& input_config,
548 const StreamConfig& output_config,
ekmeyerson60d9b332015-08-14 10:35:55 -0700549 float* const* dest) = 0;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700550
Gustaf Ullbergcb307262019-10-29 09:30:44 +0100551 // Accepts deinterleaved float audio with the range [-1, 1]. Each element
552 // of |data| points to a channel buffer, arranged according to
553 // |reverse_config|.
554 virtual int AnalyzeReverseStream(const float* const* data,
555 const StreamConfig& reverse_config) = 0;
556
Per Åhgrenc20a19c2019-11-13 11:12:29 +0100557 // Returns the most recently produced 10 ms of the linear AEC output at a rate
558 // of 16 kHz. If there is more than one capture channel, a mono representation
559 // of the input is returned. Returns true/false to indicate whether an output
560 // returned.
561 virtual bool GetLinearAecOutput(
562 rtc::ArrayView<std::array<float, 160>> linear_output) const = 0;
563
Sam Zackrissonf0d1c032019-03-27 13:28:08 +0100564 // This must be called prior to ProcessStream() if and only if adaptive analog
565 // gain control is enabled, to pass the current analog level from the audio
566 // HAL. Must be within the range provided in Config::GainController1.
567 virtual void set_stream_analog_level(int level) = 0;
568
569 // When an analog mode is set, this should be called after ProcessStream()
570 // to obtain the recommended new analog level for the audio HAL. It is the
571 // user's responsibility to apply this level.
572 virtual int recommended_stream_analog_level() const = 0;
573
niklase@google.com470e71d2011-07-07 08:21:25 +0000574 // This must be called if and only if echo processing is enabled.
575 //
aluebsb0319552016-03-17 20:39:53 -0700576 // Sets the |delay| in ms between ProcessReverseStream() receiving a far-end
niklase@google.com470e71d2011-07-07 08:21:25 +0000577 // frame and ProcessStream() receiving a near-end frame containing the
578 // corresponding echo. On the client-side this can be expressed as
579 // delay = (t_render - t_analyze) + (t_process - t_capture)
580 // where,
aluebsb0319552016-03-17 20:39:53 -0700581 // - t_analyze is the time a frame is passed to ProcessReverseStream() and
niklase@google.com470e71d2011-07-07 08:21:25 +0000582 // t_render is the time the first sample of the same frame is rendered by
583 // the audio hardware.
584 // - t_capture is the time the first sample of a frame is captured by the
alessiob13fc1802017-04-19 05:35:51 -0700585 // audio hardware and t_process is the time the same frame is passed to
niklase@google.com470e71d2011-07-07 08:21:25 +0000586 // ProcessStream().
587 virtual int set_stream_delay_ms(int delay) = 0;
588 virtual int stream_delay_ms() const = 0;
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000589 virtual bool was_stream_delay_set() const = 0;
niklase@google.com470e71d2011-07-07 08:21:25 +0000590
andrew@webrtc.org75dd2882014-02-11 20:52:30 +0000591 // Call to signal that a key press occurred (true) or did not occur (false)
592 // with this chunk of audio.
593 virtual void set_stream_key_pressed(bool key_pressed) = 0;
andrew@webrtc.org75dd2882014-02-11 20:52:30 +0000594
andrew@webrtc.org6f9f8172012-03-06 19:03:39 +0000595 // Sets a delay |offset| in ms to add to the values passed in through
596 // set_stream_delay_ms(). May be positive or negative.
597 //
598 // Note that this could cause an otherwise valid value passed to
599 // set_stream_delay_ms() to return an error.
600 virtual void set_delay_offset_ms(int offset) = 0;
601 virtual int delay_offset_ms() const = 0;
602
aleloi868f32f2017-05-23 07:20:05 -0700603 // Attaches provided webrtc::AecDump for recording debugging
604 // information. Log file and maximum file size logic is supposed to
605 // be handled by implementing instance of AecDump. Calling this
606 // method when another AecDump is attached resets the active AecDump
607 // with a new one. This causes the d-tor of the earlier AecDump to
608 // be called. The d-tor call may block until all pending logging
609 // tasks are completed.
Alex Loikobe767e02017-06-08 09:45:03 +0200610 virtual void AttachAecDump(std::unique_ptr<AecDump> aec_dump) = 0;
aleloi868f32f2017-05-23 07:20:05 -0700611
612 // If no AecDump is attached, this has no effect. If an AecDump is
613 // attached, it's destructor is called. The d-tor may block until
614 // all pending logging tasks are completed.
Alex Loikobe767e02017-06-08 09:45:03 +0200615 virtual void DetachAecDump() = 0;
aleloi868f32f2017-05-23 07:20:05 -0700616
Sam Zackrisson4d364492018-03-02 16:03:21 +0100617 // Attaches provided webrtc::AudioGenerator for modifying playout audio.
618 // Calling this method when another AudioGenerator is attached replaces the
619 // active AudioGenerator with a new one.
620 virtual void AttachPlayoutAudioGenerator(
621 std::unique_ptr<AudioGenerator> audio_generator) = 0;
622
623 // If no AudioGenerator is attached, this has no effect. If an AecDump is
624 // attached, its destructor is called.
625 virtual void DetachPlayoutAudioGenerator() = 0;
626
Bjorn Volcker4e7aa432015-07-07 11:50:05 +0200627 // Use to send UMA histograms at end of a call. Note that all histogram
628 // specific member variables are reset.
Per Åhgrenea4c5df2019-05-03 09:00:08 +0200629 // Deprecated. This method is deprecated and will be removed.
630 // TODO(peah): Remove this method.
Bjorn Volcker4e7aa432015-07-07 11:50:05 +0200631 virtual void UpdateHistogramsOnCallEnd() = 0;
632
Sam Zackrisson28127632018-11-01 11:37:15 +0100633 // Get audio processing statistics. The |has_remote_tracks| argument should be
634 // set if there are active remote tracks (this would usually be true during
635 // a call). If there are no remote tracks some of the stats will not be set by
636 // AudioProcessing, because they only make sense if there is at least one
637 // remote track.
638 virtual AudioProcessingStats GetStatistics(bool has_remote_tracks) const = 0;
Ivo Creusenae026092017-11-20 13:07:16 +0100639
henrik.lundinadf06352017-04-05 05:48:24 -0700640 // Returns the last applied configuration.
henrik.lundin77492862017-04-06 23:28:09 -0700641 virtual AudioProcessing::Config GetConfig() const = 0;
henrik.lundinadf06352017-04-05 05:48:24 -0700642
andrew@webrtc.org648af742012-02-08 01:57:29 +0000643 enum Error {
644 // Fatal errors.
niklase@google.com470e71d2011-07-07 08:21:25 +0000645 kNoError = 0,
646 kUnspecifiedError = -1,
647 kCreationFailedError = -2,
648 kUnsupportedComponentError = -3,
649 kUnsupportedFunctionError = -4,
650 kNullPointerError = -5,
651 kBadParameterError = -6,
652 kBadSampleRateError = -7,
653 kBadDataLengthError = -8,
654 kBadNumberChannelsError = -9,
655 kFileError = -10,
656 kStreamParameterNotSetError = -11,
andrew@webrtc.org648af742012-02-08 01:57:29 +0000657 kNotEnabledError = -12,
niklase@google.com470e71d2011-07-07 08:21:25 +0000658
andrew@webrtc.org648af742012-02-08 01:57:29 +0000659 // Warnings are non-fatal.
niklase@google.com470e71d2011-07-07 08:21:25 +0000660 // This results when a set_stream_ parameter is out of range. Processing
661 // will continue, but the parameter may have been truncated.
andrew@webrtc.org648af742012-02-08 01:57:29 +0000662 kBadStreamParameterWarning = -13
niklase@google.com470e71d2011-07-07 08:21:25 +0000663 };
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000664
Per Åhgrenc8626b62019-08-23 15:49:51 +0200665 // Native rates supported by the AudioFrame interfaces.
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000666 enum NativeRate {
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000667 kSampleRate8kHz = 8000,
668 kSampleRate16kHz = 16000,
aluebs@webrtc.org087da132014-11-17 23:01:23 +0000669 kSampleRate32kHz = 32000,
670 kSampleRate48kHz = 48000
andrew@webrtc.org56e4a052014-02-27 22:23:17 +0000671 };
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000672
kwibergd59d3bb2016-09-13 07:49:33 -0700673 // TODO(kwiberg): We currently need to support a compiler (Visual C++) that
674 // complains if we don't explicitly state the size of the array here. Remove
675 // the size when that's no longer the case.
676 static constexpr int kNativeSampleRatesHz[4] = {
677 kSampleRate8kHz, kSampleRate16kHz, kSampleRate32kHz, kSampleRate48kHz};
678 static constexpr size_t kNumNativeSampleRates =
679 arraysize(kNativeSampleRatesHz);
680 static constexpr int kMaxNativeSampleRateHz =
681 kNativeSampleRatesHz[kNumNativeSampleRates - 1];
Alejandro Luebscdfe20b2015-09-23 12:49:12 -0700682
andrew@webrtc.orgddbb8a22014-04-22 21:00:04 +0000683 static const int kChunkSizeMs = 10;
niklase@google.com470e71d2011-07-07 08:21:25 +0000684};
685
Mirko Bonadei3d255302018-10-11 10:50:45 +0200686class RTC_EXPORT AudioProcessingBuilder {
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100687 public:
688 AudioProcessingBuilder();
689 ~AudioProcessingBuilder();
690 // The AudioProcessingBuilder takes ownership of the echo_control_factory.
691 AudioProcessingBuilder& SetEchoControlFactory(
692 std::unique_ptr<EchoControlFactory> echo_control_factory);
693 // The AudioProcessingBuilder takes ownership of the capture_post_processing.
694 AudioProcessingBuilder& SetCapturePostProcessing(
695 std::unique_ptr<CustomProcessing> capture_post_processing);
696 // The AudioProcessingBuilder takes ownership of the render_pre_processing.
697 AudioProcessingBuilder& SetRenderPreProcessing(
698 std::unique_ptr<CustomProcessing> render_pre_processing);
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100699 // The AudioProcessingBuilder takes ownership of the echo_detector.
700 AudioProcessingBuilder& SetEchoDetector(
Ivo Creusend1f970d2018-06-14 11:02:03 +0200701 rtc::scoped_refptr<EchoDetector> echo_detector);
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200702 // The AudioProcessingBuilder takes ownership of the capture_analyzer.
703 AudioProcessingBuilder& SetCaptureAnalyzer(
704 std::unique_ptr<CustomAudioAnalyzer> capture_analyzer);
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100705 // This creates an APM instance using the previously set components. Calling
706 // the Create function resets the AudioProcessingBuilder to its initial state.
707 AudioProcessing* Create();
708 AudioProcessing* Create(const webrtc::Config& config);
709
710 private:
711 std::unique_ptr<EchoControlFactory> echo_control_factory_;
712 std::unique_ptr<CustomProcessing> capture_post_processing_;
713 std::unique_ptr<CustomProcessing> render_pre_processing_;
Ivo Creusend1f970d2018-06-14 11:02:03 +0200714 rtc::scoped_refptr<EchoDetector> echo_detector_;
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200715 std::unique_ptr<CustomAudioAnalyzer> capture_analyzer_;
Ivo Creusen5ec7e122017-12-22 11:35:59 +0100716 RTC_DISALLOW_COPY_AND_ASSIGN(AudioProcessingBuilder);
717};
718
Michael Graczyk86c6d332015-07-23 11:41:39 -0700719class StreamConfig {
720 public:
721 // sample_rate_hz: The sampling rate of the stream.
722 //
723 // num_channels: The number of audio channels in the stream, excluding the
724 // keyboard channel if it is present. When passing a
725 // StreamConfig with an array of arrays T*[N],
726 //
727 // N == {num_channels + 1 if has_keyboard
728 // {num_channels if !has_keyboard
729 //
730 // has_keyboard: True if the stream has a keyboard channel. When has_keyboard
731 // is true, the last channel in any corresponding list of
732 // channels is the keyboard channel.
733 StreamConfig(int sample_rate_hz = 0,
Peter Kasting69558702016-01-12 16:26:35 -0800734 size_t num_channels = 0,
Michael Graczyk86c6d332015-07-23 11:41:39 -0700735 bool has_keyboard = false)
736 : sample_rate_hz_(sample_rate_hz),
737 num_channels_(num_channels),
738 has_keyboard_(has_keyboard),
739 num_frames_(calculate_frames(sample_rate_hz)) {}
740
741 void set_sample_rate_hz(int value) {
742 sample_rate_hz_ = value;
743 num_frames_ = calculate_frames(value);
744 }
Peter Kasting69558702016-01-12 16:26:35 -0800745 void set_num_channels(size_t value) { num_channels_ = value; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700746 void set_has_keyboard(bool value) { has_keyboard_ = value; }
747
748 int sample_rate_hz() const { return sample_rate_hz_; }
749
750 // The number of channels in the stream, not including the keyboard channel if
751 // present.
Peter Kasting69558702016-01-12 16:26:35 -0800752 size_t num_channels() const { return num_channels_; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700753
754 bool has_keyboard() const { return has_keyboard_; }
Peter Kastingdce40cf2015-08-24 14:52:23 -0700755 size_t num_frames() const { return num_frames_; }
756 size_t num_samples() const { return num_channels_ * num_frames_; }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700757
758 bool operator==(const StreamConfig& other) const {
759 return sample_rate_hz_ == other.sample_rate_hz_ &&
760 num_channels_ == other.num_channels_ &&
761 has_keyboard_ == other.has_keyboard_;
762 }
763
764 bool operator!=(const StreamConfig& other) const { return !(*this == other); }
765
766 private:
Peter Kastingdce40cf2015-08-24 14:52:23 -0700767 static size_t calculate_frames(int sample_rate_hz) {
Yves Gerey665174f2018-06-19 15:03:05 +0200768 return static_cast<size_t>(AudioProcessing::kChunkSizeMs * sample_rate_hz /
769 1000);
Michael Graczyk86c6d332015-07-23 11:41:39 -0700770 }
771
772 int sample_rate_hz_;
Peter Kasting69558702016-01-12 16:26:35 -0800773 size_t num_channels_;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700774 bool has_keyboard_;
Peter Kastingdce40cf2015-08-24 14:52:23 -0700775 size_t num_frames_;
Michael Graczyk86c6d332015-07-23 11:41:39 -0700776};
777
778class ProcessingConfig {
779 public:
780 enum StreamName {
781 kInputStream,
782 kOutputStream,
ekmeyerson60d9b332015-08-14 10:35:55 -0700783 kReverseInputStream,
784 kReverseOutputStream,
Michael Graczyk86c6d332015-07-23 11:41:39 -0700785 kNumStreamNames,
786 };
787
788 const StreamConfig& input_stream() const {
789 return streams[StreamName::kInputStream];
790 }
791 const StreamConfig& output_stream() const {
792 return streams[StreamName::kOutputStream];
793 }
ekmeyerson60d9b332015-08-14 10:35:55 -0700794 const StreamConfig& reverse_input_stream() const {
795 return streams[StreamName::kReverseInputStream];
796 }
797 const StreamConfig& reverse_output_stream() const {
798 return streams[StreamName::kReverseOutputStream];
Michael Graczyk86c6d332015-07-23 11:41:39 -0700799 }
800
801 StreamConfig& input_stream() { return streams[StreamName::kInputStream]; }
802 StreamConfig& output_stream() { return streams[StreamName::kOutputStream]; }
ekmeyerson60d9b332015-08-14 10:35:55 -0700803 StreamConfig& reverse_input_stream() {
804 return streams[StreamName::kReverseInputStream];
805 }
806 StreamConfig& reverse_output_stream() {
807 return streams[StreamName::kReverseOutputStream];
808 }
Michael Graczyk86c6d332015-07-23 11:41:39 -0700809
810 bool operator==(const ProcessingConfig& other) const {
811 for (int i = 0; i < StreamName::kNumStreamNames; ++i) {
812 if (this->streams[i] != other.streams[i]) {
813 return false;
814 }
815 }
816 return true;
817 }
818
819 bool operator!=(const ProcessingConfig& other) const {
820 return !(*this == other);
821 }
822
823 StreamConfig streams[StreamName::kNumStreamNames];
824};
825
Valeriia Nemychnikovaf06eb572018-08-29 10:37:09 +0200826// Experimental interface for a custom analysis submodule.
827class CustomAudioAnalyzer {
828 public:
829 // (Re-) Initializes the submodule.
830 virtual void Initialize(int sample_rate_hz, int num_channels) = 0;
831 // Analyzes the given capture or render signal.
832 virtual void Analyze(const AudioBuffer* audio) = 0;
833 // Returns a string representation of the module state.
834 virtual std::string ToString() const = 0;
835
836 virtual ~CustomAudioAnalyzer() {}
837};
838
Alex Loiko5825aa62017-12-18 16:02:40 +0100839// Interface for a custom processing submodule.
840class CustomProcessing {
Sam Zackrisson0beac582017-09-25 12:04:02 +0200841 public:
842 // (Re-)Initializes the submodule.
843 virtual void Initialize(int sample_rate_hz, int num_channels) = 0;
844 // Processes the given capture or render signal.
845 virtual void Process(AudioBuffer* audio) = 0;
846 // Returns a string representation of the module state.
847 virtual std::string ToString() const = 0;
Alex Loiko73ec0192018-05-15 10:52:28 +0200848 // Handles RuntimeSettings. TODO(webrtc:9262): make pure virtual
849 // after updating dependencies.
850 virtual void SetRuntimeSetting(AudioProcessing::RuntimeSetting setting);
Sam Zackrisson0beac582017-09-25 12:04:02 +0200851
Alex Loiko5825aa62017-12-18 16:02:40 +0100852 virtual ~CustomProcessing() {}
Sam Zackrisson0beac582017-09-25 12:04:02 +0200853};
854
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100855// Interface for an echo detector submodule.
Ivo Creusend1f970d2018-06-14 11:02:03 +0200856class EchoDetector : public rtc::RefCountInterface {
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100857 public:
858 // (Re-)Initializes the submodule.
Ivo Creusen647ef092018-03-14 17:13:48 +0100859 virtual void Initialize(int capture_sample_rate_hz,
860 int num_capture_channels,
861 int render_sample_rate_hz,
862 int num_render_channels) = 0;
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100863
864 // Analysis (not changing) of the render signal.
865 virtual void AnalyzeRenderAudio(rtc::ArrayView<const float> render_audio) = 0;
866
867 // Analysis (not changing) of the capture signal.
868 virtual void AnalyzeCaptureAudio(
869 rtc::ArrayView<const float> capture_audio) = 0;
870
871 // Pack an AudioBuffer into a vector<float>.
872 static void PackRenderAudioBuffer(AudioBuffer* audio,
873 std::vector<float>* packed_buffer);
874
875 struct Metrics {
876 double echo_likelihood;
877 double echo_likelihood_recent_max;
878 };
879
880 // Collect current metrics from the echo detector.
881 virtual Metrics GetMetrics() const = 0;
Ivo Creusen09fa4b02018-01-11 16:08:54 +0100882};
883
niklase@google.com470e71d2011-07-07 08:21:25 +0000884} // namespace webrtc
885
Mirko Bonadei92ea95e2017-09-15 06:47:31 +0200886#endif // MODULES_AUDIO_PROCESSING_INCLUDE_AUDIO_PROCESSING_H_