[IndexedDB] Add transaction coordinator.

chrome/renderer/indexed_db_dispatcher.cc

 // Copyright (c) 2009 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 "chrome/renderer/indexed_db_dispatcher.h"
 
 #include "chrome/common/render_messages.h"
 #include "chrome/common/serialized_script_value.h"
 #include "chrome/renderer/render_thread.h"
 #include "chrome/renderer/render_view.h"
@@ skipping 26 matching lines @@
     IPC_MESSAGE_HANDLER(ViewMsg_IDBCallbacksSuccessIndexedDBKey,
                         OnSuccessIndexedDBKey)
     IPC_MESSAGE_HANDLER(ViewMsg_IDBCallbacksSuccessIDBObjectStore,
                         OnSuccessIDBObjectStore)
     IPC_MESSAGE_HANDLER(ViewMsg_IDBCallbacksSuccessIDBIndex,
                         OnSuccessIDBIndex)
     IPC_MESSAGE_HANDLER(ViewMsg_IDBCallbacksSuccessSerializedScriptValue,
                         OnSuccessSerializedScriptValue)
     IPC_MESSAGE_HANDLER(ViewMsg_IDBCallbacksError,
                         OnError)
+    IPC_MESSAGE_HANDLER(ViewMsg_IDBTransactionCallbacksAbort,
+                        OnAbort)
     IPC_MESSAGE_UNHANDLED(handled = false)
   IPC_END_MESSAGE_MAP()
   return handled;
 }
 
 void IndexedDBDispatcher::RequestIDBFactoryOpen(
     const string16& name, const string16& description,
     WebIDBCallbacks* callbacks_ptr, const string16& origin,
     WebFrame* web_frame) {
   scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
@@ skipping 91 matching lines @@
     const string16& name, WebIDBCallbacks* callbacks_ptr,
     int32 idb_object_store_id) {
   scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr);
 
   RenderThread::current()->Send(
       new ViewHostMsg_IDBObjectStoreRemoveIndex(
           idb_object_store_id, pending_callbacks_.Add(callbacks.release()),
           name));
 }
 
+void IndexedDBDispatcher::RequestIDBTransactionSetCallbacks(
+    WebKit::WebIDBTransactionCallbacks* callbacks) {
+    pending_transaction_callbacks_.AddWithID(callbacks, callbacks->id());
+}
+
+
 void IndexedDBDispatcher::OnSuccessNull(int32 response_id) {
   WebKit::WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
   callbacks->onSuccess();
   pending_callbacks_.Remove(response_id);
 }
 
 void IndexedDBDispatcher::OnSuccessIDBDatabase(int32 response_id,
                                                int32 object_id) {
   WebKit::WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
   callbacks->onSuccess(new RendererWebIDBDatabaseImpl(object_id));
@@ skipping 27 matching lines @@
   callbacks->onSuccess(value);
   pending_callbacks_.Remove(response_id);
 }
 
 void IndexedDBDispatcher::OnError(int32 response_id, int code,
                                   const string16& message) {
   WebKit::WebIDBCallbacks* callbacks = pending_callbacks_.Lookup(response_id);
   callbacks->onError(WebIDBDatabaseError(code, message));
   pending_callbacks_.Remove(response_id);
 }
+
+void IndexedDBDispatcher::OnAbort(int transaction_id) {
+  WebKit::WebIDBTransactionCallbacks* callbacks =
+      pending_transaction_callbacks_.Lookup(transaction_id);
+  DCHECK(callbacks);
+  callbacks->onAbort();
+  pending_transaction_callbacks_.Remove(transaction_id);
+}