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

Unified Diff: content/child/indexed_db/indexed_db_message_filter.h

Issue 63843002: Add ChildMessageFilter, a base class for renderer/worker cross-thread MessageFilter (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 1 month 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/child/indexed_db/indexed_db_message_filter.h
diff --git a/content/child/indexed_db/indexed_db_message_filter.h b/content/child/indexed_db/indexed_db_message_filter.h
index da11adf5e90b83a28eac7288ca39779d3864b7f8..55f6d2a472f71ed4450c6211ae9b62e7ee15e987 100644
--- a/content/child/indexed_db/indexed_db_message_filter.h
+++ b/content/child/indexed_db/indexed_db_message_filter.h
@@ -5,32 +5,28 @@
#ifndef CONTENT_CHILD_INDEXED_DB_INDEXED_DB_MESSAGE_FILTER_H_
#define CONTENT_CHILD_INDEXED_DB_INDEXED_DB_MESSAGE_FILTER_H_
-#include "ipc/ipc_channel_proxy.h"
+#include "content/child/cross_thread_message_filter.h"
struct IndexedDBDatabaseMetadata;
struct IndexedDBMsg_CallbacksUpgradeNeeded_Params;
-namespace base {
-class MessageLoopProxy;
-} // namespace base
-
namespace content {
-class IndexedDBDispatcher;
class ThreadSafeSender;
-class IndexedDBMessageFilter : public IPC::ChannelProxy::MessageFilter {
+class IndexedDBMessageFilter : public CrossThreadMessageFilter {
public:
explicit IndexedDBMessageFilter(ThreadSafeSender* thread_safe_sender);
- // IPC::Listener implementation.
- virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
-
protected:
virtual ~IndexedDBMessageFilter();
private:
- void DispatchMessage(const IPC::Message& msg);
- void OnStaleMessageReceived(const IPC::Message& msg);
+ // CrossThreadMessageFilter implementation:
+ virtual bool OverrideThreadIDForMessage(const IPC::Message& msg,
+ int* ipc_thread_id) OVERRIDE;
+ virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
+ virtual void OnStaleMessageReceived(const IPC::Message& msg) OVERRIDE;
+
void OnStaleSuccessIDBDatabase(int32 ipc_thread_id,
int32 ipc_callbacks_id,
int32 ipc_database_callbacks_id,
@@ -38,7 +34,6 @@ class IndexedDBMessageFilter : public IPC::ChannelProxy::MessageFilter {
const IndexedDBDatabaseMetadata&);
void OnStaleUpgradeNeeded(const IndexedDBMsg_CallbacksUpgradeNeeded_Params&);
- scoped_refptr<base::MessageLoopProxy> main_thread_loop_proxy_;
scoped_refptr<ThreadSafeSender> thread_safe_sender_;
DISALLOW_COPY_AND_ASSIGN(IndexedDBMessageFilter);

Powered by Google App Engine
This is Rietveld 408576698