#include "config.h"
#include "DatabaseTask.h"
#if ENABLE(DATABASE)
#include "Database.h"
#include "Logging.h"
namespace WebCore {
DatabaseTask::DatabaseTask(Database* database)
: m_database(database)
, m_complete(false)
{
}
DatabaseTask::~DatabaseTask()
{
}
void DatabaseTask::performTask()
{
ASSERT(!m_complete);
LOG(StorageAPI, "Performing %s %p\n", debugTaskName(), this);
m_database->resetAuthorizer();
doPerformTask();
m_database->performPolicyChecks();
if (m_synchronousMutex)
m_synchronousMutex->lock();
m_complete = true;
if (m_synchronousMutex) {
m_synchronousCondition->signal();
m_synchronousMutex->unlock();
}
}
void DatabaseTask::lockForSynchronousScheduling()
{
ASSERT(!m_synchronousMutex);
ASSERT(!m_synchronousCondition);
m_synchronousMutex.set(new Mutex);
m_synchronousCondition.set(new ThreadCondition);
}
void DatabaseTask::waitForSynchronousCompletion()
{
m_synchronousMutex->lock();
if (!m_complete)
m_synchronousCondition->wait(*m_synchronousMutex);
m_synchronousMutex->unlock();
}
DatabaseOpenTask::DatabaseOpenTask(Database* database)
: DatabaseTask(database)
, m_code(0)
, m_success(false)
{
}
void DatabaseOpenTask::doPerformTask()
{
m_success = database()->performOpenAndVerify(m_code);
}
#ifndef NDEBUG
const char* DatabaseOpenTask::debugTaskName() const
{
return "DatabaseOpenTask";
}
#endif
DatabaseCloseTask::DatabaseCloseTask(Database* database)
: DatabaseTask(database)
{
}
void DatabaseCloseTask::doPerformTask()
{
database()->close();
}
#ifndef NDEBUG
const char* DatabaseCloseTask::debugTaskName() const
{
return "DatabaseCloseTask";
}
#endif
DatabaseTransactionTask::DatabaseTransactionTask(PassRefPtr<SQLTransaction> transaction)
: DatabaseTask(transaction->database())
, m_transaction(transaction)
{
}
DatabaseTransactionTask::~DatabaseTransactionTask()
{
}
void DatabaseTransactionTask::doPerformTask()
{
if (m_transaction->performNextStep()) {
MutexLocker locker(m_transaction->database()->m_transactionInProgressMutex);
m_transaction->database()->scheduleTransaction();
}
}
#ifndef NDEBUG
const char* DatabaseTransactionTask::debugTaskName() const
{
return "DatabaseTransactionTask";
}
#endif
DatabaseTableNamesTask::DatabaseTableNamesTask(Database* database)
: DatabaseTask(database)
{
}
void DatabaseTableNamesTask::doPerformTask()
{
m_tableNames = database()->performGetTableNames();
}
#ifndef NDEBUG
const char* DatabaseTableNamesTask::debugTaskName() const
{
return "DatabaseTableNamesTask";
}
#endif
}
#endif