RemoteAudioSourceProviderProxy.cpp [plain text]
#include "config.h"
#include "RemoteAudioSourceProviderProxy.h"
#if ENABLE(GPU_PROCESS) && ENABLE(WEB_AUDIO) && PLATFORM(COCOA)
#include "RemoteAudioSourceProviderManagerMessages.h"
#include <WebCore/AudioSourceProviderAVFObjC.h>
namespace WebKit {
Ref<RemoteAudioSourceProviderProxy> RemoteAudioSourceProviderProxy::create(WebCore::MediaPlayerIdentifier identifier, Ref<IPC::Connection>&& connection, AudioSourceProviderAVFObjC& localProvider)
{
auto remoteProvider = adoptRef(*new RemoteAudioSourceProviderProxy(identifier, WTFMove(connection)));
localProvider.setRingBufferCreationCallback([remoteProvider]() {
return remoteProvider->createRingBuffer();
});
localProvider.setAudioCallback([remoteProvider](auto startFrame, auto numberOfFrames) {
remoteProvider->newAudioSamples(startFrame, numberOfFrames);
});
return remoteProvider;
}
RemoteAudioSourceProviderProxy::RemoteAudioSourceProviderProxy(WebCore::MediaPlayerIdentifier identifier, Ref<IPC::Connection>&& connection)
: m_identifier(identifier)
, m_connection(WTFMove(connection))
{
}
RemoteAudioSourceProviderProxy::~RemoteAudioSourceProviderProxy() = default;
UniqueRef<CARingBuffer> RemoteAudioSourceProviderProxy::createRingBuffer()
{
return makeUniqueRef<CARingBuffer>(makeUniqueRef<SharedRingBufferStorage>([protectedThis = makeRef(*this)](SharedMemory* memory, const CAAudioStreamDescription& format, size_t frameCount) mutable {
protectedThis->storageChanged(memory, format, frameCount);
}));
}
void RemoteAudioSourceProviderProxy::newAudioSamples(uint64_t startFrame, uint64_t numberOfFrames)
{
m_connection->send(Messages::RemoteAudioSourceProviderManager::AudioSamplesAvailable { m_identifier, startFrame, numberOfFrames }, 0);
}
void RemoteAudioSourceProviderProxy::storageChanged(SharedMemory* memory, const CAAudioStreamDescription& format, size_t frameCount)
{
SharedMemory::Handle handle;
if (memory)
memory->createHandle(handle, SharedMemory::Protection::ReadOnly);
#if OS(DARWIN) || OS(WINDOWS)
uint64_t dataSize = handle.size();
#else
uint64_t dataSize = 0;
#endif
m_connection->send(Messages::RemoteAudioSourceProviderManager::AudioStorageChanged { m_identifier, SharedMemory::IPCHandle { WTFMove(handle), dataSize }, format, frameCount }, 0);
}
}
#endif // ENABLE(GPU_PROCESS) && ENABLE(WEB_AUDIO) && PLATFORM(COCOA)