[jbosscache-commits] JBoss Cache SVN: r6456 - in core/trunk/src/test/java/org/jboss/cache/api/mvcc: read_committed and 1 other directories.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-07-31 04:29:26 -0400 (Thu, 31 Jul 2008)
New Revision: 6456

Modified:
   core/trunk/src/test/java/org/jboss/cache/api/mvcc/LockTestBase.java
   core/trunk/src/test/java/org/jboss/cache/api/mvcc/read_committed/ReadCommittedLockParentTest.java
   core/trunk/src/test/java/org/jboss/cache/api/mvcc/repeatable_read/RepeatableReadLockParentTest.java
Log:
Test for concurrent remove and insert

Modified: core/trunk/src/test/java/org/jboss/cache/api/mvcc/LockTestBase.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/api/mvcc/LockTestBase.java	2008-07-31 00:06:35 UTC (rev 6455)
+++ core/trunk/src/test/java/org/jboss/cache/api/mvcc/LockTestBase.java	2008-07-31 08:29:26 UTC (rev 6456)
@@ -624,4 +624,56 @@
       assert "v2".equals(cache.get(AB, "k"));
       assert "v".equals(cache.get(ABC, "k"));
    }
+
+   public void testConcurrentInsertRemove1() throws Exception
+   {
+      cache.put(AB, "k", "v");
+
+      tm.begin();
+      cache.put(ABC, "k", "v");
+      assert "v".equals(cache.get(AB, "k"));
+      assert "v".equals(cache.get(ABC, "k"));
+      Transaction t1 = tm.suspend();
+
+      tm.begin();
+      cache.removeNode(AB);
+      assert null == cache.get(ABC, "k");
+      assert null == cache.get(AB, "k");
+      tm.commit();
+
+      assert null == cache.get(ABC, "k");
+      assert null == cache.get(AB, "k");
+
+      tm.resume(t1);
+      t1.commit();
+
+      assert null == cache.get(ABC, "k");
+      assert null == cache.get(AB, "k");
+   }
+
+   public void testConcurrentInsertRemove2() throws Exception
+   {
+      cache.put(AB, "k", "v");
+
+      tm.begin();
+      cache.removeNode(AB);
+      assert null == cache.get(ABC, "k");
+      assert null == cache.get(AB, "k");
+      Transaction t1 = tm.suspend();
+
+      tm.begin();
+      assert "v".equals(cache.get(AB, "k"));
+      cache.put(ABC, "k", "v");
+      assert "v".equals(cache.get(ABC, "k"));
+      tm.commit();
+
+      assert "v".equals(cache.get(AB, "k"));
+      assert "v".equals(cache.get(ABC, "k"));
+
+      tm.resume(t1);
+      t1.commit();
+
+      assert null == cache.get(ABC, "k");
+      assert null == cache.get(AB, "k");
+   }
 }

Modified: core/trunk/src/test/java/org/jboss/cache/api/mvcc/read_committed/ReadCommittedLockParentTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/api/mvcc/read_committed/ReadCommittedLockParentTest.java	2008-07-31 00:06:35 UTC (rev 6455)
+++ core/trunk/src/test/java/org/jboss/cache/api/mvcc/read_committed/ReadCommittedLockParentTest.java	2008-07-31 08:29:26 UTC (rev 6456)
@@ -13,18 +13,30 @@
    @Override
    public void testOverwritingOnInsert()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
 
    @Override
    public void testOverwritingOnInsert2()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
 
    @Override
    public void testOverwritingOnInsert3()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
+
+   @Override
+   public void testConcurrentInsertRemove1()
+   {
+      // no op since a locked parent makes this test irrelevant.
+   }
+
+   @Override
+   public void testConcurrentInsertRemove2()
+   {
+      // no op since a locked parent makes this test irrelevant.
+   }
 }

Modified: core/trunk/src/test/java/org/jboss/cache/api/mvcc/repeatable_read/RepeatableReadLockParentTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/api/mvcc/repeatable_read/RepeatableReadLockParentTest.java	2008-07-31 00:06:35 UTC (rev 6455)
+++ core/trunk/src/test/java/org/jboss/cache/api/mvcc/repeatable_read/RepeatableReadLockParentTest.java	2008-07-31 08:29:26 UTC (rev 6456)
@@ -13,20 +13,32 @@
    @Override
    public void testOverwritingOnInsert()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
 
    @Override
    public void testOverwritingOnInsert2()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
 
    @Override
    public void testOverwritingOnInsert3()
    {
-      // no op since a locked parent makes tis test irrelevant.
+      // no op since a locked parent makes this test irrelevant.
    }
+
+   @Override
+   public void testConcurrentInsertRemove1()
+   {
+      // no op since a locked parent makes this test irrelevant.
+   }
+
+   @Override
+   public void testConcurrentInsertRemove2()
+   {
+      // no op since a locked parent makes this test irrelevant.
+   }
 }