Dispatch IndexedDB IPC messages to worker threads

content/renderer/indexed_db_message_filter.cc

Index: content/renderer/indexed_db_message_filter.cc
diff --git a/content/renderer/indexed_db_message_filter.cc b/content/renderer/indexed_db_message_filter.cc
new file mode 100644
index 0000000000000000000000000000000000000000..c6dac1a09767e18a1ae637fbd0db6cdada374138
--- /dev/null
+++ b/content/renderer/indexed_db_message_filter.cc
@@ -0,0 +1,37 @@
+// Copyright (c) 2011 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/renderer/indexed_db_message_filter.h"
+
+#include "base/bind.h"
+#include "base/location.h"
+#include "content/common/indexed_db_messages.h"
+#include "content/renderer/indexed_db_dispatcher.h"
+#include "webkit/glue/worker_task_runner.h"
+
+using webkit_glue::WorkerTaskRunner;
+
+IndexedDBMessageFilter::IndexedDBMessageFilter() :
+    main_thread_loop_proxy_(base::MessageLoopProxy::current()) {
+}
+
+IndexedDBMessageFilter::~IndexedDBMessageFilter() {
+}
+
+bool IndexedDBMessageFilter::OnMessageReceived(const IPC::Message& msg) {
+  if (IPC_MESSAGE_CLASS(msg) != IndexedDBMsgStart)
+    return false;
+  int thread_id = IPC::MessageIterator(msg).NextInt();
+  base::Closure closure = base::Bind(
+      &IndexedDBMessageFilter::DispatchMessage, this, msg);
+  if (thread_id)
+    WorkerTaskRunner::Instance()->PostTask(thread_id, closure);
+  else
+    main_thread_loop_proxy_->PostTask(FROM_HERE, closure);
+  return true;
+}
+
+void IndexedDBMessageFilter::DispatchMessage(const IPC::Message& msg) {
+  IndexedDBDispatcher::ThreadSpecificInstance()->OnMessageReceived(msg);
+}