Proxy new objectstore/index methods through IPC

content/browser/in_process_webkit/indexed_db_dispatcher_host.h

 // 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_BROWSER_IN_PROCESS_WEBKIT_INDEXED_DB_DISPATCHER_HOST_H_
 #define CONTENT_BROWSER_IN_PROCESS_WEBKIT_INDEXED_DB_DISPATCHER_HOST_H_
 
 #include <map>
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/id_map.h"
 #include "content/public/browser/browser_message_filter.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebExceptionCode.h"
 
 class GURL;
 struct IndexedDBDatabaseMetadata;
+struct IndexedDBHostMsg_DatabaseCount_Params;
 struct IndexedDBHostMsg_DatabaseCreateObjectStore_Params;
+struct IndexedDBHostMsg_DatabaseDeleteRange_Params;

[jsbell, 2012/12/14 23:04:34]

This was only called "DeleteRange" when we had Delete(key) vs.
DeleteRange(keyRange). Could be simplified now.

+struct IndexedDBHostMsg_DatabaseGet_Params;
+struct IndexedDBHostMsg_DatabaseOpenCursor_Params;
+struct IndexedDBHostMsg_DatabasePut_Params;
+struct IndexedDBHostMsg_DatabaseSetIndexKeys_Params;
 struct IndexedDBHostMsg_FactoryDeleteDatabase_Params;
 struct IndexedDBHostMsg_FactoryGetDatabaseNames_Params;
 struct IndexedDBHostMsg_FactoryOpen_Params;
 struct IndexedDBHostMsg_IndexCount_Params;
 struct IndexedDBHostMsg_IndexOpenCursor_Params;
 struct IndexedDBHostMsg_ObjectStoreCount_Params;
 struct IndexedDBHostMsg_ObjectStoreCreateIndex_Params;
 struct IndexedDBHostMsg_ObjectStoreOpenCursor_Params;
 struct IndexedDBHostMsg_ObjectStorePut_Params;
 
@@ skipping 69 matching lines @@
   template <class ReturnType>
   ReturnType* GetOrTerminateProcess(
     IDMap<ReturnType, IDMapOwnPointer>* map, int32 ipc_return_object_id);
 
   template <typename ObjectType>
   void DestroyObject(IDMap<ObjectType, IDMapOwnPointer>* map,
                      int32 ipc_object_id);
 
   // Used in nested classes.
   typedef std::map<int32, GURL> WebIDBObjectIDToURLMap;
-  typedef std::map<int32, int64> WebIDBTransactionIDToSizeMap;
+  typedef std::map<int32, uint64> WebIDBTransactionIPCIDToSizeMap;
+  typedef std::map<int64, uint64> WebIDBTransactionIDToSizeMap;
 
   class DatabaseDispatcherHost {
    public:
     explicit DatabaseDispatcherHost(IndexedDBDispatcherHost* parent);
     ~DatabaseDispatcherHost();
 
     bool OnMessageReceived(const IPC::Message& message, bool *msg_is_ok);
     void Send(IPC::Message* message);
 
     void OnMetadata(int32 ipc_database_id,
                     IndexedDBDatabaseMetadata* metadata);
     void OnCreateObjectStore(
         const IndexedDBHostMsg_DatabaseCreateObjectStore_Params& params,
         int32* object_store_id, WebKit::WebExceptionCode* ec);
     void OnDeleteObjectStore(int32 ipc_database_id,
                              int64 object_store_id,
                              int32 ipc_transaction_id,
                              WebKit::WebExceptionCode* ec);
     void OnCreateTransaction(int32 ipc_thread_id,
                              int32 ipc_database_id,
                              int64 transaction_id,
                              const std::vector<int64>& scope,
                              int32 mode,
                              int32* ipc_transaction_id);
     void OnOpen(int32 ipc_database_id, int32 ipc_thread_id,
                 int32 ipc_response_id);
     void OnClose(int32 ipc_database_id);
     void OnDestroyed(int32 ipc_database_id);
 
+    void OnGet(const IndexedDBHostMsg_DatabaseGet_Params& params);
+    void OnPut(const IndexedDBHostMsg_DatabasePut_Params& params);
+    void OnSetIndexKeys(
+        const IndexedDBHostMsg_DatabaseSetIndexKeys_Params& params);
+    void OnSetIndexesReady(
+        int32 ipc_database_id,
+        int64 transaction_id,
+        int64 object_store_id,
+        const std::vector<int64>& ids);
+    void OnOpenCursor(
+        const IndexedDBHostMsg_DatabaseOpenCursor_Params& params);
+    void OnCount(const IndexedDBHostMsg_DatabaseCount_Params& params);
+    void OnDelete(const IndexedDBHostMsg_DatabaseDeleteRange_Params& params);
+    void OnClear(int32 ipc_thread_id,
+                 int32 ipc_response_id,
+                 int32 ipc_database_id,
+                 int64 transaction_id,
+                 int64 object_store_id);
     IndexedDBDispatcherHost* parent_;
     IDMap<WebKit::WebIDBDatabase, IDMapOwnPointer> map_;
     WebIDBObjectIDToURLMap database_url_map_;
+    WebIDBTransactionIDToSizeMap transaction_size_map_;
   };
 
   class IndexDispatcherHost {
    public:
     explicit IndexDispatcherHost(IndexedDBDispatcherHost* parent);
     ~IndexDispatcherHost();
 
     bool OnMessageReceived(const IPC::Message& message, bool *msg_is_ok);
     void Send(IPC::Message* message);
 
@@ skipping 118 matching lines @@
                        int64 object_store_id,
                        int32* ipc_object_store_id,
                        WebKit::WebExceptionCode* ec);
     void OnDidCompleteTaskEvents(int ipc_transaction_id);
     void OnDestroyed(int32 ipc_transaction_id);
 
     IndexedDBDispatcherHost* parent_;
     typedef IDMap<WebKit::WebIDBTransaction, IDMapOwnPointer> MapType;
     MapType map_;
     WebIDBObjectIDToURLMap transaction_url_map_;
-    WebIDBTransactionIDToSizeMap transaction_size_map_;
+    WebIDBTransactionIPCIDToSizeMap transaction_ipc_size_map_;
   };
 
   scoped_refptr<IndexedDBContextImpl> indexed_db_context_;
 
   // Only access on WebKit thread.
   scoped_ptr<DatabaseDispatcherHost> database_dispatcher_host_;
   scoped_ptr<IndexDispatcherHost> index_dispatcher_host_;
   scoped_ptr<ObjectStoreDispatcherHost> object_store_dispatcher_host_;
   scoped_ptr<CursorDispatcherHost> cursor_dispatcher_host_;
   scoped_ptr<TransactionDispatcherHost> transaction_dispatcher_host_;
 
   // Used to dispatch messages to the correct view host.
   int ipc_process_id_;
 
   DISALLOW_IMPLICIT_CONSTRUCTORS(IndexedDBDispatcherHost);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_BROWSER_IN_PROCESS_WEBKIT_INDEXED_DB_DISPATCHER_HOST_H_