--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/java.base/unix/native/libnio/ch/IOUtil.c Tue Sep 12 19:03:39 2017 +0200
@@ -0,0 +1,203 @@
+/*
+ * Copyright (c) 2000, 2015, 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
+ * particular file as subject to the "Classpath" exception as provided
+ * by Oracle in the LICENSE file that accompanied this code.
+ *
+ * This code is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
+ * version 2 for more details (a copy is included in the LICENSE file that
+ * accompanied this code).
+ *
+ * You should have received a copy of the GNU General Public License version
+ * 2 along with this work; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * 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 <string.h>
+#include <sys/resource.h>
+
+#include "jni.h"
+#include "jni_util.h"
+#include "jvm.h"
+#include "jlong.h"
+#include "sun_nio_ch_IOUtil.h"
+#include "java_lang_Integer.h"
+#include "nio.h"
+#include "nio_util.h"
+
+static jfieldID fd_fdID; /* for jint 'fd' in java.io.FileDescriptor */
+
+
+JNIEXPORT void JNICALL
+Java_sun_nio_ch_IOUtil_initIDs(JNIEnv *env, jclass clazz)
+{
+ CHECK_NULL(clazz = (*env)->FindClass(env, "java/io/FileDescriptor"));
+ CHECK_NULL(fd_fdID = (*env)->GetFieldID(env, clazz, "fd", "I"));
+}
+
+JNIEXPORT jboolean JNICALL
+Java_sun_nio_ch_IOUtil_randomBytes(JNIEnv *env, jclass clazz,
+ jbyteArray randArray)
+{
+ JNU_ThrowByName(env, "java/lang/UnsupportedOperationException", NULL);
+ return JNI_FALSE;
+}
+
+JNIEXPORT jint JNICALL
+Java_sun_nio_ch_IOUtil_fdVal(JNIEnv *env, jclass clazz, jobject fdo)
+{
+ return (*env)->GetIntField(env, fdo, fd_fdID);
+}
+
+JNIEXPORT void JNICALL
+Java_sun_nio_ch_IOUtil_setfdVal(JNIEnv *env, jclass clazz, jobject fdo, jint val)
+{
+ (*env)->SetIntField(env, fdo, fd_fdID, val);
+}
+
+static int
+configureBlocking(int fd, jboolean blocking)
+{
+ int flags = fcntl(fd, F_GETFL);
+ int newflags = blocking ? (flags & ~O_NONBLOCK) : (flags | O_NONBLOCK);
+
+ return (flags == newflags) ? 0 : fcntl(fd, F_SETFL, newflags);
+}
+
+JNIEXPORT void JNICALL
+Java_sun_nio_ch_IOUtil_configureBlocking(JNIEnv *env, jclass clazz,
+ jobject fdo, jboolean blocking)
+{
+ if (configureBlocking(fdval(env, fdo), blocking) < 0)
+ JNU_ThrowIOExceptionWithLastError(env, "Configure blocking failed");
+}
+
+JNIEXPORT jlong JNICALL
+Java_sun_nio_ch_IOUtil_makePipe(JNIEnv *env, jobject this, jboolean blocking)
+{
+ int fd[2];
+
+ if (pipe(fd) < 0) {
+ JNU_ThrowIOExceptionWithLastError(env, "Pipe failed");
+ return 0;
+ }
+ if (blocking == JNI_FALSE) {
+ if ((configureBlocking(fd[0], JNI_FALSE) < 0)
+ || (configureBlocking(fd[1], JNI_FALSE) < 0)) {
+ JNU_ThrowIOExceptionWithLastError(env, "Configure blocking failed");
+ close(fd[0]);
+ close(fd[1]);
+ return 0;
+ }
+ }
+ return ((jlong) fd[0] << 32) | (jlong) fd[1];
+}
+
+JNIEXPORT jboolean JNICALL
+Java_sun_nio_ch_IOUtil_drain(JNIEnv *env, jclass cl, jint fd)
+{
+ char buf[128];
+ int tn = 0;
+
+ for (;;) {
+ int n = read(fd, buf, sizeof(buf));
+ tn += n;
+ if ((n < 0) && (errno != EAGAIN))
+ JNU_ThrowIOExceptionWithLastError(env, "Drain");
+ if (n == (int)sizeof(buf))
+ continue;
+ return (tn > 0) ? JNI_TRUE : JNI_FALSE;
+ }
+}
+
+JNIEXPORT jint JNICALL
+Java_sun_nio_ch_IOUtil_fdLimit(JNIEnv *env, jclass this)
+{
+ struct rlimit rlp;
+ if (getrlimit(RLIMIT_NOFILE, &rlp) < 0) {
+ JNU_ThrowIOExceptionWithLastError(env, "getrlimit failed");
+ return -1;
+ }
+ if (rlp.rlim_max == RLIM_INFINITY ||
+ rlp.rlim_max > (rlim_t)java_lang_Integer_MAX_VALUE) {
+ return java_lang_Integer_MAX_VALUE;
+ } else {
+ return (jint)rlp.rlim_max;
+ }
+}
+
+JNIEXPORT jint JNICALL
+Java_sun_nio_ch_IOUtil_iovMax(JNIEnv *env, jclass this)
+{
+ jlong iov_max = sysconf(_SC_IOV_MAX);
+ if (iov_max == -1)
+ iov_max = 16;
+ return (jint)iov_max;
+}
+
+/* Declared in nio_util.h for use elsewhere in NIO */
+
+jint
+convertReturnVal(JNIEnv *env, jint n, jboolean reading)
+{
+ if (n > 0) /* Number of bytes written */
+ return n;
+ else if (n == 0) {
+ if (reading) {
+ return IOS_EOF; /* EOF is -1 in javaland */
+ } else {
+ return 0;
+ }
+ }
+ else if (errno == EAGAIN)
+ return IOS_UNAVAILABLE;
+ else if (errno == EINTR)
+ return IOS_INTERRUPTED;
+ else {
+ const char *msg = reading ? "Read failed" : "Write failed";
+ JNU_ThrowIOExceptionWithLastError(env, msg);
+ return IOS_THROWN;
+ }
+}
+
+/* Declared in nio_util.h for use elsewhere in NIO */
+
+jlong
+convertLongReturnVal(JNIEnv *env, jlong n, jboolean reading)
+{
+ if (n > 0) /* Number of bytes written */
+ return n;
+ else if (n == 0) {
+ if (reading) {
+ return IOS_EOF; /* EOF is -1 in javaland */
+ } else {
+ return 0;
+ }
+ }
+ else if (errno == EAGAIN)
+ return IOS_UNAVAILABLE;
+ else if (errno == EINTR)
+ return IOS_INTERRUPTED;
+ else {
+ const char *msg = reading ? "Read failed" : "Write failed";
+ JNU_ThrowIOExceptionWithLastError(env, msg);
+ return IOS_THROWN;
+ }
+}
+
+jint
+fdval(JNIEnv *env, jobject fdo)
+{
+ return (*env)->GetIntField(env, fdo, fd_fdID);
+}