UserMediaCaptureManager.h [plain text]
#pragma once
#if PLATFORM(COCOA) && ENABLE(MEDIA_STREAM)
#include "MessageReceiver.h"
#include "SharedMemory.h"
#include "WebProcessSupplement.h"
#include <WebCore/CaptureDeviceManager.h>
#include <WebCore/RealtimeMediaSource.h>
#include <WebCore/RealtimeMediaSourceFactory.h>
#include <wtf/HashMap.h>
namespace WebCore {
class CAAudioStreamDescription;
class RemoteVideoSample;
}
namespace WebKit {
class CrossProcessRealtimeAudioSource;
class WebProcess;
class UserMediaCaptureManager : public WebProcessSupplement, public IPC::MessageReceiver {
WTF_MAKE_FAST_ALLOCATED;
public:
explicit UserMediaCaptureManager(WebProcess&);
~UserMediaCaptureManager();
static const char* supplementName();
void didReceiveMessageFromGPUProcess(IPC::Connection& connection, IPC::Decoder& decoder) { didReceiveMessage(connection, decoder); }
private:
void initialize(const WebProcessCreationParameters&) final;
class AudioFactory : public WebCore::AudioCaptureFactory {
public:
explicit AudioFactory(UserMediaCaptureManager& manager) : m_manager(manager) { }
void setShouldCaptureInGPUProcess(bool value) { m_shouldCaptureInGPUProcess = value; }
private:
WebCore::CaptureSourceOrError createAudioCaptureSource(const WebCore::CaptureDevice&, String&& hashSalt, const WebCore::MediaConstraints*) final;
WebCore::CaptureDeviceManager& audioCaptureDeviceManager() final { return m_manager.m_noOpCaptureDeviceManager; }
#if PLATFORM(IOS_FAMILY)
void setAudioCapturePageState(bool interrupted, bool pageMuted) final;
#endif
UserMediaCaptureManager& m_manager;
bool m_shouldCaptureInGPUProcess { false };
};
class VideoFactory : public WebCore::VideoCaptureFactory {
public:
explicit VideoFactory(UserMediaCaptureManager& manager) : m_manager(manager) { }
private:
WebCore::CaptureSourceOrError createVideoCaptureSource(const WebCore::CaptureDevice& device, String&& hashSalt, const WebCore::MediaConstraints* constraints) final { return m_manager.createCaptureSource(device, WTFMove(hashSalt), constraints); }
WebCore::CaptureDeviceManager& videoCaptureDeviceManager() final { return m_manager.m_noOpCaptureDeviceManager; }
#if PLATFORM(IOS_FAMILY)
void setVideoCapturePageState(bool interrupted, bool pageMuted) final;
#endif
UserMediaCaptureManager& m_manager;
};
class DisplayFactory : public WebCore::DisplayCaptureFactory {
public:
explicit DisplayFactory(UserMediaCaptureManager& manager) : m_manager(manager) { }
private:
WebCore::CaptureSourceOrError createDisplayCaptureSource(const WebCore::CaptureDevice& device, const WebCore::MediaConstraints* constraints) final { return m_manager.createCaptureSource(device, { }, constraints); }
WebCore::CaptureDeviceManager& displayCaptureDeviceManager() final { return m_manager.m_noOpCaptureDeviceManager; }
UserMediaCaptureManager& m_manager;
};
WebCore::CaptureSourceOrError createCaptureSource(const WebCore::CaptureDevice&, String&&, const WebCore::MediaConstraints*, bool shouldCaptureInGPUProcess = false);
class NoOpCaptureDeviceManager : public WebCore::CaptureDeviceManager {
public:
NoOpCaptureDeviceManager() = default;
private:
const Vector<WebCore::CaptureDevice>& captureDevices() final
{
ASSERT_NOT_REACHED();
return m_emptyDevices;
}
Vector<WebCore::CaptureDevice> m_emptyDevices;
};
void didReceiveMessage(IPC::Connection&, IPC::Decoder&) final;
void captureFailed(uint64_t id);
void sourceStopped(uint64_t id);
void sourceEnded(uint64_t id);
void sourceMutedChanged(uint64_t id, bool muted);
void sourceSettingsChanged(uint64_t id, const WebCore::RealtimeMediaSourceSettings&);
void storageChanged(uint64_t id, const SharedMemory::Handle&, const WebCore::CAAudioStreamDescription&, uint64_t numberOfFrames);
void ringBufferFrameBoundsChanged(uint64_t id, uint64_t startFrame, uint64_t endFrame);
void audioSamplesAvailable(uint64_t id, MediaTime, uint64_t numberOfFrames, uint64_t startFrame, uint64_t endFrame);
void remoteVideoSampleAvailable(uint64_t id, WebCore::RemoteVideoSample&&);
void startProducingData(uint64_t);
void stopProducingData(uint64_t);
WebCore::RealtimeMediaSourceCapabilities capabilities(uint64_t);
void applyConstraints(uint64_t, const WebCore::MediaConstraints&);
void applyConstraintsSucceeded(uint64_t, const WebCore::RealtimeMediaSourceSettings&);
void applyConstraintsFailed(uint64_t, String&&, String&&);
class Source;
friend class Source;
void requestToEnd(uint64_t sourceID);
Ref<WebCore::RealtimeMediaSource> cloneSource(Source&);
Ref<WebCore::RealtimeMediaSource> cloneVideoSource(Source&);
HashMap<uint64_t, RefPtr<Source>> m_sources;
WebProcess& m_process;
NoOpCaptureDeviceManager m_noOpCaptureDeviceManager;
AudioFactory m_audioFactory;
VideoFactory m_videoFactory;
DisplayFactory m_displayFactory;
};
}
#endif