#ifndef DatabaseProcess_h
#define DatabaseProcess_h
#if ENABLE(DATABASE_PROCESS)
#include "ChildProcess.h"
#include "UniqueIDBDatabaseIdentifier.h"
#include <wtf/NeverDestroyed.h>
class WorkQueue;
namespace WebKit {
class AsyncTask;
class DatabaseToWebProcessConnection;
class UniqueIDBDatabase;
class WebOriginDataManager;
struct DatabaseProcessCreationParameters;
class DatabaseProcess : public ChildProcess {
WTF_MAKE_NONCOPYABLE(DatabaseProcess);
friend class NeverDestroyed<DatabaseProcess>;
public:
static DatabaseProcess& shared();
~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(); }
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;
void didReceiveDatabaseProcessMessage(IPC::Connection*, IPC::MessageDecoder&);
void initializeDatabaseProcess(const DatabaseProcessCreationParameters&);
void createDatabaseToWebProcessConnection();
void postDatabaseTask(std::unique_ptr<AsyncTask>);
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;
std::unique_ptr<WebOriginDataManager> m_webOriginDataManager;
};
}
#endif // ENABLE(DATABASE_PROCESS)
#endif // DatabaseProcess_h