8164147: Improve streaming socket output

Reviewed-by: chegar, igerasim

src/share/classes/java/net/SocketInputStream.java

 /*
- * Copyright (c) 1995, 2013, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 1995, 2016, 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
@@ -155,11 +155,12 @@ class SocketInputStream extends FileInputStream
         }
 
         // bounds check
-        if (length <= 0 || off < 0 || off + length > b.length) {
+        if (length <= 0 || off < 0 || length > b.length - off) {
             if (length == 0) {
                 return 0;
             }
-            throw new ArrayIndexOutOfBoundsException();
+            throw new ArrayIndexOutOfBoundsException("length == " + length
+                    + " off == " + off + " buffer length == " + b.length);
         }
 
         boolean gotReset = false;

src/share/classes/java/net/SocketOutputStream.java

 /*
- * Copyright (c) 1995, 2013, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 1995, 2016, 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
@@ -97,11 +97,13 @@ class SocketOutputStream extends FileOutputStream
      */
     private void socketWrite(byte b[], int off, int len) throws IOException {
 
-        if (len <= 0 || off < 0 || off + len > b.length) {
+
+        if (len <= 0 || off < 0 || len > b.length - off) {
             if (len == 0) {
                 return;
             }
-            throw new ArrayIndexOutOfBoundsException();
+            throw new ArrayIndexOutOfBoundsException("len == " + len
+                    + " off == " + off + " buffer length == " + b.length);
         }
 
         FileDescriptor fd = impl.acquireFD();

src/solaris/native/java/net/SocketOutputStream.c

@@ -103,6 +103,9 @@ Java_java_net_SocketOutputStream_socketWrite0(JNIEnv *env, jobject this,
         int llen = chunkLen;
         (*env)->GetByteArrayRegion(env, data, off, chunkLen, (jbyte *)bufP);
 
+        if ((*env)->ExceptionCheck(env)) {
+            break;
+        } else {
             while(llen > 0) {
                 int n = NET_Send(fd, bufP + loff, llen, 0);
                 if (n > 0) {
@@ -129,6 +132,7 @@ Java_java_net_SocketOutputStream_socketWrite0(JNIEnv *env, jobject this,
             len -= chunkLen;
             off += chunkLen;
         }
+    }
 
     if (bufP != BUF) {
         free(bufP);

src/windows/native/java/net/SocketOutputStream.c

 /*
- * Copyright (c) 1997, 2008, Oracle and/or its affiliates. All rights reserved.
+ * Copyright (c) 1997, 2016, 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
@@ -100,7 +100,9 @@ Java_java_net_SocketOutputStream_socketWrite0(JNIEnv *env, jobject this,
         int retry = 0;
 
         (*env)->GetByteArrayRegion(env, data, off, chunkLen, (jbyte *)bufP);
-
+        if ((*env)->ExceptionCheck(env)) {
+            break;
+        } else {
             while(llen > 0) {
                 int n = send(fd, bufP + loff, llen, 0);
                 if (n > 0) {
@@ -161,6 +163,7 @@ Java_java_net_SocketOutputStream_socketWrite0(JNIEnv *env, jobject this,
             len -= chunkLen;
             off += chunkLen;
         }
+    }
 
     if (bufP != BUF) {
         free(bufP);