[jboss-svn-commits] JBL Code SVN: r28304 - labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery.

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

Author: adinn
Date: 2009-07-22 09:01:33 -0400 (Wed, 22 Jul 2009)
New Revision: 28304

Modified:
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/Listener.java
Log:
added missing syncrhonization to stop test

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/Listener.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/Listener.java	2009-07-22 12:09:21 UTC (rev 28303)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/internal/arjuna/recovery/Listener.java	2009-07-22 13:01:33 UTC (rev 28304)
@@ -120,7 +120,7 @@
 
    public void run()
    {
-      while ( !_stop_listener )
+      while ( !stopRequested() )
       {
          try
          {
@@ -230,6 +230,11 @@
        }
    }
 
+   private synchronized boolean stopRequested()
+   {
+       return _stop_listener;
+   }
+    
    // Socket & port which client(RecoveryManager) connects to.
    private ServerSocket _listener_socket;
    private int          _listener_port;