subjob.java

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

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

import java.io.Serializable;

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

public class SubJob
    implements Serializable
{
    private String jobId;
    private String subJobId;
    private String fileName = "";
    private String dataServerIp = "";
    private int dataServerPort =0;
    private String projectName = "";
    private int state;
//    private WorkerNode w;
    private String wnId;
    String userId;
    String userPwd;
    
    public String subDispatcherIp="";
    public int subDispatcherPort=0;
    
    public long distributeTime=0;//子任务被分配给一个worker的时间。（从预分配开始计算）
    public long finishedTime=0;
    public long computingTime=0;//finishedTime-distributeTime.
    
    public int redun_num=0;
    
    //private static final long serialVersionUID=762508508425139227l;  
    
    public int intervalTime=3;//backup interval time,if this time is over ,then this subjob is 
       //send to jobApply;
/*
    private final static int NOT_FINISHED = 0;
    private final static int FINISHED = 1;
    private final static int PRE_SUBTASK=2;//前一个worker未完成这个subjob，等待下一个worker接着完成
*/
    public final static int STOPPED = 0;
    public final static int RUNNING = 1;
    public final static int FINISHED = 2;
    public final static int PRE_SUBTASK = 3; //前一个worker未完成这个subjob，等待下一个worker接着完成
    public final static int FAULT_TOLERANT=4;
    
    public SubJob(String jobId, String subJobID, String fileName,
                  String dataServerIp, int dataServerPort,
                  String projectName,String backupIp,int backupPort,String userid,String userpwd)
    {
        this.jobId = jobId;
        this.subJobId = subJobID;
        this.fileName = fileName;
        this.dataServerIp = dataServerIp;
        this.dataServerPort = dataServerPort;
        this.projectName = projectName;
        this.subDispatcherIp=backupIp;
        this.subDispatcherPort=backupPort;
        this.userId=userid;
        this.userPwd=userpwd;
        //this.fileString = fileString;
//        w = null;
        wnId="";
        state = 0;
    }

    public String getJobId()
    {
        return jobId;
    }
    
    public String getUserId()
    {
     return userId;
    }
    
    public String getUserPwd()
    {
     return userPwd;
    }
    
    public long getDistributeTime()
    {
    	return distributeTime;
    }
    

    public String getSubJobId()
    {
        return subJobId;
    }

    public String getFileName()
    {
        return fileName;
    }

    public String getDataServerIp()
    {
        return dataServerIp;
    }

    public int getDataServerPort()
    {
        return dataServerPort;
    }

    public String getProjectName()
    {
        return projectName;
    }

    public int getState()
    {
    return state;
    }

    public void jobfinish()
    {
        state = FINISHED;
        this.wnId = "";
    }

    public void setWorkerNode(String wnid)
    {
        this.wnId = wnid;
    }

    public void workerQuit()
    {
        this.wnId = "";
    }

    public void setWorkerState(int state)
    {
    	if(this.state==2) return;
        this.state=state;
    }
}