incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1073227 - /incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java
Date Tue, 22 Feb 2011 04:51:51 GMT
Author: edwardyoon
Date: Tue Feb 22 04:51:50 2011
New Revision: 1073227

URL: http://svn.apache.org/viewvc?rev=1073227&view=rev
Log:
Removing thread.sleep(). It's my fault.

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java?rev=1073227&r1=1073226&r2=1073227&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java Tue Feb 22 04:51:50 2011
@@ -203,7 +203,6 @@ public class BSPPeer implements Watcher,
 
         if (list.size() < jobConf.getNumBspTask()) {
           mutex.wait();
-          Thread.sleep(10);
         } else {
           return true;
         }
@@ -219,7 +218,6 @@ public class BSPPeer implements Watcher,
         List<String> list = zk.getChildren(bspRoot, true);
         if (list.size() > 0) {
           mutex.wait();
-          Thread.sleep(10);
         } else {
           LOG.debug("[" + getPeerName() + "] leave from the leaveBarrier");
           return true;



Mime
View raw message