[dart:io][windows] Implements RawSynchronousSocket

runtime/bin/sync_socket.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 "bin/sync_socket.h"
 
 #include "bin/dartutils.h"
 #include "bin/io_buffer.h"
@@ skipping 125 matching lines @@
   intptr_t offset = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 2));
   intptr_t length = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 3));
   Dart_TypedData_Type type;
   uint8_t* buffer = NULL;
   intptr_t len;
   result = Dart_TypedDataAcquireData(buffer_obj, &type,
                                      reinterpret_cast<void**>(&buffer), &len);
   DART_CHECK_ERROR(result);
   ASSERT((offset + length) <= len);
   buffer += offset;
-  intptr_t bytes_written = SocketBase::Write(socket->fd(), buffer, length);
+  intptr_t bytes_written =
+      SynchronousSocket::Write(socket->fd(), buffer, length);
   if (bytes_written >= 0) {
     Dart_SetIntegerReturnValue(args, bytes_written);
   } else {
     OSError os_error;
     Dart_SetReturnValue(args, DartUtils::NewDartOSError(&os_error));
   }
   Dart_TypedDataReleaseData(buffer_obj);
 }
 
 
@@ skipping 10 matching lines @@
     return;
   }
   intptr_t offset = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 2));
   intptr_t bytes = DartUtils::GetIntptrValue(Dart_GetNativeArgument(args, 3));
   intptr_t array_len = 0;
 
   result = Dart_ListLength(buffer_obj, &array_len);
   DART_CHECK_ERROR(result);
 
   uint8_t* buffer = Dart_ScopeAllocate(bytes);
-  intptr_t bytes_read = SocketBase::Read(socket->fd(), buffer, bytes);
+  intptr_t bytes_read = SynchronousSocket::Read(socket->fd(), buffer, bytes);
   if (bytes_read < 0) {
     Dart_SetReturnValue(args, DartUtils::NewDartOSError());
     return;
   }
   if (bytes_read > 0) {
     result = Dart_ListSetAsBytes(buffer_obj, offset, buffer, bytes_read);
     DART_CHECK_ERROR(result);
   }
   Dart_SetIntegerReturnValue(args, bytes_read);
 }
 
 
 void FUNCTION_NAME(SynchronousSocket_Available)(Dart_NativeArguments args) {
   SynchronousSocket* socket = NULL;
   Dart_Handle result = SynchronousSocket::GetSocketIdNativeField(
       Dart_GetNativeArgument(args, 0), &socket);
   DART_CHECK_ERROR(result);
 
-  intptr_t available = SocketBase::Available(socket->fd());
+  intptr_t available = SynchronousSocket::Available(socket->fd());
   if (available >= 0) {
     Dart_SetIntegerReturnValue(args, available);
   } else {
     Dart_SetReturnValue(args, DartUtils::NewDartOSError());
   }
 }
 
 
 void FUNCTION_NAME(SynchronousSocket_CloseSync)(Dart_NativeArguments args) {
   SynchronousSocket* socket = NULL;
   Dart_Handle result = SynchronousSocket::GetSocketIdNativeField(
       Dart_GetNativeArgument(args, 0), &socket);
   DART_CHECK_ERROR(result);
 
-  SocketBase::Close(socket->fd());
+  SynchronousSocket::Close(socket->fd());
   socket->SetClosedFd();
 }
 
 
 void FUNCTION_NAME(SynchronousSocket_Read)(Dart_NativeArguments args) {
   SynchronousSocket* socket = NULL;
   Dart_Handle result = SynchronousSocket::GetSocketIdNativeField(
       Dart_GetNativeArgument(args, 0), &socket);
   DART_CHECK_ERROR(result);
 
   int64_t length = 0;
   if (!DartUtils::GetInt64Value(Dart_GetNativeArgument(args, 1), &length)) {
     Dart_SetReturnValue(args, DartUtils::NewDartArgumentError(
                                   "First parameter must be an integer."));
     return;
   }
   uint8_t* buffer = NULL;
   result = IOBuffer::Allocate(length, &buffer);
   ASSERT(buffer != NULL);
-  intptr_t bytes_read = SocketBase::Read(socket->fd(), buffer, length);
+  intptr_t bytes_read = SynchronousSocket::Read(socket->fd(), buffer, length);
   if (bytes_read == length) {
     Dart_SetReturnValue(args, result);
   } else if (bytes_read > 0) {
     uint8_t* new_buffer = NULL;
     Dart_Handle new_result = IOBuffer::Allocate(bytes_read, &new_buffer);
     ASSERT(new_buffer != NULL);
     memmove(new_buffer, buffer, bytes_read);
     Dart_SetReturnValue(args, new_result);
   } else if (bytes_read == -1) {
     Dart_SetReturnValue(args, DartUtils::NewDartOSError());
@@ skipping 20 matching lines @@
   SynchronousSocket::ShutdownWrite(socket->fd());
 }
 
 
 void FUNCTION_NAME(SynchronousSocket_GetPort)(Dart_NativeArguments args) {
   SynchronousSocket* socket = NULL;
   Dart_Handle result = SynchronousSocket::GetSocketIdNativeField(
       Dart_GetNativeArgument(args, 0), &socket);
   DART_CHECK_ERROR(result);
 
-  intptr_t port = SocketBase::GetPort(socket->fd());
+  intptr_t port = SynchronousSocket::GetPort(socket->fd());
   if (port > 0) {
     Dart_SetReturnValue(args, Dart_NewInteger(port));
   } else {
     Dart_SetReturnValue(args, DartUtils::NewDartOSError());
   }
 }
 
 
 void FUNCTION_NAME(SynchronousSocket_GetRemotePeer)(Dart_NativeArguments args) {
   SynchronousSocket* socket = NULL;
   Dart_Handle result = SynchronousSocket::GetSocketIdNativeField(
       Dart_GetNativeArgument(args, 0), &socket);
   DART_CHECK_ERROR(result);
 
   intptr_t port = 0;
-  SocketAddress* addr = SocketBase::GetRemotePeer(socket->fd(), &port);
+  SocketAddress* addr = SynchronousSocket::GetRemotePeer(socket->fd(), &port);
   if (addr == NULL) {
     Dart_SetReturnValue(args, DartUtils::NewDartOSError());
     return;
   }
   Dart_Handle list = Dart_NewList(2);
   DART_CHECK_ERROR_AND_CLEANUP(list, addr);
 
   Dart_Handle entry = Dart_NewList(3);
   DART_CHECK_ERROR_AND_CLEANUP(entry, addr);
 
@@ skipping 15 matching lines @@
   Dart_SetReturnValue(args, list);
   delete addr;
 }
 
 
 static void SynchronousSocketFinalizer(void* isolate_data,
                                        Dart_WeakPersistentHandle handle,
                                        void* data) {
   SynchronousSocket* socket = reinterpret_cast<SynchronousSocket*>(data);
   if (socket->fd() >= 0) {
-    SocketBase::Close(socket->fd());
+    SynchronousSocket::Close(socket->fd());
     socket->SetClosedFd();
   }
   delete socket;
 }
 
 
 Dart_Handle SynchronousSocket::SetSocketIdNativeField(
     Dart_Handle handle,
     SynchronousSocket* socket) {
   Dart_Handle error = Dart_SetNativeInstanceField(
@@ skipping 21 matching lines @@
     return result;
   }
   *socket = reinterpret_cast<SynchronousSocket*>(id);
   return result;
 }
 
 }  // namespace bin
 }  // namespace dart
 
 #endif  // !defined(DART_IO_DISABLED)