[dart:io][windows] Implements RawSynchronousSocket

runtime/bin/sync_socket_macos.cc

 // Copyright (c) 2017, 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_MACOS)
 
 #include "bin/sync_socket.h"
 
 #include <errno.h>  // NOLINT
 
 #include "bin/fdutils.h"
+#include "bin/socket_base.h"
 #include "platform/signal_blocker.h"
 
 namespace dart {
 namespace bin {
 
-SynchronousSocket::SynchronousSocket(intptr_t fd) : fd_(fd) {}
-
-
-void SynchronousSocket::SetClosedFd() {
-  fd_ = kClosedFd;
+bool SynchronousSocket::Initialize() {
+  // Nothing to do on Linux.
+  return true;
 }
 
 
 static intptr_t Create(const RawAddr& addr) {
   intptr_t fd;
   fd = NO_RETRY_EXPECTED(socket(addr.ss.ss_family, SOCK_STREAM, 0));
   if (fd < 0) {
     return -1;
   }
   if (!FDUtils::SetCloseOnExec(fd)) {
@@ skipping 18 matching lines @@
 
 intptr_t SynchronousSocket::CreateConnect(const RawAddr& addr) {
   intptr_t fd = Create(addr);
   if (fd < 0) {
     return fd;
   }
   return Connect(fd, addr);
 }
 
 
+intptr_t SynchronousSocket::Available(intptr_t fd) {
+  return SocketBase::Available(fd);
+}
+
+
+intptr_t SynchronousSocket::GetPort(intptr_t fd) {
+  return SocketBase::GetPort(fd);
+}
+
+
+SocketAddress* SynchronousSocket::GetRemotePeer(intptr_t fd, intptr_t* port) {
+  return SocketBase::GetRemotePeer(fd, port);
+}
+
+
+intptr_t SynchronousSocket::Read(intptr_t fd,
+                                 void* buffer,
+                                 intptr_t num_bytes) {
+  return SocketBase::Read(fd, buffer, num_bytes, SocketBase::kSync);
+}
+
+
+intptr_t SynchronousSocket::Write(intptr_t fd,
+                                  const void* buffer,
+                                  intptr_t num_bytes) {
+  return SocketBase::Write(fd, buffer, num_bytes, SocketBase::kSync);
+}
+
+
 void SynchronousSocket::ShutdownRead(intptr_t fd) {
   VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_RD));
 }
 
 
 void SynchronousSocket::ShutdownWrite(intptr_t fd) {
   VOID_NO_RETRY_EXPECTED(shutdown(fd, SHUT_WR));
 }
 
+
+void SynchronousSocket::Close(intptr_t fd) {
+  return SocketBase::Close(fd);
+}
+
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(HOST_OS_MACOS)
 
 #endif  // !defined(DART_IO_DISABLED)