objtest.java

JAMPACK Grid programming

package JAMPack;

class testy implements Task  {	
	public void runTask(int rank, int size, JGrid grid) {
		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 class objtest{
	public static void main(String args[]) throws Exception
	{
		String []hosts = {"192.168.11.83","192.168.8.141","192.168.8.113","192.168.8.228"};
		JScheduler scheduler = JScheduler.getInstance(hosts);
		Task task = JBootStrap.getBootStrapedTask("JAMPack.testy");
		JScheduler.post(task,2);			
	}	
}