dispatcherrun.java

分布式计算平台P2HP-1的源代码；P2HP-1是基于P2P的高性能计算平台

/*
 * Created on 2005-3-22
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package cn.edu.hust.cgcl.biogrid.dispatcher;


/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class DispatcherRun extends Thread{
	Dispatcher dispatcher;
	Integer synFlag;
	
	/*
     * default construction function.
     */
	public DispatcherRun(Integer synFlag)
	{
		this.synFlag=synFlag;
	}
	
	/*
     * monitorIpAddr=202.114.14.148  //monitorip
     * monitorPort=6000  //monitorport
     */
    public DispatcherRun(String MonitorIpAddr,int MonitorPort,Integer synFlag,boolean logIsActive)
    {
    	Parameter.MonitorIpAddr=MonitorIpAddr;
    	Parameter.MonitorPort=MonitorPort;
    	this.synFlag=synFlag;
    	Parameter.dispatcherLogIsActive=logIsActive;
    }
    
    /*
     * serverPort = 5002; //Dispatcher与monitor通信的服务器端口
     * workerPort = 5003; //Dispatcher与worker通信的服务器端口
     * listenPort = 5004; //Dispatcher侦听worker信息的服务器端口(轮询端口)
     * taskPort=5007;     //Dispatcher用于和用户主程序以及worker之间任务通信端口
     */
    public DispatcherRun(String MonitorIpAddr,int MonitorPort,int serverPort,
    		int workerPort, int listenPort ,int taskPort,Integer synFlag,boolean logIsActive)
    {
    	Parameter.MonitorIpAddr=MonitorIpAddr;
    	Parameter.MonitorPort=MonitorPort;
    	
    	Parameter.serverPort=serverPort;
    	Parameter.workerPort=workerPort;
    	Parameter.listenPort=listenPort;
    	Parameter.taskPort=taskPort;
    	this.synFlag=synFlag;
    	Parameter.dispatcherLogIsActive=logIsActive;
    }
    
	public void run()
	{
		System.out.print("begin\n");
        dispatcher = new Dispatcher(synFlag);
        dispatcher.start();
	}

	
	
	/*
	 * return a array int[60];
	 */
	public int[] getWorkerCount()
	{
		return CountWorker.workerCount;
	}
	
	public void quit()
	{
		dispatcher.interrupt();
		return;
	}
	
	/*
	 *  if code=-1 ; The joinning failed.
	 *  if code=-2 ; The joinning failed, the fixed monitor doesn't exit! 
	 *  if code=-3 ; The joinning failed, the master monitor doesn't exit!
	 *  if code=-4 ; The joinning failed, the dispatcher locate in LAN!
 	 */
	public int getExceptionCode()
	{
		return ExceptionCode.exceptionCode;
	}


}