RemoteAudioSourceProviderManager.h [plain text]
#pragma once
#if PLATFORM(COCOA) && ENABLE(GPU_PROCESS)
#include "Connection.h"
#include "SharedMemory.h"
#include "WebProcess.h"
#include <WebCore/CAAudioStreamDescription.h>
#include <WebCore/CARingBuffer.h>
#include <WebCore/MediaPlayerIdentifier.h>
#include <WebCore/WebAudioBufferList.h>
namespace WebKit {
class RemoteAudioSourceProvider;
class RemoteAudioSourceProviderManager : public IPC::Connection::WorkQueueMessageReceiver {
public:
static Ref<RemoteAudioSourceProviderManager> create() { return adoptRef(*new RemoteAudioSourceProviderManager()); }
~RemoteAudioSourceProviderManager();
void addProvider(Ref<RemoteAudioSourceProvider>&&);
void removeProvider(WebCore::MediaPlayerIdentifier);
void didReceiveMessage(IPC::Connection&, IPC::Decoder&);
private:
RemoteAudioSourceProviderManager();
void audioStorageChanged(WebCore::MediaPlayerIdentifier, const SharedMemory::IPCHandle&, const WebCore::CAAudioStreamDescription&, uint64_t numberOfFrames);
void audioSamplesAvailable(WebCore::MediaPlayerIdentifier, uint64_t startFrame, uint64_t numberOfFrames);
void setConnection(IPC::Connection*);
class RemoteAudio {
WTF_MAKE_FAST_ALLOCATED;
public:
explicit RemoteAudio(Ref<RemoteAudioSourceProvider>&&);
void setStorage(const SharedMemory::Handle&, const WebCore::CAAudioStreamDescription&, uint64_t numberOfFrames);
void audioSamplesAvailable(uint64_t startFrame, uint64_t numberOfFrames);
private:
Ref<RemoteAudioSourceProvider> m_provider;
WebCore::CAAudioStreamDescription m_description;
std::unique_ptr<WebCore::CARingBuffer> m_ringBuffer;
std::unique_ptr<WebCore::WebAudioBufferList> m_buffer;
};
Ref<WorkQueue> m_queue;
RefPtr<IPC::Connection> m_connection;
HashMap<WebCore::MediaPlayerIdentifier, std::unique_ptr<RemoteAudio>> m_providers;
};
}
#endif // PLATFORM(COCOA) && ENABLE(GPU_PROCESS)