diff options
Diffstat (limited to 'webrtc/modules/audio_processing/echo_control_mobile_impl.h')
-rw-r--r-- | webrtc/modules/audio_processing/echo_control_mobile_impl.h | 40 |
1 files changed, 33 insertions, 7 deletions
diff --git a/webrtc/modules/audio_processing/echo_control_mobile_impl.h b/webrtc/modules/audio_processing/echo_control_mobile_impl.h index da7022545f..4d6529d3ac 100644 --- a/webrtc/modules/audio_processing/echo_control_mobile_impl.h +++ b/webrtc/modules/audio_processing/echo_control_mobile_impl.h @@ -11,19 +11,23 @@ #ifndef WEBRTC_MODULES_AUDIO_PROCESSING_ECHO_CONTROL_MOBILE_IMPL_H_ #define WEBRTC_MODULES_AUDIO_PROCESSING_ECHO_CONTROL_MOBILE_IMPL_H_ +#include "webrtc/base/criticalsection.h" +#include "webrtc/base/scoped_ptr.h" +#include "webrtc/common_audio/swap_queue.h" #include "webrtc/modules/audio_processing/include/audio_processing.h" #include "webrtc/modules/audio_processing/processing_component.h" namespace webrtc { class AudioBuffer; -class CriticalSectionWrapper; class EchoControlMobileImpl : public EchoControlMobile, public ProcessingComponent { public: EchoControlMobileImpl(const AudioProcessing* apm, - CriticalSectionWrapper* crit); + rtc::CriticalSection* crit_render, + rtc::CriticalSection* crit_capture); + virtual ~EchoControlMobileImpl(); int ProcessRenderAudio(const AudioBuffer* audio); @@ -37,6 +41,9 @@ class EchoControlMobileImpl : public EchoControlMobile, // ProcessingComponent implementation. int Initialize() override; + // Reads render side data that has been queued on the render call. + void ReadQueuedRenderData(); + private: // EchoControlMobile implementation. int Enable(bool enable) override; @@ -46,18 +53,37 @@ class EchoControlMobileImpl : public EchoControlMobile, int GetEchoPath(void* echo_path, size_t size_bytes) const override; // ProcessingComponent implementation. + // Called holding both the render and capture locks. void* CreateHandle() const override; int InitializeHandle(void* handle) const override; int ConfigureHandle(void* handle) const override; void DestroyHandle(void* handle) const override; - int num_handles_required() const override; + size_t num_handles_required() const override; int GetHandleError(void* handle) const override; + void AllocateRenderQueue(); + + // Not guarded as its public API is thread safe. const AudioProcessing* apm_; - CriticalSectionWrapper* crit_; - RoutingMode routing_mode_; - bool comfort_noise_enabled_; - unsigned char* external_echo_path_; + + rtc::CriticalSection* const crit_render_ ACQUIRED_BEFORE(crit_capture_); + rtc::CriticalSection* const crit_capture_; + + RoutingMode routing_mode_ GUARDED_BY(crit_capture_); + bool comfort_noise_enabled_ GUARDED_BY(crit_capture_); + unsigned char* external_echo_path_ GUARDED_BY(crit_render_) + GUARDED_BY(crit_capture_); + + size_t render_queue_element_max_size_ GUARDED_BY(crit_render_) + GUARDED_BY(crit_capture_); + + std::vector<int16_t> render_queue_buffer_ GUARDED_BY(crit_render_); + std::vector<int16_t> capture_queue_buffer_ GUARDED_BY(crit_capture_); + + // Lock protection not needed. + rtc::scoped_ptr< + SwapQueue<std::vector<int16_t>, RenderQueueItemVerifier<int16_t>>> + render_signal_queue_; }; } // namespace webrtc |