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