Author: jfrederic.clere(a)jboss.com Date: 2009-11-27 12:11:52 -0500 (Fri, 27 Nov 2009) New Revision: 1302 Modified: sandbox/clients/CometTest.java Log: Run the loop for a random number of time and start 150 clients... Modified: sandbox/clients/CometTest.java =================================================================== --- sandbox/clients/CometTest.java 2009-11-27 16:01:00 UTC (rev 1301) +++ sandbox/clients/CometTest.java 2009-11-27 17:11:52 UTC (rev 1302) @@ -24,10 +24,15 @@ import java.io.OutputStream; import java.net.Socket; import java.net.URL; +import java.util.Random; -public class CometTest +public class CometTest extends Thread { + String strURL = "http://localhost:8080/comet/CometServletTest1"; + Exception ex = null; + int max = 0; + boolean failed = true; /** * * Usage: @@ -37,15 +42,50 @@ * Argument 0 is a URL to a web server * */ - public static void main(String[] args) throws Exception + public static void main(String[] args) throws Exception + { + if (args.length != 1) { - if (args.length != 1) - { - System.err.println("missing command line arguments"); - System.exit(1); - } + System.err.println("missing command line arguments"); + System.exit(1); + } - String strURL = args[0]; + String strURL = args[0]; + CometTest comet[] = new CometTest[150]; + for (int i=0; i<comet.length; i++) { + comet[i] = new CometTest(strURL, 1000); + } + for (int i=0; i<comet.length; i++) { + comet[i].start(); + } + for (int i=0; i<comet.length; i++) { + comet[i].join(); + if (comet[i].failed) { + System.err.println("Test failed! " + comet[i].ex); + System.exit(1); + } + } + } + public CometTest(String strURL, int max) + { + this.strURL = strURL; + Random generator = new Random(); + this.max = generator.nextInt( max ); + } + /** + * Run the test + */ + + public void run() + { + try { + runit(); + } catch (Exception ex) { + this.ex = ex; + } + } + public void runit()throws Exception + { URL u = new URL(strURL); Socket s = new Socket(u.getHost(), u.getPort()); @@ -60,7 +100,7 @@ InputStream is = s.getInputStream(); BufferedReader in = new BufferedReader(new InputStreamReader(is)); String sess = null; - while (true) { + while (max>0) { writechunk(os, "Testing..."); String res = readchunk(in); String cursess = readsess(res); @@ -74,7 +114,10 @@ System.out.println("Can't find Session"); break; } + max--; } + if (max == 0) + failed = false; } /* Write chunk a "" is the last chunk */ @@ -91,7 +134,7 @@ try { data = in.readLine(); len = Integer.valueOf(data, 16); - System.out.println("Got: " + len); + // System.out.println("Got: " + len); } catch (Exception ex) { System.out.println("Ex: " + ex); } @@ -130,7 +173,7 @@ } } } - System.out.println("SESSION: " + data); + // System.out.println("SESSION: " + data); return data; } }