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>
#if ENABLE(NETWORK_PROCESS)
using namespace WebCore;
namespace WebKit {
NetworkProcessConnection::NetworkProcessConnection(CoreIPC::Connection::Identifier connectionIdentifier)
{
m_connection = CoreIPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main());
m_connection->open();
}
NetworkProcessConnection::~NetworkProcessConnection()
{
}
void NetworkProcessConnection::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::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(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder, OwnPtr<CoreIPC::MessageEncoder>& replyEncoder)
{
ASSERT_NOT_REACHED();
}
void NetworkProcessConnection::didClose(CoreIPC::Connection*)
{
WebProcess::shared().networkProcessConnectionClosed(this);
}
void NetworkProcessConnection::didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::StringReference, CoreIPC::StringReference)
{
}
void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle)
{
CachedResource* resource = memoryCache()->resourceForRequest(request);
if (!resource)
return;
RefPtr<SharedBuffer> buffer = handle.tryWrapInSharedBuffer();
if (!buffer) {
LOG_ERROR("Unabled to create SharedBuffer from ShareableResource handle for resource url %s", request.url().string().utf8().data());
return;
}
resource->tryReplaceEncodedData(buffer.release());
}
}
#endif // ENABLE(NETWORK_PROCESS)