IPC implementation for create/delete ObjectStore/Index

content/common/indexed_db/proxy_webidbdatabase_impl.cc

 // 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.
 
 #include "content/common/indexed_db/proxy_webidbdatabase_impl.h"
 
 #include <vector>
 
 #include "content/common/child_thread.h"
 #include "content/common/indexed_db/indexed_db_messages.h"
@@ skipping 81 matching lines @@
   return web_metadata;
 }
 
 WebKit::WebIDBObjectStore* RendererWebIDBDatabaseImpl::createObjectStore(
     long long id,
     const WebKit::WebString& name,
     const WebKit::WebIDBKeyPath& key_path,
     bool auto_increment,
     const WebKit::WebIDBTransaction& transaction,
     WebExceptionCode& ec) {
-  IndexedDBHostMsg_DatabaseCreateObjectStore_Params params;
+  IndexedDBHostMsg_DatabaseCreateObjectStoreOld_Params params;
   params.id = id;
   params.name = name;
   params.key_path = IndexedDBKeyPath(key_path);
   params.auto_increment = auto_increment;
   params.ipc_transaction_id = IndexedDBDispatcher::TransactionId(transaction);
   params.ipc_database_id = ipc_database_id_;
 
   int object_store;
   IndexedDBDispatcher::Send(
-      new IndexedDBHostMsg_DatabaseCreateObjectStore(
+      new IndexedDBHostMsg_DatabaseCreateObjectStoreOld(
           params, &object_store, &ec));
   if (!object_store)
     return NULL;
   return new RendererWebIDBObjectStoreImpl(object_store);
 }
 
+void RendererWebIDBDatabaseImpl::createObjectStore(
+    long long transaction_id,
+    long long object_store_id,
+    const WebKit::WebString& name,
+    const WebKit::WebIDBKeyPath& key_path,
+    bool auto_increment) {
+  IndexedDBHostMsg_DatabaseCreateObjectStore_Params params;
+  params.ipc_database_id = ipc_database_id_;
+  params.transaction_id = transaction_id;
+  params.object_store_id = object_store_id;
+  params.name = name;
+  params.key_path = IndexedDBKeyPath(key_path);
+  params.auto_increment = auto_increment;
+
+  IndexedDBDispatcher::Send(
+      new IndexedDBHostMsg_DatabaseCreateObjectStore(params));
+}
+
 void RendererWebIDBDatabaseImpl::deleteObjectStore(
     long long object_store_id,
     const WebIDBTransaction& transaction,
     WebExceptionCode& ec) {
   IndexedDBDispatcher::Send(
-      new IndexedDBHostMsg_DatabaseDeleteObjectStore(
+      new IndexedDBHostMsg_DatabaseDeleteObjectStoreOld(
           ipc_database_id_, object_store_id,
           IndexedDBDispatcher::TransactionId(transaction), &ec));
 }
 
+void RendererWebIDBDatabaseImpl::deleteObjectStore(
+    long long transaction_id,
+    long long object_store_id) {
+  IndexedDBDispatcher::Send(
+      new IndexedDBHostMsg_DatabaseDeleteObjectStore(
+          ipc_database_id_,
+          transaction_id,
+          object_store_id));
+}
+
 WebKit::WebIDBTransaction* RendererWebIDBDatabaseImpl::createTransaction(
     long long transaction_id,
     const WebVector<long long>& object_store_ids,
     unsigned short mode) {
   std::vector<int64> object_stores;
   object_stores.reserve(object_store_ids.size());
   for (unsigned int i = 0; i < object_store_ids.size(); ++i)
       object_stores.push_back(object_store_ids[i]);
 
   int ipc_transaction_id;
@@ skipping 127 matching lines @@
 void RendererWebIDBDatabaseImpl::clear(
     long long transaction_id,
     long long object_store_id,
     WebIDBCallbacks* callbacks) {
   IndexedDBDispatcher* dispatcher =
       IndexedDBDispatcher::ThreadSpecificInstance();
   dispatcher->RequestIDBDatabaseClear(
       ipc_database_id_,
       transaction_id, object_store_id, callbacks);
 }
+
+void RendererWebIDBDatabaseImpl::createIndex(
+    long long transaction_id,
+    long long object_store_id,
+    long long index_id,
+    const WebString& name,
+    const WebIDBKeyPath& key_path,
+    bool unique,
+    bool multi_entry)
+{
+  IndexedDBHostMsg_DatabaseCreateIndex_Params params;
+  params.ipc_database_id = ipc_database_id_;
+  params.transaction_id = transaction_id;
+  params.object_store_id = object_store_id;
+  params.index_id = index_id;
+  params.name = name;
+  params.key_path = IndexedDBKeyPath(key_path);
+  params.unique = unique;
+  params.multi_entry = multi_entry;
+
+  IndexedDBDispatcher::Send(
+      new IndexedDBHostMsg_DatabaseCreateIndex(params));
+}
+
+void RendererWebIDBDatabaseImpl::deleteIndex(
+    long long transaction_id,
+    long long object_store_id,
+    long long index_id)
+{
+  IndexedDBDispatcher::Send(
+      new IndexedDBHostMsg_DatabaseDeleteIndex(
+          ipc_database_id_,
+          transaction_id,
+          object_store_id, index_id));
+}
 }  // namespace content