Author: jason.greene(a)jboss.com
Date: 2009-02-13 10:55:55 -0500 (Fri, 13 Feb 2009)
New Revision: 7691
Modified:
core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java
Log:
Add region test
Modified:
core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java
===================================================================
---
core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java 2009-02-13
15:55:43 UTC (rev 7690)
+++
core/trunk/src/test/java/org/jboss/cache/statetransfer/NonBlockingStateTransferTest.java 2009-02-13
15:55:55 UTC (rev 7691)
@@ -20,6 +20,7 @@
import org.jboss.cache.Cache;
import org.jboss.cache.CacheSPI;
import org.jboss.cache.Fqn;
+import org.jboss.cache.Region;
import org.jboss.cache.UnitTestCacheFactory;
import org.jboss.cache.config.Configuration;
import org.jboss.cache.config.Configuration.CacheMode;
@@ -169,6 +170,51 @@
log.info("testInitialStateTransfer end - " + testCount);
}
+ public void testActivateRegionTransfer() throws Exception
+ {
+ testCount++;
+ log.info("testActivateRegionTransfer start - " + testCount);
+ CacheSPI<Object, Object> cache1 = null, cache2 = null;
+ try
+ {
+ cache1 = createCache("nbst", false);
+ cache1.getConfiguration().setUseRegionBasedMarshalling(true);
+ Region region = cache1.getRegion(Fqn.fromString("/region1"), true);
+ region.registerContextClassLoader(getClass().getClassLoader());
+ cache1.start();
+
+ writeInitialData(cache1);
+
+ cache2 = createCache("nbst", false);
+ cache2.getConfiguration().setUseRegionBasedMarshalling(true);
+ region = cache2.getRegion(Fqn.fromString("/region1"), true);
+ region.registerContextClassLoader(getClass().getClassLoader());
+ cache2.start();
+ region.deactivate();
+
+ // Pause to give caches time to see each other
+ TestingUtil.blockUntilViewsReceived(new CacheSPI[] { cache1, cache2 }, 60000);
+
+ cache1.put("/region1/blah", "blah", "blah");
+ cache1.put("/region1/blah2", "blah", "blah");
+
+ assertEquals(null, cache2.get("/region1/blah", "blah"));
+ assertEquals(null, cache2.get("/region1/blah2", "blah"));
+
+ region.activate();
+
+ assertEquals("blah", cache2.get("/region1/blah",
"blah"));
+ assertEquals("blah", cache2.get("/region1/blah2",
"blah"));
+
+ verifyInitialData(cache2);
+ }
+ finally
+ {
+ TestingUtil.killCaches(cache1, cache2);
+ }
+ log.info("testActivateRegionTransfer end - " + testCount);
+ }
+
public void testConcurrentStateTransfer() throws Exception
{
testCount++;
Show replies by date