src/java.base/windows/native/libnio/ch/Net.c

rev 53867 : 8250521: Configure initial RTO to use minimal retry for loopback connections on Windows
Reviewed-by: alanb

*** 192,221 ****
  Java_sun_nio_ch_Net_connect0(JNIEnv *env, jclass clazz, jboolean preferIPv6, jobject fdo,
                               jobject iao, jint port)
  {
      SOCKETADDRESS sa;
      int rv;
      int sa_len = 0;
      SOCKET s = (SOCKET)fdval(env, fdo);
  
      if (NET_InetAddressToSockaddr(env, iao, port, &sa, &sa_len, preferIPv6) != 0) {
          return IOS_THROWN;
      }
  
      rv = connect(s, &sa.sa, sa_len);
      if (rv != 0) {
          int err = WSAGetLastError();
          if (err == WSAEINPROGRESS || err == WSAEWOULDBLOCK) {
              return IOS_UNAVAILABLE;
          }
          NET_ThrowNew(env, err, "connect");
          return IOS_THROWN;
      } else {
          /* Enable WSAECONNRESET errors when a UDP socket is connected */
!         int type = 0, optlen = sizeof(type);
!         rv = getsockopt(s, SOL_SOCKET, SO_TYPE, (char*)&type, &optlen);
!         if (rv == 0 && type == SOCK_DGRAM) {
              setConnectionReset(s, TRUE);
          }
      }
      return 1;
  }
--- 192,231 ----
  Java_sun_nio_ch_Net_connect0(JNIEnv *env, jclass clazz, jboolean preferIPv6, jobject fdo,
                               jobject iao, jint port)
  {
      SOCKETADDRESS sa;
      int rv;
+     int so_rv;
      int sa_len = 0;
      SOCKET s = (SOCKET)fdval(env, fdo);
+     int type = 0, optlen = sizeof(type);
  
      if (NET_InetAddressToSockaddr(env, iao, port, &sa, &sa_len, preferIPv6) != 0) {
          return IOS_THROWN;
      }
  
+     so_rv = getsockopt(s, SOL_SOCKET, SO_TYPE, (char*)&type, &optlen);
+ 
+     /**
+      * Windows has a very long socket connect timeout of 2 seconds.
+      * If it's the loopback adapter we can shorten the wait interval.
+      */
+     if (so_rv == 0 && type == SOCK_STREAM && IS_LOOPBACK_ADDRESS(&sa)) {
+         NET_EnableFastTcpLoopbackConnect((jint)s);
+     }
+ 
      rv = connect(s, &sa.sa, sa_len);
      if (rv != 0) {
          int err = WSAGetLastError();
          if (err == WSAEINPROGRESS || err == WSAEWOULDBLOCK) {
              return IOS_UNAVAILABLE;
          }
          NET_ThrowNew(env, err, "connect");
          return IOS_THROWN;
      } else {
          /* Enable WSAECONNRESET errors when a UDP socket is connected */
!         if (so_rv == 0 && type == SOCK_DGRAM) {
              setConnectionReset(s, TRUE);
          }
      }
      return 1;
  }