summaryrefslogtreecommitdiffstats
path: root/content/browser/indexed_db/indexed_db_transaction.h
diff options
context:
space:
mode:
Diffstat (limited to 'content/browser/indexed_db/indexed_db_transaction.h')
-rw-r--r--content/browser/indexed_db/indexed_db_transaction.h150
1 files changed, 0 insertions, 150 deletions
diff --git a/content/browser/indexed_db/indexed_db_transaction.h b/content/browser/indexed_db/indexed_db_transaction.h
deleted file mode 100644
index ca0f929..0000000
--- a/content/browser/indexed_db/indexed_db_transaction.h
+++ /dev/null
@@ -1,150 +0,0 @@
-// 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_TRANSACTION_H_
-#define CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_TRANSACTION_H_
-
-#include <queue>
-#include <set>
-#include <stack>
-#include <vector>
-
-#include "base/basictypes.h"
-#include "base/memory/ref_counted.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/timer.h"
-#include "content/browser/indexed_db/indexed_db_backing_store.h"
-#include "content/browser/indexed_db/indexed_db_database.h"
-#include "content/browser/indexed_db/indexed_db_database_error.h"
-
-namespace content {
-
-class IndexedDBDatabaseImpl;
-class IndexedDBCursorImpl;
-class IndexedDBDatabaseCallbacksWrapper;
-
-class IndexedDBTransaction : public base::RefCounted<IndexedDBTransaction> {
- public:
- static scoped_refptr<IndexedDBTransaction> Create(
- int64 transaction_id,
- scoped_refptr<IndexedDBDatabaseCallbacksWrapper> callbacks,
- const std::vector<int64>& scope,
- indexed_db::TransactionMode,
- IndexedDBDatabaseImpl* db);
-
- virtual void Abort();
- void Commit();
-
- class Operation {
- public:
- Operation() {}
- virtual ~Operation() {}
- virtual void Perform(IndexedDBTransaction* transaction) = 0;
- };
-
- void Abort(scoped_refptr<IndexedDBDatabaseError> error);
- void Run();
- indexed_db::TransactionMode mode() const { return mode_; }
- const std::set<int64>& scope() const { return object_store_ids_; }
- void ScheduleTask(Operation* task, Operation* abort_task = NULL) {
- ScheduleTask(IndexedDBDatabase::NORMAL_TASK, task, abort_task);
- }
- void ScheduleTask(IndexedDBDatabase::TaskType,
- Operation* task,
- Operation* abort_task = NULL);
- void RegisterOpenCursor(IndexedDBCursorImpl* cursor);
- void UnregisterOpenCursor(IndexedDBCursorImpl* cursor);
- void AddPreemptiveEvent() { pending_preemptive_events_++; }
- void DidCompletePreemptiveEvent() {
- pending_preemptive_events_--;
- DCHECK_GE(pending_preemptive_events_, 0);
- }
- IndexedDBBackingStore::Transaction* BackingStoreTransaction() {
- return &transaction_;
- }
- int64 id() const { return id_; }
-
- IndexedDBDatabaseImpl* database() const { return database_.get(); }
- IndexedDBDatabaseCallbacksWrapper* connection() const {
- return callbacks_.get();
- }
-
- protected:
- virtual ~IndexedDBTransaction();
- friend class base::RefCounted<IndexedDBTransaction>;
-
- private:
- IndexedDBTransaction(
- int64 id,
- scoped_refptr<IndexedDBDatabaseCallbacksWrapper> callbacks,
- const std::set<int64>& object_store_ids,
- indexed_db::TransactionMode,
- IndexedDBDatabaseImpl* db);
-
- enum State {
- UNUSED, // Created, but no tasks yet.
- START_PENDING, // Enqueued tasks, but backing store transaction not yet
- // started.
- RUNNING, // Backing store transaction started but not yet finished.
- FINISHED, // Either aborted or committed.
- };
-
- void Start();
-
- bool IsTaskQueueEmpty() const;
- bool HasPendingTasks() const;
-
- void TaskTimerFired();
- void CloseOpenCursors();
-
- const int64 id_;
- const std::set<int64> object_store_ids_;
- const indexed_db::TransactionMode mode_;
-
- State state_;
- bool commit_pending_;
- scoped_refptr<IndexedDBDatabaseCallbacksWrapper> callbacks_;
- scoped_refptr<IndexedDBDatabaseImpl> database_;
-
- class TaskQueue {
- public:
- TaskQueue();
- ~TaskQueue();
- bool empty() const { return queue_.empty(); }
- void push(Operation* task) { queue_.push(task); }
- scoped_ptr<Operation> pop();
- void clear();
-
- private:
- std::queue<Operation*> queue_;
- };
-
- class TaskStack {
- public:
- TaskStack();
- ~TaskStack();
- bool empty() const { return stack_.empty(); }
- void push(Operation* task) { stack_.push(task); }
- scoped_ptr<Operation> pop();
- void clear();
-
- private:
- std::stack<Operation*> stack_;
- };
-
- TaskQueue task_queue_;
- TaskQueue preemptive_task_queue_;
- TaskStack abort_task_stack_;
-
- IndexedDBBackingStore::Transaction transaction_;
-
- base::OneShotTimer<IndexedDBTransaction> task_timer_;
- int pending_preemptive_events_;
-
- std::set<IndexedDBCursorImpl*> open_cursors_;
-};
-
-} // namespace content
-
-#endif // CONTENT_BROWSER_INDEXED_DB_INDEXED_DB_TRANSACTION_H_