[jboss-svn-commits] JBL Code SVN: r36067 - in labs/jbosstm/trunk: ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery and 1 other directories.

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

Author: adinn
Date: 2010-11-25 13:57:03 -0500 (Thu, 25 Nov 2010)
New Revision: 36067

Modified:
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperThread.java
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperWorkerThread.java
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/ExpiredEntryMonitor.java
   labs/jbosstm/trunk/XTS/WSAS/classes/com/arjuna/mwlabs/wsas/activity/ReaperThread.java
Log:
ensured daemon threads have sensible names -- fixes JBTM-816

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperThread.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperThread.java	2010-11-25 17:12:54 UTC (rev 36066)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperThread.java	2010-11-25 18:57:03 UTC (rev 36067)
@@ -50,6 +50,7 @@
 
 public ReaperThread (TransactionReaper arg)
     {
+        super("Transaction Reaper");
 	reaperObject = arg;
 	sleepPeriod = reaperObject.checkingPeriod();
 	_shutdown = false;

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperWorkerThread.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperWorkerThread.java	2010-11-25 17:12:54 UTC (rev 36066)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/coordinator/ReaperWorkerThread.java	2010-11-25 18:57:03 UTC (rev 36067)
@@ -35,9 +35,15 @@
 
 public class ReaperWorkerThread extends Thread
 {
+    /**
+     * counter used to number reaper worker threads
+     */
+    private static int counter = 0;
 
     public ReaperWorkerThread (TransactionReaper arg)
     {
+        // no need for synchronization when doing the increment here as worker threads are not created in parallel.
+        super("Transaction Reaper Worker " + counter++);
         _theReaper = arg;
         _shutdown = false;
     }

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/ExpiredEntryMonitor.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/ExpiredEntryMonitor.java	2010-11-25 17:12:54 UTC (rev 36066)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/ExpiredEntryMonitor.java	2010-11-25 18:57:03 UTC (rev 36067)
@@ -125,6 +125,7 @@
 
   private ExpiredEntryMonitor(boolean skipFirst)
   {
+      super ("Transaction Expired Entry Monitor");
     if (tsLogger.logger.isDebugEnabled()) {
         tsLogger.logger.debug("ExpiredEntryMonitor - constructed");
     }

Modified: labs/jbosstm/trunk/XTS/WSAS/classes/com/arjuna/mwlabs/wsas/activity/ReaperThread.java
===================================================================
--- labs/jbosstm/trunk/XTS/WSAS/classes/com/arjuna/mwlabs/wsas/activity/ReaperThread.java	2010-11-25 17:12:54 UTC (rev 36066)
+++ labs/jbosstm/trunk/XTS/WSAS/classes/com/arjuna/mwlabs/wsas/activity/ReaperThread.java	2010-11-25 18:57:03 UTC (rev 36067)
@@ -46,6 +46,7 @@
 
     public ReaperThread (ActivityReaper arg)
     {
+        super("XTS Activity Reaper");
 	_reaperObject = arg;
 	_sleepPeriod = 0;
 	_shutdown = false;