Home | History | Annotate | Download | only in proxy 
      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 IPC {
     18 class MessageFilter;
     19 }
     20 
     21 namespace ppapi {
     22 namespace proxy {
     23 
     24 Dispatcher::Dispatcher(PP_GetInterface_Func local_get_interface,
     25                        const PpapiPermissions& permissions)
     26     : local_get_interface_(local_get_interface),
     27       permissions_(permissions) {
     28 }
     29 
     30 Dispatcher::~Dispatcher() {
     31 }
     32 
     33 InterfaceProxy* 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 
     50 void Dispatcher::AddIOThreadMessageFilter(
     51     scoped_refptr<IPC::MessageFilter> filter) {
     52   // Our filter is refcounted. The channel will call the destruct method on the
     53   // filter when the channel is done with it, so the corresponding Release()
     54   // happens there.
     55   channel()->AddFilter(filter.get());
     56 }
     57 
     58 bool Dispatcher::OnMessageReceived(const IPC::Message& msg) {
     59   if (msg.routing_id() <= 0 || msg.routing_id() >= API_ID_COUNT) {
     60     OnInvalidMessageReceived();
     61     return true;
     62   }
     63 
     64   InterfaceProxy* proxy = GetInterfaceProxy(
     65       static_cast<ApiID>(msg.routing_id()));
     66   if (!proxy) {
     67     NOTREACHED();
     68     return true;
     69   }
     70   return proxy->OnMessageReceived(msg);
     71 }
     72 
     73 void Dispatcher::SetSerializationRules(
     74     VarSerializationRules* var_serialization_rules) {
     75   serialization_rules_ = var_serialization_rules;
     76 }
     77 
     78 void Dispatcher::OnInvalidMessageReceived() {
     79 }
     80 
     81 }  // namespace proxy
     82 }  // namespace ppapi
     83