Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1014)

Unified Diff: content/common_child/indexed_db/indexed_db_message_filter.cc

Issue 16325022: move content/common_child to content/child (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: . Created 7 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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
« no previous file with comments | « content/common_child/indexed_db/indexed_db_message_filter.h ('k') | content/common_child/indexed_db/proxy_webidbcursor_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698