[jbosscache-commits] JBoss Cache SVN: r5917 - core/branches/2.1.X/src/test/java/org/jboss/cache/buddyreplication.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-05-29 10:49:10 -0400 (Thu, 29 May 2008)
New Revision: 5917

Added:
   core/branches/2.1.X/src/test/java/org/jboss/cache/buddyreplication/EmptyRegionTest.java
Log:
Added test for JBCACHE-1349

Added: core/branches/2.1.X/src/test/java/org/jboss/cache/buddyreplication/EmptyRegionTest.java
===================================================================
--- core/branches/2.1.X/src/test/java/org/jboss/cache/buddyreplication/EmptyRegionTest.java	                        (rev 0)
+++ core/branches/2.1.X/src/test/java/org/jboss/cache/buddyreplication/EmptyRegionTest.java	2008-05-29 14:49:10 UTC (rev 5917)
@@ -0,0 +1,88 @@
+package org.jboss.cache.buddyreplication;
+
+import org.jboss.cache.CacheSPI;
+import org.jboss.cache.DefaultCacheFactory;
+import org.jboss.cache.Fqn;
+import org.jboss.cache.Region;
+import org.jboss.cache.misc.TestingUtil;
+import org.jboss.cache.notifications.annotation.BuddyGroupChanged;
+import org.jboss.cache.notifications.annotation.CacheListener;
+import org.jboss.cache.notifications.event.Event;
+import org.jboss.cache.util.CachePrinter;
+import org.testng.annotations.AfterTest;
+import org.testng.annotations.BeforeTest;
+import org.testng.annotations.Test;
+
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * To test http://jira.jboss.org/jira/browse/JBCACHE-1349
+ *
+ * @author Manik Surtani (<a href="mailto:manik at jboss.org">manik at jboss.org</a>)
+ */
+ at Test(groups = "functional", enabled = false)
+// disabled since there is no intention to fix this in this branch.
+public class EmptyRegionTest extends BuddyReplicationTestsBase
+{
+   CacheSPI c1, c2;
+   Fqn regionFqn = Fqn.fromString("/a/b/c");
+   Fqn region2Fqn = Fqn.fromString("/d/e/f");
+   Region region, region2;
+   CountDownLatch buddyJoinLatch = new CountDownLatch(1);
+
+   @BeforeTest
+   public void setUp() throws Exception
+   {
+      c1 = createCache(1, null, false, false, false);
+      c1.getConfiguration().setUseRegionBasedMarshalling(true);
+      c1.getConfiguration().setFetchInMemoryState(true);
+      c2 = (CacheSPI) new DefaultCacheFactory().createCache(c1.getConfiguration().clone(), false);
+      c1.start();
+      region = c1.getRegion(regionFqn, true);
+      region2 = c1.getRegion(region2Fqn, true);
+      region.registerContextClassLoader(getClass().getClassLoader());
+      c1.put(region2Fqn, "key", "value");
+
+      c2.create();
+      c2.addCacheListener(new BuddyJoinListener());
+   }
+
+   @AfterTest
+   public void tearDown()
+   {
+      TestingUtil.killCaches(c1, c2);
+   }
+
+   public void testEmptyRegion() throws InterruptedException
+   {
+      // region on c1 is empty - with no root node.
+      assert c1.getNode(regionFqn) == null : "Node should not exist";
+      assert c1.getRegion(regionFqn, false) != null : "Region should exist";
+      assert c1.getRegion(regionFqn, false).isActive() : "Region should be active";
+
+      // now start c2
+      c2.start();
+
+      // wait for buddy join notifications to complete.
+      buddyJoinLatch.await(60, TimeUnit.SECONDS);
+
+      // should not throw any exceptions!!
+
+      System.out.println("Cache1 " + CachePrinter.printCacheDetails(c1));
+      System.out.println("Cache2 " + CachePrinter.printCacheDetails(c2));
+
+      // make sure region2 stuff did get transmitted!
+      assert c2.peek(BuddyManager.getBackupFqn(c1.getLocalAddress(), region2Fqn), false) != null : "Region2 state should have transferred!";
+   }
+
+   @CacheListener
+   public class BuddyJoinListener
+   {
+      @BuddyGroupChanged
+      public void buddyJoined(Event e)
+      {
+         buddyJoinLatch.countDown();
+      }
+   }
+}