stan/jdk-24
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

8298498: sun/net/www/http/KeepAliveCache/B8291637.java fails with "Server exception terminating: java.net.SocketException: Socket closed"

Browse Source 
Reviewed-by: dfuchs, jpai
This commit is contained in:
Daniel Jeliński 2022-12-15 06:55:25 +00:00
parent b9074fa1ed
commit 3ae718725a
1 changed files with 20 additions and 7 deletions

27
test/jdk/sun/net/www/http/KeepAliveCache/B8291637.java

@ -63,18 +63,28 @@ public class B8291637 {
} catch (IOException e) {}
}
static void readRequest(Socket s) throws IOException {
InputStream is = s.getInputStream();
is.read();
while (is.available() > 0)
is.read();
static final byte[] requestEnd = new byte[] {'\r', '\n', '\r', '\n' };
// Read until the end of a HTTP request
static void readOneRequest(InputStream is) throws IOException {
int requestEndCount = 0, r;
while ((r = is.read()) != -1) {
if (r == requestEnd[requestEndCount]) {
requestEndCount++;
if (requestEndCount == 4) {
break;
}
} else {
requestEndCount = 0;
}
}
}
public void run() {
try {
while (true) {
s = serverSocket.accept();
readRequest(s);
readOneRequest(s.getInputStream());
OutputStream os = s.getOutputStream();
String resp = "" +
"HTTP/1.1 200 OK\r\n" +
@ -87,7 +97,10 @@ public class B8291637 {
os.flush();
InputStream is = s.getInputStream();
long l1 = System.currentTimeMillis();
is.read();
int readResult = is.read();
if (readResult != -1) {
System.out.println("Unexpected byte received: " + readResult);
}
long l2 = System.currentTimeMillis();
long diff = (l2 - l1) / 1000;
/*