[IndexedDB] Integrating failures and corruption with transaction

content/browser/indexed_db/indexed_db_backing_store.h

 // Copyright (c) 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.
 
 #ifndef CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_BACKING_STORE_H_
 #define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_BACKING_STORE_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
@@ skipping 331 matching lines @@
 
     IndexedDBBackingStore* backing_store_;
     Transaction* transaction_;
     int64_t database_id_;
     const CursorOptions cursor_options_;
     std::unique_ptr<LevelDBIterator> iterator_;
     std::unique_ptr<IndexedDBKey> current_key_;
     IndexedDBBackingStore::RecordIdentifier record_identifier_;
 
    private:
+    enum class ContinueResult { LEVELDB_ERROR, DONE, OUT_OF_BOUNDS };
+
     // For cursors with direction Next or NextNoDuplicate.
-    bool ContinueNext(const IndexedDBKey* key,
-                      const IndexedDBKey* primary_key,
-                      IteratorState state,
-                      leveldb::Status*);
+    ContinueResult ContinueNext(const IndexedDBKey* key,
+                                const IndexedDBKey* primary_key,
+                                IteratorState state,
+                                leveldb::Status*);
     // For cursors with direction Prev or PrevNoDuplicate. The PrevNoDuplicate
     // case has additional complexity of not being symmetric with
     // NextNoDuplicate.
-    bool ContinuePrevious(const IndexedDBKey* key,
-                          const IndexedDBKey* primary_key,
-                          IteratorState state,
-                          leveldb::Status*);
+    ContinueResult ContinuePrevious(const IndexedDBKey* key,
+                                    const IndexedDBKey* primary_key,
+                                    IteratorState state,
+                                    leveldb::Status*);
 
     DISALLOW_COPY_AND_ASSIGN(Cursor);
   };
 
   const url::Origin& origin() const { return origin_; }
   IndexedDBFactory* factory() const { return indexed_db_factory_; }
   base::SequencedTaskRunner* task_runner() const { return task_runner_.get(); }
   base::OneShotTimer* close_timer() { return &close_timer_; }
   IndexedDBActiveBlobRegistry* active_blob_registry() {
     return &active_blob_registry_;
@@ skipping 35 matching lines @@
   // Compact is public for testing.
   virtual void Compact();
   virtual std::vector<base::string16> GetDatabaseNames(leveldb::Status*);
   virtual leveldb::Status GetIDBDatabaseMetaData(
       const base::string16& name,
       IndexedDBDatabaseMetadata* metadata,
       bool* success) WARN_UNUSED_RESULT;
   virtual leveldb::Status CreateIDBDatabaseMetaData(const base::string16& name,
                                                     int64_t version,
                                                     int64_t* row_id);
-  virtual bool UpdateIDBDatabaseIntVersion(
+  virtual void UpdateIDBDatabaseIntVersion(
       IndexedDBBackingStore::Transaction* transaction,
       int64_t row_id,
       int64_t version);
   virtual leveldb::Status DeleteDatabase(const base::string16& name);
 
   // Assumes caller has already closed the backing store.
   static leveldb::Status DestroyBackingStore(const base::FilePath& path_base,
                                              const url::Origin& origin);
   static bool RecordCorruptionInfo(const base::FilePath& path_base,
                                    const url::Origin& origin,
@@ skipping 255 matching lines @@
   // complete. While > 0, temporary journal entries may exist so out-of-band
   // journal cleaning must be deferred.
   size_t committing_transaction_count_;
 
   DISALLOW_COPY_AND_ASSIGN(IndexedDBBackingStore);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_BACKING_STORE_H_