IDBFactoryBackendImpl.cpp [plain text]
#include "config.h"
#include "IDBFactoryBackendImpl.h"
#include "DOMStringList.h"
#include "IDBBackingStore.h"
#include "IDBDatabaseBackendImpl.h"
#include "IDBDatabaseException.h"
#include "IDBLevelDBBackingStore.h"
#include "IDBTransactionCoordinator.h"
#include "SecurityOrigin.h"
#include <wtf/Threading.h>
#include <wtf/UnusedParam.h>
#if ENABLE(INDEXED_DATABASE)
namespace WebCore {
static String computeFileIdentifier(SecurityOrigin* securityOrigin)
{
static const char kLevelDBFileSuffix[] = "@1";
return securityOrigin->databaseIdentifier() + kLevelDBFileSuffix;
}
static String computeUniqueIdentifier(const String& name, SecurityOrigin* securityOrigin)
{
return computeFileIdentifier(securityOrigin) + name;
}
IDBFactoryBackendImpl::IDBFactoryBackendImpl()
: m_transactionCoordinator(IDBTransactionCoordinator::create())
{
}
IDBFactoryBackendImpl::~IDBFactoryBackendImpl()
{
}
void IDBFactoryBackendImpl::removeIDBDatabaseBackend(const String& uniqueIdentifier)
{
ASSERT(m_databaseBackendMap.contains(uniqueIdentifier));
m_databaseBackendMap.remove(uniqueIdentifier);
}
void IDBFactoryBackendImpl::addIDBBackingStore(const String& fileIdentifier, IDBBackingStore* backingStore)
{
ASSERT(!m_backingStoreMap.contains(fileIdentifier));
m_backingStoreMap.set(fileIdentifier, backingStore);
}
void IDBFactoryBackendImpl::removeIDBBackingStore(const String& fileIdentifier)
{
ASSERT(m_backingStoreMap.contains(fileIdentifier));
m_backingStoreMap.remove(fileIdentifier);
}
void IDBFactoryBackendImpl::getDatabaseNames(PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDirectory)
{
RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDirectory);
if (!backingStore) {
callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
return;
}
RefPtr<DOMStringList> databaseNames = DOMStringList::create();
Vector<String> foundNames;
backingStore->getDatabaseNames(foundNames);
for (Vector<String>::const_iterator it = foundNames.begin(); it != foundNames.end(); ++it)
databaseNames->append(*it);
callbacks->onSuccess(databaseNames.release());
}
void IDBFactoryBackendImpl::open(const String& name, IDBCallbacks* callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDirectory)
{
openInternal(name, callbacks, securityOrigin, dataDirectory);
}
void IDBFactoryBackendImpl::openFromWorker(const String& name, IDBCallbacks* callbacks, PassRefPtr<SecurityOrigin> securityOrigin, WorkerContext*, const String& dataDirectory)
{
openInternal(name, callbacks, securityOrigin, dataDirectory);
}
void IDBFactoryBackendImpl::deleteDatabase(const String& name, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDirectory)
{
const String uniqueIdentifier = computeUniqueIdentifier(name, securityOrigin.get());
IDBDatabaseBackendMap::iterator it = m_databaseBackendMap.find(uniqueIdentifier);
if (it != m_databaseBackendMap.end()) {
it->second->deleteDatabase(callbacks);
return;
}
RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDirectory);
if (!backingStore) {
callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
return;
}
RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
m_databaseBackendMap.set(uniqueIdentifier, databaseBackend.get());
databaseBackend->deleteDatabase(callbacks);
}
PassRefPtr<IDBBackingStore> IDBFactoryBackendImpl::openBackingStore(PassRefPtr<SecurityOrigin> securityOrigin, const String& dataDirectory)
{
const String fileIdentifier = computeFileIdentifier(securityOrigin.get());
RefPtr<IDBBackingStore> backingStore;
IDBBackingStoreMap::iterator it2 = m_backingStoreMap.find(fileIdentifier);
if (it2 != m_backingStoreMap.end())
backingStore = it2->second;
else {
#if USE(LEVELDB)
backingStore = IDBLevelDBBackingStore::open(securityOrigin.get(), dataDirectory, fileIdentifier, this);
#else
UNUSED_PARAM(dataDirectory);
ASSERT_NOT_REACHED();
#endif
}
if (backingStore)
return backingStore.release();
return 0;
}
void IDBFactoryBackendImpl::openInternal(const String& name, IDBCallbacks* callbacks, PassRefPtr<SecurityOrigin> prpSecurityOrigin, const String& dataDirectory)
{
RefPtr<SecurityOrigin> securityOrigin = prpSecurityOrigin;
const String uniqueIdentifier = computeUniqueIdentifier(name, securityOrigin.get());
IDBDatabaseBackendMap::iterator it = m_databaseBackendMap.find(uniqueIdentifier);
if (it != m_databaseBackendMap.end()) {
it->second->openConnection(callbacks);
return;
}
RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDirectory);
if (!backingStore) {
callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
return;
}
RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
callbacks->onSuccess(RefPtr<IDBDatabaseBackendInterface>(databaseBackend.get()).release());
m_databaseBackendMap.set(uniqueIdentifier, databaseBackend.get());
}
}
#endif // ENABLE(INDEXED_DATABASE)