#include "config.h"
#include "StorageTask.h"
#include "StorageThread.h"
#include "StorageAreaSync.h"
#include "StorageTracker.h"
namespace WebCore {
StorageTask::StorageTask(Type type, StorageAreaSync* area)
: m_type(type)
, m_area(area)
, m_thread(0)
{
ASSERT(m_area);
ASSERT(m_type == AreaImport || m_type == AreaSync || m_type == DeleteEmptyDatabase);
}
StorageTask::StorageTask(Type type, StorageThread* thread)
: m_type(type)
, m_area(0)
, m_thread(thread)
{
ASSERT(m_thread);
ASSERT(m_type == TerminateThread);
}
StorageTask::StorageTask(Type type)
: m_type(type)
, m_area(0)
, m_thread(0)
{
ASSERT(m_type == ImportOrigins || m_type == DeleteAllOrigins);
}
StorageTask::StorageTask(Type type, const String& originIdentifier)
: m_type(type)
, m_area(0)
, m_thread(0)
, m_originIdentifier(originIdentifier)
{
ASSERT(m_type == DeleteOrigin);
}
StorageTask::StorageTask(Type type, const String& originIdentifier, const String& databaseFilename)
: m_type(type)
, m_area(0)
, m_thread(0)
, m_originIdentifier(originIdentifier)
, m_databaseFilename(databaseFilename)
{
ASSERT(m_type == SetOriginDetails);
}
StorageTask::~StorageTask()
{
}
void StorageTask::performTask()
{
switch (m_type) {
case AreaImport:
m_area->performImport();
break;
case AreaSync:
m_area->performSync();
break;
case SetOriginDetails:
StorageTracker::tracker().syncSetOriginDetails(m_originIdentifier, m_databaseFilename);
break;
case ImportOrigins:
StorageTracker::tracker().syncImportOriginIdentifiers();
break;
case DeleteAllOrigins:
StorageTracker::tracker().syncDeleteAllOrigins();
break;
case DeleteOrigin:
StorageTracker::tracker().syncDeleteOrigin(m_originIdentifier);
break;
case DeleteEmptyDatabase:
m_area->deleteEmptyDatabase();
break;
case TerminateThread:
m_thread->performTerminate();
break;
}
}
}