You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2011/02/22 05:51:51 UTC
svn commit: r1073227 -
/incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPPeer.java
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;