WebToStorageProcessConnection.h [plain text]
#pragma once
#include "Connection.h"
#include "MessageSender.h"
#include "WebIDBConnectionToServer.h"
#include "WebSWClientConnection.h"
#include <WebCore/SWServer.h>
#include <pal/SessionID.h>
#include <wtf/RefCounted.h>
namespace PAL {
class SessionID;
}
namespace WebKit {
class WebToStorageProcessConnection : public RefCounted<WebToStorageProcessConnection>, private IPC::Connection::Client, private IPC::MessageSender {
public:
static Ref<WebToStorageProcessConnection> create(IPC::Connection::Identifier connectionIdentifier)
{
return adoptRef(*new WebToStorageProcessConnection(connectionIdentifier));
}
~WebToStorageProcessConnection();
IPC::Connection& connection() { return m_connection.get(); }
#if ENABLE(INDEXED_DATABASE)
WebIDBConnectionToServer* existingIDBConnectionToServerForIdentifier(uint64_t identifier) { return m_webIDBConnectionsByIdentifier.get(identifier); };
WebIDBConnectionToServer& idbConnectionToServerForSession(PAL::SessionID);
#endif
#if ENABLE(SERVICE_WORKER)
WebSWClientConnection* existingServiceWorkerConnectionForSession(PAL::SessionID sessionID) { return m_swConnectionsBySession.get(sessionID); }
WebSWClientConnection& serviceWorkerConnectionForSession(PAL::SessionID);
#endif
private:
WebToStorageProcessConnection(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;
IPC::Connection* messageSenderConnection() override { return m_connection.ptr(); }
uint64_t messageSenderDestinationID() override { return 0; }
Ref<IPC::Connection> m_connection;
#if ENABLE(INDEXED_DATABASE)
HashMap<PAL::SessionID, RefPtr<WebIDBConnectionToServer>> m_webIDBConnectionsBySession;
HashMap<uint64_t, RefPtr<WebIDBConnectionToServer>> m_webIDBConnectionsByIdentifier;
#endif
#if ENABLE(SERVICE_WORKER)
HashMap<PAL::SessionID, RefPtr<WebSWClientConnection>> m_swConnectionsBySession;
HashMap<WebCore::SWServerConnectionIdentifier, WebSWClientConnection*> m_swConnectionsByIdentifier;
#endif
};
}