simplenb.java

MPI for java for Distributed Programming

package mpi.pt2pt ;

import mpi.*;
import java.util.Arrays;

public class SimpleNB {
    public SimpleNB(String args[]) throws Exception{
	Request sreq = null;
	mpi.Status status = null;
	MPI.Init(args);
		
	int intArray [] = new int[100];       		
	int intReadArray [] = new int[100];
		
	for(int i =0;i < intArray.length;i++) {
	    intArray[i] = i+1;
 	    intReadArray[i] = 3;
	}    	
		
	if(MPI.COMM_WORLD.Rank() == 0) {

 	    sreq = MPI.COMM_WORLD.Issend(intArray,0,100,MPI.INT,1,999);	    
	    status = sreq.Wait();
	   // System.out.println("isend icopmpleted<"+status.source+
	    //		       ">,tag ==<"+status.tag+">");
	    
	} else if (MPI.COMM_WORLD.Rank() == 1) {			
	    sreq = MPI.COMM_WORLD.Irecv(intReadArray,0,100,MPI.INT,0,999);
	    status = sreq.Wait();	    
	   // System.out.println("irecv completed<"+status.source+	    
	 //		       ">,tag ==<"+status.tag+">");

	    if(Arrays.equals(intArray,intReadArray)) {
		//System.out.println("\n#################"+
		//		   "\n <<<<PASSED>>>> "+
		//		   "\n################");
	    } else {
		System.out.println("\n#################"+
				   "\n <<<<FAILED>>>> "+
				   "\n################");			
	    }

	}
	
	MPI.Finalize();
    }
    
    public static void main(String args[]) throws Exception{
    	SimpleNB test = new SimpleNB(args);
    }
}