SpeechRecognitionRemoteRealtimeMediaSource.cpp [plain text]
#include "config.h"
#include "SpeechRecognitionRemoteRealtimeMediaSource.h"
#if ENABLE(MEDIA_STREAM)
#include "SpeechRecognitionRealtimeMediaSourceManagerMessages.h"
#include "SpeechRecognitionRemoteRealtimeMediaSourceManager.h"
#if PLATFORM(COCOA)
#include "SharedRingBufferStorage.h"
#endif
namespace WebKit {
Ref<WebCore::RealtimeMediaSource> SpeechRecognitionRemoteRealtimeMediaSource::create(SpeechRecognitionRemoteRealtimeMediaSourceManager& manager, const WebCore::CaptureDevice& captureDevice)
{
return adoptRef(*new SpeechRecognitionRemoteRealtimeMediaSource(WebCore::RealtimeMediaSourceIdentifier::generate(), manager, captureDevice));
}
SpeechRecognitionRemoteRealtimeMediaSource::SpeechRecognitionRemoteRealtimeMediaSource(WebCore::RealtimeMediaSourceIdentifier identifier, SpeechRecognitionRemoteRealtimeMediaSourceManager& manager, const WebCore::CaptureDevice& captureDevice)
: WebCore::RealtimeMediaSource(WebCore::RealtimeMediaSource::Type::Audio, String { captureDevice.label() }, String { captureDevice.persistentId() })
, m_identifier(identifier)
, m_manager(makeWeakPtr(manager))
#if PLATFORM(COCOA)
, m_ringBuffer(makeUnique<CARingBuffer>())
#endif
{
m_manager->addSource(*this, captureDevice);
}
SpeechRecognitionRemoteRealtimeMediaSource::~SpeechRecognitionRemoteRealtimeMediaSource()
{
if (m_manager)
m_manager->removeSource(*this);
}
void SpeechRecognitionRemoteRealtimeMediaSource::startProducingData()
{
if (m_manager)
m_manager->send(Messages::SpeechRecognitionRealtimeMediaSourceManager::Start { m_identifier });
}
void SpeechRecognitionRemoteRealtimeMediaSource::stopProducingData()
{
if (m_manager)
m_manager->send(Messages::SpeechRecognitionRealtimeMediaSourceManager::Stop { m_identifier });
}
#if PLATFORM(COCOA)
void SpeechRecognitionRemoteRealtimeMediaSource::setStorage(const SharedMemory::Handle& handle, const WebCore::CAAudioStreamDescription& description, uint64_t numberOfFrames)
{
m_description = description;
m_ringBuffer = makeUnique<CARingBuffer>(makeUniqueRef<ReadOnlySharedRingBufferStorage>(handle), description, numberOfFrames);
m_buffer = makeUnique<WebAudioBufferList>(description, numberOfFrames);
}
#endif
void SpeechRecognitionRemoteRealtimeMediaSource::remoteAudioSamplesAvailable(MediaTime time, uint64_t numberOfFrames)
{
#if PLATFORM(COCOA)
if (!m_buffer) {
LOG_ERROR("Buffer for remote source is null");
captureFailed();
return;
}
m_buffer->setSampleCount(numberOfFrames);
m_ringBuffer->fetch(m_buffer->list(), numberOfFrames, time.timeValue());
audioSamplesAvailable(time, *m_buffer, m_description, numberOfFrames);
#else
UNUSED_PARAM(time);
UNUSED_PARAM(numberOfFrames);
#endif
}
void SpeechRecognitionRemoteRealtimeMediaSource::remoteCaptureFailed()
{
captureFailed();
}
void SpeechRecognitionRemoteRealtimeMediaSource::remoteSourceStopped()
{
stop();
}
}
#endif