The Tor Browser: dom/indexedDB/DatabaseInfo.cpp@b8a032363ba2 (annotated)

dom/indexedDB/DatabaseInfo.cpp@b8a032363ba2 (annotated)

dom/indexedDB/DatabaseInfo.cpp

Thu, 22 Jan 2015 13:21:57 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Thu, 22 Jan 2015 13:21:57 +0100
branch: TOR_BUG_9701
changeset 15: b8a032363ba2
permissions: -rw-r--r--

Incorporate requested changes from Mozilla in review:
https://bugzilla.mozilla.org/show_bug.cgi?id=1123480#c6

 /* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
 /* vim: set ts=2 et sw=2 tw=80: */
 /* This Source Code Form is subject to the terms of the Mozilla Public
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
 #include "DatabaseInfo.h"
 #include "nsDataHashtable.h"
 #include "nsThreadUtils.h"
 USING_INDEXEDDB_NAMESPACE
 namespace {
 typedef nsDataHashtable<nsCStringHashKey, DatabaseInfo*>
         DatabaseHash;
 DatabaseHash* gDatabaseHash = nullptr;
 PLDHashOperator
 EnumerateObjectStoreNames(const nsAString& aKey,
                           ObjectStoreInfo* aData,
                           void* aUserArg)
 {
   nsTArray<nsString>* array = static_cast<nsTArray<nsString>*>(aUserArg);
   if (!array->InsertElementSorted(aData->name)) {
     NS_ERROR("Out of memory?");
     return PL_DHASH_STOP;
   }
   return PL_DHASH_NEXT;
 }
 PLDHashOperator
 CloneObjectStoreInfo(const nsAString& aKey,
                      ObjectStoreInfo* aData,
                      void* aUserArg)
 {
   ObjectStoreInfoHash* hash = static_cast<ObjectStoreInfoHash*>(aUserArg);
   nsRefPtr<ObjectStoreInfo> newInfo(new ObjectStoreInfo(*aData));
   hash->Put(aKey, newInfo);
   return PL_DHASH_NEXT;
 }
 }
 DatabaseInfo::~DatabaseInfo()
 {
   // Clones are never in the hash.
   if (!cloned) {
     DatabaseInfo::Remove(id);
   }
 }
 ObjectStoreInfo::ObjectStoreInfo(ObjectStoreInfo& aOther)
 : nextAutoIncrementId(aOther.nextAutoIncrementId),
   comittedAutoIncrementId(aOther.comittedAutoIncrementId)
 {
   *static_cast<ObjectStoreInfoGuts*>(this) =
     static_cast<ObjectStoreInfoGuts&>(aOther);
   // Doesn't copy the refcount
   MOZ_COUNT_CTOR(ObjectStoreInfo);
 }
 #ifdef NS_BUILD_REFCNT_LOGGING
 IndexInfo::IndexInfo()
 : id(INT64_MIN),
   keyPath(0),
   unique(false),
   multiEntry(false)
 {
   MOZ_COUNT_CTOR(IndexInfo);
 }
 IndexInfo::IndexInfo(const IndexInfo& aOther)
 : name(aOther.name),
   id(aOther.id),
   keyPath(aOther.keyPath),
   unique(aOther.unique),
   multiEntry(aOther.multiEntry)
 {
   MOZ_COUNT_CTOR(IndexInfo);
 }
 IndexInfo::~IndexInfo()
 {
   MOZ_COUNT_DTOR(IndexInfo);
 }
 ObjectStoreInfo::ObjectStoreInfo()
 : nextAutoIncrementId(0),
   comittedAutoIncrementId(0)
 {
   MOZ_COUNT_CTOR(ObjectStoreInfo);
 }
 ObjectStoreInfo::~ObjectStoreInfo()
 {
   MOZ_COUNT_DTOR(ObjectStoreInfo);
 }
 IndexUpdateInfo::IndexUpdateInfo()
 : indexId(0),
   indexUnique(false)
 {
   MOZ_COUNT_CTOR(IndexUpdateInfo);
 }
 IndexUpdateInfo::IndexUpdateInfo(const IndexUpdateInfo& aOther)
 : indexId(aOther.indexId),
   indexUnique(aOther.indexUnique),
   value(aOther.value)
 {
   MOZ_COUNT_CTOR(IndexUpdateInfo);
 }
 IndexUpdateInfo::~IndexUpdateInfo()
 {
   MOZ_COUNT_DTOR(IndexUpdateInfo);
 }
 #endif /* NS_BUILD_REFCNT_LOGGING */
 // static
 bool
 DatabaseInfo::Get(const nsACString& aId,
                   DatabaseInfo** aInfo)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   NS_ASSERTION(!aId.IsEmpty(), "Bad id!");
   if (gDatabaseHash &&
       gDatabaseHash->Get(aId, aInfo)) {
     NS_IF_ADDREF(*aInfo);
     return true;
   }
   return false;
 }
 // static
 bool
 DatabaseInfo::Put(DatabaseInfo* aInfo)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   NS_ASSERTION(aInfo, "Null pointer!");
   if (!gDatabaseHash) {
     nsAutoPtr<DatabaseHash> databaseHash(new DatabaseHash());
     gDatabaseHash = databaseHash.forget();
   }
   if (gDatabaseHash->Get(aInfo->id, nullptr)) {
     NS_ERROR("Already know about this database!");
     return false;
   }
   gDatabaseHash->Put(aInfo->id, aInfo);
   return true;
 }
 // static
 void
 DatabaseInfo::Remove(const nsACString& aId)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   if (gDatabaseHash) {
     gDatabaseHash->Remove(aId);
     if (!gDatabaseHash->Count()) {
       delete gDatabaseHash;
       gDatabaseHash = nullptr;
     }
   }
 }
 bool
 DatabaseInfo::GetObjectStoreNames(nsTArray<nsString>& aNames)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   aNames.Clear();
   if (objectStoreHash) {
     objectStoreHash->EnumerateRead(EnumerateObjectStoreNames, &aNames);
   }
   return true;
 }
 bool
 DatabaseInfo::ContainsStoreName(const nsAString& aName)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   return objectStoreHash && objectStoreHash->Get(aName, nullptr);
 }
 ObjectStoreInfo*
 DatabaseInfo::GetObjectStore(const nsAString& aName)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   if (objectStoreHash) {
     return objectStoreHash->GetWeak(aName);
   }
   return nullptr;
 }
 bool
 DatabaseInfo::PutObjectStore(ObjectStoreInfo* aInfo)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   NS_ASSERTION(aInfo, "Null pointer!");
   if (!objectStoreHash) {
     nsAutoPtr<ObjectStoreInfoHash> hash(new ObjectStoreInfoHash());
     objectStoreHash = hash.forget();
   }
   if (objectStoreHash->Get(aInfo->name, nullptr)) {
     NS_ERROR("Already have an entry for this objectstore!");
     return false;
   }
   objectStoreHash->Put(aInfo->name, aInfo);
   return true;
 }
 void
 DatabaseInfo::RemoveObjectStore(const nsAString& aName)
 {
   NS_ASSERTION(NS_IsMainThread(), "Wrong thread!");
   NS_ASSERTION(GetObjectStore(aName), "Don't know about this one!");
   if (objectStoreHash) {
     objectStoreHash->Remove(aName);
   }
 }
 already_AddRefed<DatabaseInfo>
 DatabaseInfo::Clone()
 {
   nsRefPtr<DatabaseInfo> dbInfo(new DatabaseInfo());
   dbInfo->cloned = true;
   dbInfo->name = name;
   dbInfo->group = group;
   dbInfo->origin = origin;
   dbInfo->version = version;
   dbInfo->persistenceType = persistenceType;
   dbInfo->id = id;
   dbInfo->filePath = filePath;
   dbInfo->nextObjectStoreId = nextObjectStoreId;
   dbInfo->nextIndexId = nextIndexId;
   if (objectStoreHash) {
     dbInfo->objectStoreHash = new ObjectStoreInfoHash();
     objectStoreHash->EnumerateRead(CloneObjectStoreInfo,
                                    dbInfo->objectStoreHash);
   }
   return dbInfo.forget();
 }

The Tor Browser / annotate

dom/indexedDB/DatabaseInfo.cpp@b8a032363ba2 (annotated)

dom/indexedDB/DatabaseInfo.cpp