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 40#if ENABLE(NETWORK_PROCESS) 41 42using namespace WebCore; 43 44namespace WebKit { 45 46NetworkProcessConnection::NetworkProcessConnection(CoreIPC::Connection::Identifier connectionIdentifier) 47{ 48 m_connection = CoreIPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main()); 49 m_connection->open(); 50} 51 52NetworkProcessConnection::~NetworkProcessConnection() 53{ 54} 55 56void NetworkProcessConnection::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder) 57{ 58 if (decoder.messageReceiverName() == Messages::WebResourceLoader::messageReceiverName()) { 59 if (WebResourceLoader* webResourceLoader = WebProcess::shared().webResourceLoadScheduler().webResourceLoaderForIdentifier(decoder.destinationID())) 60 webResourceLoader->didReceiveWebResourceLoaderMessage(connection, decoder); 61 62 return; 63 } 64 65 didReceiveNetworkProcessConnectionMessage(connection, decoder); 66} 67 68void NetworkProcessConnection::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder, OwnPtr<CoreIPC::MessageEncoder>& replyEncoder) 69{ 70 ASSERT_NOT_REACHED(); 71} 72 73void NetworkProcessConnection::didClose(CoreIPC::Connection*) 74{ 75 // The NetworkProcess probably crashed. 76 WebProcess::shared().networkProcessConnectionClosed(this); 77} 78 79void NetworkProcessConnection::didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::StringReference, CoreIPC::StringReference) 80{ 81} 82 83void NetworkProcessConnection::didCacheResource(const ResourceRequest& request, const ShareableResource::Handle& handle) 84{ 85 CachedResource* resource = memoryCache()->resourceForRequest(request); 86 if (!resource) 87 return; 88 89 RefPtr<SharedBuffer> buffer = handle.tryWrapInSharedBuffer(); 90 if (!buffer) { 91 LOG_ERROR("Unabled to create SharedBuffer from ShareableResource handle for resource url %s", request.url().string().utf8().data()); 92 return; 93 } 94 95 resource->tryReplaceEncodedData(buffer.release()); 96} 97 98} // namespace WebKit 99 100#endif // ENABLE(NETWORK_PROCESS) 101