DatabaseToWebProcessConnection.h [plain text]
#ifndef DatabaseToWebProcessConnection_h
#define DatabaseToWebProcessConnection_h
#include "Connection.h"
#include "MessageSender.h"
#include <wtf/HashMap.h>
#if ENABLE(DATABASE_PROCESS)
namespace WebKit {
class WebIDBConnectionToClient;
class DatabaseToWebProcessConnection : public RefCounted<DatabaseToWebProcessConnection>, public IPC::Connection::Client, public IPC::MessageSender {
public:
static Ref<DatabaseToWebProcessConnection> create(IPC::Connection::Identifier);
~DatabaseToWebProcessConnection();
IPC::Connection& connection() { return m_connection.get(); }
private:
DatabaseToWebProcessConnection(IPC::Connection::Identifier);
void didReceiveMessage(IPC::Connection&, IPC::Decoder&) override;
void didReceiveSyncMessage(IPC::Connection&, IPC::Decoder&, std::unique_ptr<IPC::Encoder>&) override;
void didClose(IPC::Connection&) override;
void didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName) override;
void didReceiveDatabaseToWebProcessConnectionMessage(IPC::Connection&, IPC::Decoder&);
void didReceiveSyncDatabaseToWebProcessConnectionMessage(IPC::Connection&, IPC::Decoder&, std::unique_ptr<IPC::Encoder>&);
IPC::Connection* messageSenderConnection() override { return m_connection.ptr(); }
uint64_t messageSenderDestinationID() override { return 0; }
#if ENABLE(INDEXED_DATABASE)
void establishIDBConnectionToServer(uint64_t& serverConnectionIdentifier);
void removeIDBConnectionToServer(uint64_t serverConnectionIdentifier);
HashMap<uint64_t, RefPtr<WebIDBConnectionToClient>> m_webIDBConnections;
#endif // ENABLE(INDEXED_DATABASE)
Ref<IPC::Connection> m_connection;
};
}
#endif // ENABLE(DATABASE_PROCESS)
#endif // DatabaseToWebProcessConnection_h