| 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
|
|
|