NetworkProcessConnection.cpp [plain text]
#include "config.h"
#include "NetworkProcessConnection.h"
#include "DataReference.h"
#include "NetworkConnectionToWebProcessMessages.h"
#include "WebCoreArgumentCoders.h"
#include "WebProcess.h"
#include "WebResourceBuffer.h"
#include "WebResourceLoadScheduler.h"
#include "WebResourceLoaderMessages.h"
#include <WebCore/CachedResource.h>
#include <WebCore/MemoryCache.h>
#include <WebCore/ResourceBuffer.h>
#include <WebCore/SessionID.h>
#if ENABLE(NETWORK_PROCESS)
using namespace WebCore;
namespace WebKit {
NetworkProcessConnection::NetworkProcessConnection(IPC::Connection::Identifier connectionIdentifier)
{
m_connection = IPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main());
m_connection->open();
}
NetworkProcessConnection::~NetworkProcessConnection()
{
}
void NetworkProcessConnection::didReceiveMessage(IPC::Connection* connection, IPC::MessageDecoder& decoder)
{
if (decoder.messageReceiverName() == Messages::WebResourceLoader::messageReceiverName()) {
if (WebResourceLoader* webResourceLoader = WebProcess::shared().webResourceLoadScheduler().webResourceLoaderForIdentifier(decoder.destinationID()))
webResourceLoader->didReceiveWebResourceLoaderMessage(connection, decoder);
return;
}
didReceiveNetworkProcessConnectionMessage(connection, decoder);
}
void NetworkProcessConnection::didReceiveSyncMessage(IPC::Connection*, IPC::MessageDecoder&, std::unique_ptr<IPC::MessageEncoder>&)
{
ASSERT_NOT_REACHED();
}
void NetworkProcessConnection::didClose(IPC::Connection*)
{
WebProcess::shared().networkProcessConnectionClosed(this);
}
void NetworkProcessConnection::didReceiveInvalidMessage(IPC::Connection*, IPC::StringReference, IPC::StringReference)
{
}
#if ENABLE(SHAREABLE_RESOURCE)
void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle, SessionID sessionID)
{
CachedResource* resource = memoryCache()->resourceForRequest(request, sessionID);
if (!resource)
return;
RefPtr<SharedBuffer> buffer = handle.tryWrapInSharedBuffer();
if (!buffer) {
LOG_ERROR("Unable to create SharedBuffer from ShareableResource handle for resource url %s", request.url().string().utf8().data());
return;
}
resource->tryReplaceEncodedData(buffer.release());
}
#endif
}
#endif // ENABLE(NETWORK_PROCESS)