[hornetq-commits] JBoss hornetq SVN: r11230 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-08-26 02:41:31 -0400 (Fri, 26 Aug 2011)
New Revision: 11230

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
Log:
I'm having issues with versioning of Topic Members. Until I implement a better algorithm I will keep a sleep before each server is started on the testsuite

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-08-26 03:53:29 UTC (rev 11229)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterTestBase.java	2011-08-26 06:41:31 UTC (rev 11230)
@@ -88,7 +88,7 @@
 
    private static final long WAIT_TIMEOUT = 10000;
    
-   private static final long TIMEOUT_START_SERVER = 1000;
+   private static final long TIMEOUT_START_SERVER = 500;
 
    @Override
    protected void setUp() throws Exception
@@ -2023,10 +2023,11 @@
       for (int node : nodes)
       {
          log.info("#test start node " + node);
-         if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER)
-         {
-            Thread.sleep(TIMEOUT_START_SERVER);
-         }
+//         if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER)
+//         {
+//            Thread.sleep(TIMEOUT_START_SERVER);
+//         }
+         Thread.sleep(TIMEOUT_START_SERVER);
          timeStarts[node] = System.currentTimeMillis();
          
          servers[node].setIdentity("server " + node);
@@ -2067,11 +2068,14 @@
          {
             try
             {
-               if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER)
-               {
-                  // We can't stop and start a node too fast (faster than what the Topology could realize about this
-                  Thread.sleep(TIMEOUT_START_SERVER);
-               }
+//               if (System.currentTimeMillis() - timeStarts[node] < TIMEOUT_START_SERVER)
+//               {
+//                  // We can't stop and start a node too fast (faster than what the Topology could realize about this
+//                  Thread.sleep(TIMEOUT_START_SERVER);
+//               }
+               
+               Thread.sleep(TIMEOUT_START_SERVER);
+
                timeStarts[node] = System.currentTimeMillis();
                
                ClusterTestBase.log.info("stopping server " + node);