objtest.java

JAMPACK Grid programming

package JAMPack;

class testy implements Task  {	
	private JGrid grid;
	
	public void runTask(int rank, int size) {
		Comm x = new JComm();
		String s = "Om Namo Narayana";
		String r = "                ";
		System.out.println("Inside sendobj");
		try {
			if (rank == 0) 
			{	 
				r = (String)x.receive((Object)r,1,grid,1);
				System.out.println(r+"Got Object!");			
			}
			else if(rank == 1) {  x.send((Object)s,0,grid,1); }
		}catch(Exception e) { e.printStackTrace();  }
		System.out.println("Handa Bhagyam Jananam");
	}
	
	public void setGrid(JGrid grid) {
		this.grid = grid;
	}
	
}

public class objtest{
	public static void main(String args[]) throws Exception
	{
		//String []hosts = {"192.168.8.9","192.168.8.210","192.168.8.176","192.168.8.249"};
		JScheduler scheduler = JScheduler.getInstance("Hosts.txt");
		System.out.println("How r u 1?");	
		Task task = JBootStrap.getBootStrapedTask("JAMPack.testy");
		System.out.println("How r u 2?");	
		JScheduler.post(task,4);
		System.out.println("How r u 3?");			
	}	
}