--- /dev/null	2018-11-27 03:18:47.532777276 -0500
+++ new/src/jdk.net/linux/native/libextnet/RdmaSocketInputStream.c	2018-11-30 08:33:11.468539222 -0500
@@ -0,0 +1,163 @@
+/*
+ * Copyright (c) 2018, 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 <stdlib.h>
+#include "jvm.h"
+#include "net_util.h"
+#include "rdma_util_md.h"
+#include "jdk_internal_net_rdma_RdmaSocketInputStream.h"
+
+static jfieldID IO_fd_fdID;
+
+/*
+ * Class:     jdk_net_RdmaSocketInputStream
+ * Method:    init
+ * Signature: ()V
+ */
+JNIEXPORT void JNICALL
+Java_jdk_internal_net_rdma_RdmaSocketInputStream_init(JNIEnv *env, jclass cls) {
+    IO_fd_fdID = NET_GetFileDescriptorID(env);
+}
+
+static int RDMA_ReadWithTimeout(JNIEnv *env, int fd, char *bufP, int len,
+        long timeout) {
+    int result = 0;
+    jlong prevNanoTime = JVM_NanoTime(env, 0);
+    jlong nanoTimeout = (jlong) timeout * NET_NSEC_PER_MSEC;
+    while (nanoTimeout >= NET_NSEC_PER_MSEC) {
+        result = RDMA_Timeout(env, fd, nanoTimeout / NET_NSEC_PER_MSEC,
+                prevNanoTime);
+        if (result <= 0) {
+            if (result == 0) {
+                JNU_ThrowByName(env, "java/net/SocketTimeoutException",
+                        "Read timed out");
+            } else if (result == -1) {
+                if (errno == EBADF) {
+                    JNU_ThrowByName(env, "java/net/SocketException",
+                            "Socket closed");
+                } else if (errno == ENOMEM) {
+                    JNU_ThrowOutOfMemoryError
+                            (env, "NET_Timeout native heap allocation failed");
+                } else {
+                    JNU_ThrowByNameWithMessageAndLastError
+                            (env, "java/net/SocketException", "select/poll failed");
+                }
+            }
+            return -1;
+        }
+        result = RDMA_NonBlockingRead(fd, bufP, len);
+        if (result == -1 && ((errno == EAGAIN) || (errno == EWOULDBLOCK))) {
+            jlong newtNanoTime = JVM_NanoTime(env, 0);
+            nanoTimeout -= newtNanoTime - prevNanoTime;
+            if (nanoTimeout >= NET_NSEC_PER_MSEC) {
+                prevNanoTime = newtNanoTime;
+            }
+        } else {
+            break;
+        }
+    }
+    return result;
+}
+
+/*
+ * Class:     jdk_net_RdmaSocketInputStream
+ * Method:    rdmaSocketRead0
+ * Signature: (Ljava/io/FileDescriptor;[BIII)I
+ */
+JNIEXPORT jint JNICALL
+Java_jdk_internal_net_rdma_RdmaSocketInputStream_rdmaSocketRead0(JNIEnv *env,
+        jobject this, jobject fdObj, jbyteArray data,
+        jint off, jint len, jint timeout) {
+    char BUF[MAX_BUFFER_LEN];
+    char *bufP;
+    jint fd, nread;
+
+    if (IS_NULL(fdObj)) {
+        JNU_ThrowByName(env, "java/net/SocketException",
+                        "Socket closed");
+        return -1;
+    }
+    fd = (*env)->GetIntField(env, fdObj, IO_fd_fdID);
+    if (fd == -1) {
+        JNU_ThrowByName(env, "java/net/SocketException", "Socket closed");
+        return -1;
+    }
+
+    if (len > MAX_BUFFER_LEN) {
+        if (len > MAX_HEAP_BUFFER_LEN) {
+            len = MAX_HEAP_BUFFER_LEN;
+        }
+        bufP = (char *)malloc((size_t)len);
+        if (bufP == NULL) {
+            bufP = BUF;
+            len = MAX_BUFFER_LEN;
+        }
+    } else {
+        bufP = BUF;
+    }
+    if (timeout) {
+        nread = RDMA_ReadWithTimeout(env, fd, bufP, len, timeout);
+        if ((*env)->ExceptionCheck(env)) {
+            if (bufP != BUF) {
+                free(bufP);
+            }
+            return nread;
+        }
+    } else {
+        nread = RDMA_Read(fd, bufP, len);
+    }
+
+    if (nread <= 0) {
+        if (nread < 0) {
+
+            switch (errno) {
+                case ECONNRESET:
+                case EPIPE:
+                    JNU_ThrowByName(env, "sun/net/ConnectionResetException",
+                        "Connection reset");
+                    break;
+
+                case EBADF:
+                    JNU_ThrowByName(env, "java/net/SocketException",
+                        "Socket closed");
+                    break;
+
+                case EINTR:
+                     JNU_ThrowByName(env, "java/io/InterruptedIOException",
+                           "Operation interrupted");
+                     break;
+                default:
+                    JNU_ThrowByNameWithMessageAndLastError
+                        (env, "java/net/SocketException", "Read failed");
+            }
+        }
+    } else {
+        (*env)->SetByteArrayRegion(env, data, off, nread, (jbyte *)bufP);
+    }
+
+    if (bufP != BUF) {
+        free(bufP);
+    }
+    return nread;
+}