infernap12/jdk
1
0
Fork 0
mirror of https://github.com/openjdk/jdk.git synced 2026-05-12 06:29:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

7058832: com/sun/net/httpserver/bugs/B6373555.java failing intermittently

Browse Source 
Reviewed-by: alanb
This commit is contained in:
Michael McMahon 2011-06-28 10:07:41 +01:00
parent 27d3dc1f41
commit f9cb1ca594
1 changed files with 1 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
jdk/test/com/sun/net/httpserver/bugs/B6373555.java
View File

@ -43,14 +43,12 @@ public class B6373555 {
private static int port;
private static volatile boolean error = false;
private static Object lock;
static HttpServer httpServer;
static ExecutorService pool, execs;
static int NUM = 1000;
public static void main(String[] args) throws Exception {
try {
lock = new Object();
if (args.length > 0) {
NUM = Integer.parseInt (args[0]);
}
@ -117,12 +115,6 @@ public class B6373555 {
System.out.println("Doesn't match");
error = true;
}
synchronized(lock) {
++received;
if ((received % 1000) == 0) {
System.out.println("Received="+received);
}
}
}
catch(Exception e) {
e.printStackTrace();
@ -150,18 +142,12 @@ public class B6373555 {
private static HttpServer createHttpServer(ExecutorService execs)
throws Exception {
InetSocketAddress inetAddress = new InetSocketAddress(0);
HttpServer testServer = HttpServer.create(inetAddress, 5);
HttpServer testServer = HttpServer.create(inetAddress, 15);
testServer.setExecutor(execs);
HttpContext context = testServer.createContext("/test");
context.setHandler(new HttpHandler() {
public void handle(HttpExchange msg) {
try {
synchronized(lock) {
++s_received;
if ((s_received % 1000) == 0) {
System.out.println("Received="+s_received);
}
}
String method = msg.getRequestMethod();
if (method.equals("POST")) {
InputStream is = msg.getRequestBody();
@ -172,12 +158,6 @@ public class B6373555 {
System.out.println("****** METHOD not handled ***** "+method);
System.out.println("Received="+s_received);
}
synchronized(lock) {
++sent;
if ((sent % 1000) == 0) {
System.out.println("sent="+sent);
}
}
}
catch(Exception e) {
e.printStackTrace();