|  | // Copyright 2013 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/cpp/tcp_socket.h" | 
|  |  | 
|  | #include "ppapi/c/pp_errors.h" | 
|  | #include "ppapi/cpp/completion_callback.h" | 
|  | #include "ppapi/cpp/instance_handle.h" | 
|  | #include "ppapi/cpp/module_impl.h" | 
|  |  | 
|  | namespace pp { | 
|  |  | 
|  | namespace { | 
|  |  | 
|  | template <> const char* interface_name<PPB_TCPSocket_1_0>() { | 
|  | return PPB_TCPSOCKET_INTERFACE_1_0; | 
|  | } | 
|  |  | 
|  | template <> const char* interface_name<PPB_TCPSocket_1_1>() { | 
|  | return PPB_TCPSOCKET_INTERFACE_1_1; | 
|  | } | 
|  |  | 
|  | template <> const char* interface_name<PPB_TCPSocket_1_2>() { | 
|  | return PPB_TCPSOCKET_INTERFACE_1_2; | 
|  | } | 
|  |  | 
|  | }  // namespace | 
|  |  | 
|  | TCPSocket::TCPSocket() { | 
|  | } | 
|  |  | 
|  | TCPSocket::TCPSocket(const InstanceHandle& instance) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | PassRefFromConstructor(get_interface<PPB_TCPSocket_1_2>()->Create( | 
|  | instance.pp_instance())); | 
|  | } else if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | PassRefFromConstructor(get_interface<PPB_TCPSocket_1_1>()->Create( | 
|  | instance.pp_instance())); | 
|  | } else if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | PassRefFromConstructor(get_interface<PPB_TCPSocket_1_0>()->Create( | 
|  | instance.pp_instance())); | 
|  | } | 
|  | } | 
|  |  | 
|  | TCPSocket::TCPSocket(PassRef, PP_Resource resource) | 
|  | : Resource(PASS_REF, resource) { | 
|  | } | 
|  |  | 
|  | TCPSocket::TCPSocket(const TCPSocket& other) : Resource(other) { | 
|  | } | 
|  |  | 
|  | TCPSocket::~TCPSocket() { | 
|  | } | 
|  |  | 
|  | TCPSocket& TCPSocket::operator=(const TCPSocket& other) { | 
|  | Resource::operator=(other); | 
|  | return *this; | 
|  | } | 
|  |  | 
|  | // static | 
|  | bool TCPSocket::IsAvailable() { | 
|  | return has_interface<PPB_TCPSocket_1_2>() || | 
|  | has_interface<PPB_TCPSocket_1_1>() || | 
|  | has_interface<PPB_TCPSocket_1_0>(); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Bind(const NetAddress& addr, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Bind( | 
|  | pp_resource(), addr.pp_resource(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Bind( | 
|  | pp_resource(), addr.pp_resource(), callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Connect(const NetAddress& addr, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Connect( | 
|  | pp_resource(), addr.pp_resource(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Connect( | 
|  | pp_resource(), addr.pp_resource(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return get_interface<PPB_TCPSocket_1_0>()->Connect( | 
|  | pp_resource(), addr.pp_resource(), callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | NetAddress TCPSocket::GetLocalAddress() const { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_2>()->GetLocalAddress(pp_resource())); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_1>()->GetLocalAddress(pp_resource())); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_0>()->GetLocalAddress(pp_resource())); | 
|  | } | 
|  | return NetAddress(); | 
|  | } | 
|  |  | 
|  | NetAddress TCPSocket::GetRemoteAddress() const { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_2>()->GetRemoteAddress(pp_resource())); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_1>()->GetRemoteAddress(pp_resource())); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return NetAddress( | 
|  | PASS_REF, | 
|  | get_interface<PPB_TCPSocket_1_0>()->GetRemoteAddress(pp_resource())); | 
|  | } | 
|  | return NetAddress(); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Read(char* buffer, | 
|  | int32_t bytes_to_read, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Read( | 
|  | pp_resource(), buffer, bytes_to_read, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Read( | 
|  | pp_resource(), buffer, bytes_to_read, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return get_interface<PPB_TCPSocket_1_0>()->Read( | 
|  | pp_resource(), buffer, bytes_to_read, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Write(const char* buffer, | 
|  | int32_t bytes_to_write, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Write( | 
|  | pp_resource(), buffer, bytes_to_write, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Write( | 
|  | pp_resource(), buffer, bytes_to_write, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return get_interface<PPB_TCPSocket_1_0>()->Write( | 
|  | pp_resource(), buffer, bytes_to_write, | 
|  | callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Listen(int32_t backlog, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Listen( | 
|  | pp_resource(), backlog, callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Listen( | 
|  | pp_resource(), backlog, callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::Accept( | 
|  | const CompletionCallbackWithOutput<TCPSocket>& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->Accept( | 
|  | pp_resource(), callback.output(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->Accept( | 
|  | pp_resource(), callback.output(), callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | void TCPSocket::Close() { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | get_interface<PPB_TCPSocket_1_2>()->Close(pp_resource()); | 
|  | } else if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | get_interface<PPB_TCPSocket_1_1>()->Close(pp_resource()); | 
|  | } else if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | get_interface<PPB_TCPSocket_1_0>()->Close(pp_resource()); | 
|  | } | 
|  | } | 
|  |  | 
|  | int32_t TCPSocket::SetOption(PP_TCPSocket_Option name, | 
|  | const Var& value, | 
|  | const CompletionCallback& callback) { | 
|  | if (has_interface<PPB_TCPSocket_1_2>()) { | 
|  | return get_interface<PPB_TCPSocket_1_2>()->SetOption( | 
|  | pp_resource(), name, value.pp_var(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_1>()) { | 
|  | return get_interface<PPB_TCPSocket_1_1>()->SetOption( | 
|  | pp_resource(), name, value.pp_var(), callback.pp_completion_callback()); | 
|  | } | 
|  | if (has_interface<PPB_TCPSocket_1_0>()) { | 
|  | return get_interface<PPB_TCPSocket_1_0>()->SetOption( | 
|  | pp_resource(), name, value.pp_var(), callback.pp_completion_callback()); | 
|  | } | 
|  | return callback.MayForce(PP_ERROR_NOINTERFACE); | 
|  | } | 
|  |  | 
|  | }  // namespace pp |