[infinispan-commits] Infinispan SVN: r712 - trunk/core/src/test/java/org/infinispan/distribution/rehash.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-08-20 19:04:13 -0400 (Thu, 20 Aug 2009)
New Revision: 712

Modified:
   trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashTestBase.java
Log:
Sucky timeout

Modified: trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashTestBase.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashTestBase.java	2009-08-20 23:02:39 UTC (rev 711)
+++ trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashTestBase.java	2009-08-20 23:04:13 UTC (rev 712)
@@ -41,6 +41,10 @@
     */
    abstract void waitForRehashCompletion();
 
+   void additionalWait() {
+      TestingUtil.sleepThread(1000);
+   }
+
    protected int locateJoiner(Address joinerAddress) {
       for (Cache c : Arrays.asList(c1, c2, c3, c4)) {
          DefaultConsistentHash dch = getDefaultConsistentHash(c, SECONDS.toMillis(480));
@@ -81,10 +85,9 @@
 
       waitForRehashCompletion();
       log.info("Rehash complete");
-
+      additionalWait();
       int i = 0;
       for (MagicKey key : keys) assertOnAllCachesAndOwnership(key, "v" + ++i);
-
       assertProperConsistentHashOnAllCaches();
    }
 
@@ -132,6 +135,7 @@
       th.join();
 
       log.info("Rehash complete");
+      additionalWait();
 
       assertOnAllCachesAndOwnership(keys.get(0), "transactionally_replaced");
       assertOnAllCachesAndOwnership(keys.get(1), "v" + 2);
@@ -176,6 +180,7 @@
       for (Updater u : updaters) u.join();
 
       waitForRehashCompletion();
+      additionalWait();
 
       log.info("Rehash complete");