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 ppapi {
     18 namespace proxy {
     19 
     20 Dispatcher::Dispatcher(PP_GetInterface_Func local_get_interface,
     21                        const PpapiPermissions& permissions)
     22     : local_get_interface_(local_get_interface),
     23       permissions_(permissions) {
     24 }
     25 
     26 Dispatcher::~Dispatcher() {
     27 }
     28 
     29 void Dispatcher::AddFilter(IPC::Listener* listener) {
     30   filters_.push_back(listener);
     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 base::MessageLoopProxy* Dispatcher::GetIPCMessageLoop() {
     51   return delegate()->GetIPCMessageLoop();
     52 }
     53 
     54 void 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 
     62 bool 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 
     77 void Dispatcher::SetSerializationRules(
     78     VarSerializationRules* var_serialization_rules) {
     79   serialization_rules_ = var_serialization_rules;
     80 }
     81 
     82 void Dispatcher::OnInvalidMessageReceived() {
     83 }
     84 
     85 }  // namespace proxy
     86 }  // namespace ppapi
     87