#ifndef DatabaseProcess_h
#define DatabaseProcess_h
#if ENABLE(DATABASE_PROCESS)
#include "ChildProcess.h"
#include "UniqueIDBDatabaseIdentifier.h"
#include <wtf/NeverDestroyed.h>
namespace WebCore {
class SessionID;
}
namespace WebKit {
class AsyncTask;
class DatabaseToWebProcessConnection;
class UniqueIDBDatabase;
struct DatabaseProcessCreationParameters;
class DatabaseProcess : public ChildProcess {
WTF_MAKE_NONCOPYABLE(DatabaseProcess);
friend class NeverDestroyed<DatabaseProcess>;
public:
static DatabaseProcess& singleton();
~DatabaseProcess();
const String& indexedDatabaseDirectory() const { return m_indexedDatabaseDirectory; }
PassRefPtr<UniqueIDBDatabase> getOrCreateUniqueIDBDatabase(const UniqueIDBDatabaseIdentifier&);
void removeUniqueIDBDatabase(const UniqueIDBDatabase&);
void ensureIndexedDatabaseRelativePathExists(const String&);
String absoluteIndexedDatabasePathFromDatabaseRelativePath(const String&);
WorkQueue& queue() { return m_queue.get(); }
void postDatabaseTask(std::unique_ptr<AsyncTask>);
private:
DatabaseProcess();
virtual void initializeProcess(const ChildProcessInitializationParameters&) override;
virtual void initializeProcessName(const ChildProcessInitializationParameters&) override;
virtual void initializeSandbox(const ChildProcessInitializationParameters&, SandboxInitializationParameters&) override;
virtual void initializeConnection(IPC::Connection*) override;
virtual bool shouldTerminate() override;
virtual void didReceiveMessage(IPC::Connection&, IPC::MessageDecoder&) override;
virtual void didClose(IPC::Connection&) override;
virtual void didReceiveInvalidMessage(IPC::Connection&, IPC::StringReference messageReceiverName, IPC::StringReference messageName) override;
virtual IPC::ProcessType localProcessType() override { return IPC::ProcessType::Database; }
virtual IPC::ProcessType remoteProcessType() override { return IPC::ProcessType::UI; }
void didReceiveDatabaseProcessMessage(IPC::Connection&, IPC::MessageDecoder&);
void initializeDatabaseProcess(const DatabaseProcessCreationParameters&);
void createDatabaseToWebProcessConnection();
void fetchWebsiteData(WebCore::SessionID, uint64_t websiteDataTypes, uint64_t callbackID);
void deleteWebsiteData(WebCore::SessionID, uint64_t websiteDataTypes, std::chrono::system_clock::time_point modifiedSince, uint64_t callbackID);
void deleteWebsiteDataForOrigins(WebCore::SessionID, uint64_t websiteDataTypes, const Vector<SecurityOriginData>& origins, uint64_t callbackID);
Vector<RefPtr<WebCore::SecurityOrigin>> indexedDatabaseOrigins();
void deleteIndexedDatabaseEntriesForOrigins(const Vector<RefPtr<WebCore::SecurityOrigin>>&);
void deleteIndexedDatabaseEntriesModifiedSince(std::chrono::system_clock::time_point modifiedSince);
void performNextDatabaseTask();
void ensurePathExists(const String&);
Vector<RefPtr<DatabaseToWebProcessConnection>> m_databaseToWebProcessConnections;
Ref<WorkQueue> m_queue;
String m_indexedDatabaseDirectory;
HashMap<UniqueIDBDatabaseIdentifier, RefPtr<UniqueIDBDatabase>> m_idbDatabases;
Deque<std::unique_ptr<AsyncTask>> m_databaseTasks;
Mutex m_databaseTaskMutex;
};
}
#endif // ENABLE(DATABASE_PROCESS)
#endif // DatabaseProcess_h