Home | History | Annotate | Download | only in pepper 
      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 "content/renderer/pepper/ppb_tcp_socket_private_impl.h"
      6 
      7 #include "content/common/pepper_messages.h"
      8 #include "content/renderer/pepper/host_globals.h"
      9 #include "content/renderer/pepper/pepper_plugin_instance_impl.h"
     10 #include "content/renderer/render_thread_impl.h"
     11 #include "ppapi/proxy/ppapi_messages.h"
     12 #include "ppapi/shared_impl/socket_option_data.h"
     13 
     14 namespace content {
     15 
     16 PPB_TCPSocket_Private_Impl::PPB_TCPSocket_Private_Impl(
     17     PP_Instance instance,
     18     uint32 socket_id,
     19     int routing_id)
     20     : ppapi::TCPSocketPrivateImpl(instance, socket_id),
     21       routing_id_(routing_id) {
     22   ChildThread::current()->AddRoute(routing_id, this);
     23 }
     24 
     25 PPB_TCPSocket_Private_Impl::~PPB_TCPSocket_Private_Impl() {
     26   ChildThread::current()->RemoveRoute(routing_id_);
     27   Disconnect();
     28 }
     29 
     30 PP_Resource PPB_TCPSocket_Private_Impl::CreateResource(PP_Instance instance) {
     31   int routing_id = RenderThreadImpl::current()->GenerateRoutingID();
     32   uint32 socket_id = 0;
     33   RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_CreatePrivate(
     34       routing_id, 0, &socket_id));
     35   if (!socket_id)
     36     return 0;
     37 
     38   return (new PPB_TCPSocket_Private_Impl(
     39       instance, socket_id, routing_id))->GetReference();
     40 }
     41 
     42 void PPB_TCPSocket_Private_Impl::SendConnect(const std::string& host,
     43                                              uint16_t port) {
     44   RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_Connect(
     45       routing_id_, socket_id_, host, port));
     46 }
     47 
     48 void PPB_TCPSocket_Private_Impl::SendConnectWithNetAddress(
     49     const PP_NetAddress_Private& addr) {
     50   RenderThreadImpl::current()->Send(
     51       new PpapiHostMsg_PPBTCPSocket_ConnectWithNetAddress(
     52           routing_id_, socket_id_, addr));
     53 }
     54 
     55 void PPB_TCPSocket_Private_Impl::SendSSLHandshake(
     56     const std::string& server_name,
     57     uint16_t server_port,
     58     const std::vector<std::vector<char> >& trusted_certs,
     59     const std::vector<std::vector<char> >& untrusted_certs) {
     60   RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_SSLHandshake(
     61       socket_id_, server_name, server_port, trusted_certs, untrusted_certs));
     62 }
     63 
     64 void PPB_TCPSocket_Private_Impl::SendRead(int32_t bytes_to_read) {
     65   RenderThreadImpl::current()->Send(new PpapiHostMsg_PPBTCPSocket_Read(
     66       socket_id_, bytes_to_read));
     67 }
     68 
     69 
     70 void PPB_TCPSocket_Private_Impl::SendWrite(const std::string& buffer) {
     71   RenderThreadImpl::current()->Send(
     72       new PpapiHostMsg_PPBTCPSocket_Write(socket_id_, buffer));
     73 }
     74 
     75 void PPB_TCPSocket_Private_Impl::SendDisconnect() {
     76   RenderThreadImpl::current()->Send(
     77       new PpapiHostMsg_PPBTCPSocket_Disconnect(socket_id_));
     78 }
     79 
     80 void PPB_TCPSocket_Private_Impl::SendSetOption(
     81     PP_TCPSocket_Option name,
     82     const ppapi::SocketOptionData& value) {
     83   RenderThreadImpl::current()->Send(
     84       new PpapiHostMsg_PPBTCPSocket_SetOption(socket_id_, name, value));
     85 }
     86 
     87 bool PPB_TCPSocket_Private_Impl::OnMessageReceived(
     88     const IPC::Message& message) {
     89   bool handled = true;
     90   IPC_BEGIN_MESSAGE_MAP(PPB_TCPSocket_Private_Impl, message)
     91     IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ConnectACK, OnTCPSocketConnectACK)
     92     IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SSLHandshakeACK,
     93                         OnTCPSocketSSLHandshakeACK)
     94     IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_ReadACK, OnTCPSocketReadACK)
     95     IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_WriteACK, OnTCPSocketWriteACK)
     96     IPC_MESSAGE_HANDLER(PpapiMsg_PPBTCPSocket_SetOptionACK,
     97                         OnTCPSocketSetOptionACK)
     98     IPC_MESSAGE_UNHANDLED(handled = false)
     99   IPC_END_MESSAGE_MAP()
    100   return handled;
    101 }
    102 
    103 void PPB_TCPSocket_Private_Impl::OnTCPSocketConnectACK(
    104     uint32 plugin_dispatcher_id,
    105     uint32 socket_id,
    106     int32_t result,
    107     const PP_NetAddress_Private& local_addr,
    108     const PP_NetAddress_Private& remote_addr) {
    109   OnConnectCompleted(result, local_addr, remote_addr);
    110 }
    111 
    112 void PPB_TCPSocket_Private_Impl::OnTCPSocketSSLHandshakeACK(
    113     uint32 plugin_dispatcher_id,
    114     uint32 socket_id,
    115     bool succeeded,
    116     const ppapi::PPB_X509Certificate_Fields& certificate_fields) {
    117   OnSSLHandshakeCompleted(succeeded, certificate_fields);
    118 }
    119 
    120 void PPB_TCPSocket_Private_Impl::OnTCPSocketReadACK(uint32 plugin_dispatcher_id,
    121                                                     uint32 socket_id,
    122                                                     int32_t result,
    123                                                     const std::string& data) {
    124   OnReadCompleted(result, data);
    125 }
    126 
    127 void PPB_TCPSocket_Private_Impl::OnTCPSocketWriteACK(
    128     uint32 plugin_dispatcher_id,
    129     uint32 socket_id,
    130     int32_t result) {
    131   OnWriteCompleted(result);
    132 }
    133 
    134 void PPB_TCPSocket_Private_Impl::OnTCPSocketSetOptionACK(
    135     uint32 plugin_dispatcher_id,
    136     uint32 socket_id,
    137     int32_t result) {
    138   OnSetOptionCompleted(result);
    139 }
    140 
    141 }  // namespace content
    142