[jboss-svn-commits] JBL Code SVN: r27612 - labs/jbosstm/trunk/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/objectstore.

[jboss-svn-commits at lists.jboss.org]

Author: mark.little at jboss.com
Date: 2009-07-06 07:51:24 -0400 (Mon, 06 Jul 2009)
New Revision: 27612

Modified:
   labs/jbosstm/trunk/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/objectstore/LogStressTest.java
Log:
https://jira.jboss.org/jira/browse/JBTM-576

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/objectstore/LogStressTest.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/objectstore/LogStressTest.java	2009-07-06 11:44:33 UTC (rev 27611)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/objectstore/LogStressTest.java	2009-07-06 11:51:24 UTC (rev 27612)
@@ -43,6 +43,19 @@
 import org.junit.Test;
 import static org.junit.Assert.*;
 
+/*
+ * Define our own transaction type to avoid conflicts
+ * with other tests.
+ */
+
+class MyAtomicAction extends AtomicAction
+{
+    public String type ()
+    {
+        return "/StateManager/BasicAction/TwoPhaseCoordinator/AtomicAction/MyAtomicAction";
+    }
+}
+
 class StressWorker extends Thread
 {
     public StressWorker(int iters, int thread)
@@ -55,7 +68,7 @@
     {
         for (int i = 0; i < _iters; i++) {
             try {
-                AtomicAction A = new AtomicAction();
+                MyAtomicAction A = new MyAtomicAction();
 
                 A.begin();
 
@@ -85,6 +98,7 @@
 
         System.setProperty(Environment.COMMIT_ONE_PHASE, "NO");
         System.setProperty(Environment.OBJECTSTORE_TYPE, ArjunaNames.Implementation_ObjectStore_ActionLogStore().stringForm());
+        
         System.setProperty(Environment.TRANSACTION_LOG_PURGE_TIME, "10000");
 
         StressWorker[] workers = new StressWorker[threads];
@@ -107,7 +121,7 @@
         boolean passed = false;
 
         try {
-            TxControl.getStore().allObjUids(new AtomicAction().type(), ios, ObjectStore.OS_UNKNOWN);
+            TxControl.getStore().allObjUids(new MyAtomicAction().type(), ios, ObjectStore.OS_UNKNOWN);
 
             Uid tempUid = new Uid(Uid.nullUid());