[hibernate-commits] Hibernate SVN: r14261 - core/trunk/cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2.

[hibernate-commits at lists.jboss.org]

Author: bstansberry at jboss.com
Date: 2007-12-23 09:53:06 -0500 (Sun, 23 Dec 2007)
New Revision: 14261

Modified:
   core/trunk/cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/AbstractGeneralDataRegionTestCase.java
Log:
Update evict/removeAll tests to reflect JBCACHE-1251 problem

Modified: core/trunk/cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/AbstractGeneralDataRegionTestCase.java
===================================================================
--- core/trunk/cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/AbstractGeneralDataRegionTestCase.java	2007-12-23 14:52:02 UTC (rev 14260)
+++ core/trunk/cache-jbosscache2/src/test/java/org/hibernate/test/cache/jbc2/AbstractGeneralDataRegionTestCase.java	2007-12-23 14:53:06 UTC (rev 14261)
@@ -26,6 +26,7 @@
 import java.util.Iterator;
 import java.util.Set;
 
+import org.hibernate.cache.CacheException;
 import org.hibernate.cache.GeneralDataRegion;
 import org.hibernate.cache.QueryResultsRegion;
 import org.hibernate.cache.Region;
@@ -215,6 +216,24 @@
         assertFalse(regionRoot == null);
         assertEquals(0, regionRoot.getChildrenNames().size());
         assertTrue(regionRoot.isResident());
+
+        if (CacheHelper.isClusteredInvalidation(remoteCache)) {
+           // With invalidation, a node that removes the region root cannot reestablish
+           // it on remote nodes, since the only message the propagates is "invalidate".
+           // So, we have to reestablish it ourselves
+           
+           // First, do a get to help test whether a get messes up the optimistic version
+           String msg = "Known issue JBCACHE-1251 -- problem reestablishing invalidated region root";
+           try {
+              assertEquals(null, remoteRegion.get(KEY));
+           }
+           catch (CacheException ce) {
+              log.error(msg, ce);
+              fail(msg + " -- cause: " + ce);
+           }
+           remoteRegion.put(KEY, VALUE1);
+           assertEquals(msg, VALUE1, remoteRegion.get(KEY));
+        }
     
         regionRoot = remoteCache.getRoot().getChild(regionFqn);
         assertFalse(regionRoot == null);