Index: content/common_child/indexed_db/indexed_db_message_filter.cc |
diff --git a/content/common_child/indexed_db/indexed_db_message_filter.cc b/content/common_child/indexed_db/indexed_db_message_filter.cc |
deleted file mode 100644 |
index 360a6b909c10aa1c3a23dbdec051209f596b8aa8..0000000000000000000000000000000000000000 |
--- a/content/common_child/indexed_db/indexed_db_message_filter.cc |
+++ /dev/null |
@@ -1,79 +0,0 @@ |
-// 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_child/indexed_db/indexed_db_message_filter.h" |
- |
-#include "base/bind.h" |
-#include "base/location.h" |
-#include "base/message_loop_proxy.h" |
-#include "base/pickle.h" |
-#include "content/common/child_thread.h" |
-#include "content/common/indexed_db/indexed_db_messages.h" |
-#include "content/common_child/indexed_db/indexed_db_dispatcher.h" |
-#include "webkit/glue/worker_task_runner.h" |
- |
-using webkit_glue::WorkerTaskRunner; |
- |
-namespace content { |
- |
-IndexedDBMessageFilter::IndexedDBMessageFilter() : |
- main_thread_loop_proxy_(base::MessageLoopProxy::current()) { |
-} |
- |
-bool IndexedDBMessageFilter::OnMessageReceived(const IPC::Message& msg) { |
- if (IPC_MESSAGE_CLASS(msg) != IndexedDBMsgStart) |
- return false; |
- int ipc_thread_id = -1; |
- bool result = PickleIterator(msg).ReadInt(&ipc_thread_id); |
- DCHECK(result); |
- base::Closure closure = base::Bind( |
- &IndexedDBMessageFilter::DispatchMessage, this, msg); |
- if (!ipc_thread_id) { |
- main_thread_loop_proxy_->PostTask(FROM_HERE, closure); |
- return true; |
- } |
- if (WorkerTaskRunner::Instance()->PostTask(ipc_thread_id, closure)) |
- return true; |
- |
- // Message for a terminated worker - perform necessary cleanup |
- OnStaleMessageReceived(msg); |
- return true; |
-} |
- |
-IndexedDBMessageFilter::~IndexedDBMessageFilter() {} |
- |
-void IndexedDBMessageFilter::DispatchMessage(const IPC::Message& msg) { |
- IndexedDBDispatcher::ThreadSpecificInstance()->OnMessageReceived(msg); |
-} |
- |
-void IndexedDBMessageFilter::OnStaleMessageReceived(const IPC::Message& msg) { |
- IPC_BEGIN_MESSAGE_MAP(IndexedDBMessageFilter, msg) |
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksSuccessIDBDatabase, |
- OnStaleSuccessIDBDatabase) |
- IPC_MESSAGE_HANDLER(IndexedDBMsg_CallbacksUpgradeNeeded, |
- OnStaleUpgradeNeeded) |
- IPC_END_MESSAGE_MAP() |
-} |
- |
-void IndexedDBMessageFilter::OnStaleSuccessIDBDatabase( |
- int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int32 ipc_database_callbacks_id, |
- int32 ipc_database_id, |
- const IndexedDBDatabaseMetadata& idb_metadata) { |
- scoped_refptr<IPC::SyncMessageFilter> filter( |
- ChildThread::current()->sync_message_filter()); |
- filter->Send( |
- new IndexedDBHostMsg_DatabaseClose(ipc_database_id)); |
-} |
- |
-void IndexedDBMessageFilter::OnStaleUpgradeNeeded( |
- const IndexedDBMsg_CallbacksUpgradeNeeded_Params& p) { |
- scoped_refptr<IPC::SyncMessageFilter> filter( |
- ChildThread::current()->sync_message_filter()); |
- filter->Send( |
- new IndexedDBHostMsg_DatabaseClose(p.ipc_database_id)); |
-} |
- |
-} // namespace content |