ppapi/cpp/udp_socket.cc

   1 // Copyright 2013 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/cpp/udp_socket.h"
   6
   7 #include "ppapi/c/pp_errors.h"
   8 #include "ppapi/cpp/completion_callback.h"
   9 #include "ppapi/cpp/instance_handle.h"
  10 #include "ppapi/cpp/module_impl.h"
  11 #include "ppapi/cpp/var.h"
  12
  13 namespace pp {
  14
  15 namespace {
  16
  17 template <> const char* interface_name<PPB_UDPSocket_1_0>() {
  18   return PPB_UDPSOCKET_INTERFACE_1_0;
  19 }
  20
  21 template <> const char* interface_name<PPB_UDPSocket_1_1>() {
  22   return PPB_UDPSOCKET_INTERFACE_1_1;
  23 }
  24
  25 }  // namespace
  26
  27 UDPSocket::UDPSocket() {
  28 }
  29
  30 UDPSocket::UDPSocket(const InstanceHandle& instance) {
  31   if (has_interface<PPB_UDPSocket_1_1>()) {
  32     PassRefFromConstructor(get_interface<PPB_UDPSocket_1_1>()->Create(
  33         instance.pp_instance()));
  34   } else if (has_interface<PPB_UDPSocket_1_0>()) {
  35     PassRefFromConstructor(get_interface<PPB_UDPSocket_1_0>()->Create(
  36         instance.pp_instance()));
  37   }
  38 }
  39
  40 UDPSocket::UDPSocket(PassRef, PP_Resource resource)
  41     : Resource(PASS_REF, resource) {
  42 }
  43
  44 UDPSocket::UDPSocket(const UDPSocket& other) : Resource(other) {
  45 }
  46
  47 UDPSocket::~UDPSocket() {
  48 }
  49
  50 UDPSocket& UDPSocket::operator=(const UDPSocket& other) {
  51   Resource::operator=(other);
  52   return *this;
  53 }
  54
  55 // static
  56 bool UDPSocket::IsAvailable() {
  57   return has_interface<PPB_UDPSocket_1_1>() ||
  58          has_interface<PPB_UDPSocket_1_0>();
  59 }
  60
  61 int32_t UDPSocket::Bind(const NetAddress& addr,
  62                         const CompletionCallback& callback) {
  63   if (has_interface<PPB_UDPSocket_1_1>()) {
  64     return get_interface<PPB_UDPSocket_1_1>()->Bind(
  65         pp_resource(), addr.pp_resource(), callback.pp_completion_callback());
  66   }
  67   if (has_interface<PPB_UDPSocket_1_0>()) {
  68     return get_interface<PPB_UDPSocket_1_0>()->Bind(
  69         pp_resource(), addr.pp_resource(), callback.pp_completion_callback());
  70   }
  71   return callback.MayForce(PP_ERROR_NOINTERFACE);
  72 }
  73
  74 NetAddress UDPSocket::GetBoundAddress() {
  75   if (has_interface<PPB_UDPSocket_1_1>()) {
  76     return NetAddress(
  77         PASS_REF,
  78         get_interface<PPB_UDPSocket_1_1>()->GetBoundAddress(pp_resource()));
  79   }
  80   if (has_interface<PPB_UDPSocket_1_0>()) {
  81     return NetAddress(
  82         PASS_REF,
  83         get_interface<PPB_UDPSocket_1_0>()->GetBoundAddress(pp_resource()));
  84   }
  85   return NetAddress();
  86 }
  87
  88 int32_t UDPSocket::RecvFrom(
  89     char* buffer,
  90     int32_t num_bytes,
  91     const CompletionCallbackWithOutput<NetAddress>& callback) {
  92   if (has_interface<PPB_UDPSocket_1_1>()) {
  93     return get_interface<PPB_UDPSocket_1_1>()->RecvFrom(
  94         pp_resource(), buffer, num_bytes, callback.output(),
  95         callback.pp_completion_callback());
  96   }
  97   if (has_interface<PPB_UDPSocket_1_0>()) {
  98     return get_interface<PPB_UDPSocket_1_0>()->RecvFrom(
  99         pp_resource(), buffer, num_bytes, callback.output(),
 100         callback.pp_completion_callback());
 101   }
 102   return callback.MayForce(PP_ERROR_NOINTERFACE);
 103 }
 104
 105 int32_t UDPSocket::SendTo(const char* buffer,
 106                           int32_t num_bytes,
 107                           const NetAddress& addr,
 108                           const CompletionCallback& callback) {
 109   if (has_interface<PPB_UDPSocket_1_1>()) {
 110     return get_interface<PPB_UDPSocket_1_1>()->SendTo(
 111         pp_resource(), buffer, num_bytes, addr.pp_resource(),
 112         callback.pp_completion_callback());
 113   }
 114   if (has_interface<PPB_UDPSocket_1_0>()) {
 115     return get_interface<PPB_UDPSocket_1_0>()->SendTo(
 116         pp_resource(), buffer, num_bytes, addr.pp_resource(),
 117         callback.pp_completion_callback());
 118   }
 119   return callback.MayForce(PP_ERROR_NOINTERFACE);
 120 }
 121
 122 void UDPSocket::Close() {
 123   if (has_interface<PPB_UDPSocket_1_1>())
 124     return get_interface<PPB_UDPSocket_1_1>()->Close(pp_resource());
 125   if (has_interface<PPB_UDPSocket_1_0>())
 126     return get_interface<PPB_UDPSocket_1_0>()->Close(pp_resource());
 127 }
 128
 129 int32_t UDPSocket::SetOption(PP_UDPSocket_Option name,
 130                              const Var& value,
 131                              const CompletionCallback& callback) {
 132   if (has_interface<PPB_UDPSocket_1_1>()) {
 133     return get_interface<PPB_UDPSocket_1_1>()->SetOption(
 134         pp_resource(), name, value.pp_var(), callback.pp_completion_callback());
 135   }
 136   if (has_interface<PPB_UDPSocket_1_0>()) {
 137     return get_interface<PPB_UDPSocket_1_0>()->SetOption(
 138         pp_resource(), name, value.pp_var(), callback.pp_completion_callback());
 139   }
 140   return callback.MayForce(PP_ERROR_NOINTERFACE);
 141 }
 142
 143 }  // namespace pp