workernode.java

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

package cn.edu.hust.cgcl.biogrid.worker;



/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class WorkerNode
extends Thread
{   private WorkerInfo nodeInfo;
    //private SubJob subJob;
    DispatcherCommunication dc;
    TaskTransfer tt;

    public WorkerNode()
    {
    nodeInfo=new WorkerInfo();
    //subJob=new SubJob();
    }


    public WorkerNode(String workerId, String dipAddr,int heartbeatport)
    {
        nodeInfo=new WorkerInfo(workerId,dipAddr,heartbeatport);
       // subJob = null;
    } //WorkerNode

    public WorkerNode(WorkerInfo nodeInfo)
    {
    this.nodeInfo=nodeInfo;
    //subJob=null;
    }

    public void run()
    {
    dc=new DispatcherCommunication(nodeInfo);
    dc.start();
    
    /**********************************************
     * this is used to test subprogram
     */
    /*Test_subprogram ts=new Test_subprogram();
    ts.run();*/
    }

    public void quit()
    {
    System.out.println("WorkerNode start quitting...");
    if(dc!=null) 
    	{dc.interrupt();
         dc.quit();
    	}
    tt=new TaskTransfer(nodeInfo);
    tt.workerQuit();
    System.out.println("WorkerNode quit!");
    return;
    }

    public void init(String workerId,String dId, String dipAddr,int heartbeatport)
    {
    nodeInfo.setWorkerInfo(workerId,dId,dipAddr,heartbeatport);
    }
    
    public WorkerInfo getWorkerInfo()
    {
    	return this.nodeInfo;
    }

}