diff options
author | Konstantin Tokarev <annulen@yandex.ru> | 2016-08-25 19:20:41 +0300 |
---|---|---|
committer | Konstantin Tokarev <annulen@yandex.ru> | 2017-02-02 12:30:55 +0000 |
commit | 6882a04fb36642862b11efe514251d32070c3d65 (patch) | |
tree | b7959826000b061fd5ccc7512035c7478742f7b0 /Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp | |
parent | ab6df191029eeeb0b0f16f127d553265659f739e (diff) | |
download | qtwebkit-6882a04fb36642862b11efe514251d32070c3d65.tar.gz |
Imported QtWebKit TP3 (git b57bc6801f1876c3220d5a4bfea33d620d477443)
Change-Id: I3b1d8a2808782c9f34d50240000e20cb38d3680f
Reviewed-by: Konstantin Tokarev <annulen@yandex.ru>
Diffstat (limited to 'Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp')
-rw-r--r-- | Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp | 36 |
1 files changed, 17 insertions, 19 deletions
diff --git a/Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp b/Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp index dfa859fce..5564f6a0b 100644 --- a/Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp +++ b/Source/WebKit2/WebProcess/Network/NetworkProcessConnection.cpp @@ -29,23 +29,21 @@ #include "DataReference.h" #include "NetworkConnectionToWebProcessMessages.h" #include "WebCoreArgumentCoders.h" +#include "WebLoaderStrategy.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) +#include <WebCore/SessionID.h> +#include <WebCore/SharedBuffer.h> using namespace WebCore; namespace WebKit { -NetworkProcessConnection::NetworkProcessConnection(CoreIPC::Connection::Identifier connectionIdentifier) +NetworkProcessConnection::NetworkProcessConnection(IPC::Connection::Identifier connectionIdentifier) { - m_connection = CoreIPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main()); + m_connection = IPC::Connection::createClientConnection(connectionIdentifier, *this); m_connection->open(); } @@ -53,10 +51,10 @@ NetworkProcessConnection::~NetworkProcessConnection() { } -void NetworkProcessConnection::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder) +void NetworkProcessConnection::didReceiveMessage(IPC::Connection& connection, IPC::MessageDecoder& decoder) { if (decoder.messageReceiverName() == Messages::WebResourceLoader::messageReceiverName()) { - if (WebResourceLoader* webResourceLoader = WebProcess::shared().webResourceLoadScheduler().webResourceLoaderForIdentifier(decoder.destinationID())) + if (WebResourceLoader* webResourceLoader = WebProcess::singleton().webLoaderStrategy().webResourceLoaderForIdentifier(decoder.destinationID())) webResourceLoader->didReceiveWebResourceLoaderMessage(connection, decoder); return; @@ -65,36 +63,36 @@ void NetworkProcessConnection::didReceiveMessage(CoreIPC::Connection* connection didReceiveNetworkProcessConnectionMessage(connection, decoder); } -void NetworkProcessConnection::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder, OwnPtr<CoreIPC::MessageEncoder>& replyEncoder) +void NetworkProcessConnection::didReceiveSyncMessage(IPC::Connection&, IPC::MessageDecoder&, std::unique_ptr<IPC::MessageEncoder>&) { ASSERT_NOT_REACHED(); } -void NetworkProcessConnection::didClose(CoreIPC::Connection*) +void NetworkProcessConnection::didClose(IPC::Connection&) { // The NetworkProcess probably crashed. - WebProcess::shared().networkProcessConnectionClosed(this); + WebProcess::singleton().networkProcessConnectionClosed(this); } -void NetworkProcessConnection::didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::StringReference, CoreIPC::StringReference) +void NetworkProcessConnection::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference, IPC::StringReference) { } -void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle) +#if ENABLE(SHAREABLE_RESOURCE) +void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle, SessionID sessionID) { - CachedResource* resource = memoryCache()->resourceForRequest(request); + CachedResource* resource = MemoryCache::singleton().resourceForRequest(request, sessionID); 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()); + LOG_ERROR("Unable to create SharedBuffer from ShareableResource handle for resource url %s", request.url().string().utf8().data()); return; } - resource->tryReplaceEncodedData(buffer.release()); + resource->tryReplaceEncodedData(*buffer); } +#endif } // namespace WebKit - -#endif // ENABLE(NETWORK_PROCESS) |