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/12/21 10:00:40 UTC
svn commit: r1221650 -
/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
Author: edwardyoon
Date: Wed Dec 21 09:00:39 2011
New Revision: 1221650
URL: http://svn.apache.org/viewvc?rev=1221650&view=rev
Log:
Trivial changes
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java?rev=1221650&r1=1221649&r2=1221650&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java Wed Dec 21 09:00:39 2011
@@ -150,12 +150,12 @@ public class GroomServer implements Runn
int prevPort = Constants.DEFAULT_PEER_PORT;
for (GroomServerAction action : actions) {
- Task t = ((LaunchTaskAction) action).getTask();
-
- prevPort = BSPNetUtils.getNextAvailable(prevPort);
- assignedPeerNames.put(t.getTaskID(), prevPort);
-
if (action instanceof LaunchTaskAction) {
+ Task t = ((LaunchTaskAction) action).getTask();
+
+ prevPort = BSPNetUtils.getNextAvailable(prevPort);
+ assignedPeerNames.put(t.getTaskID(), prevPort);
+
startNewTask((LaunchTaskAction) action);
} else {