| Index: ipc/ipc_forwarding_message_filter.h
|
| diff --git a/ipc/ipc_forwarding_message_filter.h b/ipc/ipc_forwarding_message_filter.h
|
| index 474fbf4591ab7fda7fdd58a5313bf55dc19310ed..70078fe94ccd4f88d0540e6087d39505e1084c0d 100644
|
| --- a/ipc/ipc_forwarding_message_filter.h
|
| +++ b/ipc/ipc_forwarding_message_filter.h
|
| @@ -19,30 +19,32 @@ namespace IPC {
|
| // This class can be used to intercept routed messages and
|
| // deliver them to a different task runner than they would otherwise
|
| // be sent. Messages are filtered based on type. To route these messages,
|
| -// add a MessageRouter to the handler.
|
| +// add a Handler to the filter.
|
| //
|
| -// The user of this class implements ForwardingMessageFilter::Client,
|
| +// The user of this class implements ForwardingMessageFilter::Handler,
|
| // which will receive the intercepted messages, on the specified target thread.
|
| +// The caller must ensure that each handler in |multi_handlers_| outlives the
|
| +// lifetime of the filter.
|
| +// User can add multiple handlers for specific routing id. When messages are
|
| +// arrived, all handlers in |multi_handlers_| for routing id will be executed.
|
| class IPC_EXPORT ForwardingMessageFilter : public MessageFilter {
|
| public:
|
|
|
| // The handler is invoked on the thread associated with
|
| - // |target_task_runner| with messages that were intercepted by this filter.
|
| + // |target_task_runner_| with messages that were intercepted by this filter.
|
| typedef base::Callback<void(const Message&)> Handler;
|
|
|
| // This filter will intercept |message_ids_to_filter| and post
|
| // them to the provided |target_task_runner|, where they will be given
|
| - // to |handler|.
|
| - //
|
| - // The caller must ensure that |handler| outlives the lifetime of the filter.
|
| + // to all handlers in the |multi_handlers_|.
|
| ForwardingMessageFilter(
|
| const uint32* message_ids_to_filter,
|
| size_t num_message_ids_to_filter,
|
| base::TaskRunner* target_task_runner);
|
|
|
| - // Define the message routes to be filtered.
|
| + // Define the message handler to be filtered.
|
| void AddRoute(int routing_id, const Handler& handler);
|
| - void RemoveRoute(int routing_id);
|
| + void RemoveRoute(int routing_id, const Handler& handler);
|
|
|
| // MessageFilter methods:
|
| virtual bool OnMessageReceived(const Message& message) override;
|
| @@ -52,15 +54,16 @@ class IPC_EXPORT ForwardingMessageFilter : public MessageFilter {
|
|
|
| std::set<int> message_ids_to_filter_;
|
|
|
| - // The handler_ only gets Run on the thread corresponding to
|
| + // The handler only gets run on the thread corresponding to
|
| // target_task_runner_.
|
| scoped_refptr<base::TaskRunner> target_task_runner_;
|
|
|
| - // Protects access to routes_.
|
| + // Protects access to |multi_handlers_|.
|
| base::Lock handlers_lock_;
|
|
|
| - // Indicates the routing_ids for which messages should be filtered.
|
| - std::map<int, Handler> handlers_;
|
| + // Maps the routing_id for which messages should be filtered and handlers
|
| + // which will be routed.
|
| + std::multimap<int, Handler> multi_handlers_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(ForwardingMessageFilter);
|
| };
|
|
|