WebAudioSourceProviderAVFObjC.h [plain text]
#ifndef WebAudioSourceProviderAVFObjC_h
#define WebAudioSourceProviderAVFObjC_h
#if ENABLE(WEB_AUDIO) && ENABLE(MEDIA_STREAM)
#include "AVAudioCaptureSource.h"
#include "AudioSourceProvider.h"
#include <wtf/Lock.h>
#include <wtf/RefCounted.h>
#include <wtf/RefPtr.h>
#include <wtf/RetainPtr.h>
typedef struct AudioBufferList AudioBufferList;
typedef struct OpaqueAudioConverter* AudioConverterRef;
typedef struct AudioStreamBasicDescription AudioStreamBasicDescription;
typedef const struct opaqueCMFormatDescription *CMFormatDescriptionRef;
typedef struct opaqueCMSampleBuffer *CMSampleBufferRef;
namespace WebCore {
class AVAudioCaptureSource;
class CARingBuffer;
class WebAudioSourceProviderAVFObjC : public RefCounted<WebAudioSourceProviderAVFObjC>, public AudioSourceProvider, public AVAudioCaptureSource::Observer {
public:
static Ref<WebAudioSourceProviderAVFObjC> create(AVAudioCaptureSource&);
virtual ~WebAudioSourceProviderAVFObjC();
private:
WebAudioSourceProviderAVFObjC(AVAudioCaptureSource&);
void startProducingData();
void stopProducingData();
void provideInput(AudioBus*, size_t) override;
void setClient(AudioSourceProviderClient*) override;
void prepare(const AudioStreamBasicDescription *) override;
void unprepare() override;
void process(CMFormatDescriptionRef, CMSampleBufferRef) override;
size_t m_listBufferSize { 0 };
std::unique_ptr<AudioBufferList> m_list;
AudioConverterRef m_converter;
std::unique_ptr<AudioStreamBasicDescription> m_inputDescription;
std::unique_ptr<AudioStreamBasicDescription> m_outputDescription;
std::unique_ptr<CARingBuffer> m_ringBuffer;
uint64_t m_writeAheadCount { 0 };
uint64_t m_writeCount { 0 };
uint64_t m_readCount { 0 };
AudioSourceProviderClient* m_client { nullptr };
AVAudioCaptureSource* m_captureSource { nullptr };
bool m_connected { false };
};
}
#endif
#endif