Proxy new objectstore/index methods through IPC

content/common/indexed_db/indexed_db_dispatcher.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_COMMON_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
 #define CONTENT_COMMON_INDEXED_DB_INDEXED_DB_DISPATCHER_H_
 
 #include <map>
 #include <vector>
 
@@ skipping 99 matching lines @@
                                      int32 ipc_cursor_id);
 
   void RequestIDBCursorDelete(
       WebKit::WebIDBCallbacks* callbacks_ptr,
       int32 ipc_cursor_id,
       WebKit::WebExceptionCode* ec);
 
   void RequestIDBDatabaseClose(
       int32 ipc_database_id);
 
+  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,
+      WebKit::WebVector<unsigned char>* 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);
+
   void RequestIDBIndexOpenObjectCursor(
       const WebKit::WebIDBKeyRange& idb_key_range,
       unsigned short direction,
       WebKit::WebIDBCallbacks* callbacks,
       int32 ipc_index_id,
       const WebKit::WebIDBTransaction& transaction,
       WebKit::WebExceptionCode* ec);
 
   void RequestIDBIndexOpenKeyCursor(
       const WebKit::WebIDBKeyRange& idb_key_range,
@@ skipping 76 matching lines @@
       int32 id);
 
   void CursorDestroyed(int32 ipc_cursor_id);
   void DatabaseDestroyed(int32 ipc_database_id);
 
   static int32 TransactionId(const WebKit::WebIDBTransaction& transaction);
 
  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_response_id = pending_callbacks_.Add(callbacks.release());
+  }
+
   // IDBCallback message handlers.
   void OnSuccessIDBDatabase(int32 ipc_thread_id,
                             int32 ipc_response_id,
                             int32 ipc_object_id);
   void OnSuccessIndexedDBKey(int32 ipc_thread_id,
                              int32 ipc_response_id,
                              const IndexedDBKey& key);
   void OnSuccessOpenCursor(
       const IndexedDBMsg_CallbacksSuccessIDBCursor_Params& p);
   void OnSuccessCursorContinue(
@@ skipping 61 matching lines @@
   std::map<int32, RendererWebIDBCursorImpl*> cursors_;
 
   std::map<int32, RendererWebIDBDatabaseImpl*> databases_;
 
   DISALLOW_COPY_AND_ASSIGN(IndexedDBDispatcher);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_COMMON_INDEXED_DB_INDEXED_DB_DISPATCHER_H_