1/* 2 * Copyright (C) 2010, 2011, 2012 Apple Inc. All rights reserved. 3 * 4 * Redistribution and use in source and binary forms, with or without 5 * modification, are permitted provided that the following conditions 6 * are met: 7 * 1. Redistributions of source code must retain the above copyright 8 * notice, this list of conditions and the following disclaimer. 9 * 2. Redistributions in binary form must reproduce the above copyright 10 * notice, this list of conditions and the following disclaimer in the 11 * documentation and/or other materials provided with the distribution. 12 * 13 * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' 14 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, 15 * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS 17 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 18 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 19 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 20 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 21 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 22 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF 23 * THE POSSIBILITY OF SUCH DAMAGE. 24 */ 25 26#include "config.h" 27#include "NetworkProcessConnection.h" 28 29#include "DataReference.h" 30#include "NetworkConnectionToWebProcessMessages.h" 31#include "WebCoreArgumentCoders.h" 32#include "WebProcess.h" 33#include "WebResourceBuffer.h" 34#include "WebResourceLoadScheduler.h" 35#include "WebResourceLoaderMessages.h" 36#include <WebCore/CachedResource.h> 37#include <WebCore/MemoryCache.h> 38#include <WebCore/ResourceBuffer.h> 39#include <WebCore/SessionID.h> 40 41#if ENABLE(NETWORK_PROCESS) 42 43using namespace WebCore; 44 45namespace WebKit { 46 47NetworkProcessConnection::NetworkProcessConnection(IPC::Connection::Identifier connectionIdentifier) 48{ 49 m_connection = IPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main()); 50 m_connection->open(); 51} 52 53NetworkProcessConnection::~NetworkProcessConnection() 54{ 55} 56 57void NetworkProcessConnection::didReceiveMessage(IPC::Connection* connection, IPC::MessageDecoder& decoder) 58{ 59 if (decoder.messageReceiverName() == Messages::WebResourceLoader::messageReceiverName()) { 60 if (WebResourceLoader* webResourceLoader = WebProcess::shared().webResourceLoadScheduler().webResourceLoaderForIdentifier(decoder.destinationID())) 61 webResourceLoader->didReceiveWebResourceLoaderMessage(connection, decoder); 62 63 return; 64 } 65 66 didReceiveNetworkProcessConnectionMessage(connection, decoder); 67} 68 69void NetworkProcessConnection::didReceiveSyncMessage(IPC::Connection*, IPC::MessageDecoder&, std::unique_ptr<IPC::MessageEncoder>&) 70{ 71 ASSERT_NOT_REACHED(); 72} 73 74void NetworkProcessConnection::didClose(IPC::Connection*) 75{ 76 // The NetworkProcess probably crashed. 77 WebProcess::shared().networkProcessConnectionClosed(this); 78} 79 80void NetworkProcessConnection::didReceiveInvalidMessage(IPC::Connection*, IPC::StringReference, IPC::StringReference) 81{ 82} 83 84#if ENABLE(SHAREABLE_RESOURCE) 85void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle, SessionID sessionID) 86{ 87 CachedResource* resource = memoryCache()->resourceForRequest(request, sessionID); 88 if (!resource) 89 return; 90 91 RefPtr<SharedBuffer> buffer = handle.tryWrapInSharedBuffer(); 92 if (!buffer) { 93 LOG_ERROR("Unable to create SharedBuffer from ShareableResource handle for resource url %s", request.url().string().utf8().data()); 94 return; 95 } 96 97 resource->tryReplaceEncodedData(buffer.release()); 98} 99#endif 100 101} // namespace WebKit 102 103#endif // ENABLE(NETWORK_PROCESS) 104