[NaCl SDK] Support non blocking TCP/UDP

native_client_sdk/src/libraries/nacl_io/mount_node_socket.cc

 // Copyright (c) 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 "nacl_io/ossocket.h"
 #ifdef PROVIDES_SOCKET_API
 
 #include <errno.h>
 #include <string.h>
 
 #include "nacl_io/mount.h"
 #include "nacl_io/mount_node_socket.h"
 #include "nacl_io/pepper_interface.h"
 
 #include "ppapi/c/pp_resource.h"
 #include "ppapi/c/ppb_net_address.h"
 
 namespace nacl_io {
 
 MountNodeSocket::MountNodeSocket(Mount* mount)
-    : MountNode(mount),
+    : MountNodeStream(mount),
       socket_resource_(0),
       local_addr_(0),
-      remote_addr_(0) {
+      remote_addr_(0),
+      socket_flags_(0) {
   stat_.st_mode |= S_IFSOCK;
 }
 
 void MountNodeSocket::Destroy() {
   if (socket_resource_)
     mount_->ppapi()->ReleaseResource(socket_resource_);
   if (local_addr_)
     mount_->ppapi()->ReleaseResource(local_addr_);
   if (remote_addr_)
     mount_->ppapi()->ReleaseResource(remote_addr_);
-}
 
-// Default to always signaled, until socket select support is added.
-uint32_t MountNodeSocket::GetEventStatus() {
-  return POLLIN | POLLOUT;
+  socket_resource_ = 0;
+  local_addr_ = 0;
+  remote_addr_ = 0;
 }
 
 // Assume that |addr| and |out_addr| are non-NULL.
 Error MountNodeSocket::MMap(void* addr,
                             size_t length,
                             int prot,
                             int flags,
                             size_t offset,
                             void** out_addr) {
   return EACCES;
@@ skipping 10 matching lines @@
 Error MountNodeSocket::Write(size_t offs,
                       const void* buf,
                       size_t count,
                       int* out_bytes) {
   if (0 == remote_addr_)
     return EDESTADDRREQ;
 
   return Send(buf, count, 0, out_bytes);
 }
 
-NetAddressInterface* MountNodeSocket::NetAddress() {
+NetAddressInterface* MountNodeSocket::NetInterface() {
+  if (mount_->ppapi() == NULL)
+    return NULL;
+
   return mount_->ppapi()->GetNetAddressInterface();
 }
 
+TCPSocketInterface* MountNodeSocket::TCPInterface() {
+  if (mount_->ppapi() == NULL)
+    return NULL;
+
+  return mount_->ppapi()->GetTCPSocketInterface();
+}
+
+UDPSocketInterface* MountNodeSocket::UDPInterface() {
+  if (mount_->ppapi() == NULL)
+    return NULL;
+
+  return mount_->ppapi()->GetUDPSocketInterface();
+}
+
 PP_Resource MountNodeSocket::SockAddrToResource(const struct sockaddr* addr,
                                                 socklen_t len) {
   if (AF_INET == addr->sa_family) {
     PP_NetAddress_IPv4 addr4;
     const sockaddr_in* sin = reinterpret_cast<const sockaddr_in*>(addr);
 
     if (len != sizeof(sockaddr_in))
       return 0;
 
     memset(&addr4, 0, sizeof(addr4));
@@ skipping 24 matching lines @@
 
 socklen_t MountNodeSocket::ResourceToSockAddr(PP_Resource addr,
                                               socklen_t len,
                                               struct sockaddr* out_addr) {
   if (0 == addr)
     return 0;
 
   PP_NetAddress_IPv4 ipv4;
   PP_NetAddress_IPv6 ipv6;
 
-  if (PP_TRUE == NetAddress()->DescribeAsIPv4Address(addr, &ipv4)) {
+  if (PP_TRUE == NetInterface()->DescribeAsIPv4Address(addr, &ipv4)) {
     sockaddr_in addr4;
     addr4.sin_family = AF_INET;
     addr4.sin_port = ipv4.port;
     memcpy(&addr4.sin_addr, ipv4.addr, sizeof(ipv4.addr));
     memcpy(out_addr, &addr4, len);
 
     // Returns required size not copied size like getpeername/getsockname.
     return sizeof(sockaddr_in);
   }
 
-  if (PP_TRUE == NetAddress()->DescribeAsIPv6Address(addr, &ipv6)) {
+  if (PP_TRUE == NetInterface()->DescribeAsIPv6Address(addr, &ipv6)) {
     sockaddr_in6 addr6;
     addr6.sin6_family = AF_INET6;
     addr6.sin6_port = ipv6.port;
     memcpy(&addr6.sin6_addr, ipv6.addr, sizeof(ipv6.addr));
     memcpy(out_addr, &addr6, len);
 
     // Returns required size not copied size like getpeername/getsockname.
     return sizeof(sockaddr_in6);
   }
 
@@ skipping 110 matching lines @@
 
   AUTO_LOCK(node_lock_);
   if (local_addr_ != 0) {
     *len = ResourceToSockAddr(local_addr_, *len, addr);
     return 0;
   }
 
   return ENOTCONN;
 }
 
-
 }  // namespace nacl_io
 
 #endif  // PROVIDES_SOCKET_API