[jboss-cvs] JBossCache/tests/functional/org/jboss/cache/transaction ...
Brian Stansberry
brian.stansberry at jboss.com
Wed Nov 22 16:38:13 EST 2006
User: bstansberry
Date: 06/11/22 16:38:13
Modified: tests/functional/org/jboss/cache/transaction Tag:
JBossCache_1_3_0_SP3_JBCACHE-873
IsolationLevelReadCommittedTest.java
Added: tests/functional/org/jboss/cache/transaction Tag:
JBossCache_1_3_0_SP3_JBCACHE-873
IsolationLevelSerializableTest.java
Log:
[JBCACHE-873] Test JBCACHE-871 Fix
Revision Changes Path
No revision
No revision
1.5.14.1 +110 -9 JBossCache/tests/functional/org/jboss/cache/transaction/IsolationLevelReadCommittedTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: IsolationLevelReadCommittedTest.java
===================================================================
RCS file: /cvsroot/jboss/JBossCache/tests/functional/org/jboss/cache/transaction/IsolationLevelReadCommittedTest.java,v
retrieving revision 1.5
retrieving revision 1.5.14.1
diff -u -b -r1.5 -r1.5.14.1
--- IsolationLevelReadCommittedTest.java 22 Feb 2006 17:04:45 -0000 1.5
+++ IsolationLevelReadCommittedTest.java 22 Nov 2006 21:38:13 -0000 1.5.14.1
@@ -11,6 +11,7 @@
import org.jboss.cache.Fqn;
import org.jboss.cache.TreeCache;
import org.jboss.cache.lock.IsolationLevel;
+import org.jboss.cache.lock.TimeoutException;
import javax.transaction.NotSupportedException;
import javax.transaction.SystemException;
@@ -23,7 +24,7 @@
*
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
*
- * @version $Id: IsolationLevelReadCommittedTest.java,v 1.5 2006/02/22 17:04:45 msurtani Exp $
+ * @version $Id: IsolationLevelReadCommittedTest.java,v 1.5.14.1 2006/11/22 21:38:13 bstansberry Exp $
*/
public class IsolationLevelReadCommittedTest extends TestCase
@@ -31,6 +32,7 @@
private TreeCache cache = null;
private final Fqn FQN = Fqn.fromString("/a/b/c");
+ private final Fqn PARENT_FQN = Fqn.fromString("/a/b");
private final String KEY = "key";
private final String VALUE = "value";
@@ -53,6 +55,7 @@
cache.setCacheMode(TreeCache.LOCAL);
cache.setIsolationLevel(IsolationLevel.READ_COMMITTED);
cache.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+ cache.setLockAcquisitionTimeout(1000);
cache.startService();
}
@@ -105,10 +108,17 @@
// yet commit or roll back.
readerCanRead.acquire();
+ try
+ {
// I shouldn't be able to see the "dirty" value
assertEquals("thread w/ read lock " +
"can see subsequent uncommitted changes",
VALUE, cache.get(FQN, KEY));
+ }
+ catch (TimeoutException good)
+ {
+ // this is what should happen due to writer's WL
+ }
// let the writer know it can rollback
writerCanRollback.release();
@@ -210,6 +220,99 @@
}
}
+ /**
+ * Test creates a cache node then starts a separate thread that removes
+ * the node inside a tx. Test confirms that the removal cannot be seen
+ * before the test commits.
+ *
+ * @throws Exception
+ */
+ public void testNodeRemoved() throws Exception
+ {
+ final Latch readerCanRead = new Latch();
+ final Latch readerDone = new Latch();
+ final Latch writerDone = new Latch();
+
+ cache.put(FQN, KEY, VALUE);
+ assertEquals(VALUE, cache.get(FQN, KEY));
+
+ // start a writer thread and a transaction
+
+ Thread writerThread = new Thread(new Runnable()
+ {
+ public void run()
+ {
+ try
+ {
+ Transaction tx = startTransaction();
+
+ // change VALUE in a transaction
+ cache.remove(PARENT_FQN);
+
+ // notify the reading thread
+ readerCanRead.release();
+
+ readerDone.acquire();
+
+ tx.commit();
+ }
+ catch (AssertionFailedError e)
+ {
+ writerError = e;
+ }
+ catch(Throwable t)
+ {
+ t.printStackTrace();
+ writerFailed = true;
+ }
+ finally
+ {
+ System.out.println("writer thread exits");
+ readerCanRead.release();
+ writerDone.release();
+ }
+ }
+ }, "WRITER");
+ writerThread.start();
+
+ try
+ {
+ // wait until the writer thread changes the value in a transaction,
+ // but it did not yet commit or roll back.
+ readerCanRead.acquire();
+
+ // I shouldn't be able to see the "dirty" value
+ assertEquals("2nd thread cannot see uncommitted changes",
+ VALUE, cache.get(FQN, KEY));
+ }
+ catch (TimeoutException t)
+ {
+ // ignore, this is good
+ }
+ finally
+ {
+ System.out.println("reader thread exits");
+ readerDone.release();
+ }
+
+ // wait for the writer to finish
+ writerDone.acquire();
+
+ assertNull("Node was removed", cache.get(FQN));
+
+ // If any assertion failed, throw on the AssertionFailedError
+
+ if (writerError != null)
+ {
+ throw writerError;
+ }
+
+ if (writerFailed)
+ {
+ fail("The writer thread exited incorrectly. Watch the log for previous stack traces");
+ }
+ }
+
private Transaction startTransaction() throws SystemException, NotSupportedException
{
DummyTransactionManager mgr=DummyTransactionManager.getInstance();
@@ -217,8 +320,6 @@
return mgr.getTransaction();
}
-
-
public static Test suite() {
return new TestSuite(IsolationLevelReadCommittedTest.class);
No revision
No revision
1.2.2.2 +179 -0 JBossCache/tests/functional/org/jboss/cache/transaction/IsolationLevelSerializableTest.java
(In the diff below, changes in quantity of whitespace are not shown.)
Index: IsolationLevelSerializableTest.java
===================================================================
RCS file: IsolationLevelSerializableTest.java
diff -N IsolationLevelSerializableTest.java
--- /dev/null 1 Jan 1970 00:00:00 -0000
+++ IsolationLevelSerializableTest.java 22 Nov 2006 21:38:13 -0000 1.2.2.2
@@ -0,0 +1,179 @@
+package org.jboss.cache.transaction;
+
+
+
+import EDU.oswego.cs.dl.util.concurrent.Latch;
+import junit.framework.AssertionFailedError;
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+import org.jboss.cache.DummyTransactionManagerLookup;
+import org.jboss.cache.Fqn;
+import org.jboss.cache.TreeCache;
+import org.jboss.cache.lock.IsolationLevel;
+import org.jboss.cache.lock.TimeoutException;
+
+import javax.transaction.NotSupportedException;
+import javax.transaction.SystemException;
+import javax.transaction.Transaction;
+
+
+
+/**
+ * Tests READ_COMMITED isolation level.
+ *
+ * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
+ *
+ * @version $Id: IsolationLevelSerializableTest.java,v 1.2.2.2 2006/11/22 21:38:13 bstansberry Exp $
+ */
+
+public class IsolationLevelSerializableTest extends TestCase
+{
+
+ private TreeCache cache = null;
+ private final Fqn FQN = Fqn.fromString("/a");
+ private final String KEY = "key";
+ private final String VALUE = "value";
+
+ private volatile boolean writerFailed;
+ private volatile boolean readerFailed;
+ private volatile AssertionFailedError writerError;
+ private volatile AssertionFailedError readerError;
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+
+ writerFailed = false;
+ readerFailed = false;
+
+ writerError = null;
+ readerError = null;
+
+ cache = new TreeCache();
+ cache.setCacheMode(TreeCache.LOCAL);
+ cache.setIsolationLevel(IsolationLevel.SERIALIZABLE);
+ cache.setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
+ cache.setLockAcquisitionTimeout(1000);
+ cache.startService();
+ }
+
+
+ protected void tearDown() throws Exception
+ {
+ super.tearDown();
+
+ cache.stopService();
+ cache.destroyService();
+ cache=null;
+ }
+
+ /**
+ * Test creates a cache node then starts a separate thread that removes
+ * the node inside a tx. Test confirms that the removal cannot be seen
+ * before the test commits.
+ *
+ * @throws Exception
+ */
+ public void testNodeRemoved() throws Exception
+ {
+ final Latch readerCanRead = new Latch();
+ final Latch readerDone = new Latch();
+ final Latch writerDone = new Latch();
+
+ cache.put(FQN, KEY, VALUE);
+ assertEquals(VALUE, cache.get(FQN, KEY));
+
+ // start a writer thread and a transaction
+
+ Thread writerThread = new Thread(new Runnable()
+ {
+ public void run()
+ {
+ try
+ {
+ Transaction tx = startTransaction();
+
+ // change VALUE in a transaction
+ cache.remove(FQN);
+
+ // notify the reading thread
+ readerCanRead.release();
+
+ readerDone.acquire();
+
+ tx.commit();
+ }
+ catch (AssertionFailedError e)
+ {
+ writerError = e;
+ }
+ catch(Throwable t)
+ {
+ t.printStackTrace();
+ writerFailed = true;
+ }
+ finally
+ {
+ System.out.println("writer thread exits");
+ readerCanRead.release();
+ writerDone.release();
+ }
+ }
+ }, "WRITER");
+ writerThread.start();
+
+ try
+ {
+ // wait until the writer thread changes the value in a transaction,
+ // but it did not yet commit or roll back.
+ readerCanRead.acquire();
+
+ // I shouldn't be able to see the "dirty" value
+ assertEquals("2nd thread cannot see uncommitted changes",
+ VALUE, cache.get(FQN, KEY));
+ }
+ catch (TimeoutException t)
+ {
+ // ignore, this is good
+ }
+ finally
+ {
+ System.out.println("reader thread exits");
+ readerDone.release();
+ }
+
+ // wait for the writer to finish
+ writerDone.acquire();
+
+ assertNull("Node was removed", cache.get(FQN));
+
+ // If any assertion failed, throw on the AssertionFailedError
+
+ if (writerError != null)
+ {
+ throw writerError;
+ }
+
+ if (writerFailed)
+ {
+ fail("The writer thread exited incorrectly. Watch the log for previous stack traces");
+ }
+
+ }
+
+ private Transaction startTransaction() throws SystemException, NotSupportedException
+ {
+ DummyTransactionManager mgr=DummyTransactionManager.getInstance();
+ mgr.begin();
+ return mgr.getTransaction();
+ }
+
+ public static Test suite() {
+
+ return new TestSuite(IsolationLevelSerializableTest.class);
+
+ }
+
+}
+
More information about the jboss-cvs-commits
mailing list