diff options
Diffstat (limited to 'content/browser/indexed_db/indexed_db_transaction.h')
-rw-r--r-- | content/browser/indexed_db/indexed_db_transaction.h | 150 |
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_ |