openjdk/jdk8u
1
0
Fork 0
mirror of https://github.com/openjdk/jdk8u.git synced 2025-12-10 10:44:16 -06:00
Code Issues Packages Projects Releases Wiki Activity

8041924: [TESTBUG] sun/net/www/http/ChunkedOutputStream/checkError.java fails on some systems

Browse Source 
Reviewed-by: phh
Backport-of: 6461c37c9a106cbf07731ef414873ca9dbe5c698
This commit is contained in:
SendaoYan 2025-08-28 08:38:22 +00:00 committed by Severin Gehwolf
parent f362183b50
commit 1d7e10189f
2 changed files with 131 additions and 251 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

131
jdk/test/sun/net/www/http/ChunkedOutputStream/CheckError.java Normal file
View File

@ -0,0 +1,131 @@
/*
* Copyright (c) 2004, 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
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* 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.
*/
/**
* @test
* @bug 5054016
* @summary get the failure immediately when writing individual chunks over socket fail
*/
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.URL;
import static java.lang.System.out;
public class CheckError {
static int BUFFER_SIZE = 8192; // 8k
static int TOTAL_BYTES = 1 * 1024 * 1024; // 1M
public static void main(String[] args) throws Exception {
HTTPServer server = new HTTPServer();
server.start();
int port = server.getPort();
out.println("Server listening on " + port);
URL url = new URL("http://localhost:" + port);
HttpURLConnection conn = (HttpURLConnection)url.openConnection();
conn.setRequestMethod("POST");
conn.setDoOutput(true);
conn.setChunkedStreamingMode(1024);
out.println("sending " + TOTAL_BYTES + " bytes");
int byteAtOnce;
int sendingBytes = TOTAL_BYTES;
byte[] buffer = getBuffer(BUFFER_SIZE);
try (OutputStream toServer = conn.getOutputStream()) {
while (sendingBytes > 0) {
if (sendingBytes > BUFFER_SIZE) {
byteAtOnce = BUFFER_SIZE;
} else {
byteAtOnce = sendingBytes;
}
toServer.write(buffer, 0, byteAtOnce);
sendingBytes -= byteAtOnce;
out.print((TOTAL_BYTES - sendingBytes) + " was sent. ");
toServer.flush();
// gives the server thread time to read, and eventually close;
Thread.sleep(500);
}
} catch (IOException expected) {
// Expected IOException due to server.close()
out.println("PASSED. Caught expected: " + expected);
return;
}
// Expected IOException not received. FAIL
throw new RuntimeException("Failed: Expected IOException not received");
}
static byte[] getBuffer(int size) {
byte[] buffer = new byte[size];
for (int i = 0; i < size; i++)
buffer[i] = (byte)i;
return buffer;
}
static class HTTPServer extends Thread {
final ServerSocket serverSocket;
HTTPServer() throws IOException {
serverSocket = new ServerSocket(0);
}
int getPort() {
return serverSocket.getLocalPort();
}
public void run() {
try (Socket client = serverSocket.accept()) {
InputStream in = client.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
String line;
do {
line = reader.readLine();
out.println("Server: " + line);
} while (line != null && line.length() > 0);
System.out.println("Server: receiving some data");
// just read some data, then close the connection
in.read(new byte[1024]);
in.close();
client.close();
out.println("Server closed socket");
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

251
jdk/test/sun/net/www/http/ChunkedOutputStream/checkError.java
View File

@ -1,251 +0,0 @@
/*
* Copyright (c) 2004, 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.
*
* 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.
*/
/**
* @test
* @bug 5054016
* @run main/othervm/timeout=300 checkError
* @summary get the failure immediately when writing individual chunks over socket fail
*/
import java.io.*;
import java.net.*;
import java.util.StringTokenizer;
public class checkError {
static final int TEST_PASSED = 95;
static final int TEST_FAILED = 97;
static int testStatus = TEST_PASSED;
static String serverName = "localhost";
static int bufferSize = 8192; // 8k
static int totalBytes = 1048576; // 1M
static int j = 0;
static public Object threadStarting = new Object();
static public Object threadWaiting = new Object();
public static void main(String[] args) throws Exception {
HttpURLConnection conn = null;
OutputStream toServer = null;
byte[] buffer = null;
HTTPServer server = null;
synchronized(threadWaiting) {
System.out.println("HTTP-client>Starting default Http-server");
synchronized(threadStarting) {
server = new HTTPServer();
server.start();
try {
System.out.println("waiting server to be start");
threadStarting.wait();
} catch (InterruptedException e) {
}
}
int port = server.getPort();
URL url = new URL("http://" + serverName + ":" + port);
conn = (HttpURLConnection )url.openConnection();
conn.setRequestMethod("POST");
conn.setDoOutput(true);
System.out.println("assigning 1024 to the chunk length");
conn.setChunkedStreamingMode(1024);
conn.connect();
toServer = conn.getOutputStream();
buffer = getThickBuffer(bufferSize);
System.out.println("sending " + totalBytes + " bytes");
}
int byteAtOnce = 0;
int sendingBytes = totalBytes;
try {
while (sendingBytes > 0) {
if (sendingBytes > bufferSize) {
byteAtOnce = bufferSize;
} else {
byteAtOnce = sendingBytes;
}
toServer.write(buffer, 0, byteAtOnce);
sendingBytes -= byteAtOnce;
// System.out.println((totalBytes - sendingBytes) + " was sent");
toServer.flush();
}
} catch (OutOfMemoryError e) {
e.printStackTrace();
System.out.println("***ERR***> UNEXPECTED error: " + e);
testStatus = TEST_FAILED;
testExit();
} catch (IOException e) {
// e.printStackTrace();
// this is the expected IOException
// due to server.close()
testStatus = TEST_PASSED;
testExit();
} finally {
toServer.close();
}
// we have not received the expected IOException
// test fail
testStatus = TEST_FAILED;
testExit();
}
static void testExit() {
if (testStatus == TEST_FAILED) {
throw new RuntimeException("Test Failed: haven't received the expected IOException");
} else {
System.out.println("TEST PASSED");
}
System.exit(testStatus);
}
static byte[] getThickBuffer(int size) {
byte[] buffer = new byte[size];
for (int i = 0; i < size; i++) {
if (j > 9)
j = 0;
String s = Integer.toString(j);
buffer[i] = (byte )s.charAt(0);
j++;
}
return buffer;
}
}
class HTTPServer extends Thread {
static volatile boolean isCompleted;
Socket client;
ServerSocket serverSocket;
int getPort() {
return serverSocket.getLocalPort();
}
public void run() {
synchronized(checkError.threadStarting) {
try {
serverSocket = new ServerSocket(0, 100);
} catch (Exception e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
}
checkError.threadStarting.notify();
}
try {
client = serverSocket.accept();
} catch (Exception e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
}
System.out.println("Server started");
BufferedReader in = null;
PrintStream out = null;
InputStreamReader reader = null;
String version = null;
String line;
String method;
synchronized(checkError.threadWaiting) {
try {
reader = new InputStreamReader(client.getInputStream());
in = new BufferedReader(reader);
line = in.readLine();
} catch (Exception e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
}
StringTokenizer st = new StringTokenizer(line);
method = st.nextToken();
String fileName = st.nextToken();
// save version for replies
if (st.hasMoreTokens()) version = st.nextToken();
System.out.println("HTTP version: " + version);
}
try {
while (line != null && line.length() > 0) {
line = in.readLine();
System.out.println(line);
}
} catch (IOException e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
}
if (method.equals("POST")) {
System.out.println("receiving data");
byte[] buf = new byte[1024];
try {
//reading bytes until chunk whose size is zero,
// see 19.4.6 Introduction of Transfer-Encoding in RFC2616
int count = 0;
while (count <=5) {
count++;
in.readLine();
}
System.out.println("Server socket is closed");
in.close();
client.close();
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
} catch (OutOfMemoryError e) {
e.printStackTrace();
checkError.testStatus = checkError.TEST_FAILED;
return;
}
}
}
}