initiativepoll.java

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

/*
 * Created on 2004-10-28
 *
 * 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;

import java.io.IOException;
import java.util.Vector;
/**
 * @author Administrator
 * take initiative to poll backup dispatchernode, and send data to it
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class InitiativePoll extends D_Communication implements Runnable{

	private static final int POLL_INTERVAL = 60 * 1000;
	private boolean isActive=true;
	
	private DispatcherInfo dispatcherInfo;
    //private int status;

    private Vector jobList; //job队列
    private Vector workerNodeList; //worker队列
    private Vector idleWorkerNodeList; //空闲worker队列
    private Vector deadWorkerNodeList; //死亡的worker队列
    
	private String dispatcherid;
	
	public InitiativePoll(String _ipAddr, int _Port,DispatcherInfo d_info,Vector jobList,Vector workerNodeList,Vector idleWorkerNodeList,Vector deadWorkerNodeList)
	{
		super(_ipAddr,_Port);
		this.dispatcherInfo=d_info;
		this.jobList=jobList;
		this.workerNodeList=workerNodeList;
		this.idleWorkerNodeList=idleWorkerNodeList;
		this.deadWorkerNodeList=deadWorkerNodeList;
		dispatcherid=d_info.getDispatcherId();
	}
	
	protected boolean process()
	  {
		try{
			D_item=new Item(dispatcherInfo,jobList,workerNodeList,idleWorkerNodeList,deadWorkerNodeList);
			os.println(dispatcherid);
			os.flush();
			oob.writeObject(D_item);
			oob.flush();
			return true;
		}catch(IOException e)
		{
			log(e);
			return false;
		}
	  }
	
	public void run()
	{
		while (isActive) {
		      this.onpoll();
		      try {
		        Thread.sleep(POLL_INTERVAL);
		      }
		      catch (InterruptedException e) {
		        //get back to work
		      }
		    }
	}
	
	public void terminate()
	{
		isActive=false;
	}
}