[IndexedDB] Adding transaction and value support to observers

content/browser/indexed_db/indexed_db_connection.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/indexed_db/indexed_db_connection.h"
 
 #include "base/logging.h"
 #include "base/stl_util.h"
 #include "content/browser/indexed_db/indexed_db_class_factory.h"
 #include "content/browser/indexed_db/indexed_db_database_callbacks.h"
 #include "content/browser/indexed_db/indexed_db_observer.h"
 #include "content/browser/indexed_db/indexed_db_tracing.h"
 #include "content/browser/indexed_db/indexed_db_transaction.h"
 
 namespace content {
 
 namespace {
-
+static const int64_t kMaxObserverTransactionId = -1ll;

[cmumford, 2017/01/17 20:58:10]

Add newline before.

[dmurph, 2017/01/17 23:28:04]

Done.

Actually, as per working with Victor, we removed all of this and simplified the
ID incrementing system to just have a uint32_t that then we shift by 32 before
returning.

 static int32_t next_id;
 
 }  // namespace
 
 IndexedDBConnection::IndexedDBConnection(
     int child_process_id,
     scoped_refptr<IndexedDBDatabase> database,
     scoped_refptr<IndexedDBDatabaseCallbacks> callbacks)
     : id_(next_id++),
       child_process_id_(child_process_id),
@@ skipping 122 matching lines @@
   base::WeakPtr<IndexedDBTransaction> transaction_ptr =
       transaction->ptr_factory_.GetWeakPtr();
   transactions_[transaction->id()] = std::move(transaction);
   return transaction_ptr;
 }
 
 void IndexedDBConnection::RemoveTransaction(int64_t id) {
   transactions_.erase(id);
 }
 
+int64_t IndexedDBConnection::NewObserverTransactionId() {
+  // If we ever overflow, just reset the ID.
+  if (next_observer_transaction_id_ == kMaxObserverTransactionId)
+    next_observer_transaction_id_ = 1ll << 32;
+  DCHECK_EQ(next_observer_transaction_id_ & 0xFFFFFFFF, 0)
+      << "Highest order bits reserved for renderer-created transactions";
+  return next_observer_transaction_id_++;
+}
+
 }  // namespace content