1/* 2 * Copyright (C) 2013 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. ``AS IS'' AND ANY 14 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 15 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR 17 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 18 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 19 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 20 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY 21 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 24 * 25 */ 26 27#include "config.h" 28#include "WebToDatabaseProcessConnection.h" 29 30#include "DatabaseToWebProcessConnectionMessages.h" 31#include "WebIDBServerConnection.h" 32#include "WebIDBServerConnectionMessages.h" 33#include "WebProcess.h" 34#include <wtf/RunLoop.h> 35 36#if ENABLE(INDEXED_DATABASE) 37 38using namespace WebCore; 39 40namespace WebKit { 41 42WebToDatabaseProcessConnection::WebToDatabaseProcessConnection(IPC::Connection::Identifier connectionIdentifier) 43{ 44 m_connection = IPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main()); 45 m_connection->open(); 46} 47 48WebToDatabaseProcessConnection::~WebToDatabaseProcessConnection() 49{ 50} 51 52void WebToDatabaseProcessConnection::didReceiveMessage(IPC::Connection* connection, IPC::MessageDecoder& decoder) 53{ 54 if (decoder.messageReceiverName() == Messages::WebIDBServerConnection::messageReceiverName()) { 55 HashMap<uint64_t, WebIDBServerConnection*>::iterator connectionIterator = m_webIDBServerConnections.find(decoder.destinationID()); 56 if (connectionIterator != m_webIDBServerConnections.end()) 57 connectionIterator->value->didReceiveWebIDBServerConnectionMessage(connection, decoder); 58 return; 59 } 60 61 ASSERT_NOT_REACHED(); 62} 63 64void WebToDatabaseProcessConnection::didClose(IPC::Connection* connection) 65{ 66 WebProcess::shared().webToDatabaseProcessConnectionClosed(this); 67} 68 69void WebToDatabaseProcessConnection::didReceiveInvalidMessage(IPC::Connection*, IPC::StringReference messageReceiverName, IPC::StringReference messageName) 70{ 71} 72 73void WebToDatabaseProcessConnection::registerWebIDBServerConnection(WebIDBServerConnection& connection) 74{ 75 ASSERT(!m_webIDBServerConnections.contains(connection.messageSenderDestinationID())); 76 m_webIDBServerConnections.set(connection.messageSenderDestinationID(), &connection); 77 78} 79 80void WebToDatabaseProcessConnection::removeWebIDBServerConnection(WebIDBServerConnection& connection) 81{ 82 ASSERT(m_webIDBServerConnections.contains(connection.messageSenderDestinationID())); 83 84 send(Messages::DatabaseToWebProcessConnection::RemoveDatabaseProcessIDBConnection(connection.messageSenderDestinationID())); 85 86 m_webIDBServerConnections.remove(connection.messageSenderDestinationID()); 87} 88 89} // namespace WebKit 90 91#endif // ENABLE(INDEXED_DATABASE) 92