Page History

    @Override
    public void bsp(
	    BSPPeer<NullWritable, NullWritable, NullWritable, NullWritable, IntWritable> peer)
	    throws IOException, SyncException, InterruptedException {

	if (isMaster) {
	    Random random = new Random();
	    // produces new random integers every second
	    while (true) {
		int newInt = random.nextInt();
                // just send to other not master peers
		peer.send(peer.getAllPeerNames()[Math.abs(newInt % (peer.getNumPeers()-1))+1],
			new IntWritable(newInt));
		System.out.println("Sending " + newInt);
		peer.sync();
		Thread.sleep(1000);
	    }
	} else {
	    // if I'm not the master, then I am one of the slaves!
	    while (true) {
		peer.sync();
		IntWritable msg = null;
		while ((msg = peer.getCurrentMessage()) != null) {
		    System.out.println(msg.get() + " received!");
		}
	    }
	}
    }