[jboss-remoting-commits] JBoss Remoting SVN: r6392 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at 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");
       }
    }