RemoteAudioDestinationProxy.cpp [plain text]
#include "config.h"
#include "RemoteAudioDestinationProxy.h"
#if ENABLE(GPU_PROCESS) && ENABLE(WEB_AUDIO)
#include "GPUConnectionToWebProcess.h"
#include "GPUProcessConnection.h"
#include "RemoteAudioDestinationManager.h"
#include "RemoteAudioDestinationManagerMessages.h"
#include "RemoteAudioDestinationProxyMessages.h"
#include "WebProcess.h"
#include <WebCore/AudioBus.h>
#include <WebCore/AudioDestination.h>
namespace WebKit {
using AudioBus = WebCore::AudioBus;
using AudioDestination = WebCore::AudioDestination;
using AudioIOCallback = WebCore::AudioIOCallback;
std::unique_ptr<AudioDestination> RemoteAudioDestinationProxy::create(AudioIOCallback& callback,
const String& inputDeviceId, unsigned numberOfInputChannels, unsigned numberOfOutputChannels, float sampleRate)
{
return makeUnique<RemoteAudioDestinationProxy>(callback, inputDeviceId, numberOfInputChannels, numberOfOutputChannels, sampleRate);
}
RemoteAudioDestinationProxy::RemoteAudioDestinationProxy(AudioIOCallback& callback, const String& inputDeviceId, unsigned numberOfInputChannels, unsigned numberOfOutputChannels, float sampleRate)
: m_callback(callback)
, m_sampleRate(sampleRate)
{
RemoteAudioDestinationIdentifier destinationID;
auto& connection = WebProcess::singleton().ensureGPUProcessConnection();
connection.connection().sendSync(
Messages::RemoteAudioDestinationManager::CreateAudioDestination(inputDeviceId, numberOfInputChannels, numberOfOutputChannels, sampleRate),
Messages::RemoteAudioDestinationManager::CreateAudioDestination::Reply(destinationID), 0);
connection.messageReceiverMap().addMessageReceiver(Messages::RemoteAudioDestinationProxy::messageReceiverName(), destinationID.toUInt64(), *this);
m_destinationID = destinationID;
}
RemoteAudioDestinationProxy::~RemoteAudioDestinationProxy()
{
auto& connection = WebProcess::singleton().ensureGPUProcessConnection();
connection.messageReceiverMap().removeMessageReceiver(Messages::RemoteAudioDestinationProxy::messageReceiverName(), m_destinationID.toUInt64());
connection.connection().sendWithAsyncReply(
Messages::RemoteAudioDestinationManager::DeleteAudioDestination(m_destinationID), [] {
});
}
void RemoteAudioDestinationProxy::start()
{
WebProcess::singleton().ensureGPUProcessConnection().connection().sendSync(
Messages::RemoteAudioDestinationManager::StartAudioDestination(m_destinationID),
Messages::RemoteAudioDestinationManager::StartAudioDestination::Reply(m_isPlaying), 0);
}
void RemoteAudioDestinationProxy::stop()
{
WebProcess::singleton().ensureGPUProcessConnection().connection().sendSync(
Messages::RemoteAudioDestinationManager::StopAudioDestination(m_destinationID),
Messages::RemoteAudioDestinationManager::StopAudioDestination::Reply(m_isPlaying), 0);
}
void RemoteAudioDestinationProxy::renderBuffer(const WebKit::RemoteAudioBusData& audioBusData, CompletionHandler<void()>&& completionHandler)
{
ASSERT(audioBusData.framesToProcess);
ASSERT(audioBusData.channelBuffers.size());
auto audioBus = AudioBus::create(audioBusData.channelBuffers.size(), audioBusData.framesToProcess, false);
for (unsigned i = 0; i < audioBusData.channelBuffers.size(); ++i)
audioBus->setChannelMemory(i, (float*)audioBusData.channelBuffers[i]->data(), audioBusData.framesToProcess);
m_callback.render(0, audioBus.get(), audioBusData.framesToProcess);
completionHandler();
}
void RemoteAudioDestinationProxy::didChangeIsPlaying(bool isPlaying)
{
}
}
#endif // ENABLE(GPU_PROCESS) && ENABLE(WEB_AUDIO)