Source/WebCore/storage/IDBFactoryBackendImpl.cpp

   1 /*
   2  * Copyright (C) 2011 Google Inc. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions
   6  * are met:
   7  *
   8  * 1.  Redistributions of source code must retain the above copyright
   9  *     notice, this list of conditions and the following disclaimer.
  10  * 2.  Redistributions in binary form must reproduce the above copyright
  11  *     notice, this list of conditions and the following disclaimer in the
  12  *     documentation and/or other materials provided with the distribution.
  13  * 3.  Neither the name of Apple Computer, Inc. ("Apple") nor the names of
  14  *     its contributors may be used to endorse or promote products derived
  15  *     from this software without specific prior written permission.
  16  *
  17  * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
  18  * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  19  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  20  * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
  21  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  22  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  23  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  24  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  25  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
  26  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  27  */
  28
  29 #include "config.h"
  30 #include "IDBFactoryBackendImpl.h"
  31
  32 #include "DOMStringList.h"
  33 #include "IDBDatabaseBackendImpl.h"
  34 #include "IDBDatabaseException.h"
  35 #include "IDBLevelDBBackingStore.h"
  36 #include "IDBTransactionCoordinator.h"
  37 #include "SecurityOrigin.h"
  38 #include <wtf/Threading.h>
  39 #include <wtf/UnusedParam.h>
  40
  41 #if ENABLE(INDEXED_DATABASE)
  42
  43 namespace WebCore {
  44
  45 static String computeFileIdentifier(SecurityOrigin* securityOrigin)
  46 {
  47     static const char kLevelDBFileSuffix[] = "@1";
  48     return securityOrigin->databaseIdentifier() + kLevelDBFileSuffix;
  49 }
  50
  51 static String computeUniqueIdentifier(const String& name, SecurityOrigin* securityOrigin)
  52 {
  53     return computeFileIdentifier(securityOrigin) + name;
  54 }
  55
  56 IDBFactoryBackendImpl::IDBFactoryBackendImpl()
  57     : m_transactionCoordinator(IDBTransactionCoordinator::create())
  58 {
  59 }
  60
  61 IDBFactoryBackendImpl::~IDBFactoryBackendImpl()
  62 {
  63 }
  64
  65 void IDBFactoryBackendImpl::removeIDBDatabaseBackend(const String& uniqueIdentifier)
  66 {
  67     ASSERT(m_databaseBackendMap.contains(uniqueIdentifier));
  68     m_databaseBackendMap.remove(uniqueIdentifier);
  69 }
  70
  71 void IDBFactoryBackendImpl::addIDBBackingStore(const String& fileIdentifier, IDBBackingStore* backingStore)
  72 {
  73     ASSERT(!m_backingStoreMap.contains(fileIdentifier));
  74     m_backingStoreMap.set(fileIdentifier, backingStore);
  75 }
  76
  77 void IDBFactoryBackendImpl::removeIDBBackingStore(const String& fileIdentifier)
  78 {
  79     ASSERT(m_backingStoreMap.contains(fileIdentifier));
  80     m_backingStoreMap.remove(fileIdentifier);
  81 }
  82
  83 void IDBFactoryBackendImpl::getDatabaseNames(PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDir)
  84 {
  85     RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDir);
  86     if (!backingStore) {
  87         callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
  88         return;
  89     }
  90
  91     RefPtr<DOMStringList> databaseNames = DOMStringList::create();
  92
  93     Vector<String> foundNames;
  94     backingStore->getDatabaseNames(foundNames);
  95     for (Vector<String>::const_iterator it = foundNames.begin(); it != foundNames.end(); ++it)
  96         databaseNames->append(*it);
  97
  98     callbacks->onSuccess(databaseNames.release());
  99 }
 100
 101 #if ENABLE(TIZEN_INDEXED_DATABASE)
 102 void IDBFactoryBackendImpl::open(ScriptExecutionContext* context, const String& name, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDir)
 103 #else
 104 void IDBFactoryBackendImpl::open(const String& name, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDir)
 105 #endif // TIZEN_INDEXED_DATABASE
 106 {
 107     const String uniqueIdentifier = computeUniqueIdentifier(name, securityOrigin.get());
 108
 109     IDBDatabaseBackendMap::iterator it = m_databaseBackendMap.find(uniqueIdentifier);
 110     if (it != m_databaseBackendMap.end()) {
 111         // If it's already been opened, we have to wait for any pending
 112         // setVersion calls to complete.
 113         it->second->openConnection(callbacks);
 114         return;
 115     }
 116
 117     // FIXME: Everything from now on should be done on another thread.
 118     RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDir);
 119     if (!backingStore) {
 120         callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
 121         return;
 122     }
 123
 124 #if ENABLE(TIZEN_INDEXED_DATABASE)
 125     RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(context, name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
 126 #else
 127     RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
 128 #endif // TIZEN_INDEXED_DATABASE
 129     callbacks->onSuccess(databaseBackend.get());
 130     m_databaseBackendMap.set(uniqueIdentifier, databaseBackend.get());
 131 }
 132
 133 #if ENABLE(TIZEN_INDEXED_DATABASE)
 134 void IDBFactoryBackendImpl::deleteDatabase(ScriptExecutionContext* context, const String& name, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDir)
 135 #else
 136 void IDBFactoryBackendImpl::deleteDatabase(const String& name, PassRefPtr<IDBCallbacks> callbacks, PassRefPtr<SecurityOrigin> securityOrigin, Frame*, const String& dataDir)
 137 #endif // TIZEN_INDEXED_DATABASE
 138 {
 139     const String uniqueIdentifier = computeUniqueIdentifier(name, securityOrigin.get());
 140
 141     IDBDatabaseBackendMap::iterator it = m_databaseBackendMap.find(uniqueIdentifier);
 142     if (it != m_databaseBackendMap.end()) {
 143         // If there are any connections to the database, directly delete the
 144         // database.
 145         it->second->deleteDatabase(callbacks);
 146         return;
 147     }
 148
 149     // FIXME: Everything from now on should be done on another thread.
 150     RefPtr<IDBBackingStore> backingStore = openBackingStore(securityOrigin, dataDir);
 151     if (!backingStore) {
 152         callbacks->onError(IDBDatabaseError::create(IDBDatabaseException::UNKNOWN_ERR, "Internal error."));
 153         return;
 154     }
 155
 156 #if ENABLE(TIZEN_INDEXED_DATABASE)
 157     RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(context, name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
 158 #else
 159     RefPtr<IDBDatabaseBackendImpl> databaseBackend = IDBDatabaseBackendImpl::create(name, backingStore.get(), m_transactionCoordinator.get(), this, uniqueIdentifier);
 160 #endif // TIZEN_INDEXED_DATABASE
 161     m_databaseBackendMap.set(uniqueIdentifier, databaseBackend.get());
 162     databaseBackend->deleteDatabase(callbacks);
 163 }
 164
 165 PassRefPtr<IDBBackingStore> IDBFactoryBackendImpl::openBackingStore(PassRefPtr<SecurityOrigin> securityOrigin, const String& dataDir)
 166 {
 167     const String fileIdentifier = computeFileIdentifier(securityOrigin.get());
 168
 169     RefPtr<IDBBackingStore> backingStore;
 170     IDBBackingStoreMap::iterator it2 = m_backingStoreMap.find(fileIdentifier);
 171     if (it2 != m_backingStoreMap.end())
 172         backingStore = it2->second;
 173     else {
 174 #if USE(LEVELDB)
 175         backingStore = IDBLevelDBBackingStore::open(securityOrigin.get(), dataDir, fileIdentifier, this);
 176 #else
 177         ASSERT_NOT_REACHED();
 178 #endif
 179     }
 180
 181     if (backingStore)
 182         return backingStore.release();
 183
 184     return 0;
 185 }
 186
 187 } // namespace WebCore
 188
 189 #endif // ENABLE(INDEXED_DATABASE)