From 6882a04fb36642862b11efe514251d32070c3d65 Mon Sep 17 00:00:00 2001 From: Konstantin Tokarev Date: Thu, 25 Aug 2016 19:20:41 +0300 Subject: Imported QtWebKit TP3 (git b57bc6801f1876c3220d5a4bfea33d620d477443) Change-Id: I3b1d8a2808782c9f34d50240000e20cb38d3680f Reviewed-by: Konstantin Tokarev --- .../Databases/WebToDatabaseProcessConnection.cpp | 90 ++++++++++++++++++++++ 1 file changed, 90 insertions(+) create mode 100644 Source/WebKit2/WebProcess/Databases/WebToDatabaseProcessConnection.cpp (limited to 'Source/WebKit2/WebProcess/Databases/WebToDatabaseProcessConnection.cpp') diff --git a/Source/WebKit2/WebProcess/Databases/WebToDatabaseProcessConnection.cpp b/Source/WebKit2/WebProcess/Databases/WebToDatabaseProcessConnection.cpp new file mode 100644 index 000000000..fd51fdcde --- /dev/null +++ b/Source/WebKit2/WebProcess/Databases/WebToDatabaseProcessConnection.cpp @@ -0,0 +1,90 @@ +/* + * Copyright (C) 2013 Apple Inc. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY APPLE, INC. ``AS IS'' AND ANY + * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY + * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + * + */ + +#include "config.h" +#include "WebToDatabaseProcessConnection.h" + +#include "DatabaseToWebProcessConnectionMessages.h" +#include "WebIDBConnectionToServerMessages.h" +#include "WebProcess.h" +#include + +#if ENABLE(DATABASE_PROCESS) + +using namespace WebCore; + +namespace WebKit { + +WebToDatabaseProcessConnection::WebToDatabaseProcessConnection(IPC::Connection::Identifier connectionIdentifier) +{ + m_connection = IPC::Connection::createClientConnection(connectionIdentifier, *this); + m_connection->open(); +} + +WebToDatabaseProcessConnection::~WebToDatabaseProcessConnection() +{ +} + +void WebToDatabaseProcessConnection::didReceiveMessage(IPC::Connection& connection, IPC::MessageDecoder& decoder) +{ +#if ENABLE(INDEXED_DATABASE) + if (decoder.messageReceiverName() == Messages::WebIDBConnectionToServer::messageReceiverName()) { + auto iterator = m_webIDBConnectionsByIdentifier.find(decoder.destinationID()); + if (iterator != m_webIDBConnectionsByIdentifier.end()) + iterator->value->didReceiveMessage(connection, decoder); + return; + } +#endif + + ASSERT_NOT_REACHED(); +} + +void WebToDatabaseProcessConnection::didClose(IPC::Connection& connection) +{ + WebProcess::singleton().webToDatabaseProcessConnectionClosed(this); +} + +void WebToDatabaseProcessConnection::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName) +{ +} + +#if ENABLE(INDEXED_DATABASE) +WebIDBConnectionToServer& WebToDatabaseProcessConnection::idbConnectionToServerForSession(const SessionID& sessionID) +{ + auto result = m_webIDBConnectionsBySession.add(sessionID, nullptr); + if (result.isNewEntry) { + result.iterator->value = WebIDBConnectionToServer::create(); + ASSERT(!m_webIDBConnectionsByIdentifier.contains(result.iterator->value->identifier())); + m_webIDBConnectionsByIdentifier.set(result.iterator->value->identifier(), result.iterator->value); + } + + return *result.iterator->value; +} +#endif + +} // namespace WebKit + +#endif // ENABLE(DATABASE_PROCESS) -- cgit v1.2.1