[jbosscache-commits] JBoss Cache SVN: r4565 - core/trunk/src/test/java/org/jboss/cache/lock/pessimistic.
jbosscache-commits at lists.jboss.org
jbosscache-commits at lists.jboss.org
Mon Oct 8 11:43:54 EDT 2007
Author: manik.surtani at jboss.com
Date: 2007-10-08 11:43:54 -0400 (Mon, 08 Oct 2007)
New Revision: 4565
Removed:
core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockNotReleasedTest.java
Modified:
core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/ConcurrentPutRemoveTest.java
core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockUpgradeTest.java
Log:
Commented on why tests are disabled - linked to JIRA tasks.
Modified: core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/ConcurrentPutRemoveTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/ConcurrentPutRemoveTest.java 2007-10-08 14:56:22 UTC (rev 4564)
+++ core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/ConcurrentPutRemoveTest.java 2007-10-08 15:43:54 UTC (rev 4565)
@@ -15,7 +15,7 @@
import javax.transaction.TransactionManager;
- at Test(groups = {"functional"}, enabled = false)
+ at Test(groups = {"functional"}, enabled = false) // Known issue - See JBCACHE-1164 and JBCACHE-1165
public class ConcurrentPutRemoveTest
{
private TransactionManager tm;
Deleted: core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockNotReleasedTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockNotReleasedTest.java 2007-10-08 14:56:22 UTC (rev 4564)
+++ core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockNotReleasedTest.java 2007-10-08 15:43:54 UTC (rev 4565)
@@ -1,161 +0,0 @@
-package org.jboss.cache.lock.pessimistic;
-
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-
-import javax.transaction.TransactionManager;
-
-
-import org.jboss.cache.CacheException;
-import org.jboss.cache.Node;
-import org.jboss.cache.Cache;
-import org.jboss.cache.DefaultCacheFactory;
-import org.jboss.cache.Fqn;
-import org.jboss.cache.UnversionedNode;
-import org.jboss.cache.CacheImpl;
-import org.jboss.cache.config.ConfigurationComponent;
-import org.jboss.cache.config.Configuration;
-import org.jboss.cache.transaction.DummyTransactionManagerLookup;
-import org.jboss.cache.lock.IsolationLevel;
-import org.testng.annotations.Test;
-import org.testng.annotations.AfterMethod;
-
- at Test(groups = {"functional"})
-public class LockNotReleasedTest
-{
- Random rand = new Random(System.currentTimeMillis());
-
- private TransactionManager tm;
-
- private Cache cache;
-
- private void startTest() throws Exception {
- cache = DefaultCacheFactory.getInstance().createCache(false);
- cache.getConfiguration().setCacheMode(Configuration.CacheMode.LOCAL);
- cache.getConfiguration().setIsolationLevel(IsolationLevel.READ_COMMITTED);
- cache.getConfiguration().setTransactionManagerLookupClass(DummyTransactionManagerLookup.class.getName());
- cache.getConfiguration().setLockAcquisitionTimeout(1000);
- cache.create();
- cache.start();
- tm = cache.getConfiguration().getRuntimeConfig().getTransactionManager();
- }
-
- @AfterMethod(alwaysRun = true)
- public void tearDown() throws Exception {
- cache.stop();
- cache.destroy();
- }
-
-
- public int getNumberOfLocksHeld()
- {
- return numLocks(cache.getRoot());
- }
-
- private int numLocks(Node node)
- {
- UnversionedNode n = (UnversionedNode) node;
- int num = 0;
- Map children;
-
- if (n.getLock().isLocked()){
- num++;
- System.out.println("Node ["+n.getFqn()+"] is locked");
- }
- if ((children = n.getChildrenMapDirect()) != null)
- {
- for (Object o : children.values())
- {
- num += numLocks((Node) o);
- }
- }
- return num;
- }
-
- public void testTransactionStorm() throws Exception {
- startTest();
- List<WorkThread> threads = new ArrayList<WorkThread>();
-// System.out.println(cache.getNumberOfLocksHeld());
- assert 0 == getNumberOfLocksHeld();
- while (true) {
- for (int x = 0; x < 2; x++) {
- WorkThread t = new WorkThread(x == 1);
- threads.add(t);
- t.start();
- }
- for (WorkThread separateThread : threads) {
- separateThread.join();
- if (separateThread.getException() != null) {
- //separateThread.getException().getMessage();
- }
- }
- int locksNum = getNumberOfLocksHeld();
-// System.out.println("Locks="+locksNum);
- // checkpoint
- if (((CacheImpl) cache).getNumberOfLocksHeld()>0){
- System.out.println("ERROR, locks="+locksNum);
- doDomethingOnCache(1);
- }
- assert 0 == locksNum;
- }
-
- }
-
- private class WorkThread extends Thread {
- Exception e = null;
-
- private boolean remove;
-
- public WorkThread(boolean remove) {
- this.remove = remove;
- }
-
- public Exception getException() {
- return e;
- }
-
- public void run() {
- try {
- for (int x = 0; x < 100; x++) {
- tm.begin();
- try {
- doDomethingOnCache(x);
- } finally {
- if (x % 3 == 0) {
- tm.commit();
- } else {
- tm.rollback();
- }
- }
- }
- } catch (Exception e) {
-// System.out.println(e.getMessage());
- this.e = e;
- }
- }
-
- }
-
- private void doDomethingOnCache(int x) throws CacheException, InterruptedException {
- cache.put(Fqn.fromString("/a/b/c/a"), "text1" + x, "");
- cache.removeNode(Fqn.fromString("/q/b/c/d"));
- cache.put(Fqn.fromString("/a/b/c/b"), "text2" + x, "");
- cache.removeNode(Fqn.fromString("/q/b/c/c"));
- cache.put(Fqn.fromString("/a/b/c/c"), "text3" + x, "");
- cache.removeNode(Fqn.fromString("/q/b/c/b"));
- cache.put(Fqn.fromString("/a/b/c/d"), "text4" + x, "");
- cache.removeNode(Fqn.fromString("/q/b/c/a"));
- cache.put(Fqn.fromString("/q/b/c/a"), "text5" + x, "");
- cache.removeNode(Fqn.fromString("/a/b/c/d"));
- cache.put(Fqn.fromString("/q/b/c/b"), "text6" + x, "");
- cache.removeNode(Fqn.fromString("/a/b/c/c"));
- cache.put(Fqn.fromString("/q/b/c/c"), "text7" + x, "");
- cache.removeNode(Fqn.fromString("/a/b/c/b"));
- cache.put(Fqn.fromString("/q/b/c/d"), "text8" + x, "");
- cache.removeNode(Fqn.fromString("/a/b/c/a"));
- }
-
-}
Modified: core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockUpgradeTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockUpgradeTest.java 2007-10-08 14:56:22 UTC (rev 4564)
+++ core/trunk/src/test/java/org/jboss/cache/lock/pessimistic/LockUpgradeTest.java 2007-10-08 15:43:54 UTC (rev 4565)
@@ -23,7 +23,7 @@
*
* @author jhalat
*/
- at Test(groups = {"functional"}, enabled = false)
+ at Test(groups = {"functional"}, enabled = false) // Known failure - see JBCACHE-1166
public class LockUpgradeTest{
private TransactionManager tm;
More information about the jbosscache-commits
mailing list