#include "config.h"
#include "LocalStorage.h"
#include "CString.h"
#include "EventNames.h"
#include "FileSystem.h"
#include "Frame.h"
#include "FrameTree.h"
#include "LocalStorageArea.h"
#include "Page.h"
#include "PageGroup.h"
#include "StorageArea.h"
#include <wtf/StdLibExtras.h>
namespace WebCore {
typedef HashMap<String, LocalStorage*> LocalStorageMap;
static LocalStorageMap& localStorageMap()
{
DEFINE_STATIC_LOCAL(LocalStorageMap, localStorageMap, ());
return localStorageMap;
}
PassRefPtr<LocalStorage> LocalStorage::localStorage(const String& path)
{
const String lookupPath = path.isNull() ? String("") : path;
LocalStorageMap::iterator it = localStorageMap().find(lookupPath);
if (it == localStorageMap().end()) {
RefPtr<LocalStorage> localStorage = adoptRef(new LocalStorage(lookupPath));
localStorageMap().set(lookupPath, localStorage.get());
return localStorage.release();
}
return it->second;
}
LocalStorage::LocalStorage(const String& path)
: m_path(path.copy())
{
if (path.isEmpty())
return;
m_thread = LocalStorageThread::create();
m_thread->start();
m_thread->scheduleImport(this);
}
LocalStorage::~LocalStorage()
{
ASSERT(localStorageMap().get(m_path) == this);
localStorageMap().remove(m_path);
}
PassRefPtr<StorageArea> LocalStorage::storageArea(SecurityOrigin* origin)
{
ASSERT(isMainThread());
RefPtr<LocalStorageArea> storageArea;
if (storageArea = m_storageAreaMap.get(origin))
return storageArea.release();
storageArea = LocalStorageArea::create(origin, this);
m_storageAreaMap.set(origin, storageArea);
return storageArea.release();
}
String LocalStorage::fullDatabaseFilename(SecurityOrigin* origin)
{
if (m_path.isEmpty())
return String();
ASSERT(origin);
if (!origin)
return String();
if (!makeAllDirectories(m_path)) {
LOG_ERROR("Unabled to create LocalStorage database path %s", m_path.utf8().data());
return String();
}
return pathByAppendingComponent(m_path, origin->databaseIdentifier() + ".localstorage");
}
void LocalStorage::performImport()
{
ASSERT(!isMainThread());
}
void LocalStorage::performSync()
{
ASSERT(!isMainThread());
}
void LocalStorage::close()
{
ASSERT(isMainThread());
LocalStorageAreaMap::iterator end = m_storageAreaMap.end();
for (LocalStorageAreaMap::iterator it = m_storageAreaMap.begin(); it != end; ++it)
it->second->scheduleFinalSync();
if (m_thread) {
m_thread->terminate();
m_thread = 0;
}
}
bool LocalStorage::scheduleImport(PassRefPtr<LocalStorageArea> area)
{
ASSERT(isMainThread());
if (m_thread)
m_thread->scheduleImport(area);
return m_thread;
}
void LocalStorage::scheduleSync(PassRefPtr<LocalStorageArea> area)
{
ASSERT(isMainThread());
if (m_thread)
m_thread->scheduleSync(area);
}
}