WebToDatabaseProcessConnection.cpp [plain text]
#include "config.h"
#include "WebToDatabaseProcessConnection.h"
#include "DatabaseToWebProcessConnectionMessages.h"
#include "WebIDBServerConnection.h"
#include "WebIDBServerConnectionMessages.h"
#include "WebProcess.h"
#include <wtf/RunLoop.h>
#if ENABLE(INDEXED_DATABASE)
using namespace WebCore;
namespace WebKit {
WebToDatabaseProcessConnection::WebToDatabaseProcessConnection(IPC::Connection::Identifier connectionIdentifier)
{
m_connection = IPC::Connection::createClientConnection(connectionIdentifier, this, RunLoop::main());
m_connection->open();
}
WebToDatabaseProcessConnection::~WebToDatabaseProcessConnection()
{
}
void WebToDatabaseProcessConnection::didReceiveMessage(IPC::Connection* connection, IPC::MessageDecoder& decoder)
{
if (decoder.messageReceiverName() == Messages::WebIDBServerConnection::messageReceiverName()) {
HashMap<uint64_t, WebIDBServerConnection*>::iterator connectionIterator = m_webIDBServerConnections.find(decoder.destinationID());
if (connectionIterator != m_webIDBServerConnections.end())
connectionIterator->value->didReceiveWebIDBServerConnectionMessage(connection, decoder);
return;
}
ASSERT_NOT_REACHED();
}
void WebToDatabaseProcessConnection::didClose(IPC::Connection* connection)
{
WebProcess::shared().webToDatabaseProcessConnectionClosed(this);
}
void WebToDatabaseProcessConnection::didReceiveInvalidMessage(IPC::Connection*, IPC::StringReference messageReceiverName, IPC::StringReference messageName)
{
}
void WebToDatabaseProcessConnection::registerWebIDBServerConnection(WebIDBServerConnection& connection)
{
ASSERT(!m_webIDBServerConnections.contains(connection.messageSenderDestinationID()));
m_webIDBServerConnections.set(connection.messageSenderDestinationID(), &connection);
}
void WebToDatabaseProcessConnection::removeWebIDBServerConnection(WebIDBServerConnection& connection)
{
ASSERT(m_webIDBServerConnections.contains(connection.messageSenderDestinationID()));
send(Messages::DatabaseToWebProcessConnection::RemoveDatabaseProcessIDBConnection(connection.messageSenderDestinationID()));
m_webIDBServerConnections.remove(connection.messageSenderDestinationID());
}
}
#endif // ENABLE(INDEXED_DATABASE)