+ * Copyright May 31, 2011 + */ +public class ThreadPoolStackTestCase extends TestCase +{ + private static Logger log =3D Logger.getLogger(ThreadPoolStackTestCase.= class); + = + private static boolean firstTime =3D true; + = + protected String host; + protected int port; + protected String locatorURI; + protected InvokerLocator serverLocator; + protected Connector connector; + protected TestInvocationHandler invocationHandler; + + = + public void setUp() throws Exception + { + if (firstTime) + { + firstTime =3D false; + Logger.getLogger("org.jboss.remoting").setLevel(XLevel.TRACE); + Logger.getLogger("org.jboss.test.remoting").setLevel(Level.INFO); + String pattern =3D "[%d{ABSOLUTE}] [%t] %5p (%F:%L) - %m%n"; + PatternLayout layout =3D new PatternLayout(pattern); + ConsoleAppender consoleAppender =3D new ConsoleAppender(layout); + Logger.getRootLogger().addAppender(consoleAppender); = + } + } + + = + public void tearDown() + { + } + = + = + public void testThreadpoolAsStack() throws Throwable + { + log.info("entering " + getName()); + = + // Start server. + setupServer(); + = + // Get threadpool and clientpool. + Field field =3D SocketServerInvoker.class.getDeclaredField("threadpo= ol"); + field.setAccessible(true); + List threadpool =3D (List) field.get(connector.getServerInvoker()); + field =3D SocketServerInvoker.class.getDeclaredField("clientpool"); + field.setAccessible(true); + LRUPool clientpool =3D (LRUPool) field.get(connector.getServerInvoke= r()); + = + // Create client. + InvokerLocator clientLocator =3D new InvokerLocator(locatorURI); + HashMap clientConfig =3D new HashMap(); + clientConfig.put(InvokerLocator.FORCE_REMOTE, "true"); + addExtraClientConfig(clientConfig); + Client client =3D new Client(clientLocator, clientConfig); + client.connect(); + log.info("client is connected"); + = + Thread.sleep(2000); + = + // Create 5 connections. + for (int i =3D 0; i < 5; i++) + { + client.invokeOneway("4", null, true); + } + + Thread.sleep(2000); // time =3D 4000 + assertEquals(0, threadpool.size()); + assertEquals(5, clientpool.size()); + = + // ServerThreads should be back in threadpool at 6000. + client.disconnect(); + Thread.sleep(4000); // time =3D 8000 + assertEquals(5, threadpool.size()); + assertEquals(0, clientpool.size()); + = + // Wait until IdleTimerTask runs at 10000. + Thread.sleep(4000); // time =3D 12000 + = + for (int i =3D 0; i < 6; i++) + { + client =3D new Client(clientLocator, clientConfig); + client.connect(); + log.info("i =3D " + i); + client.invoke("1"); + client.disconnect(); + } + = + // Time =3D 18000. IdleTimerTask will run at 20000, at which point + // all but one ServerThread should be removed from threadpool. + Thread.sleep(4000); // time =3D 22000 + assertEquals(1, threadpool.size()); + = + shutdownServer(); + log.info(getName() + " PASSES"); + } + = + = + protected String getTransport() + { + return "socket"; + } + = + = + protected void addExtraClientConfig(Map config) {} + protected void addExtraServerConfig(Map config) {} + = + + protected void setupServer() throws Exception + { + host =3D InetAddress.getLocalHost().getHostAddress(); + port =3D PortUtil.findFreePort(host); + locatorURI =3D getTransport() + "://" + host + ":" + port; + String metadata =3D System.getProperty("remoting.metadata"); + if (metadata !=3D null) + { + locatorURI +=3D "/?" + metadata; + } + serverLocator =3D new InvokerLocator(locatorURI); + log.info("Starting remoting server with locator uri of: " + locatorU= RI); + HashMap config =3D new HashMap(); + config.put(InvokerLocator.FORCE_REMOTE, "true"); + config.put("idleTimeout", "10"); + addExtraServerConfig(config); + connector =3D new Connector(serverLocator, config); + connector.create(); + invocationHandler =3D new TestInvocationHandler(); + connector.addInvocationHandler("test", invocationHandler); + connector.start(); + } + = + = + protected void shutdownServer() throws Exception + { + if (connector !=3D null) + connector.stop(); + } + = + = + static class TestInvocationHandler implements ServerInvocationHandler + { + public void addListener(InvokerCallbackHandler callbackHandler) {} + public Object invoke(final InvocationRequest invocation) throws Thro= wable + { + Integer.valueOf((String) invocation.getParameter()).intValue(); + Thread.sleep(Integer.valueOf((String) invocation.getParameter()).= intValue() * 1000); + log.info("parameter: " + invocation.getParameter()); + return invocation.getParameter(); + } + public void removeListener(InvokerCallbackHandler callbackHandler) {} + public void setMBeanServer(MBeanServer server) {} + public void setInvoker(ServerInvoker invoker) {} + } +} \ No newline at end of file Property changes on: remoting2/branches/2.2/src/tests/org/jboss/test/remoti= ng/transport/socket/idle/ThreadPoolStackTestCase.java ___________________________________________________________________ Added: svn:executable + * --===============3274665713417492519==--