package com.ibm.user.examples;

import com.ibm.dthreads.DThread;
import com.ibm.dthreads.DistributedExecutionManager;
import com.ibm.dthreads.SPMDDistributedExecutionManager;
import com.ibm.dthreads.DThreadExecutionContext;


public class ASPPartTest {

public static void main(String args[]) 
{
	   long start,end;
	   start=System.currentTimeMillis();
	//int totalthreads=5;
	//int noofvertices =1000;
	if(args.length<2)
	{
		System.out.println("Command Usage : ");
		System.out.println("java FloydPartTest  no_of_threads no_of_vertices");
		System.out.println("Please Refer README.htm");
		System.exit(0); 
	}

	int totalthreads=Integer.parseInt(args[0]);
	int noofvertices=Integer.parseInt(args[1]);
	   boolean debugMode=true;
	   //int numberofNodes=1000;
	   /*int[][] data=new int[numberofNodes][numberofNodes];
	   int totalthreads=1;

	   int size=data.length/totalthreads;
	   int extra=(data.length%totalthreads);
	for(int i=0;i<numberofNodes;i++)
	{
	for(int j=0;j<numberofNodes;j++)
	{
	   data[i][j]=99999;
		if(i==j) data[i][j]=0;
	
	}
	}		
	
	data[0][1]=2;
	data[0][2]=5;
	data[1][2]=7;
	data[1][3]=1;
	data[1][5]=8;
	data[2][3]=4;
	data[3][4]=3;
	data[4][2]=2;
	data[4][5]=3;
	data[5][1]=1;
	data[5][3]=2;
	data[5][4]=4; */
	   //For Global array Floyd
        ASPBroadcastPart arraydthread=new ASPBroadcastPart(noofvertices);
	   DistributedExecutionManager dmanager = new SPMDDistributedExecutionManager(0);
	   DThreadExecutionContext context = new DThreadExecutionContext(totalthreads);
     context.setMode(args);
	   context.setexperimentName("Floyd");
	   //System.out.println("CALLING STMD:execute() with Dthread Obj "+arraydthread);

	   //if(debugMode) context.setdebugMode();
	   dmanager.execute((DThread)arraydthread,context);
	   end=System.currentTimeMillis();
	   System.out.println("TIME TAKEN IS "+(end-start)+" milliSeconds");
}
}