RemoteMediaResourceManager.cpp [plain text]
#include "config.h"
#include "RemoteMediaResourceManager.h"
#if ENABLE(GPU_PROCESS)
#include "Connection.h"
#include "DataReference.h"
#include "RemoteMediaResource.h"
#include "RemoteMediaResourceIdentifier.h"
#include "WebCoreArgumentCoders.h"
#include <WebCore/ResourceRequest.h>
namespace WebKit {
using namespace WebCore;
RemoteMediaResourceManager::RemoteMediaResourceManager()
{
}
RemoteMediaResourceManager::~RemoteMediaResourceManager()
{
}
void RemoteMediaResourceManager::addMediaResource(RemoteMediaResourceIdentifier remoteMediaResourceIdentifier, RemoteMediaResource& remoteMediaResource)
{
ASSERT(!m_remoteMediaResources.contains(remoteMediaResourceIdentifier));
m_remoteMediaResources.add(remoteMediaResourceIdentifier, &remoteMediaResource);
}
void RemoteMediaResourceManager::removeMediaResource(RemoteMediaResourceIdentifier remoteMediaResourceIdentifier)
{
ASSERT(m_remoteMediaResources.contains(remoteMediaResourceIdentifier));
m_remoteMediaResources.remove(remoteMediaResourceIdentifier);
}
void RemoteMediaResourceManager::responseReceived(RemoteMediaResourceIdentifier id, const ResourceResponse& response, bool didPassAccessControlCheck, CompletionHandler<void(ShouldContinuePolicyCheck)>&& completionHandler)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready()) {
completionHandler(ShouldContinuePolicyCheck::No);
return;
}
resource->responseReceived(response, didPassAccessControlCheck, WTFMove(completionHandler));
}
void RemoteMediaResourceManager::redirectReceived(RemoteMediaResourceIdentifier id, ResourceRequest&& request, const ResourceResponse& response, CompletionHandler<void(WebCore::ResourceRequest&&)>&& completionHandler)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready()) {
completionHandler({ });
return;
}
resource->redirectReceived(WTFMove(request), response, WTFMove(completionHandler));
}
void RemoteMediaResourceManager::dataSent(RemoteMediaResourceIdentifier id, uint64_t bytesSent, uint64_t totalBytesToBeSent)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready())
return;
resource->dataSent(bytesSent, totalBytesToBeSent);
}
void RemoteMediaResourceManager::dataReceived(RemoteMediaResourceIdentifier id, const IPC::DataReference& data)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready())
return;
resource->dataReceived(reinterpret_cast<const char*>(data.data()), data.size());
}
void RemoteMediaResourceManager::accessControlCheckFailed(RemoteMediaResourceIdentifier id, const ResourceError& error)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready())
return;
resource->accessControlCheckFailed(error);
}
void RemoteMediaResourceManager::loadFailed(RemoteMediaResourceIdentifier id, const ResourceError& error)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready())
return;
resource->loadFailed(error);
}
void RemoteMediaResourceManager::loadFinished(RemoteMediaResourceIdentifier id, const NetworkLoadMetrics& metrics)
{
auto* resource = m_remoteMediaResources.get(id);
if (!resource || !resource->ready())
return;
resource->loadFinished(metrics);
}
}
#endif