[jbossweb-commits] JBossWeb SVN: r1301 - in sandbox: webapps/src and 1 other directory.
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();