[jboss-remoting-commits] JBoss Remoting SVN: r6392 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/versioning/identity.
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");
}
}