[jboss-svn-commits] JBL Code SVN: r30849 - labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP05_JBPAPP-3174/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/recovery.

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

Author: vicky.kak at jboss.com
Date: 2009-12-29 02:00:58 -0500 (Tue, 29 Dec 2009)
New Revision: 30849

Added:
   labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP05_JBPAPP-3174/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/recovery/LogMoveTest.java
Log:
Backport JBTM-418 for one off JBPAPP-3174.

Added: labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP05_JBPAPP-3174/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/recovery/LogMoveTest.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP05_JBPAPP-3174/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/recovery/LogMoveTest.java	                        (rev 0)
+++ labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP05_JBPAPP-3174/ArjunaCore/arjuna/tests/classes/com/hp/mwtests/ts/arjuna/recovery/LogMoveTest.java	2009-12-29 07:00:58 UTC (rev 30849)
@@ -0,0 +1,102 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, Red Hat Middleware LLC, and individual contributors 
+ * as indicated by the @author tags. 
+ * See the copyright.txt in the distribution for a
+ * full listing of individual contributors. 
+ * This copyrighted material is made available to anyone wishing to use,
+ * modify, copy, or redistribute it subject to the terms and conditions
+ * of the GNU Lesser General Public License, v. 2.1.
+ * This program is distributed in the hope that it will be useful, but WITHOUT A 
+ * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A 
+ * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
+ * You should have received a copy of the GNU Lesser General Public License,
+ * v.2.1 along with this distribution; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 
+ * MA  02110-1301, USA.
+ * 
+ * (C) 2005-2006,
+ * @author JBoss Inc.
+ */
+/*
+ * Copyright (C) 2004,
+ *
+ * Arjuna Technologies Ltd,
+ * Newcastle upon Tyne,
+ * Tyne and Wear,
+ * UK.
+ *
+ * $Id: RecoveryManagerTest.java 2342 2006-03-30 13:06:17Z  $
+ */
+
+package com.hp.mwtests.ts.arjuna.recovery;
+
+import com.arjuna.ats.arjuna.AtomicAction;
+import com.arjuna.ats.arjuna.common.Environment;
+import com.arjuna.ats.arjuna.common.Uid;
+import com.arjuna.ats.arjuna.coordinator.TxControl;
+import com.arjuna.ats.arjuna.objectstore.ObjectStore;
+import com.arjuna.ats.arjuna.recovery.RecoveryEnvironment;
+import com.arjuna.ats.arjuna.recovery.RecoveryManager;
+import com.arjuna.ats.arjuna.state.OutputObjectState;
+
+public class LogMoveTest
+{
+    public static void main (String[] args)
+    {
+        ObjectStore os = TxControl.getStore();
+        OutputObjectState fluff = new OutputObjectState();
+        Uid kungfuTx = new Uid();
+        boolean outcome = false;
+        final String tn = new AtomicAction().type();
+
+        try
+        {
+            kungfuTx.pack(fluff);
+
+            System.err.println("Creating dummy log");
+            
+            os.write_committed(kungfuTx, tn, fluff);
+
+            if (os.currentState(kungfuTx, tn) == ObjectStore.OS_COMMITTED)
+            {
+                System.err.println("Wrote dummy transaction "+kungfuTx);
+
+                System.setProperty(RecoveryEnvironment.EXPIRY_SCAN_INTERVAL, "1");
+                System.setProperty(Environment.PERIODIC_RECOVERY_PERIOD, "8000000");
+                
+                RecoveryManager manager = RecoveryManager
+                        .manager(RecoveryManager.DIRECT_MANAGEMENT);
+
+                manager.scan();
+                
+                try
+                {
+                   Thread.sleep(3600000);
+                }
+                catch (final Exception ex)
+                {                  
+                }
+                
+                manager.scan();
+                
+                if (os.currentState(kungfuTx, tn) == ObjectStore.OS_COMMITTED)
+                    System.err.println("Transaction log not moved!");
+                else
+                {
+                    System.err.println("Transaction log moved!");
+                    
+                    outcome = true;
+                }
+            }
+            else
+                System.err.println("State is not committed!");
+        }
+        catch (final Exception ex)
+        {
+            ex.printStackTrace();
+        }
+
+        System.err.println("Test outcome: " + (outcome ? "passed" : "failed"));
+    }
+}