StorageToWebProcessConnection.h [plain text]
#pragma once
#include "Connection.h"
#include "MessageSender.h"
#include <WebCore/SWServer.h>
#include <pal/SessionID.h>
#include <wtf/HashMap.h>
namespace WebKit {
class WebIDBConnectionToClient;
class WebSWServerConnection;
class WebSWServerToContextConnection;
class StorageToWebProcessConnection : public RefCounted<StorageToWebProcessConnection>, private IPC::Connection::Client, private IPC::MessageSender {
public:
static Ref<StorageToWebProcessConnection> create(IPC::Connection::Identifier);
~StorageToWebProcessConnection();
IPC::Connection& connection() { return m_connection.get(); }
private:
StorageToWebProcessConnection(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 didReceiveStorageToWebProcessConnectionMessage(IPC::Connection&, IPC::Decoder&);
void didReceiveSyncStorageToWebProcessConnectionMessage(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(PAL::SessionID, uint64_t& serverConnectionIdentifier);
void removeIDBConnectionToServer(uint64_t serverConnectionIdentifier);
HashMap<uint64_t, RefPtr<WebIDBConnectionToClient>> m_webIDBConnections;
#endif // ENABLE(INDEXED_DATABASE)
#if ENABLE(SERVICE_WORKER)
void establishSWServerConnection(PAL::SessionID, WebCore::SWServerConnectionIdentifier&);
void unregisterSWConnections();
HashMap<WebCore::SWServerConnectionIdentifier, WeakPtr<WebSWServerConnection>> m_swConnections;
#endif
Ref<IPC::Connection> m_connection;
};
}