incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r950911 - in /incubator/hama/trunk/src: java/org/apache/hama/bsp/BSPInterface.java test/org/apache/hama/bsp/UserInterface.java
Date Thu, 03 Jun 2010 08:20:58 GMT
Author: edwardyoon
Date: Thu Jun  3 08:20:58 2010
New Revision: 950911

URL: http://svn.apache.org/viewvc?rev=950911&view=rev
Log:
Trivial change of parameter name

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPInterface.java
    incubator/hama/trunk/src/test/org/apache/hama/bsp/UserInterface.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPInterface.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPInterface.java?rev=950911&r1=950910&r2=950911&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPInterface.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/BSPInterface.java Thu Jun  3 08:20:58
2010
@@ -33,12 +33,12 @@ public interface BSPInterface {
    * Applications can use the {@link org.apache.hama.bsp.BSPPeer} to handle the
    * communication and synchronization between processors.
    * 
-   * @param peer
+   * @param bspPeer
    * @throws IOException
    * @throws KeeperException
    * @throws InterruptedException
    */
-  public void bsp(BSPPeer peer) throws IOException, KeeperException,
+  public void bsp(BSPPeer bspPeer) throws IOException, KeeperException,
       InterruptedException;
 
 }

Modified: incubator/hama/trunk/src/test/org/apache/hama/bsp/UserInterface.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/test/org/apache/hama/bsp/UserInterface.java?rev=950911&r1=950910&r2=950911&view=diff
==============================================================================
--- incubator/hama/trunk/src/test/org/apache/hama/bsp/UserInterface.java (original)
+++ incubator/hama/trunk/src/test/org/apache/hama/bsp/UserInterface.java Thu Jun  3 08:20:58
2010
@@ -47,7 +47,7 @@ public class UserInterface extends HamaC
       super(conf);
     }
 
-    public void bsp(BSPPeer peer) throws IOException, KeeperException,
+    public void bsp(BSPPeer bspPeer) throws IOException, KeeperException,
         InterruptedException {
       int in = 0, out = 0;
       for (int i = 0; i < iterations; i++) {
@@ -63,17 +63,17 @@ public class UserInterface extends HamaC
       byte[] myData = Bytes.toBytes(4.0 * (double) in / (double) iterations);
       BSPMessage estimate = new BSPMessage(tagName, myData);
 
-      peer.send(new InetSocketAddress("localhost", 30000), estimate);
-      peer.sync();
+      bspPeer.send(new InetSocketAddress("localhost", 30000), estimate);
+      bspPeer.sync();
 
       double pi = 0.0;
       BSPMessage received;
-      while ((received = peer.getCurrentMessage()) != null) {
+      while ((received = bspPeer.getCurrentMessage()) != null) {
         pi = (pi + Bytes.toDouble(received.getData())) / 2;
       }
 
       if (pi != 0.0)
-        System.out.println(peer.getServerName() + ": " + pi);
+        System.out.println(bspPeer.getServerName() + ": " + pi);
     }
   }
 



Mime
View raw message