[jboss-svn-commits] JBL Code SVN: r25323 - labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP02_JBPAPP-1683/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore.

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

Author: tkimura at redhat.com
Date: 2009-02-18 08:27:45 -0500 (Wed, 18 Feb 2009)
New Revision: 25323

Modified:
   labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP02_JBPAPP-1683/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java
Log:
[JBPAPP-1683] Port fix from revision 25203.

Modified: labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP02_JBPAPP-1683/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java
===================================================================
--- labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP02_JBPAPP-1683/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java	2009-02-18 13:15:57 UTC (rev 25322)
+++ labs/jbosstm/branches/JBOSSTS_4_2_3_SP5_CP02_JBPAPP-1683/ArjunaJTA/jta/classes/com/arjuna/ats/internal/jta/transaction/arjunacore/BaseTransaction.java	2009-02-18 13:27:45 UTC (rev 25323)
@@ -84,8 +84,7 @@
 			}
 		}
 
-
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = (Integer)_timeouts.get();
 		int v = 0; // if not set then assume 0. What else can we do?
 
 		if (value != null)
@@ -216,13 +215,13 @@
 	{
 		if (seconds >= 0)
 		{
-			_timeouts.put(ThreadUtil.getThreadId(), new Integer(seconds));
+		    _timeouts.set(new Integer(seconds));
 		}
 	}
 
 	public int getTimeout() throws javax.transaction.SystemException
 	{
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = (Integer)_timeouts.get();
 
 		if (value != null)
 		{
@@ -265,7 +264,7 @@
 			throw new javax.transaction.SystemException(e2.toString());
 		}
 		
-		Integer value = (Integer) _timeouts.get(ThreadUtil.getThreadId());
+		Integer value = (Integer)_timeouts.get();
 		int v = 0; // if not set then assume 0. What else can we do?
 		
 		if (value != null)
@@ -300,7 +299,7 @@
 
 		if (theTransaction == null)
 			return;
-		else
+		else 
 		{
 			if ((theTransaction.getStatus() != javax.transaction.Status.STATUS_NO_TRANSACTION)
 					&& !_supportSubtransactions)
@@ -314,7 +313,7 @@
 
 	private static boolean _supportSubtransactions = false;
 
-	private static Hashtable _timeouts = new Hashtable();
+	private static ThreadLocal _timeouts = new ThreadLocal(); // Integers
 
 	static
 	{