[jboss-svn-commits] JBL Code SVN: r31294 - labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/abstractrecord.

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

Author: mark.little at jboss.com
Date: 2010-01-29 04:26:25 -0500 (Fri, 29 Jan 2010)
New Revision: 31294

Modified:
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/abstractrecord/RecordTypeManager.java
Log:
https://jira.jboss.org/jira/browse/JBTM-642

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/abstractrecord/RecordTypeManager.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/abstractrecord/RecordTypeManager.java	2010-01-29 02:47:15 UTC (rev 31293)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/abstractrecord/RecordTypeManager.java	2010-01-29 09:26:25 UTC (rev 31294)
@@ -33,6 +33,7 @@
 
 import java.util.ArrayList;
 
+import com.arjuna.ats.arjuna.coordinator.AbstractRecord;
 import com.arjuna.ats.arjuna.coordinator.RecordType;
 
 /**
@@ -42,8 +43,12 @@
 
 public class RecordTypeManager
 {
-    @SuppressWarnings("unchecked")
-    public Class getClass (int type)
+    /*
+     * We can afford to synchronize on the instance because this shouldn't
+     * be a performance problem for recovery.
+     */
+    
+    public synchronized Class<AbstractRecord> getClass (int type)
     {
         /*
          * Stop at first hit.
@@ -58,8 +63,7 @@
         return null;
     }
     
-    @SuppressWarnings("unchecked")
-    public int getType (Class c)
+    public synchronized int getType (Class<AbstractRecord> c)
     {
         for (int i = 0; i < _map.size(); i++)
         {
@@ -70,12 +74,12 @@
         return RecordType.UNTYPED;
     }
     
-    public void add (RecordTypeMap map)
+    public synchronized void add (RecordTypeMap map)
     {
         _map.add(map);
     }
     
-    public void remove (RecordTypeMap map)
+    public synchronized void remove (RecordTypeMap map)
     {
         _map.remove(map);
     }