[dart:io][windows] Implements RawSynchronousSocket

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"
@@ skipping 75 matching lines @@
 }
 
 
 intptr_t SocketBase::Available(intptr_t fd) {
   intptr_t available = FDUtils::AvailableBytes(fd);
   LOG_INFO("SocketBase::Available(%ld) = %ld\n", fd, available);
   return available;
 }
 
 
-intptr_t SocketBase::Read(intptr_t fd, void* buffer, intptr_t num_bytes) {
+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));
   ASSERT(EAGAIN == EWOULDBLOCK);
-  if ((read_bytes == -1) && (errno == 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);
   } else {
     LOG_INFO("SocketBase::Read: read(%ld, %p, %ld) succeeded\n", fd, buffer,
              num_bytes);
   }
   return read_bytes;
 }
 
 
 intptr_t SocketBase::RecvFrom(intptr_t fd,
                               void* buffer,
                               intptr_t num_bytes,
-                              RawAddr* addr) {
+                              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) {
+                           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));
   ASSERT(EAGAIN == EWOULDBLOCK);
-  if ((written_bytes == -1) && (errno == 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);
   } else {
     LOG_INFO("SocketBase::Write: write(%ld, %p, %ld) succeeded\n", fd, buffer,
              num_bytes);
   }
   return written_bytes;
 }
 
 
 intptr_t SocketBase::SendTo(intptr_t fd,
                             const void* buffer,
                             intptr_t num_bytes,
-                            const RawAddr& addr) {
+                            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);
   RawAddr raw;
   socklen_t size = sizeof(raw);
@@ skipping 203 matching lines @@
   UNIMPLEMENTED();
   return false;
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // defined(HOST_OS_FUCHSIA)
 
 #endif  // !defined(DART_IO_DISABLED)