#include "config.h"
#include "DatabaseTask.h"
#include "Database.h"
#include "Logging.h"
#include "SQLTransaction.h"
namespace WebCore {
DatabaseTaskSynchronizer::DatabaseTaskSynchronizer()
{
}
void DatabaseTaskSynchronizer::waitForTaskCompletion()
{
m_synchronousMutex.lock();
while (!m_taskCompleted)
m_synchronousCondition.wait(m_synchronousMutex);
m_synchronousMutex.unlock();
}
void DatabaseTaskSynchronizer::taskCompleted()
{
m_synchronousMutex.lock();
m_taskCompleted = true;
m_synchronousCondition.notifyOne();
m_synchronousMutex.unlock();
}
DatabaseTask::DatabaseTask(Database& database, DatabaseTaskSynchronizer* synchronizer)
: m_database(database)
, m_synchronizer(synchronizer)
{
}
DatabaseTask::~DatabaseTask()
{
ASSERT(m_complete || !m_synchronizer);
}
void DatabaseTask::performTask()
{
ASSERT(!m_complete);
LOG(StorageAPI, "Performing %s %p\n", debugTaskName(), this);
m_database.resetAuthorizer();
doPerformTask();
if (m_synchronizer)
m_synchronizer->taskCompleted();
#if !ASSERT_DISABLED
m_complete = true;
#endif
}
DatabaseOpenTask::DatabaseOpenTask(Database& database, bool setVersionInNewDatabase, DatabaseTaskSynchronizer& synchronizer, ExceptionOr<void>& result)
: DatabaseTask(database, &synchronizer)
, m_setVersionInNewDatabase(setVersionInNewDatabase)
, m_result(result)
{
}
void DatabaseOpenTask::doPerformTask()
{
m_result = isolatedCopy(database().performOpenAndVerify(m_setVersionInNewDatabase));
}
#if !LOG_DISABLED
const char* DatabaseOpenTask::debugTaskName() const
{
return "DatabaseOpenTask";
}
#endif
DatabaseCloseTask::DatabaseCloseTask(Database& database, DatabaseTaskSynchronizer& synchronizer)
: DatabaseTask(database, &synchronizer)
{
}
void DatabaseCloseTask::doPerformTask()
{
database().performClose();
}
#if !LOG_DISABLED
const char* DatabaseCloseTask::debugTaskName() const
{
return "DatabaseCloseTask";
}
#endif
DatabaseTransactionTask::DatabaseTransactionTask(RefPtr<SQLTransaction>&& transaction)
: DatabaseTask(transaction->database(), 0)
, m_transaction(WTFMove(transaction))
, m_didPerformTask(false)
{
}
DatabaseTransactionTask::~DatabaseTransactionTask()
{
if (!m_didPerformTask)
m_transaction->notifyDatabaseThreadIsShuttingDown();
}
void DatabaseTransactionTask::doPerformTask()
{
m_transaction->performNextStep();
m_didPerformTask = true;
}
#if !LOG_DISABLED
const char* DatabaseTransactionTask::debugTaskName() const
{
return "DatabaseTransactionTask";
}
#endif
DatabaseTableNamesTask::DatabaseTableNamesTask(Database& database, DatabaseTaskSynchronizer& synchronizer, Vector<String>& result)
: DatabaseTask(database, &synchronizer)
, m_result(result)
{
}
void DatabaseTableNamesTask::doPerformTask()
{
m_result = database().performGetTableNames();
}
#if !LOG_DISABLED
const char* DatabaseTableNamesTask::debugTaskName() const
{
return "DatabaseTableNamesTask";
}
#endif
}