Author: ron.sigal(a)jboss.com Date: 2011-08-14 23:17:37 -0400 (Sun, 14 Aug 2011) New Revision: 6392 Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java Log: JBREM-1299: Various changes. Modified: remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java =================================================================== --- remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java 2011-08-13 02:37:48 UTC (rev 6391) +++ remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity/ServerIdentityVersionTestServer.java 2011-08-15 03:17:37 UTC (rev 6392) @@ -24,6 +24,7 @@ import java.lang.reflect.Field; import java.net.InetAddress; import java.util.HashMap; +import java.util.HashSet; import java.util.Iterator; import java.util.Map; import java.util.Set; @@ -111,6 +112,7 @@ Thread.sleep(15000); // Bounce server. + log.info("SHUTTING DOWN SERVER"); shutdownServer(); log.info("SHUT DOWN SERVER"); setupServer(true); @@ -148,7 +150,7 @@ if (useLeasing) { locatorURI += "&" + InvokerLocator.CLIENT_LEASE + "=true"; - locatorURI += "&" + InvokerLocator.CLIENT_LEASE_PERIOD + "=20000"; + locatorURI += "&" + "leasePeriod=20000"; } String metadata = System.getProperty("remoting.metadata"); if (metadata != null) @@ -186,16 +188,20 @@ socketWrapperField.setAccessible(true); LRUPool clientpool = (LRUPool) clientpoolField.get(invoker); Set threads = clientpool.getContents(); + threads = new HashSet(threads); + log.info("NUMBER of SERVER THREADS: " + threads.size()); Iterator it = threads.iterator(); while (it.hasNext()) { ServerThread t = (ServerThread) it.next(); + log.info("CLOSING " + t); ServerSocketWrapper socketWrapper = (ServerSocketWrapper) socketWrapperField.get(t); socketWrapper.close(); - log.info(this + " closed " + socketWrapper); + log.info(this + " CLOSED " + socketWrapper); } - + log.info("CLOSED SERVER THREADS"); connector.stop(); + log.info("STOPPED CONNECTOR"); } }