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);
}