#include "ppapi/proxy/ppapi_messages.h"
#include "ppapi/proxy/var_serialization_rules.h"
+namespace IPC {
+class MessageFilter;
+}
+
namespace ppapi {
namespace proxy {
Dispatcher::~Dispatcher() {
}
-void Dispatcher::AddFilter(IPC::Listener* listener) {
- filters_.push_back(listener);
-}
-
InterfaceProxy* Dispatcher::GetInterfaceProxy(ApiID id) {
InterfaceProxy* proxy = proxies_[id].get();
if (!proxy) {
return proxy;
}
-base::MessageLoopProxy* Dispatcher::GetIPCMessageLoop() {
- return delegate()->GetIPCMessageLoop();
-}
-
void Dispatcher::AddIOThreadMessageFilter(
- IPC::ChannelProxy::MessageFilter* filter) {
+ scoped_refptr<IPC::MessageFilter> filter) {
// Our filter is refcounted. The channel will call the destruct method on the
// filter when the channel is done with it, so the corresponding Release()
// happens there.
- channel()->AddFilter(filter);
+ channel()->AddFilter(filter.get());
}
bool Dispatcher::OnMessageReceived(const IPC::Message& msg) {