#include "config.h"
#include "DatabaseTask.h"
#include "Database.h"
#include "Logging.h"
namespace WebCore {
DatabaseTaskSynchronizer::DatabaseTaskSynchronizer()
: m_taskCompleted(false)
#ifndef NDEBUG
, m_hasCheckedForTermination(false)
#endif
{
}
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)
#if !LOG_DISABLED
, m_complete(false)
#endif
{
}
DatabaseTask::~DatabaseTask()
{
#if !LOG_DISABLED
ASSERT(m_complete || !m_synchronizer);
#endif
}
void DatabaseTask::performTask()
{
#if !LOG_DISABLED
ASSERT(!m_complete);
#endif
LOG(StorageAPI, "Performing %s %p\n", debugTaskName(), this);
m_database.resetAuthorizer();
doPerformTask();
if (m_synchronizer)
m_synchronizer->taskCompleted();
#if !LOG_DISABLED
m_complete = true;
#endif
}
DatabaseOpenTask::DatabaseOpenTask(Database& database, bool setVersionInNewDatabase, DatabaseTaskSynchronizer& synchronizer, DatabaseError& error, String& errorMessage, bool& success)
: DatabaseTask(database, &synchronizer)
, m_setVersionInNewDatabase(setVersionInNewDatabase)
, m_error(error)
, m_errorMessage(errorMessage)
, m_success(success)
{
}
void DatabaseOpenTask::doPerformTask()
{
String errorMessage;
m_success = database().performOpenAndVerify(m_setVersionInNewDatabase, m_error, errorMessage);
if (!m_success)
m_errorMessage = errorMessage.isolatedCopy();
}
#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<SQLTransactionBackend>&& 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>& names)
: DatabaseTask(database, &synchronizer)
, m_tableNames(names)
{
}
void DatabaseTableNamesTask::doPerformTask()
{
m_tableNames = database().performGetTableNames();
}
#if !LOG_DISABLED
const char* DatabaseTableNamesTask::debugTaskName() const
{
return "DatabaseTableNamesTask";
}
#endif
}