RemoteLegacyCDMSession.cpp [plain text]
#include "config.h"
#include "RemoteLegacyCDMSession.h"
#if ENABLE(GPU_PROCESS) && ENABLE(LEGACY_ENCRYPTED_MEDIA)
#include "GPUProcessConnection.h"
#include "RemoteLegacyCDMFactory.h"
#include "RemoteLegacyCDMSessionProxyMessages.h"
#include "SharedBufferCopy.h"
#include <JavaScriptCore/GenericTypedArrayViewInlines.h>
#include <JavaScriptCore/JSGenericTypedArrayViewInlines.h>
#include <JavaScriptCore/TypedArrayType.h>
namespace WebKit {
using namespace WebCore;
static RefPtr<ArrayBuffer> convertToArrayBuffer(IPC::SharedBufferCopy&& buffer)
{
if (buffer.buffer())
return ArrayBuffer::create(buffer.data(), buffer.size());
return nullptr;
}
static RefPtr<Uint8Array> convertToUint8Array(IPC::SharedBufferCopy&& buffer)
{
auto arrayBuffer = convertToArrayBuffer(WTFMove(buffer));
if (!arrayBuffer)
return nullptr;
size_t sizeInBytes = arrayBuffer->byteLength();
return Uint8Array::create(WTFMove(arrayBuffer), 0, sizeInBytes);
}
template <typename T>
static IPC::SharedBufferCopy convertToSharedBufferCopy(T array)
{
if (!array)
return { };
return { SharedBuffer::create(array->data(), array->byteLength()) };
}
std::unique_ptr<RemoteLegacyCDMSession> RemoteLegacyCDMSession::create(WeakPtr<RemoteLegacyCDMFactory> factory, RemoteLegacyCDMSessionIdentifier&& identifier)
{
return std::unique_ptr<RemoteLegacyCDMSession>(new RemoteLegacyCDMSession(WTFMove(factory), WTFMove(identifier)));
}
RemoteLegacyCDMSession::RemoteLegacyCDMSession(WeakPtr<RemoteLegacyCDMFactory> factory, RemoteLegacyCDMSessionIdentifier&& identifier)
: m_factory(WTFMove(factory))
, m_identifier(WTFMove(identifier))
{
}
RefPtr<Uint8Array> RemoteLegacyCDMSession::generateKeyRequest(const String& mimeType, Uint8Array* initData, String& destinationURL, unsigned short& errorCode, uint32_t& systemCode)
{
if (!m_factory || !initData)
return nullptr;
auto ipcInitData = convertToSharedBufferCopy(initData);
Optional<IPC::SharedBufferCopy> ipcNextMessage;
m_factory->gpuProcessConnection().connection().sendSync(Messages::RemoteLegacyCDMSessionProxy::GenerateKeyRequest(mimeType, ipcInitData), Messages::RemoteLegacyCDMSessionProxy::GenerateKeyRequest::Reply(ipcNextMessage, destinationURL, errorCode, systemCode), m_identifier);
if (!ipcNextMessage)
return nullptr;
return convertToUint8Array(WTFMove(*ipcNextMessage));
}
void RemoteLegacyCDMSession::releaseKeys()
{
if (!m_factory)
return;
m_factory->gpuProcessConnection().connection().send(Messages::RemoteLegacyCDMSessionProxy::ReleaseKeys(), m_identifier);
m_cachedKeyCache.clear();
}
bool RemoteLegacyCDMSession::update(Uint8Array* keyData, RefPtr<Uint8Array>& nextMessage, unsigned short& errorCode, uint32_t& systemCode)
{
if (!m_factory || !keyData)
return false;
auto ipcKeyData = convertToSharedBufferCopy(WTFMove(keyData));
bool succeeded { false };
Optional<IPC::SharedBufferCopy> ipcNextMessage;
m_factory->gpuProcessConnection().connection().sendSync(Messages::RemoteLegacyCDMSessionProxy::Update(ipcKeyData), Messages::RemoteLegacyCDMSessionProxy::Update::Reply(succeeded, ipcNextMessage, errorCode, systemCode), m_identifier);
if (ipcNextMessage)
nextMessage = convertToUint8Array(WTFMove(*ipcNextMessage));
return false;
}
RefPtr<ArrayBuffer> RemoteLegacyCDMSession::cachedKeyForKeyID(const String& keyId) const
{
if (!m_factory)
return nullptr;
auto foundInCache = m_cachedKeyCache.find(keyId);
if (foundInCache != m_cachedKeyCache.end())
return foundInCache->value;
Optional<IPC::SharedBufferCopy> ipcKey;
m_factory->gpuProcessConnection().connection().sendSync(Messages::RemoteLegacyCDMSessionProxy::CachedKeyForKeyID(keyId), Messages::RemoteLegacyCDMSessionProxy::CachedKeyForKeyID::Reply(ipcKey), m_identifier);
if (!ipcKey)
return nullptr;
auto ipcKeyBuffer = convertToArrayBuffer(WTFMove(*ipcKey));
m_cachedKeyCache.set(keyId, ipcKeyBuffer);
return ipcKeyBuffer;
}
void RemoteLegacyCDMSession::sendMessage(Optional<IPC::SharedBufferCopy>&& message, const String& destinationURL)
{
if (!m_client)
return;
if (!message) {
m_client->sendMessage(nullptr, destinationURL);
return;
}
m_client->sendMessage(convertToUint8Array(WTFMove(*message)).get(), destinationURL);
}
void RemoteLegacyCDMSession::sendError(WebCore::LegacyCDMSessionClient::MediaKeyErrorCode errorCode, uint32_t systemCode)
{
if (m_client)
m_client->sendError(errorCode, systemCode);
}
}
#endif