Index: content/child/quota_message_filter.h |
diff --git a/content/child/quota_message_filter.h b/content/child/quota_message_filter.h |
index eba63137dfe451b038281ae31f87d8008a9c7e95..dccadd5fd2068d8a0fecdb02af950612b4e6d2de 100644 |
--- a/content/child/quota_message_filter.h |
+++ b/content/child/quota_message_filter.h |
@@ -8,23 +8,16 @@ |
#include <map> |
#include "base/synchronization/lock.h" |
-#include "ipc/ipc_channel_proxy.h" |
- |
-namespace base { |
-class MessageLoopProxy; |
-} |
+#include "content/child/cross_thread_message_filter.h" |
namespace content { |
class ThreadSafeSender; |
-class QuotaMessageFilter : public IPC::ChannelProxy::MessageFilter { |
+class QuotaMessageFilter : public CrossThreadMessageFilter { |
public: |
explicit QuotaMessageFilter(ThreadSafeSender* thread_safe_sender); |
- // IPC::Listener implementation. |
- virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE; |
- |
// Generates a new request_id, registers { request_id, thread_id } map to |
// the message filter and returns the request_id. |
// This method can be called on any thread. |
@@ -37,11 +30,13 @@ class QuotaMessageFilter : public IPC::ChannelProxy::MessageFilter { |
virtual ~QuotaMessageFilter(); |
private: |
- typedef std::map<int, int> RequestIdToThreadId; |
+ // CrossThreadMessageFilter implementation: |
+ virtual bool OverrideThreadIDForMessage(const IPC::Message& msg, |
+ int* thread_id) OVERRIDE; |
+ virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE; |
- void DispatchMessage(const IPC::Message& msg); |
+ typedef std::map<int, int> RequestIdToThreadId; |
- scoped_refptr<base::MessageLoopProxy> main_thread_loop_proxy_; |
scoped_refptr<ThreadSafeSender> thread_safe_sender_; |
base::Lock request_id_map_lock_; |