Dispatch IndexedDB IPC messages to worker threads

content/renderer/renderer_webidbdatabase_impl.cc

Index: content/renderer/renderer_webidbdatabase_impl.cc
diff --git a/content/renderer/renderer_webidbdatabase_impl.cc b/content/renderer/renderer_webidbdatabase_impl.cc
index 79fc28be7317c38a6d7354c1f216b44ff1d37232..6feb5468dd3acb10368e0434bf0faa3da8b61a3e 100644
--- a/content/renderer/renderer_webidbdatabase_impl.cc
+++ b/content/renderer/renderer_webidbdatabase_impl.cc
@@ -11,6 +11,7 @@
 #include "content/renderer/renderer_webidbtransaction_impl.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebString.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/platform/WebVector.h"
+#include "webkit/glue/worker_task_runner.h"
 
 using WebKit::WebDOMStringList;
 using WebKit::WebExceptionCode;
@@ -20,6 +21,7 @@ using WebKit::WebIDBDatabaseCallbacks;
 using WebKit::WebIDBTransaction;
 using WebKit::WebString;
 using WebKit::WebVector;
+using webkit_glue::WorkerTaskRunner;
 
 RendererWebIDBDatabaseImpl::RendererWebIDBDatabaseImpl(int32 idb_database_id)
     : idb_database_id_(idb_database_id) {
@@ -96,8 +98,7 @@ void RendererWebIDBDatabaseImpl::setVersion(
     const WebString& version,
     WebIDBCallbacks* callbacks,
     WebExceptionCode& ec) {
-  IndexedDBDispatcher* dispatcher =
-      RenderThreadImpl::current()->indexed_db_dispatcher();
+  IndexedDBDispatcher* dispatcher = IndexedDBDispatcher::Instance();
   dispatcher->RequestIDBDatabaseSetVersion(
       version, callbacks, idb_database_id_, &ec);
 }
@@ -112,23 +113,21 @@ WebKit::WebIDBTransaction* RendererWebIDBDatabaseImpl::transaction(
     object_stores.push_back(names.item(i));
 
   int transaction_id;
-  ChildThread::current()->Send(
-      new IndexedDBHostMsg_DatabaseTransaction(
-          idb_database_id_, object_stores, mode,
-          &transaction_id, &ec));
+  ChildThread::current()->Send(new IndexedDBHostMsg_DatabaseTransaction(
+      WorkerTaskRunner::Instance()->CurrentWorkerId(),
+      idb_database_id_, object_stores, mode, &transaction_id, &ec));
   if (!transaction_id)
     return NULL;
   return new RendererWebIDBTransactionImpl(transaction_id);
 }
 
 void RendererWebIDBDatabaseImpl::close() {
-  IndexedDBDispatcher* dispatcher =
-      RenderThreadImpl::current()->indexed_db_dispatcher();
+  IndexedDBDispatcher* dispatcher = IndexedDBDispatcher::Instance();
   dispatcher->RequestIDBDatabaseClose(idb_database_id_);
 }
 
 void RendererWebIDBDatabaseImpl::open(WebIDBDatabaseCallbacks* callbacks) {
-  IndexedDBDispatcher* dispatcher =
-      RenderThreadImpl::current()->indexed_db_dispatcher();
+  IndexedDBDispatcher* dispatcher = IndexedDBDispatcher::Instance();
+  DCHECK(dispatcher);
   dispatcher->RequestIDBDatabaseOpen(callbacks, idb_database_id_);
 }