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

[infinispan-commits at lists.jboss.org]

Author: galder.zamarreno at jboss.com
Date: 2010-05-11 12:33:06 -0400 (Tue, 11 May 2010)
New Revision: 1783

Added:
   trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashCompletedOnJoinTest.java
Log:
[ISPN-425] (Stale data read when L1 invalidation happens while UnionConsistentHash is in use) Forgot to add unit test.

Added: trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashCompletedOnJoinTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashCompletedOnJoinTest.java	                        (rev 0)
+++ trunk/core/src/test/java/org/infinispan/distribution/rehash/RehashCompletedOnJoinTest.java	2010-05-11 16:33:06 UTC (rev 1783)
@@ -0,0 +1,44 @@
+package org.infinispan.distribution.rehash;
+
+import org.infinispan.Cache;
+import org.infinispan.distribution.BaseDistFunctionalTest;
+import org.infinispan.distribution.DistributionManager;
+import org.infinispan.manager.CacheManager;
+import org.testng.annotations.Test;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * // TODO: Document this
+ *
+ * @author Galder Zamarreño
+ * @since // TODO
+ */
+ at Test(groups = "functional", testName = "distribution.rehash.WorkDuringJoinTest")
+public class RehashCompletedOnJoinTest extends BaseDistFunctionalTest {
+
+   public RehashCompletedOnJoinTest() {
+      INIT_CLUSTER_SIZE = 2;
+      performRehashing = true;
+   }
+
+   public void testJoinComplete() {
+      List<MagicKey> keys = new ArrayList<MagicKey>(Arrays.asList(
+            new MagicKey(c1, "k1"), new MagicKey(c2, "k2"),
+            new MagicKey(c1, "k3"), new MagicKey(c2, "k4")
+      ));
+
+      int i = 0;
+      for (Cache<Object, String> c : caches) c.put(keys.get(i++), "v" + i);
+      log.info("Initialized with keys {0}", keys);
+      
+      CacheManager joinerManager = addClusterEnabledCacheManager();
+      joinerManager.defineConfiguration(cacheName, configuration);
+      Cache joiner = joinerManager.getCache(cacheName);
+      DistributionManager dmi = joiner.getAdvancedCache().getDistributionManager();
+      assert dmi.isJoinComplete() == true;
+   }
+
+}