[jbosscache-commits] JBoss Cache SVN: r5971 - core/branches/1.4.X/tests/functional/org/jboss/cache/transaction.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-06-11 05:30:03 -0400 (Wed, 11 Jun 2008)
New Revision: 5971

Added:
   core/branches/1.4.X/tests/functional/org/jboss/cache/transaction/IsolationLevelReadUncommitedTest.java
Log:
added a new unit test

Added: core/branches/1.4.X/tests/functional/org/jboss/cache/transaction/IsolationLevelReadUncommitedTest.java
===================================================================
--- core/branches/1.4.X/tests/functional/org/jboss/cache/transaction/IsolationLevelReadUncommitedTest.java	                        (rev 0)
+++ core/branches/1.4.X/tests/functional/org/jboss/cache/transaction/IsolationLevelReadUncommitedTest.java	2008-06-11 09:30:03 UTC (rev 5971)
@@ -0,0 +1,102 @@
+package org.jboss.cache.transaction;
+
+import EDU.oswego.cs.dl.util.concurrent.Latch;
+
+import javax.transaction.Transaction;
+import javax.transaction.SystemException;
+import javax.transaction.NotSupportedException;
+
+import org.jboss.cache.TreeCache;
+import org.jboss.cache.DummyTransactionManagerLookup;
+import org.jboss.cache.lock.IsolationLevel;
+import junit.framework.TestCase;
+
+/**
+ * @author Mircea.Markus at jboss.com
+ * @since 2.2
+ */
+public class IsolationLevelReadUncommitedTest extends TestCase {
+
+   private TreeCache cache = null;
+
+   private Transaction startTransaction() throws SystemException, NotSupportedException
+   {
+      DummyTransactionManager mgr = DummyTransactionManager.getInstance();
+      mgr.begin();
+      return mgr.getTransaction();
+   }
+
+   protected void setUp() throws Exception
+   {
+      super.setUp();
+      cache = new TreeCache();
+      cache.setCacheMode(TreeCache.LOCAL);
+      cache.setIsolationLevel(IsolationLevel.READ_UNCOMMITTED);
+      cache.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+      cache.setLockAcquisitionTimeout(1000);
+      cache.startService();
+   }
+
+
+   protected void tearDown() throws Exception
+   {
+      super.tearDown();
+
+      cache.stopService();
+      cache.destroyService();
+      cache = null;
+   }
+
+   /**
+    * Tests following scenario:
+    * tx1 starts and create /a/b/c
+    * tx2 starts and adds a key value under /a/b
+    * tx2 commits
+    * tx1 rollabcks
+    *
+    * the key/value added bu tx should be in the cache still, and should not be affected by tx1 rollback.
+    */
+   public void testInterlacedTx() throws Exception
+   {
+      Transaction tx = startTransaction();
+      cache.put("/a/b/c", "key", "value");
+      System.out.println("Tx1 just added /a/b/c");
+      System.out.println(cache.printLockInfo());
+      Latch latch = new Latch();
+      TxThread txThread = new TxThread(cache, latch);
+      txThread.start();
+      latch.acquire();
+      tx.rollback();
+      System.out.println("Tx1 just rolled back");
+      System.out.println(cache.printLockInfo());
+
+      assertNotNull(cache.get("/a/b"));
+      assertNotNull(cache.get("/a/b", "newKey"));
+   }
+
+   private class TxThread extends Thread
+   {
+      TreeCache cache;
+      Latch latch;
+
+      private TxThread(TreeCache cache, Latch latch) {
+         this.cache = cache;
+         this.latch = latch;
+      }
+
+      public void run() {
+         try {
+            Transaction tx = startTransaction();
+            cache.put("/a/b","newKey","newValue");
+            System.out.println("Tx2 just updated /a/b");
+            System.out.println(cache.printLockInfo());
+            tx.commit();
+            System.out.println("Tx2 commited");
+            latch.release();
+         } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException();
+         }
+      }
+   }
+}
\ No newline at end of file