You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by Apache Wiki <wi...@apache.org> on 2011/02/16 00:56:44 UTC

[Hama Wiki] Update of "PiEstimator" by edwardyoon

Dear Wiki user,

You have subscribed to a wiki page or wiki category on "Hama Wiki" for change notification.

The "PiEstimator" page has been changed by edwardyoon.
http://wiki.apache.org/hama/PiEstimator?action=diff&rev1=10&rev2=11

--------------------------------------------------

        bspPeer.send(masterTask, estimate);
        bspPeer.sync();
  
-       double pi = 0.0;
-       int numPeers = bspPeer.getNumCurrentMessages();
-       BSPMessage received;
-       while ((received = bspPeer.getCurrentMessage()) != null) {
-         pi += Bytes.toDouble(received.getData());
-       }
  
        if (bspPeer.getPeerName().equals(masterTask)) {
+         double pi = 0.0;
+         int numPeers = bspPeer.getNumCurrentMessages();
+         BSPMessage received;
+         while ((received = bspPeer.getCurrentMessage()) != null) {
+           pi += Bytes.toDouble(received.getData());
+         }
+ 
          pi = pi / numPeers;
          writeResult(pi);
        }