RemoteAudioSourceProviderManager.cpp [plain text]
#include "config.h"
#include "RemoteAudioSourceProviderManager.h"
#include "GPUProcessConnection.h"
#include "Logging.h"
#include "RemoteAudioSourceProvider.h"
#include "RemoteAudioSourceProviderManagerMessages.h"
#include "SharedRingBufferStorage.h"
#include "WebProcess.h"
#if PLATFORM(COCOA) && ENABLE(GPU_PROCESS)
namespace WebKit {
using namespace WebCore;
RemoteAudioSourceProviderManager::RemoteAudioSourceProviderManager()
: m_queue(WorkQueue::create("RemoteAudioSourceProviderManager", WorkQueue::Type::Serial, WorkQueue::QOS::UserInteractive))
{
}
RemoteAudioSourceProviderManager::~RemoteAudioSourceProviderManager()
{
setConnection(nullptr);
}
void RemoteAudioSourceProviderManager::setConnection(IPC::Connection* connection)
{
if (m_connection == connection)
return;
if (m_connection)
m_connection->removeWorkQueueMessageReceiver(Messages::RemoteAudioSourceProviderManager::messageReceiverName());
m_connection = WTFMove(connection);
if (m_connection)
m_connection->addWorkQueueMessageReceiver(Messages::RemoteAudioSourceProviderManager::messageReceiverName(), m_queue, this);
}
void RemoteAudioSourceProviderManager::addProvider(Ref<RemoteAudioSourceProvider>&& provider)
{
ASSERT(WTF::isMainRunLoop());
setConnection(&WebProcess::singleton().ensureGPUProcessConnection().connection());
m_queue->dispatch([this, provider = WTFMove(provider)]() mutable {
auto identifier = provider->identifier();
ASSERT(!m_providers.contains(identifier));
m_providers.add(identifier, makeUnique<RemoteAudio>(WTFMove(provider)));
});
}
void RemoteAudioSourceProviderManager::removeProvider(MediaPlayerIdentifier identifier)
{
ASSERT(WTF::isMainRunLoop());
m_queue->dispatch([this, identifier] {
ASSERT(m_providers.contains(identifier));
m_providers.remove(identifier);
});
}
void RemoteAudioSourceProviderManager::audioStorageChanged(MediaPlayerIdentifier identifier, const SharedMemory::IPCHandle& ipcHandle, const WebCore::CAAudioStreamDescription& description, uint64_t numberOfFrames)
{
ASSERT(!WTF::isMainRunLoop());
auto iterator = m_providers.find(identifier);
if (iterator == m_providers.end()) {
RELEASE_LOG_ERROR(Media, "Unable to find provider %llu for storageChanged", identifier.toUInt64());
return;
}
iterator->value->setStorage(ipcHandle.handle, description, numberOfFrames);
}
void RemoteAudioSourceProviderManager::audioSamplesAvailable(MediaPlayerIdentifier identifier, uint64_t startFrame, uint64_t numberOfFrames)
{
ASSERT(!WTF::isMainRunLoop());
auto iterator = m_providers.find(identifier);
if (iterator == m_providers.end()) {
RELEASE_LOG_ERROR(Media, "Unable to find provider %llu for audioSamplesAvailable", identifier.toUInt64());
return;
}
iterator->value->audioSamplesAvailable(startFrame, numberOfFrames);
}
RemoteAudioSourceProviderManager::RemoteAudio::RemoteAudio(Ref<RemoteAudioSourceProvider>&& provider)
: m_provider(WTFMove(provider))
, m_ringBuffer(makeUnique<CARingBuffer>())
{
}
void RemoteAudioSourceProviderManager::RemoteAudio::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);
}
void RemoteAudioSourceProviderManager::RemoteAudio::audioSamplesAvailable(uint64_t startFrame, uint64_t numberOfFrames)
{
if (!m_buffer) {
RELEASE_LOG_ERROR(Media, "buffer for audio provider %llu is null", m_provider->identifier().toUInt64());
return;
}
if (!WebAudioBufferList::isSupportedDescription(m_description, numberOfFrames)) {
RELEASE_LOG_ERROR(Media, "Unable to support description with given number of frames for audio provider %llu", m_provider->identifier().toUInt64());
return;
}
m_buffer->setSampleCount(numberOfFrames);
m_ringBuffer->fetch(m_buffer->list(), numberOfFrames, startFrame);
m_provider->audioSamplesAvailable(*m_buffer, m_description, numberOfFrames);
}
}
#endif // PLATFORM(COCOA) && ENABLE(GPU_PROCESS)