Chromium Code Reviews| Index: content/child/child_message_filter.h |
| diff --git a/content/child/child_message_filter.h b/content/child/child_message_filter.h |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..3486494975ed6f7dcc594a6097f928334cee81f2 |
| --- /dev/null |
| +++ b/content/child/child_message_filter.h |
| @@ -0,0 +1,62 @@ |
| +// Copyright 2013 The Chromium Authors. All rights reserved. |
| +// Use of this source code is governed by a BSD-style license that can be |
| +// found in the LICENSE file. |
| + |
| +#ifndef CONTENT_CHILD_CHILD_MESSAGE_FILTER_H_ |
| +#define CONTENT_CHILD_CHILD_MESSAGE_FILTER_H_ |
| + |
| +#include "ipc/ipc_channel_proxy.h" |
| + |
| +namespace content { |
| + |
| +class ThreadSafeSender; |
| + |
| +// Convenience base class for implementing IPC MessageFilters that run on the |
| +// child thread and can dispatch messages to arbitrary task runners. |
| +class ChildMessageFilter |
| + : public base::RefCountedThreadSafe<ChildMessageFilter>, |
| + public IPC::Sender { |
| + public: |
| + ChildMessageFilter(); |
| + |
| + // IPC::Sender implementation. |
| + // |
| + // Can be called on any thread. |
| + virtual bool Send(IPC::Message* message) OVERRIDE; |
| + |
| + // Override to have OnMessageReceived() run on a TaskRunner of your choosing. |
| + // Returns NULL by default, which runs OnMessageReceived() on the child |
| + // thread. |
| + virtual base::TaskRunner* OverrideTaskRunnerForMessage( |
| + const IPC::Message& message); |
| + |
| + virtual bool OnMessageReceived(const IPC::Message& message) = 0; |
|
scherkus (not reviewing)
2013/11/07 21:24:23
reminder to self: needs docs
|
| + |
| + protected: |
| + friend class base::RefCountedThreadSafe<ChildMessageFilter>; |
| + virtual ~ChildMessageFilter(); |
| + |
| + private: |
| + class Internal; |
| + friend class RenderThreadImpl; |
| + |
| + // Returns private IPC::ChannelProxy::MessageFilter implementation. Intended |
| + // for use by friend classes listed above. |
| + scoped_refptr<IPC::ChannelProxy::MessageFilter> get_internal() { |
| + return internal_; |
| + } |
| + |
| + // Private implementation of IPC::ChannelProxy::MessageFilter hidden from |
| + // child classes. An equivalent API is provided to child classes. |
| + scoped_refptr<IPC::ChannelProxy::MessageFilter> internal_; |
| + |
| + // Used to implement a thread-safe IPC::Sender implementation for child |
| + // classes. |
| + scoped_refptr<ThreadSafeSender> thread_safe_sender_; |
| + |
| + DISALLOW_COPY_AND_ASSIGN(ChildMessageFilter); |
| +}; |
| + |
| +} // namespace content |
| + |
| +#endif // CONTENT_CHILD_CHILD_MESSAGE_FILTER_H_ |