Index: content/common_child/indexed_db/indexed_db_dispatcher.h |
diff --git a/content/common_child/indexed_db/indexed_db_dispatcher.h b/content/common_child/indexed_db/indexed_db_dispatcher.h |
deleted file mode 100644 |
index cba01fe1aa521361a99da6eae266350e459ed0c1..0000000000000000000000000000000000000000 |
--- a/content/common_child/indexed_db/indexed_db_dispatcher.h |
+++ /dev/null |
@@ -1,241 +0,0 @@ |
-// Copyright (c) 2012 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_COMMON_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
-#define CONTENT_COMMON_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |
- |
-#include <map> |
-#include <vector> |
- |
-#include "base/gtest_prod_util.h" |
-#include "base/id_map.h" |
-#include "base/nullable_string16.h" |
-#include "content/common/content_export.h" |
-#include "ipc/ipc_sync_message_filter.h" |
-#include "third_party/WebKit/public/platform/WebIDBCallbacks.h" |
-#include "third_party/WebKit/public/platform/WebIDBCursor.h" |
-#include "third_party/WebKit/public/platform/WebIDBDatabase.h" |
-#include "third_party/WebKit/public/platform/WebIDBDatabaseCallbacks.h" |
-#include "webkit/glue/worker_task_runner.h" |
- |
-struct IndexedDBDatabaseMetadata; |
-struct IndexedDBMsg_CallbacksSuccessCursorContinue_Params; |
-struct IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params; |
-struct IndexedDBMsg_CallbacksSuccessIDBCursor_Params; |
-struct IndexedDBMsg_CallbacksUpgradeNeeded_Params; |
- |
-namespace WebKit { |
-class WebData; |
-} |
- |
-namespace content { |
-class IndexedDBKey; |
-class IndexedDBKeyPath; |
-class IndexedDBKeyRange; |
-class RendererWebIDBCursorImpl; |
-class RendererWebIDBDatabaseImpl; |
- |
-CONTENT_EXPORT extern const size_t kMaxIDBValueSizeInBytes; |
- |
-// Handle the indexed db related communication for this context thread - the |
-// main thread and each worker thread have their own copies. |
-class CONTENT_EXPORT IndexedDBDispatcher |
- : public webkit_glue::WorkerTaskRunner::Observer { |
- public: |
- // Constructor made public to allow RenderThreadImpl to own a copy without |
- // failing a NOTREACHED in ThreadSpecificInstance in tests that instantiate |
- // two copies of RenderThreadImpl on the same thread. Everyone else probably |
- // wants to use ThreadSpecificInstance(). |
- IndexedDBDispatcher(); |
- virtual ~IndexedDBDispatcher(); |
- static IndexedDBDispatcher* ThreadSpecificInstance(); |
- |
- // webkit_glue::WorkerTaskRunner::Observer implementation. |
- virtual void OnWorkerRunLoopStopped() OVERRIDE; |
- |
- static WebKit::WebIDBMetadata ConvertMetadata( |
- const IndexedDBDatabaseMetadata& idb_metadata); |
- |
- void OnMessageReceived(const IPC::Message& msg); |
- static bool Send(IPC::Message* msg); |
- |
- void RequestIDBFactoryGetDatabaseNames(WebKit::WebIDBCallbacks* callbacks, |
- const string16& database_identifier); |
- |
- void RequestIDBFactoryOpen( |
- const string16& name, |
- int64 version, |
- int64 transaction_id, |
- WebKit::WebIDBCallbacks* callbacks, |
- WebKit::WebIDBDatabaseCallbacks* database_callbacks, |
- const string16& database_identifier); |
- |
- void RequestIDBFactoryDeleteDatabase(const string16& name, |
- WebKit::WebIDBCallbacks* callbacks, |
- const string16& database_identifier); |
- |
- void RequestIDBCursorAdvance(unsigned long count, |
- WebKit::WebIDBCallbacks* callbacks_ptr, |
- int32 ipc_cursor_id); |
- |
- virtual void RequestIDBCursorContinue(const IndexedDBKey& key, |
- WebKit::WebIDBCallbacks* callbacks_ptr, |
- int32 ipc_cursor_id); |
- |
- virtual void RequestIDBCursorPrefetch(int n, |
- WebKit::WebIDBCallbacks* callbacks_ptr, |
- int32 ipc_cursor_id); |
- |
- void RequestIDBCursorPrefetchReset(int used_prefetches, |
- int unused_prefetches, |
- int32 ipc_cursor_id); |
- |
- void RequestIDBDatabaseClose(int32 ipc_database_id, |
- int32 ipc_database_callbacks_id); |
- |
- void RequestIDBDatabaseCreateTransaction( |
- int32 ipc_database_id, |
- int64 transaction_id, |
- WebKit::WebIDBDatabaseCallbacks* database_callbacks_ptr, |
- WebKit::WebVector<long long> object_store_ids, |
- unsigned short mode); |
- |
- void RequestIDBDatabaseGet(int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- int64 index_id, |
- const IndexedDBKeyRange& key_range, |
- bool key_only, |
- WebKit::WebIDBCallbacks* callbacks); |
- |
- void RequestIDBDatabasePut( |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- const WebKit::WebData& value, |
- const IndexedDBKey& key, |
- WebKit::WebIDBDatabase::PutMode put_mode, |
- WebKit::WebIDBCallbacks* callbacks, |
- const WebKit::WebVector<long long>& index_ids, |
- const WebKit::WebVector<WebKit::WebVector<WebKit::WebIDBKey> >& |
- index_keys); |
- |
- void RequestIDBDatabaseOpenCursor(int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- int64 index_id, |
- const IndexedDBKeyRange& key_range, |
- unsigned short direction, |
- bool key_only, |
- WebKit::WebIDBDatabase::TaskType task_type, |
- WebKit::WebIDBCallbacks* callbacks); |
- |
- void RequestIDBDatabaseCount(int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- int64 index_id, |
- const IndexedDBKeyRange& key_range, |
- WebKit::WebIDBCallbacks* callbacks); |
- |
- void RequestIDBDatabaseDeleteRange(int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- const IndexedDBKeyRange& key_range, |
- WebKit::WebIDBCallbacks* callbacks); |
- |
- void RequestIDBDatabaseClear(int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- WebKit::WebIDBCallbacks* callbacks); |
- |
- virtual void CursorDestroyed(int32 ipc_cursor_id); |
- void DatabaseDestroyed(int32 ipc_database_id); |
- |
- private: |
- FRIEND_TEST_ALL_PREFIXES(IndexedDBDispatcherTest, ValueSizeTest); |
- |
- static int32 CurrentWorkerId() { |
- return webkit_glue::WorkerTaskRunner::Instance()->CurrentWorkerId(); |
- } |
- |
- template <typename T> |
- void init_params(T& params, WebKit::WebIDBCallbacks* callbacks_ptr) { |
- scoped_ptr<WebKit::WebIDBCallbacks> callbacks(callbacks_ptr); |
- params.ipc_thread_id = CurrentWorkerId(); |
- params.ipc_callbacks_id = pending_callbacks_.Add(callbacks.release()); |
- } |
- |
- // IDBCallback message handlers. |
- void OnSuccessIDBDatabase(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int32 ipc_database_callbacks_id, |
- int32 ipc_object_id, |
- const IndexedDBDatabaseMetadata& idb_metadata); |
- void OnSuccessIndexedDBKey(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- const IndexedDBKey& key); |
- |
- void OnSuccessOpenCursor( |
- const IndexedDBMsg_CallbacksSuccessIDBCursor_Params& p); |
- void OnSuccessCursorContinue( |
- const IndexedDBMsg_CallbacksSuccessCursorContinue_Params& p); |
- void OnSuccessCursorPrefetch( |
- const IndexedDBMsg_CallbacksSuccessCursorPrefetch_Params& p); |
- void OnSuccessStringList(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- const std::vector<string16>& value); |
- void OnSuccessValue(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- const std::vector<char>& value); |
- void OnSuccessValueWithKey(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- const std::vector<char>& value, |
- const IndexedDBKey& primary_key, |
- const IndexedDBKeyPath& key_path); |
- void OnSuccessInteger(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int64 value); |
- void OnSuccessUndefined(int32 ipc_thread_id, int32 ipc_callbacks_id); |
- void OnError(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int code, |
- const string16& message); |
- void OnIntBlocked(int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int64 existing_version); |
- void OnUpgradeNeeded(const IndexedDBMsg_CallbacksUpgradeNeeded_Params& p); |
- void OnAbort(int32 ipc_thread_id, |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int code, |
- const string16& message); |
- void OnComplete(int32 ipc_thread_id, |
- int32 ipc_database_id, |
- int64 transaction_id); |
- void OnForcedClose(int32 ipc_thread_id, int32 ipc_database_id); |
- void OnIntVersionChange(int32 ipc_thread_id, |
- int32 ipc_database_id, |
- int64 old_version, |
- int64 new_version); |
- |
- // Reset cursor prefetch caches for all cursors except exception_cursor_id. |
- void ResetCursorPrefetchCaches(int32 ipc_exception_cursor_id = -1); |
- |
- // Careful! WebIDBCallbacks wraps non-threadsafe data types. It must be |
- // destroyed and used on the same thread it was created on. |
- IDMap<WebKit::WebIDBCallbacks, IDMapOwnPointer> pending_callbacks_; |
- IDMap<WebKit::WebIDBDatabaseCallbacks, IDMapOwnPointer> |
- pending_database_callbacks_; |
- |
- // Map from cursor id to RendererWebIDBCursorImpl. |
- std::map<int32, RendererWebIDBCursorImpl*> cursors_; |
- |
- std::map<int32, RendererWebIDBDatabaseImpl*> databases_; |
- |
- DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher); |
-}; |
- |
-} // namespace content |
- |
-#endif // CONTENT_COMMON_CHILD_INDEXED_DB_INDEXED_DB_DISPATCHER_H_ |