| Index: ppapi/proxy/ppb_udp_socket_private_proxy.cc
|
| diff --git a/ppapi/proxy/ppb_udp_socket_private_proxy.cc b/ppapi/proxy/ppb_udp_socket_private_proxy.cc
|
| deleted file mode 100644
|
| index 3f76e41f933e7945f1773c75e1de2556299696dd..0000000000000000000000000000000000000000
|
| --- a/ppapi/proxy/ppb_udp_socket_private_proxy.cc
|
| +++ /dev/null
|
| @@ -1,180 +0,0 @@
|
| -// Copyright (c) 2012 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/ppb_udp_socket_private_proxy.h"
|
| -
|
| -#include <map>
|
| -
|
| -#include "base/logging.h"
|
| -#include "ppapi/c/private/ppb_udp_socket_private.h"
|
| -#include "ppapi/proxy/plugin_dispatcher.h"
|
| -#include "ppapi/proxy/plugin_globals.h"
|
| -#include "ppapi/proxy/plugin_resource_tracker.h"
|
| -#include "ppapi/proxy/ppapi_messages.h"
|
| -#include "ppapi/shared_impl/private/udp_socket_private_impl.h"
|
| -#include "ppapi/shared_impl/resource.h"
|
| -#include "ppapi/thunk/thunk.h"
|
| -
|
| -namespace ppapi {
|
| -namespace proxy {
|
| -
|
| -namespace {
|
| -
|
| -typedef std::map<uint32, UDPSocketPrivateImpl*> IDToSocketMap;
|
| -IDToSocketMap* g_id_to_socket = NULL;
|
| -
|
| -class UDPSocket : public UDPSocketPrivateImpl {
|
| - public:
|
| - UDPSocket(const HostResource& resource, uint32 socket_id);
|
| - virtual ~UDPSocket();
|
| -
|
| - virtual void SendBoolSocketFeature(int32_t name, bool value) OVERRIDE;
|
| - virtual void SendBind(const PP_NetAddress_Private& addr) OVERRIDE;
|
| - virtual void SendRecvFrom(int32_t num_bytes) OVERRIDE;
|
| - virtual void SendSendTo(const std::string& data,
|
| - const PP_NetAddress_Private& addr) OVERRIDE;
|
| - virtual void SendClose() OVERRIDE;
|
| -
|
| - private:
|
| - void SendToBrowser(IPC::Message* msg);
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(UDPSocket);
|
| -};
|
| -
|
| -UDPSocket::UDPSocket(const HostResource& resource, uint32 socket_id)
|
| - : UDPSocketPrivateImpl(resource, socket_id) {
|
| - if (!g_id_to_socket)
|
| - g_id_to_socket = new IDToSocketMap();
|
| - DCHECK(g_id_to_socket->find(socket_id) == g_id_to_socket->end());
|
| - (*g_id_to_socket)[socket_id] = this;
|
| -}
|
| -
|
| -UDPSocket::~UDPSocket() {
|
| - Close();
|
| -}
|
| -
|
| -void UDPSocket::SendBoolSocketFeature(int32_t name, bool value) {
|
| - SendToBrowser(new PpapiHostMsg_PPBUDPSocket_SetBoolSocketFeature(
|
| - API_ID_PPB_UDPSOCKET_PRIVATE, socket_id_, name, value));
|
| -}
|
| -
|
| -void UDPSocket::SendBind(const PP_NetAddress_Private& addr) {
|
| - SendToBrowser(new PpapiHostMsg_PPBUDPSocket_Bind(
|
| - API_ID_PPB_UDPSOCKET_PRIVATE, socket_id_, addr));
|
| -}
|
| -
|
| -void UDPSocket::SendRecvFrom(int32_t num_bytes) {
|
| - SendToBrowser(new PpapiHostMsg_PPBUDPSocket_RecvFrom(socket_id_, num_bytes));
|
| -}
|
| -
|
| -void UDPSocket::SendSendTo(const std::string& data,
|
| - const PP_NetAddress_Private& addr) {
|
| - SendToBrowser(new PpapiHostMsg_PPBUDPSocket_SendTo(
|
| - API_ID_PPB_UDPSOCKET_PRIVATE, socket_id_, data, addr));
|
| -}
|
| -
|
| -void UDPSocket::SendClose() {
|
| - // After removed from the mapping, this object won't receive any notifications
|
| - // from the proxy.
|
| - DCHECK(g_id_to_socket->find(socket_id_) != g_id_to_socket->end());
|
| - g_id_to_socket->erase(socket_id_);
|
| - SendToBrowser(new PpapiHostMsg_PPBUDPSocket_Close(socket_id_));
|
| -}
|
| -
|
| -void UDPSocket::SendToBrowser(IPC::Message* msg) {
|
| - PluginGlobals::Get()->GetBrowserSender()->Send(msg);
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -//------------------------------------------------------------------------------
|
| -
|
| -PPB_UDPSocket_Private_Proxy::PPB_UDPSocket_Private_Proxy(Dispatcher* dispatcher)
|
| - : InterfaceProxy(dispatcher) {
|
| -}
|
| -
|
| -PPB_UDPSocket_Private_Proxy::~PPB_UDPSocket_Private_Proxy() {
|
| -}
|
| -
|
| -// static
|
| -PP_Resource PPB_UDPSocket_Private_Proxy::CreateProxyResource(
|
| - PP_Instance instance) {
|
| - PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance);
|
| - if (!dispatcher)
|
| - return 0;
|
| -
|
| - uint32 socket_id = 0;
|
| - PluginGlobals::Get()->GetBrowserSender()->Send(
|
| - new PpapiHostMsg_PPBUDPSocket_Create(
|
| - API_ID_PPB_UDPSOCKET_PRIVATE, dispatcher->plugin_dispatcher_id(),
|
| - &socket_id));
|
| - if (socket_id == 0)
|
| - return 0;
|
| -
|
| - return (new UDPSocket(HostResource::MakeInstanceOnly(instance),
|
| - socket_id))->GetReference();
|
| -}
|
| -
|
| -bool PPB_UDPSocket_Private_Proxy::OnMessageReceived(const IPC::Message& msg) {
|
| - bool handled = true;
|
| - IPC_BEGIN_MESSAGE_MAP(PPB_UDPSocket_Private_Proxy, msg)
|
| - IPC_MESSAGE_HANDLER(PpapiMsg_PPBUDPSocket_BindACK,
|
| - OnMsgBindACK)
|
| - IPC_MESSAGE_HANDLER(PpapiMsg_PPBUDPSocket_RecvFromACK,
|
| - OnMsgRecvFromACK)
|
| - IPC_MESSAGE_HANDLER(PpapiMsg_PPBUDPSocket_SendToACK,
|
| - OnMsgSendToACK)
|
| - IPC_MESSAGE_UNHANDLED(handled = false)
|
| - IPC_END_MESSAGE_MAP()
|
| - return handled;
|
| -}
|
| -
|
| -void PPB_UDPSocket_Private_Proxy::OnMsgBindACK(
|
| - uint32 /* plugin_dispatcher_id */,
|
| - uint32 socket_id,
|
| - bool succeeded,
|
| - const PP_NetAddress_Private& bound_addr) {
|
| - if (!g_id_to_socket) {
|
| - NOTREACHED();
|
| - return;
|
| - }
|
| - IDToSocketMap::iterator iter = g_id_to_socket->find(socket_id);
|
| - if (iter == g_id_to_socket->end())
|
| - return;
|
| - iter->second->OnBindCompleted(succeeded, bound_addr);
|
| -}
|
| -
|
| -void PPB_UDPSocket_Private_Proxy::OnMsgRecvFromACK(
|
| - uint32 /* plugin_dispatcher_id */,
|
| - uint32 socket_id,
|
| - bool succeeded,
|
| - const std::string& data,
|
| - const PP_NetAddress_Private& addr) {
|
| - if (!g_id_to_socket) {
|
| - NOTREACHED();
|
| - return;
|
| - }
|
| - IDToSocketMap::iterator iter = g_id_to_socket->find(socket_id);
|
| - if (iter == g_id_to_socket->end())
|
| - return;
|
| - iter->second->OnRecvFromCompleted(succeeded, data, addr);
|
| -}
|
| -
|
| -void PPB_UDPSocket_Private_Proxy::OnMsgSendToACK(
|
| - uint32 /* plugin_dispatcher_id */,
|
| - uint32 socket_id,
|
| - bool succeeded,
|
| - int32_t bytes_written) {
|
| - if (!g_id_to_socket) {
|
| - NOTREACHED();
|
| - return;
|
| - }
|
| - IDToSocketMap::iterator iter = g_id_to_socket->find(socket_id);
|
| - if (iter == g_id_to_socket->end())
|
| - return;
|
| - iter->second->OnSendToCompleted(succeeded, bytes_written);
|
| -}
|
| -
|
| -} // namespace proxy
|
| -} // namespace ppapi
|
|
|