incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1076219 - /incubator/hama/trunk/src/java/org/apache/hama/bsp/GroomServer.java
Date Wed, 02 Mar 2011 13:49:22 GMT
Author: edwardyoon
Date: Wed Mar  2 13:49:21 2011
New Revision: 1076219

URL: http://svn.apache.org/viewvc?rev=1076219&view=rev
Log:
Trivial changes

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

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/GroomServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/GroomServer.java?rev=1076219&r1=1076218&r2=1076219&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/GroomServer.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/GroomServer.java Wed Mar  2 13:49:21
2011
@@ -311,11 +311,11 @@ public class GroomServer implements Runn
   public State offerService() throws Exception {
     while (running && !shuttingDown) {
       try {
-        Thread.sleep(REPORT_INTERVAL);
 
         // Reports to a BSPMaster
         for (Map.Entry<TaskAttemptID, TaskInProgress> e : runningTasks
             .entrySet()) {
+          Thread.sleep(REPORT_INTERVAL);
           TaskInProgress tip = e.getValue();
           TaskStatus taskStatus = tip.getStatus();
           taskStatus.setProgress(bspPeer.getSuperstepCount());
@@ -331,6 +331,7 @@ public class GroomServer implements Runn
           doReport(taskStatus);
         }
 
+        Thread.sleep(REPORT_INTERVAL);
       } catch (InterruptedException ie) {
       }
 



Mime
View raw message