StorageSyncManager.cpp [plain text]
#include "config.h"
#include "StorageSyncManager.h"
#include "EventNames.h"
#include "FileSystem.h"
#include "Frame.h"
#include "FrameTree.h"
#include "StorageTask.h"
#include "StorageThread.h"
#include "Page.h"
#include "PageGroup.h"
#include "StorageAreaSync.h"
#include <wtf/MainThread.h>
#include <wtf/StdLibExtras.h>
#include <wtf/text/CString.h>
namespace WebCore {
PassRefPtr<StorageSyncManager> StorageSyncManager::create(const String& path)
{
return adoptRef(new StorageSyncManager(path));
}
StorageSyncManager::StorageSyncManager(const String& path)
: m_thread(StorageThread::create())
, m_path(path.isolatedCopy())
{
ASSERT(isMainThread());
ASSERT(!m_path.isEmpty());
m_thread->start();
}
StorageSyncManager::~StorageSyncManager()
{
ASSERT(isMainThread());
ASSERT(!m_thread);
}
String StorageSyncManager::fullDatabaseFilename(const String& databaseIdentifier)
{
if (!makeAllDirectories(m_path)) {
LOG_ERROR("Unabled to create LocalStorage database path %s", m_path.utf8().data());
return String();
}
return pathByAppendingComponent(m_path, databaseIdentifier + ".localstorage");
}
void StorageSyncManager::close()
{
ASSERT(isMainThread());
if (m_thread) {
m_thread->terminate();
m_thread.clear();
}
}
bool StorageSyncManager::scheduleImport(PassRefPtr<StorageAreaSync> area)
{
ASSERT(isMainThread());
ASSERT(m_thread);
if (m_thread)
m_thread->scheduleTask(StorageTask::createImport(area.get()));
return m_thread;
}
void StorageSyncManager::scheduleSync(PassRefPtr<StorageAreaSync> area)
{
ASSERT(isMainThread());
ASSERT(m_thread);
if (m_thread)
m_thread->scheduleTask(StorageTask::createSync(area.get()));
}
void StorageSyncManager::scheduleDeleteEmptyDatabase(PassRefPtr<StorageAreaSync> area)
{
ASSERT(isMainThread());
ASSERT(m_thread);
if (m_thread)
m_thread->scheduleTask(StorageTask::createDeleteEmptyDatabase(area.get()));
}
}