1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 2 // Use of this source code is governed by a BSD-style license that can be 3 // found in the LICENSE file. 4 5 #include "ppapi/proxy/dispatcher.h" 6 7 #include <string.h> // For memset. 8 9 #include <map> 10 11 #include "base/compiler_specific.h" 12 #include "base/logging.h" 13 #include "base/memory/singleton.h" 14 #include "ppapi/proxy/ppapi_messages.h" 15 #include "ppapi/proxy/var_serialization_rules.h" 16 17 namespace ppapi { 18 namespace proxy { 19 Dispatcher(PP_GetInterface_Func local_get_interface,const PpapiPermissions & permissions)20Dispatcher::Dispatcher(PP_GetInterface_Func local_get_interface, 21 const PpapiPermissions& permissions) 22 : local_get_interface_(local_get_interface), 23 permissions_(permissions) { 24 } 25 ~Dispatcher()26Dispatcher::~Dispatcher() { 27 } 28 AddFilter(IPC::Listener * listener)29void Dispatcher::AddFilter(IPC::Listener* listener) { 30 filters_.push_back(listener); 31 } 32 GetInterfaceProxy(ApiID id)33InterfaceProxy* Dispatcher::GetInterfaceProxy(ApiID id) { 34 InterfaceProxy* proxy = proxies_[id].get(); 35 if (!proxy) { 36 // Handle the first time for a given API by creating the proxy for it. 37 InterfaceProxy::Factory factory = 38 InterfaceList::GetInstance()->GetFactoryForID(id); 39 if (!factory) { 40 NOTREACHED(); 41 return NULL; 42 } 43 proxy = factory(this); 44 DCHECK(proxy); 45 proxies_[id].reset(proxy); 46 } 47 return proxy; 48 } 49 GetIPCMessageLoop()50base::MessageLoopProxy* Dispatcher::GetIPCMessageLoop() { 51 return delegate()->GetIPCMessageLoop(); 52 } 53 AddIOThreadMessageFilter(IPC::ChannelProxy::MessageFilter * filter)54void Dispatcher::AddIOThreadMessageFilter( 55 IPC::ChannelProxy::MessageFilter* filter) { 56 // Our filter is refcounted. The channel will call the destruct method on the 57 // filter when the channel is done with it, so the corresponding Release() 58 // happens there. 59 channel()->AddFilter(filter); 60 } 61 OnMessageReceived(const IPC::Message & msg)62bool Dispatcher::OnMessageReceived(const IPC::Message& msg) { 63 if (msg.routing_id() <= 0 || msg.routing_id() >= API_ID_COUNT) { 64 OnInvalidMessageReceived(); 65 return true; 66 } 67 68 InterfaceProxy* proxy = GetInterfaceProxy( 69 static_cast<ApiID>(msg.routing_id())); 70 if (!proxy) { 71 NOTREACHED(); 72 return true; 73 } 74 return proxy->OnMessageReceived(msg); 75 } 76 SetSerializationRules(VarSerializationRules * var_serialization_rules)77void Dispatcher::SetSerializationRules( 78 VarSerializationRules* var_serialization_rules) { 79 serialization_rules_ = var_serialization_rules; 80 } 81 OnInvalidMessageReceived()82void Dispatcher::OnInvalidMessageReceived() { 83 } 84 85 } // namespace proxy 86 } // namespace ppapi 87