sametag.java

MPI for java for Distributed Programming

/*
 * File         : SendRecv.java
 * Author       : Sang Lim
 * Revision     : $Revision: 1.1.1.1 $
 * Updated      : $Date: 2005/03/19 16:06:39 $
 */
import mpjdev.*;
import mpjbuf.*;
import java.io.*;

public class SameTag {
  public static void main(String[] args) throws Exception {
    Comm.init(args);
    Buffer wb = new Buffer(16);
    int id = Comm.WORLD.id();
    int size = Comm.WORLD.size();
    int tag = 99;

    if (id == 0) {

      for (int z = 0; z < 100; z++) {
        int[] fArray0 = new int[2];
        for (int i = 0; i < fArray0.length; i++)
          fArray0[i] = i + z;
        wb.putSectionHeader(Buffer.INT);
        wb.write(fArray0, 0, fArray0.length);
        wb.commit();
        Comm.WORLD.send(wb, 1, tag);
        wb.clear();
      }
      System.out.println("Written all messages");

    }
    else if (id == 1) {
      System.out.println("sleeping");
      try {
        Thread.currentThread().sleep(5000);
      }
      catch (Exception e) {}
      System.out.println("sleeping");
      for (int z = 0; z < 100; z++) {
        Comm.WORLD.recv(wb, 0, tag);
        wb.commit();
        int[] rArray0 = new int[2];
        for (int i = 0; i < rArray0.length; i++)
          rArray0[i] = -1;
        int numEls = wb.getSectionHeader(Buffer.INT);
        wb.read(rArray0, 0, rArray0.length);

        for (int i = 0; i < rArray0.length; i++) {
          if (rArray0[i] != i + z) {
            System.out.println("z " + z);
            System.out.println("Its all fucked up");
            System.exit(0);
          }
        }
        wb.clear();
        System.out.print(" P<" + z + ">");
      }

    }

    Comm.WORLD.nbarrier();
    Comm.finish();
  }
}