8304962: sun/net/www/http/KeepAliveCache/B5045306.java: java.lang.Run…

…timeException: Failed: Initial Keep Alive Connection is not being reused Reviewed-by: jpai
openjdk · Mar 28, 2023 · cddaf68 · cddaf68 · openjdk-notifier · Mar 28, 2023
1 parent a06f461
commit cddaf68
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/test/jdk/sun/net/www/http/KeepAliveCache/B5045306.java b/test/jdk/sun/net/www/http/KeepAliveCache/B5045306.java
@@ -31,7 +31,7 @@
 
 import java.io.IOException;
 import java.io.InputStream;
-import java.io.PrintWriter;
+import java.io.OutputStream;
 import java.lang.management.ManagementFactory;
 import java.lang.management.ThreadInfo;
 import java.lang.management.ThreadMXBean;
@@ -40,7 +40,6 @@
 import java.net.InetSocketAddress;
 import java.net.Proxy;
 import java.net.URL;
-import java.nio.charset.Charset;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.Executors;
@@ -175,9 +174,9 @@ public void handle(HttpExchange trans) {
                 byte[] responseBody = new byte[RESPONSE_DATA_LENGTH];
                 for (int i=0; i<responseBody.length; i++)
                     responseBody[i] = 0x41;
-                trans.sendResponseHeaders(200, 0);
-                try(PrintWriter pw = new PrintWriter(trans.getResponseBody(), false, Charset.forName("UTF-8"))) {
-                    pw.print(responseBody);
+                trans.sendResponseHeaders(200, responseBody.length);
+                try (OutputStream os = trans.getResponseBody()) {
+                    os.write(responseBody);
                 }
             } else if (path.equals("/secondCall")) {
                 int port2 = trans.getRemoteAddress().getPort();
@@ -200,10 +199,10 @@ public void handle(HttpExchange trans) {
                     responseBody[i] = 0x41;
                 // override the Content-length header to be greater than the actual response body
                 trans.sendResponseHeaders(200, responseBody.length+1);
-                try(PrintWriter pw = new PrintWriter(trans.getResponseBody(), false, Charset.forName("UTF-8"))) {
-                    pw.print(responseBody);
-                }
+                OutputStream os = trans.getResponseBody();
+                os.write(responseBody);
                 // now close the socket
+                // closing the stream here would throw; close the exchange instead
                 trans.close();
             }
         } catch (Exception e) {