Author: jfrederic.clere(a)jboss.com Date: 2009-11-27 11:01:00 -0500 (Fri, 27 Nov 2009) New Revision: 1301 Modified: sandbox/clients/CometTest.java sandbox/webapps/src/CometServletTest1.java Log: Send and test the sessionid... Modified: sandbox/clients/CometTest.java =================================================================== --- sandbox/clients/CometTest.java 2009-11-27 14:36:01 UTC (rev 1300) +++ sandbox/clients/CometTest.java 2009-11-27 16:01:00 UTC (rev 1301) @@ -59,9 +59,21 @@ InputStream is = s.getInputStream(); BufferedReader in = new BufferedReader(new InputStreamReader(is)); + String sess = null; while (true) { writechunk(os, "Testing..."); String res = readchunk(in); + String cursess = readsess(res); + if (sess != null && cursess.compareTo(sess) != 0) { + System.out.println("Session changed: " + cursess + " " + sess); + break; + } + if (sess == null) + sess = cursess; + if (sess == null) { + System.out.println("Can't find Session"); + break; + } } } @@ -95,7 +107,30 @@ offset = recv; } data = new String(buf); - System.out.println("DATA: " + recv + " : " + data); + // System.out.println("DATA: " + recv + " : " + data); return data; } + static String readsess(String in) + { + String data = null; + int start = in.indexOf('['); + if (start != -1) { + int end = in.indexOf(']'); + if (end != -1) { + if (end > start) { + data = in.substring(start+1, end); + } else { + start = in.indexOf('[', end); + if (start != -1) { + end = in.indexOf(']', start); + if (end != -1) { + data = in.substring(start+1, end); + } + } + } + } + } + System.out.println("SESSION: " + data); + return data; + } } Modified: sandbox/webapps/src/CometServletTest1.java =================================================================== --- sandbox/webapps/src/CometServletTest1.java 2009-11-27 14:36:01 UTC (rev 1300) +++ sandbox/webapps/src/CometServletTest1.java 2009-11-27 16:01:00 UTC (rev 1301) @@ -61,17 +61,14 @@ // Using while (true): Not checking if the connection is available to writing immediately // will cause the write to be performed in blocking mode. // boolean b = true; - // while (b) { + String sessid = sess.getId(); while (event.isWriteReady()) { if (count % 100 == 0) { - os.println((count++) + " "); + os.println("[" + sessid + "] " + (count++) + " "); } else { - os.print((count++) + " "); + os.print("[" + sessid + "] " + (count++) + " "); } } - // } - //if (event.ready()) - // os.flush(); break; case READ: ServletInputStream is = event.getHttpServletRequest().getInputStream();