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

rev 57653 : [mq]: Truncate

@@ -1,7 +1,7 @@
 /*
- * Copyright (c) 2002, 2018, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 2002, 2020, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this

@@ -21,25 +21,23 @@
  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  * or visit www.oracle.com if you need additional information or have any
  * questions.
  */
 
-/*
- */
-
 #include <windows.h>
 #include <winsock2.h>
 #include <ctype.h>
+
 #include "jni.h"
 #include "jni_util.h"
 #include "jvm.h"
 #include "jlong.h"
-#include "sun_nio_ch_DatagramDispatcher.h"
-
 #include "nio.h"
 #include "nio_util.h"
 
+#include "sun_nio_ch_DatagramDispatcher.h"
+
 
 /**************************************************************
  * DatagramDispatcher.c
  */
 

@@ -67,21 +65,23 @@
             0,              /* no overlapped sockets */
             0);             /* no completion routine */
 
     if (i == SOCKET_ERROR) {
         int theErr = (jint)WSAGetLastError();
+        if (theErr != WSAEMSGSIZE) {
         if (theErr == WSAEWOULDBLOCK) {
             return IOS_UNAVAILABLE;
         }
         if (theErr == WSAECONNRESET) {
             purgeOutstandingICMP(env, clazz, fd);
             JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
             return IOS_THROWN;
         }
-        JNU_ThrowIOExceptionWithLastError(env, "Write failed");
+            JNU_ThrowIOExceptionWithLastError(env, "WSARecv failed");
         return IOS_THROWN;
     }
+    }
 
     return convertReturnVal(env, (jint)read, JNI_TRUE);
 }
 
 JNIEXPORT jlong JNICALL

@@ -118,21 +118,23 @@
     /* clean up */
     free(bufs);
 
     if (i != 0) {
         int theErr = (jint)WSAGetLastError();
+        if (theErr != WSAEMSGSIZE) {
         if (theErr == WSAEWOULDBLOCK) {
             return IOS_UNAVAILABLE;
         }
         if (theErr == WSAECONNRESET) {
             purgeOutstandingICMP(env, clazz, fd);
             JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
             return IOS_THROWN;
         }
-        JNU_ThrowIOExceptionWithLastError(env, "Write failed");
+            JNU_ThrowIOExceptionWithLastError(env, "WSARecv failed");
         return IOS_THROWN;
     }
+    }
 
     return convertLongReturnVal(env, (jlong)read, JNI_TRUE);
 }
 
 

@@ -167,11 +169,11 @@
         if (theErr == WSAECONNRESET) {
             purgeOutstandingICMP(env, clazz, fd);
             JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
             return IOS_THROWN;
         }
-        JNU_ThrowIOExceptionWithLastError(env, "Write failed");
+        JNU_ThrowIOExceptionWithLastError(env, "WSASend failed");
         return IOS_THROWN;
     }
 
     return convertReturnVal(env, (jint)written, JNI_FALSE);
 }

@@ -217,11 +219,11 @@
         if (theErr == WSAECONNRESET) {
             purgeOutstandingICMP(env, clazz, fd);
             JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
             return IOS_THROWN;
         }
-        JNU_ThrowIOExceptionWithLastError(env, "Write failed");
+        JNU_ThrowIOExceptionWithLastError(env, "WSASend failed");
         return IOS_THROWN;
     }
 
     return convertLongReturnVal(env, (jlong)written, JNI_FALSE);
 }