[jboss-remoting-commits] JBoss Remoting SVN: r4285 - remoting2/branches/2.2/src/tests/org/jboss/test/remoting/callback/asynch.

Author: ron.sigal(a)jboss.com Date: 2008-06-10 21:16:26 -0400 (Tue, 10 Jun 2008) New Revision: 4285 Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClientRoot.java Log: JBREM-995: Extended wait times. Modified: remoting2/branches/2.2/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClientRoot.java =================================================================== --- remoting2/branches/2.2/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClientRoot.java 2008-06-10 05:48:55 UTC (rev 4284) +++ remoting2/branches/2.2/src/tests/org/jboss/test/remoting/callback/asynch/AsynchCallbackTestClientRoot.java 2008-06-11 01:16:26 UTC (rev 4285) @@ -51,6 +51,7 @@ public void testSynchronousCallback() throws Throwable { + log.info("entering " + getName()); String transport = getTransport(); String host = InetAddress.getLocalHost().getHostName(); int port = AsynchCallbackTestServerRoot.port; @@ -71,7 +72,7 @@ Boolean done = (Boolean) client.invoke(AsynchCallbackTestServerRoot.GET_STATUS); log.info("done 1: " + done); assertFalse(done.booleanValue()); - Thread.sleep(2000); + Thread.sleep(8000); done = (Boolean) client.invoke(AsynchCallbackTestServerRoot.GET_STATUS); log.info("done 2: " + done); assertTrue(done.booleanValue()); @@ -81,11 +82,13 @@ log.info("disconnecting"); client.disconnect(); log.info("disconnected"); + log.info(getName() + " PASSES"); } public void testASynchronousCallbackClientSide() throws Throwable { + log.info("entering " + getName()); String transport = getTransport(); String host = InetAddress.getLocalHost().getHostName(); int port = AsynchCallbackTestServerRoot.port; @@ -101,7 +104,7 @@ client.addListener(callbackHandler, null, null, true); log.info("client added callback handler"); client.invokeOneway(AsynchCallbackTestServerRoot.ASYNCHRONOUS_CLIENT_SIDE_TEST); - Thread.sleep(500); + Thread.sleep(4000); // Should have returned. Boolean done = (Boolean) client.invoke(AsynchCallbackTestServerRoot.GET_STATUS); assertTrue(done.booleanValue()); @@ -109,11 +112,13 @@ client.invoke(AsynchCallbackTestServerRoot.RESET); client.removeListener(callbackHandler); client.disconnect(); + log.info(getName() + " PASSES"); } public void testASynchronousCallbackServerSide() throws Throwable { + log.info("entering " + getName()); String transport = getTransport(); String host = InetAddress.getLocalHost().getHostName(); int port = AsynchCallbackTestServerRoot.port; @@ -129,11 +134,17 @@ client.addListener(callbackHandler, null, null, true); log.info("client added callback handler"); client.invokeOneway(AsynchCallbackTestServerRoot.ASYNCHRONOUS_SERVER_SIDE_TEST); - Thread.sleep(500); + Thread.sleep(4000); + // Should have returned. Boolean done = (Boolean) client.invoke(AsynchCallbackTestServerRoot.GET_STATUS); assertTrue(done.booleanValue()); assertTrue(callbackHandler.receivedCallback); + Thread.sleep(5000); + + // Callback should be handled. + assertTrue(callbackHandler.done); + String threadCount = (String) client.invoke(AsynchCallbackTestServerRoot.GET_THREAD_COUNT); assertEquals(AsynchCallbackTestServerRoot.THREAD_COUNT, threadCount); String queueSize = (String) client.invoke(AsynchCallbackTestServerRoot.GET_QUEUE_SIZE); @@ -141,6 +152,7 @@ client.invoke(AsynchCallbackTestServerRoot.RESET); client.removeListener(callbackHandler); client.disconnect(); + log.info(getName() + " PASSES"); } @@ -154,6 +166,7 @@ static class SampleCallbackHandler implements InvokerCallbackHandler { boolean receivedCallback; + boolean done; public void handleCallback(Callback callback) throws HandleCallbackException { @@ -161,11 +174,12 @@ receivedCallback = true; try { - Thread.sleep(2000); + Thread.sleep(5000); } catch (InterruptedException e) { } + done = true; } } }