[jbosscache-commits] JBoss Cache SVN: r5376 - core/trunk/src/test/java/org/jboss/cache/invalidation.

[jbosscache-commits at lists.jboss.org]

Author: bstansberry at jboss.com
Date: 2008-02-27 12:37:38 -0500 (Wed, 27 Feb 2008)
New Revision: 5376

Modified:
   core/trunk/src/test/java/org/jboss/cache/invalidation/InvalidationInterceptorTest.java
Log:
[JBCACHE-1297] Add test for invalidation of locally non-existent Fqns

Modified: core/trunk/src/test/java/org/jboss/cache/invalidation/InvalidationInterceptorTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/invalidation/InvalidationInterceptorTest.java	2008-02-27 15:52:37 UTC (rev 5375)
+++ core/trunk/src/test/java/org/jboss/cache/invalidation/InvalidationInterceptorTest.java	2008-02-27 17:37:38 UTC (rev 5376)
@@ -754,7 +754,60 @@
       n = caches.get(0).getNode(fqn);
       assertHasBeenInvalidated(n, "Should have been invalidated");
    }
+   
+   public void testDeleteNonExistentPessimistic() throws Exception
+   {
+      deleteNonExistentTest(false);
+   }
+   
+   public void testDeleteNonExistentOptimistic() throws Exception
+   {
+      deleteNonExistentTest(true);
+   }
+   
+   private void deleteNonExistentTest(boolean optimistic) throws Exception
+   {
+      List<CacheSPI<Object, Object>> caches = new ArrayList<CacheSPI<Object, Object>>();
+      caches.add(createUnstartedCache(optimistic));
+      caches.add(createUnstartedCache(optimistic));
+      cache1 = caches.get(0);
+      cache2 = caches.get(1);
 
+      cache1.start();
+      cache2.start();
+
+      TestingUtil.blockUntilViewsReceived(caches.toArray(new CacheSPI[0]), 5000);
+
+      Fqn fqn = Fqn.fromString("/a/b");
+
+      assertNull("Should be null", cache1.getNode(fqn));
+      assertNull("Should be null", cache2.getNode(fqn));
+
+      cache1.putForExternalRead(fqn, "key", "value");
+      
+      assertEquals("value",cache1.getNode(fqn).get("key"));
+      assertNull("Should be null", cache2.getNode(fqn));
+      
+      // OK, here's the real test
+      TransactionManager tm = cache2.getTransactionManager();
+      tm.begin();
+      try
+      {
+         // Remove a node that doesn't exist in cache2
+         cache2.removeNode(fqn);
+         tm.commit();
+      }
+      catch (Exception e)
+      {
+         String msg = "Unable to remove non-existent node " + fqn;
+         log.error(msg, e);
+         fail(msg + " -- " + e);
+      }
+      
+      assertHasBeenInvalidated(cache1.getNode(fqn), "Should have been invalidated");      
+      assertNull("Should be null", cache2.getNode(fqn));      
+   }
+
    protected CacheSPI<Object, Object> createUnstartedCache(boolean optimistic) throws Exception
    {
       CacheSPI<Object, Object> cache = (CacheSPI<Object, Object>) new DefaultCacheFactory().createCache(false);