DatabaseToWebProcessConnection.cpp [plain text]
#include "config.h"
#include "DatabaseToWebProcessConnection.h"
#include "DatabaseProcessIDBConnection.h"
#include "DatabaseProcessIDBConnectionMessages.h"
#include "DatabaseToWebProcessConnectionMessages.h"
#include <wtf/RunLoop.h>
#if ENABLE(DATABASE_PROCESS)
namespace WebKit {
Ref<DatabaseToWebProcessConnection> DatabaseToWebProcessConnection::create(IPC::Connection::Identifier connectionIdentifier)
{
return adoptRef(*new DatabaseToWebProcessConnection(connectionIdentifier));
}
DatabaseToWebProcessConnection::DatabaseToWebProcessConnection(IPC::Connection::Identifier connectionIdentifier)
{
m_connection = IPC::Connection::createServerConnection(connectionIdentifier, *this);
m_connection->setOnlySendMessagesAsDispatchWhenWaitingForSyncReplyWhenProcessingSuchAMessage(true);
m_connection->open();
}
DatabaseToWebProcessConnection::~DatabaseToWebProcessConnection()
{
}
void DatabaseToWebProcessConnection::didReceiveMessage(IPC::Connection& connection, IPC::MessageDecoder& decoder)
{
if (decoder.messageReceiverName() == Messages::DatabaseToWebProcessConnection::messageReceiverName()) {
didReceiveDatabaseToWebProcessConnectionMessage(connection, decoder);
return;
}
if (decoder.messageReceiverName() == Messages::DatabaseProcessIDBConnection::messageReceiverName()) {
IDBConnectionMap::iterator backendIterator = m_idbConnections.find(decoder.destinationID());
if (backendIterator != m_idbConnections.end())
backendIterator->value->didReceiveDatabaseProcessIDBConnectionMessage(connection, decoder);
return;
}
ASSERT_NOT_REACHED();
}
void DatabaseToWebProcessConnection::didReceiveSyncMessage(IPC::Connection& connection, IPC::MessageDecoder& decoder, std::unique_ptr<IPC::MessageEncoder>& reply)
{
if (decoder.messageReceiverName() == Messages::DatabaseProcessIDBConnection::messageReceiverName()) {
IDBConnectionMap::iterator backendIterator = m_idbConnections.find(decoder.destinationID());
if (backendIterator != m_idbConnections.end())
backendIterator->value->didReceiveSyncDatabaseProcessIDBConnectionMessage(connection, decoder, reply);
return;
}
ASSERT_NOT_REACHED();
}
void DatabaseToWebProcessConnection::didClose(IPC::Connection&)
{
while (!m_idbConnections.isEmpty())
removeDatabaseProcessIDBConnection(m_idbConnections.begin()->key);
}
void DatabaseToWebProcessConnection::didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName)
{
}
void DatabaseToWebProcessConnection::establishIDBConnection(uint64_t serverConnectionIdentifier)
{
RefPtr<DatabaseProcessIDBConnection> idbConnection = DatabaseProcessIDBConnection::create(*this, serverConnectionIdentifier);
m_idbConnections.set(serverConnectionIdentifier, idbConnection.release());
}
void DatabaseToWebProcessConnection::removeDatabaseProcessIDBConnection(uint64_t serverConnectionIdentifier)
{
ASSERT(m_idbConnections.contains(serverConnectionIdentifier));
RefPtr<DatabaseProcessIDBConnection> idbConnection = m_idbConnections.take(serverConnectionIdentifier);
idbConnection->disconnectedFromWebProcess();
}
}
#endif // ENABLE(DATABASE_PROCESS)