#ifndef DatabaseThread_h
#define DatabaseThread_h
#if ENABLE(DATABASE)
#include <wtf/Deque.h>
#include <wtf/HashMap.h>
#include <wtf/HashSet.h>
#include <wtf/MessageQueue.h>
#include <wtf/OwnPtr.h>
#include <wtf/PassOwnPtr.h>
#include <wtf/PassRefPtr.h>
#include <wtf/RefPtr.h>
#include <wtf/Threading.h>
namespace WebCore {
class Database;
class DatabaseTask;
class DatabaseTaskSynchronizer;
class Document;
class SQLTransactionClient;
class SQLTransactionCoordinator;
class DatabaseThread : public ThreadSafeShared<DatabaseThread> {
public:
static PassRefPtr<DatabaseThread> create() { return adoptRef(new DatabaseThread); }
~DatabaseThread();
bool start();
void requestTermination(DatabaseTaskSynchronizer* cleanupSync);
bool terminationRequested() const;
void scheduleTask(PassOwnPtr<DatabaseTask>);
void scheduleImmediateTask(PassOwnPtr<DatabaseTask>); void unscheduleDatabaseTasks(Database*);
void recordDatabaseOpen(Database*);
void recordDatabaseClosed(Database*);
ThreadIdentifier getThreadID() { return m_threadID; }
SQLTransactionClient* transactionClient() { return m_transactionClient.get(); }
SQLTransactionCoordinator* transactionCoordinator() { return m_transactionCoordinator.get(); }
void setPaused(bool);
void handlePausedQueue();
private:
DatabaseThread();
static void* databaseThreadStart(void*);
void* databaseThread();
Mutex m_threadCreationMutex;
ThreadIdentifier m_threadID;
RefPtr<DatabaseThread> m_selfRef;
MessageQueue<DatabaseTask> m_queue;
MessageQueue<DatabaseTask> m_pausedQueue;
Mutex m_pausedMutex;
volatile bool m_paused;
typedef HashSet<RefPtr<Database> > DatabaseSet;
DatabaseSet m_openDatabaseSet;
OwnPtr<SQLTransactionClient> m_transactionClient;
OwnPtr<SQLTransactionCoordinator> m_transactionCoordinator;
DatabaseTaskSynchronizer* m_cleanupSync;
};
}
#endif // ENABLE(DATABASE)
#endif // DatabaseThread_h