WebDatabaseProvider.cpp [plain text]
#include "config.h"
#include "WebDatabaseProvider.h"
#include "WebProcess.h"
#include "WebToDatabaseProcessConnection.h"
#include <WebCore/SessionID.h>
#include <wtf/HashMap.h>
#include <wtf/NeverDestroyed.h>
using namespace WebCore;
namespace WebKit {
static HashMap<uint64_t, WebDatabaseProvider*>& databaseProviders()
{
static NeverDestroyed<HashMap<uint64_t, WebDatabaseProvider*>> databaseProviders;
return databaseProviders;
}
Ref<WebDatabaseProvider> WebDatabaseProvider::getOrCreate(uint64_t identifier)
{
auto& slot = databaseProviders().add(identifier, nullptr).iterator->value;
if (slot)
return *slot;
Ref<WebDatabaseProvider> databaseProvider = adoptRef(*new WebDatabaseProvider(identifier));
slot = databaseProvider.ptr();
return databaseProvider;
}
WebDatabaseProvider::WebDatabaseProvider(uint64_t identifier)
: m_identifier(identifier)
{
}
WebDatabaseProvider::~WebDatabaseProvider()
{
ASSERT(databaseProviders().contains(m_identifier));
databaseProviders().remove(m_identifier);
}
#if ENABLE(INDEXED_DATABASE)
WebCore::IDBClient::IDBConnectionToServer& WebDatabaseProvider::idbConnectionToServerForSession(const WebCore::SessionID& sessionID)
{
if (sessionID.isEphemeral()) {
auto result = m_idbEphemeralConnectionMap.add(sessionID.sessionID(), nullptr);
if (result.isNewEntry)
result.iterator->value = WebCore::InProcessIDBServer::create();
return result.iterator->value->connectionToServer();
}
ASSERT(WebProcess::singleton().webToDatabaseProcessConnection());
return WebProcess::singleton().webToDatabaseProcessConnection()->idbConnectionToServerForSession(sessionID).coreConnectionToServer();
}
#endif
}