diff options
Diffstat (limited to 'ppapi/proxy/dispatcher.cc')
| -rw-r--r-- | ppapi/proxy/dispatcher.cc | 215 |
1 files changed, 0 insertions, 215 deletions
diff --git a/ppapi/proxy/dispatcher.cc b/ppapi/proxy/dispatcher.cc deleted file mode 100644 index e2c6f1e..0000000 --- a/ppapi/proxy/dispatcher.cc +++ /dev/null @@ -1,215 +0,0 @@ -// Copyright (c) 2010 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. - -#include "ppapi/proxy/dispatcher.h" - -#include <string.h> // For memset. - -#include <map> - -#include "base/logging.h" -#include "ipc/ipc_message.h" -#include "ipc/ipc_sync_channel.h" -#include "ppapi/proxy/interface_proxy.h" -#include "ppapi/proxy/ppapi_messages.h" -#include "ppapi/c/dev/ppb_var_deprecated.h" -#include "ppapi/c/pp_errors.h" -#include "ppapi/c/ppb_core.h" -#include "ppapi/c/ppb_graphics_2d.h" -#include "ppapi/c/ppb_image_data.h" -#include "ppapi/c/ppb_instance.h" -#include "ppapi/c/ppp_instance.h" -#include "ppapi/proxy/ppb_core_proxy.h" -#include "ppapi/proxy/ppb_graphics_2d_proxy.h" -#include "ppapi/proxy/ppb_image_data_proxy.h" -#include "ppapi/proxy/ppb_instance_proxy.h" -#include "ppapi/proxy/ppb_var_deprecated_proxy.h" -#include "ppapi/proxy/ppp_class_proxy.h" -#include "ppapi/proxy/ppp_instance_proxy.h" -#include "ppapi/proxy/var_serialization_rules.h" - -namespace pp { -namespace proxy { - -Dispatcher::Dispatcher(GetInterfaceFunc local_get_interface) - : pp_module_(0), - disallow_trusted_interfaces_(true), - local_get_interface_(local_get_interface), - declared_supported_remote_interfaces_(false), - callback_tracker_(this) { - memset(id_to_proxy_, 0, - static_cast<int>(INTERFACE_ID_COUNT) * sizeof(InterfaceProxy*)); -} - -Dispatcher::~Dispatcher() { -} - -bool Dispatcher::InitWithChannel(MessageLoop* ipc_message_loop, - const std::string& channel_name, - bool is_client, - base::WaitableEvent* shutdown_event) { - IPC::Channel::Mode mode = is_client ? IPC::Channel::MODE_CLIENT - : IPC::Channel::MODE_SERVER; - channel_.reset(new IPC::SyncChannel(channel_name, mode, this, NULL, - ipc_message_loop, false, shutdown_event)); - return true; -} - -void Dispatcher::OnMessageReceived(const IPC::Message& msg) { - // Control messages. - if (msg.routing_id() == MSG_ROUTING_CONTROL) { - IPC_BEGIN_MESSAGE_MAP(Dispatcher, msg) - IPC_MESSAGE_HANDLER(PpapiMsg_DeclareInterfaces, - OnMsgDeclareInterfaces) - IPC_MESSAGE_HANDLER(PpapiMsg_SupportsInterface, OnMsgSupportsInterface) - IPC_MESSAGE_FORWARD(PpapiMsg_ExecuteCallback, &callback_tracker_, - CallbackTracker::ReceiveExecuteSerializedCallback) - IPC_END_MESSAGE_MAP() - return; - } - - // Interface-specific messages. - if (msg.routing_id() > 0 && msg.routing_id() < INTERFACE_ID_COUNT) { - InterfaceProxy* proxy = id_to_proxy_[msg.routing_id()]; - if (proxy) - proxy->OnMessageReceived(msg); - else - NOTREACHED(); - // TODO(brettw): kill the plugin if it starts sending invalid messages? - } -} - -void Dispatcher::SetSerializationRules( - VarSerializationRules* var_serialization_rules) { - serialization_rules_.reset(var_serialization_rules); -} - -void Dispatcher::InjectProxy(InterfaceID id, - const std::string& name, - InterfaceProxy* proxy) { - proxies_[name] = linked_ptr<InterfaceProxy>(proxy); - id_to_proxy_[id] = proxy; -} - -const void* Dispatcher::GetLocalInterface(const char* interface) { - return local_get_interface_(interface); -} - -const void* Dispatcher::GetProxiedInterface(const std::string& interface) { - // See if we already know about this interface and have created a host. - ProxyMap::const_iterator found = proxies_.find(interface); - if (found != proxies_.end()) - return found->second->GetSourceInterface(); - - // When the remote side has sent us a declared list of all interfaces it - // supports and we don't have it in our list, we know the requested interface - // doesn't exist and we can return failure. - if (declared_supported_remote_interfaces_) - return NULL; - - if (!RemoteSupportsTargetInterface(interface)) - return NULL; - - linked_ptr<InterfaceProxy> proxy(CreateProxyForInterface(interface, NULL)); - if (!proxy.get()) - return NULL; // Don't know how to proxy this interface. - - // Save our proxy. - proxies_[interface] = proxy; - id_to_proxy_[proxy->GetInterfaceId()] = proxy.get(); - return proxy->GetSourceInterface(); -} - -bool Dispatcher::Send(IPC::Message* msg) { - return channel_->Send(msg); -} - -bool Dispatcher::RemoteSupportsTargetInterface(const std::string& interface) { - bool result = false; - Send(new PpapiMsg_SupportsInterface(interface, &result)); - return result; -} - -bool Dispatcher::IsInterfaceTrusted(const std::string& interface) { - // FIXME(brettw) - (void)interface; - return false; -} - -bool Dispatcher::SetupProxyForTargetInterface(const std::string& interface) { - // If we already have a proxy that knows about the locally-implemented - // interface, we know it's supported and don't need to re-query. - ProxyMap::const_iterator found = proxies_.find(interface); - if (found != proxies_.end()) - return true; - - if (disallow_trusted_interfaces_ && IsInterfaceTrusted(interface)) - return false; - - // Create the proxy if it doesn't exist and set the local interface on it. - // This also handles the case where possibly an interface could be supported - // by both the local and remote side. - const void* interface_functions = local_get_interface_(interface.c_str()); - if (!interface_functions) - return false; - InterfaceProxy* proxy = CreateProxyForInterface(interface, - interface_functions); - if (!proxy) - return false; - - proxies_[interface] = linked_ptr<InterfaceProxy>(proxy); - id_to_proxy_[proxy->GetInterfaceId()] = proxy; - return true; -} - -void Dispatcher::OnMsgSupportsInterface(const std::string& interface_name, - bool* result) { - *result = SetupProxyForTargetInterface(interface_name); -} - -void Dispatcher::OnMsgDeclareInterfaces( - const std::vector<std::string>& interfaces) { - // Make proxies for all the interfaces it supports that we also support. - for (size_t i = 0; i < interfaces.size(); i++) { - // Possibly the plugin could request an interface before the "declare" - // message is received, so we could already have an entry for this - // interface. In this case, we can just skip to the next one. - if (proxies_.find(interfaces[i]) != proxies_.end()) - continue; - - linked_ptr<InterfaceProxy> proxy(CreateProxyForInterface(interfaces[i], - NULL)); - if (!proxy.get()) { - // Since only the browser declares supported interfaces, we should never - // get one we don't support. - //NOTREACHED() << "Remote side declaring an unsupported proxy."; - continue; - } - proxies_[interfaces[i]] = proxy; - id_to_proxy_[proxy->GetInterfaceId()] = proxy.get(); - } -} - -InterfaceProxy* Dispatcher::CreateProxyForInterface( - const std::string& interface_name, - const void* interface_functions) { - if (interface_name == PPB_CORE_INTERFACE) - return new PPB_Core_Proxy(this, interface_functions); - if (interface_name == PPB_GRAPHICS_2D_INTERFACE) - return new PPB_Graphics2D_Proxy(this, interface_functions); - if (interface_name == PPB_IMAGEDATA_INTERFACE) - return new PPB_ImageData_Proxy(this, interface_functions); - if (interface_name == PPB_INSTANCE_INTERFACE) - return new PPB_Instance_Proxy(this, interface_functions); - if (interface_name == PPB_VAR_DEPRECATED_INTERFACE) - return new PPB_Var_Deprecated_Proxy(this, interface_functions); - if (interface_name == PPP_INSTANCE_INTERFACE) - return new PPP_Instance_Proxy(this, interface_functions); - - return NULL; -} - -} // namespace proxy -} // namespace pp - |