[jboss-cvs] JBoss Messaging SVN: r4223 - in trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting: impl and 1 other directory.

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

Author: jmesnil
Date: 2008-05-16 11:54:01 -0400 (Fri, 16 May 2008)
New Revision: 4223

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/TestPacketHandler.java
   trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/SessionTestBase.java
Log:
in testWriteMany(), increased latch's wait time + output the received number of message if the latch is not counted down on time

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/TestPacketHandler.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/TestPacketHandler.java	2008-05-16 15:51:17 UTC (rev 4222)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/TestPacketHandler.java	2008-05-16 15:54:01 UTC (rev 4223)
@@ -37,7 +37,10 @@
    {
      if (latch == null)
         return false;
-     return latch.await(time, timeUnit);
+     boolean receivedAll = latch.await(time, timeUnit);
+     if (!receivedAll)
+        System.out.println("Received only " + latch.getCount() + " packets");
+     return receivedAll;
    }
 
    public void expectMessage(int count)

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/SessionTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/SessionTestBase.java	2008-05-16 15:51:17 UTC (rev 4222)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/remoting/impl/SessionTestBase.java	2008-05-16 15:54:01 UTC (rev 4223)
@@ -94,7 +94,7 @@
          session.write(packets[i]);
       }
 
-      assertTrue(serverPacketHandler.await(10, SECONDS));
+      assertTrue(serverPacketHandler.await(25, SECONDS));
 
       List<Ping> receivedPackets = serverPacketHandler.getPackets();
       assertEquals(MANY_MESSAGES, receivedPackets.size());