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

rev 57653 : [mq]: Truncate

*** 1,7 ****
  /*
!  * Copyright (c) 2002, 2012, 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
--- 1,7 ----
  /*
!  * 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,56 ****
   * 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 "jni.h"
- #include "jni_util.h"
- #include "jvm.h"
- #include "jlong.h"
- #include "sun_nio_ch_DatagramDispatcher.h"
  #include <sys/types.h>
  #include <sys/uio.h>
  #include <sys/socket.h>
  #include <string.h>
  
  #include "nio_util.h"
! #include <limits.h>
  
  JNIEXPORT jint JNICALL
  Java_sun_nio_ch_DatagramDispatcher_read0(JNIEnv *env, jclass clazz,
                           jobject fdo, jlong address, jint len)
  {
      jint fd = fdval(env, fdo);
      void *buf = (void *)jlong_to_ptr(address);
      int result = recv(fd, buf, len, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return -2;
      }
      return convertReturnVal(env, result, JNI_TRUE);
  }
  
  
--- 21,54 ----
   * 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 <sys/types.h>
  #include <sys/uio.h>
  #include <sys/socket.h>
  #include <string.h>
+ #include <limits.h>
  
+ #include "jni.h"
+ #include "jni_util.h"
+ #include "jvm.h"
+ #include "jlong.h"
+ #include "nio.h"
  #include "nio_util.h"
! #include "sun_nio_ch_DatagramDispatcher.h"
  
  JNIEXPORT jint JNICALL
  Java_sun_nio_ch_DatagramDispatcher_read0(JNIEnv *env, jclass clazz,
                                           jobject fdo, jlong address, jint len)
  {
      jint fd = fdval(env, fdo);
      void *buf = (void *)jlong_to_ptr(address);
      int result = recv(fd, buf, len, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return IOS_THROWN;
      }
      return convertReturnVal(env, result, JNI_TRUE);
  }
  
  
*** 72,82 ****
      m.msg_iovlen = len;
  
      result = recvmsg(fd, &m, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return -2;
      }
      return convertLongReturnVal(env, (jlong)result, JNI_TRUE);
  }
  
  JNIEXPORT jint JNICALL
--- 70,80 ----
      m.msg_iovlen = len;
  
      result = recvmsg(fd, &m, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return IOS_THROWN;
      }
      return convertLongReturnVal(env, (jlong)result, JNI_TRUE);
  }
  
  JNIEXPORT jint JNICALL
*** 86,96 ****
      jint fd = fdval(env, fdo);
      void *buf = (void *)jlong_to_ptr(address);
      int result = send(fd, buf, len, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return -2;
      }
      return convertReturnVal(env, result, JNI_FALSE);
  }
  
  JNIEXPORT jlong JNICALL
--- 84,94 ----
      jint fd = fdval(env, fdo);
      void *buf = (void *)jlong_to_ptr(address);
      int result = send(fd, buf, len, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return IOS_THROWN;
      }
      return convertReturnVal(env, result, JNI_FALSE);
  }
  
  JNIEXPORT jlong JNICALL
*** 111,119 ****
      m.msg_iovlen = len;
  
      result = sendmsg(fd, &m, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return -2;
      }
      return convertLongReturnVal(env, (jlong)result, JNI_FALSE);
  }
--- 109,117 ----
      m.msg_iovlen = len;
  
      result = sendmsg(fd, &m, 0);
      if (result < 0 && errno == ECONNREFUSED) {
          JNU_ThrowByName(env, JNU_JAVANETPKG "PortUnreachableException", 0);
!         return IOS_THROWN;
      }
      return convertLongReturnVal(env, (jlong)result, JNI_FALSE);
  }