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

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

Author: adinn
Date: 2009-06-04 15:01:19 -0400 (Thu, 04 Jun 2009)
New Revision: 26832

Modified:
   labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/TransactionReaper.java
Log:
corrected wakeup calls to wake all threads -- fixes JBTM-564

Modified: labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/TransactionReaper.java
===================================================================
--- labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/TransactionReaper.java	2009-06-04 18:59:50 UTC (rev 26831)
+++ labs/jbosstm/trunk/ArjunaCore/arjuna/classes/com/arjuna/ats/arjuna/coordinator/TransactionReaper.java	2009-06-04 19:01:19 UTC (rev 26832)
@@ -290,7 +290,7 @@
 			synchronized (_workQueue)
 			{
 			    _workQueue.add(e);
-			    _workQueue.notify();
+			    _workQueue.notifyAll();
 			}
 		    }
 		    break;
@@ -547,7 +547,7 @@
 		{
 		    e._worker = Thread.currentThread();
 		    e._status = ReaperElement.CANCEL;
-		    e.notify();
+		    e.notifyAll();
 		}
 
 		// we are now exposed to at most one interrupt from
@@ -624,14 +624,14 @@
 
 			cancelled = false;
 			e._status = ReaperElement.FAIL;
-			e.notify();
+			e.notifyAll();
 		    }
 		    else
 		    {
 			e._status = (cancelled
 				     ? ReaperElement.COMPLETE
 				     : ReaperElement.FAIL);
-			e.notify();
+			e.notifyAll();
 		    }
 		}
 
@@ -787,7 +787,7 @@
 
 			if(_dynamic)
 			{
-				notify(); // force recalc of next wakeup time, taking into account the newly inserted element
+				notifyAll(); // force recalc of next wakeup time, taking into account the newly inserted element
 			}
 
 			return rtn;
@@ -1001,7 +1001,7 @@
 
 	            synchronized (this)
 	            {
-	                notify();
+	                notifyAll();
 	            }
 
 	            try
@@ -1049,7 +1049,7 @@
 
 	        if (_inShutdown && (_transactions.size() == 0))
 	        {
-	            _shutdownLock.notify();
+	            _shutdownLock.notifyAll();
 	        }
 	    }
 	}