Handle EINTR in socket functions and continue incomplete sends.

src/platform-posix.cc

 // Copyright 2012 the V8 project authors. All rights reserved.
 // Redistribution and use in source and binary forms, with or without
 // modification, are permitted provided that the following conditions are
 // met:
 //
 //     * Redistributions of source code must retain the above copyright
 //       notice, this list of conditions and the following disclaimer.
 //     * Redistributions in binary form must reproduce the above
 //       copyright notice, this list of conditions and the following
 //       disclaimer in the documentation and/or other materials provided
@@ skipping 403 matching lines @@
   int status = listen(socket_, backlog);
   return status == 0;
 }
 
 
 Socket* POSIXSocket::Accept() const {
   if (!IsValid()) {
     return NULL;
   }
 
-  int socket = accept(socket_, NULL, NULL);
+  int socket;
+  do {
+    socket = accept(socket_, NULL, NULL);
+  } while (socket == -1 && errno == EINTR);
+
   if (socket == -1) {
     return NULL;
   } else {
     return new POSIXSocket(socket);
   }
 }
 
 
 bool POSIXSocket::Connect(const char* host, const char* port) {
   if (!IsValid()) {
     return false;
   }
 
   // Lookup host and port.
   struct addrinfo *result = NULL;
   struct addrinfo hints;
   memset(&hints, 0, sizeof(addrinfo));
   hints.ai_family = AF_INET;
   hints.ai_socktype = SOCK_STREAM;
   hints.ai_protocol = IPPROTO_TCP;
   int status = getaddrinfo(host, port, &hints, &result);
   if (status != 0) {
     return false;
   }
 
   // Connect.
-  status = connect(socket_, result->ai_addr, result->ai_addrlen);
+  do {
+    status = connect(socket_, result->ai_addr, result->ai_addrlen);
+  } while (status == -1 && errno == EINTR);
   freeaddrinfo(result);
   return status == 0;
 }
 
 
 bool POSIXSocket::Shutdown() {
   if (IsValid()) {
     // Shutdown socket for both read and write.
     int status = shutdown(socket_, SHUT_RDWR);
     close(socket_);
     socket_ = -1;
     return status == 0;
   }
   return true;
 }
 
 
 int POSIXSocket::Send(const char* data, int len) const {
   if (len <= 0) return 0;
-  int status = send(socket_, data, len, 0);
-  return (status < 0) ? 0 : status;
+  int written = 0;
+  while (written < len) {
+    int status = send(socket_, data + written, len - written, 0);
+    if (status == 0) {
+      break;
+    } else if (status > 0) {
+      written += status;
+    } else if (errno != EINTR) {
+      return 0;
+    }
+  }
+  return written;
 }
 
 
 int POSIXSocket::Receive(char* data, int len) const {
   if (len <= 0) return 0;
-  int status = recv(socket_, data, len, 0);
+  int status;
+  do {
+    status = recv(socket_, data, len, 0);
+  } while (status == -1 && errno == EINTR);
   return (status < 0) ? 0 : status;
 }
 
 
 bool POSIXSocket::SetReuseAddress(bool reuse_address) {
   int on = reuse_address ? 1 : 0;
   int status = setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
   return status == 0;
 }
 
@@ skipping 28 matching lines @@
   return ntohl(value);
 }
 
 
 Socket* OS::CreateSocket() {
   return new POSIXSocket();
 }
 
 
 } }  // namespace v8::internal