| 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_
|
|
|