[Fuchsia] EventHandler: epoll -> ports v2

runtime/bin/socket_base_fuchsia.cc

 // Copyright (c) 2016, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 #if !defined(DART_IO_DISABLED)
 
 #include "platform/globals.h"
 #if defined(HOST_OS_FUCHSIA)
 
 #include "bin/socket_base.h"
 
 #include <errno.h>        // NOLINT
 #include <fcntl.h>        // NOLINT
 #include <ifaddrs.h>      // NOLINT
 #include <net/if.h>       // NOLINT
 #include <netinet/tcp.h>  // NOLINT
 #include <stdio.h>        // NOLINT
 #include <stdlib.h>       // NOLINT
 #include <string.h>       // NOLINT
 #include <sys/ioctl.h>    // NOLINT
 #include <sys/stat.h>     // NOLINT
 #include <unistd.h>       // NOLINT
 
+#include "bin/eventhandler.h"
 #include "bin/fdutils.h"
 #include "bin/file.h"
 #include "bin/socket_base_fuchsia.h"
 #include "platform/signal_blocker.h"
 
 // #define SOCKET_LOG_INFO 1
 // #define SOCKET_LOG_ERROR 1
 
 // define SOCKET_LOG_ERROR to get log messages only for errors.
 // define SOCKET_LOG_INFO to get log messages for both information and errors.
