[jboss-remoting-commits] JBoss Remoting SVN: r6290 - remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/accept.
Author: ron.sigal(a)jboss.com
Date: 2011-03-21 12:58:20 -0400 (Mon, 21 Mar 2011)
New Revision: 6290
Modified:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/accept/AcceptThreadPriorityTestCase.java
Log:
JBREM-1277: Test worker threads priority.
Modified:
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/accept/AcceptThreadPriorityTestCase.java
===================================================================
---
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/accept/AcceptThreadPriorityTestCase.java 2011-03-21
16:57:12 UTC (rev 6289)
+++
remoting2/branches/2.x/src/tests/org/jboss/test/remoting/transport/socket/accept/AcceptThreadPriorityTestCase.java 2011-03-21
16:58:20 UTC (rev 6290)
@@ -25,7 +25,10 @@
import java.lang.reflect.Field;
import java.net.InetAddress;
import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
import java.util.Map;
+import java.util.Set;
import javax.management.MBeanServer;
@@ -44,6 +47,7 @@
import org.jboss.remoting.callback.InvokerCallbackHandler;
import org.jboss.remoting.transport.Connector;
import org.jboss.remoting.transport.PortUtil;
+import org.jboss.remoting.transport.socket.LRUPool;
import org.jboss.remoting.transport.socket.SocketServerInvoker;
@@ -126,6 +130,29 @@
}
+ // Test worker threads priority.
+ field = SocketServerInvoker.class.getDeclaredField("clientpool");
+ field.setAccessible(true);
+ LRUPool clientpool = (LRUPool) field.get((SocketServerInvoker)
connector.getServerInvoker());
+ Iterator it = clientpool.getContents().iterator();
+ while (it.hasNext())
+ {
+ Thread t = (Thread) it.next();
+ log.info(t + " priority: " + t.getPriority());
+ assertEquals(Thread.NORM_PRIORITY, t.getPriority());
+ }
+
+ field = SocketServerInvoker.class.getDeclaredField("threadpool");
+ field.setAccessible(true);
+ List threadpool = (List) field.get((SocketServerInvoker)
connector.getServerInvoker());
+ it = threadpool.iterator();
+ while (it.hasNext())
+ {
+ Thread t = (Thread) it.next();
+ log.info(t + " priority: " + t.getPriority());
+ assertEquals(Thread.NORM_PRIORITY, t.getPriority());
+ }
+
client.disconnect();
shutdownServer();
log.info(getName() + " PASSES");
@@ -167,6 +194,29 @@
}
+ // Test worker threads priority.
+ field = SocketServerInvoker.class.getDeclaredField("clientpool");
+ field.setAccessible(true);
+ LRUPool clientpool = (LRUPool) field.get((SocketServerInvoker)
connector.getServerInvoker());
+ Iterator it = clientpool.getContents().iterator();
+ while (it.hasNext())
+ {
+ Thread t = (Thread) it.next();
+ log.info(t + " priority: " + t.getPriority());
+ assertEquals(Thread.NORM_PRIORITY, t.getPriority());
+ }
+
+ field = SocketServerInvoker.class.getDeclaredField("threadpool");
+ field.setAccessible(true);
+ List threadpool = (List) field.get((SocketServerInvoker)
connector.getServerInvoker());
+ it = threadpool.iterator();
+ while (it.hasNext())
+ {
+ Thread t = (Thread) it.next();
+ log.info(t + " priority: " + t.getPriority());
+ assertEquals(Thread.NORM_PRIORITY, t.getPriority());
+ }
+
client.disconnect();
shutdownServer();
log.info(getName() + " PASSES");