dispatchercommunication.java

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

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

//import java.net.*;
import java.util.HashMap;
import java.util.Vector;
//import java.io.*;

/**
 * <p>Title: </p>
 * <p>Description:用于处理与dispatcher的通信 </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

//communicate to other dispatcher node
public class DispatcherCommunication extends Thread{

  private String ipAddr; //target dispatcher node's ipaddr and port
  private int dispatcherPort;
  private int serverPort;
  //private Item item;//the data of host, which should be backuped in other dispatcher node
  private HashMap items;//the data of guestes
  private InitiativePoll i_poll=null;
  private PassivePoll p_poll=null;

  public DispatcherCommunication(String _ipAddr, int _Port,int _serverPort,DispatcherInfo d_info,Vector jobList,Vector workerNodeList,Vector idleWorkerNodeList,Vector deadWorkerNodeList)
  {
    this.ipAddr = _ipAddr;
    this.dispatcherPort = _Port;
    this.serverPort=_serverPort;
    items=new HashMap();   
  	i_poll=new InitiativePoll(ipAddr,dispatcherPort,d_info,jobList,workerNodeList,idleWorkerNodeList,deadWorkerNodeList);
    //item=new Item(dispatcherInfo,jobList,workerNodeList,idleWorkerNodeList,deadWorkerNodeList);
  }
  
  public void run()
  {
  	i_poll.run();
  	p_poll=new PassivePoll(serverPort,items);
  	p_poll.start();
  }
}