@@ skipping 46 matching lines @@
 }
 
 
 bool SocketBase::IsBindError(intptr_t error_number) {
   return error_number == EADDRINUSE || error_number == EADDRNOTAVAIL ||
          error_number == EINVAL;
 }
 
 
 intptr_t SocketBase::Available(intptr_t fd) {
-  intptr_t available = FDUtils::AvailableBytes(fd);
-  LOG_INFO("SocketBase::Available(%ld) = %ld\n", fd, available);
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
+  intptr_t available = FDUtils::AvailableBytes(handle->fd());
+  LOG_INFO("SocketBase::Available(%ld) = %ld\n", handle->fd(), available);
   return available;
 }
 
 
 intptr_t SocketBase::Read(intptr_t fd,
                           void* buffer,
                           intptr_t num_bytes,
                           SocketOpKind sync) {
-  ASSERT(fd >= 0);
-  LOG_INFO("SocketBase::Read: calling read(%ld, %p, %ld)\n", fd, buffer,
-           num_bytes);
-  ssize_t read_bytes = NO_RETRY_EXPECTED(read(fd, buffer, num_bytes));
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
+  LOG_INFO("SocketBase::Read: calling read(%ld, %p, %ld)\n", handle->fd(),
+           buffer, num_bytes);
+  intptr_t read_bytes = handle->Read(buffer, num_bytes);
   ASSERT(EAGAIN == EWOULDBLOCK);
   if ((sync == kAsync) && (read_bytes == -1) && (errno == EWOULDBLOCK)) {
     // If the read would block we need to retry and therefore return 0
     // as the number of bytes written.
     read_bytes = 0;
   } else if (read_bytes == -1) {
-    LOG_ERR("SocketBase::Read: read(%ld, %p, %ld) failed\n", fd, buffer,
-            num_bytes);
+    LOG_ERR("SocketBase::Read: read(%ld, %p, %ld) failed\n", handle->fd(),
+            buffer, num_bytes);
   } else {
-    LOG_INFO("SocketBase::Read: read(%ld, %p, %ld) succeeded\n", fd, buffer,
-             num_bytes);
+    LOG_INFO("SocketBase::Read: read(%ld, %p, %ld) succeeded\n", handle->fd(),
+             buffer, num_bytes);
   }
   return read_bytes;
 }
 
 
 intptr_t SocketBase::RecvFrom(intptr_t fd,
                               void* buffer,
                               intptr_t num_bytes,
                               RawAddr* addr,
                               SocketOpKind sync) {
   LOG_ERR("SocketBase::RecvFrom is unimplemented\n");
   UNIMPLEMENTED();
   return -1;
 }
 
 
 intptr_t SocketBase::Write(intptr_t fd,
                            const void* buffer,
                            intptr_t num_bytes,
                            SocketOpKind sync) {
-  ASSERT(fd >= 0);
-  LOG_INFO("SocketBase::Write: calling write(%ld, %p, %ld)\n", fd, buffer,
-           num_bytes);
-  ssize_t written_bytes = NO_RETRY_EXPECTED(write(fd, buffer, num_bytes));
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
+  LOG_INFO("SocketBase::Write: calling write(%ld, %p, %ld)\n", handle->fd(),
+           buffer, num_bytes);
+  intptr_t written_bytes = handle->Write(buffer, num_bytes);
   ASSERT(EAGAIN == EWOULDBLOCK);
   if ((sync == kAsync) && (written_bytes == -1) && (errno == EWOULDBLOCK)) {
     // If the would block we need to retry and therefore return 0 as
     // the number of bytes written.
     written_bytes = 0;
   } else if (written_bytes == -1) {
-    LOG_ERR("SocketBase::Write: write(%ld, %p, %ld) failed\n", fd, buffer,
-            num_bytes);
+    LOG_ERR("SocketBase::Write: write(%ld, %p, %ld) failed\n", handle->fd(),
+            buffer, num_bytes);
   } else {
-    LOG_INFO("SocketBase::Write: write(%ld, %p, %ld) succeeded\n", fd, buffer,
-             num_bytes);
+    LOG_INFO("SocketBase::Write: write(%ld, %p, %ld) succeeded\n", handle->fd(),
+             buffer, num_bytes);
   }
   return written_bytes;
 }
 
 
 intptr_t SocketBase::SendTo(intptr_t fd,
                             const void* buffer,
                             intptr_t num_bytes,
                             const RawAddr& addr,
                             SocketOpKind sync) {
   LOG_ERR("SocketBase::SendTo is unimplemented\n");
   UNIMPLEMENTED();
   return -1;
 }
 
 
 intptr_t SocketBase::GetPort(intptr_t fd) {
-  ASSERT(fd >= 0);
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
   RawAddr raw;
   socklen_t size = sizeof(raw);
-  LOG_INFO("SocketBase::GetPort: calling getsockname(%ld)\n", fd);
-  if (NO_RETRY_EXPECTED(getsockname(fd, &raw.addr, &size))) {
+  LOG_INFO("SocketBase::GetPort: calling getsockname(%ld)\n", handle->fd());
+  if (NO_RETRY_EXPECTED(getsockname(handle->fd(), &raw.addr, &size))) {
     return 0;
   }
   return SocketAddress::GetAddrPort(raw);
 }
 
 
 SocketAddress* SocketBase::GetRemotePeer(intptr_t fd, intptr_t* port) {
-  ASSERT(fd >= 0);
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
   RawAddr raw;
   socklen_t size = sizeof(raw);
-  if (NO_RETRY_EXPECTED(getpeername(fd, &raw.addr, &size))) {
+  if (NO_RETRY_EXPECTED(getpeername(handle->fd(), &raw.addr, &size))) {
     return NULL;
   }
   *port = SocketAddress::GetAddrPort(raw);
   return new SocketAddress(&raw.addr);
 }
 
 
 void SocketBase::GetError(intptr_t fd, OSError* os_error) {
   LOG_ERR("SocketBase::GetError is unimplemented\n");
   UNIMPLEMENTED();
@@ skipping 89 matching lines @@
 
 AddressList<InterfaceSocketAddress>* SocketBase::ListInterfaces(
     int type,
     OSError** os_error) {
   UNIMPLEMENTED();
   return NULL;
 }
 
 
 void SocketBase::Close(intptr_t fd) {
-  ASSERT(fd >= 0);
-  NO_RETRY_EXPECTED(close(fd));
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
+  ASSERT(handle->fd() >= 0);
+  NO_RETRY_EXPECTED(close(handle->fd()));
 }
 
 
 bool SocketBase::GetNoDelay(intptr_t fd, bool* enabled) {
   LOG_ERR("SocketBase::GetNoDelay is unimplemented\n");
   UNIMPLEMENTED();
   return false;
 }
 
 
 bool SocketBase::SetNoDelay(intptr_t fd, bool enabled) {
+  IOHandle* handle = reinterpret_cast<IOHandle*>(fd);
   int on = enabled ? 1 : 0;
-  return NO_RETRY_EXPECTED(setsockopt(fd, IPPROTO_TCP, TCP_NODELAY,
+  return NO_RETRY_EXPECTED(setsockopt(handle->fd(), IPPROTO_TCP, TCP_NODELAY,
                                       reinterpret_cast<char*>(&on),
                                       sizeof(on))) == 0;
 }
 
 
 bool SocketBase::GetMulticastLoop(intptr_t fd,
                                   intptr_t protocol,
                                   bool* enabled) {
   LOG_ERR("SocketBase::GetMulticastLoop is unimplemented\n");
   UNIMPLEMENTED();
@@ skipping 56 matching lines @@
   UNIMPLEMENTED();
   return false;
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(HOST_OS_FUCHSIA)
 
 #endif  // !defined(DART_IO_DISABLED)