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