job.java

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

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

//import cn.edu.hust.cgcl.biogrid.service.MessageService;
import java.io.FileInputStream;
import java.io.ObjectInputStream;

import cn.edu.hust.cgcl.biogrid.user.desc.JobDesc;
//import cn.edu.hust.cgcl.biogrid.dispatcher.SubJob;

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

public class Job
{
    public String jobId;
    public String monitorIp;
    public int monitorPort;
    public String userId;
    public String userPwd;

    public String dataServerIp;
    public int dataServerPort;

    public JobDesc jobDesc;

    public static JobDesc getJobDesc(String jobdescFile)
    throws Exception
    {
            FileInputStream fis = new FileInputStream(jobdescFile);
            ObjectInputStream ois = new ObjectInputStream(fis);
            JobDesc jobesc=(JobDesc)ois.readObject();
            fis.close();
            ois.close();
            return jobesc;
    } // getJobDesc

    public Job(JobDesc jobdesc)
    {
        jobDesc=jobdesc;
        this.jobId=jobdesc.getID();
        this.monitorIp=jobdesc.getMonitor().getIP();
        this.monitorPort=jobdesc.getMonitor().getPort();
        this.dataServerIp=jobdesc.getDataPool().getPoolIP();
        this.dataServerPort=jobdesc.getDataPool().getPoolPort();
        userId=jobdesc.getDataPool().getLoginName();
        userPwd=jobdesc.getDataPool().getPassword();
    } // Job
    
    public Job(String jobdescFile)throws Exception
    {
    	FileInputStream fis = new FileInputStream(jobdescFile);
        ObjectInputStream ois = new ObjectInputStream(fis);
        jobDesc=(JobDesc)ois.readObject();
        fis.close();
        ois.close();
        this.jobId=jobDesc.getID();
        this.monitorIp=jobDesc.getMonitor().getIP();
        this.monitorPort=jobDesc.getMonitor().getPort();
        this.dataServerIp=jobDesc.getDataPool().getPoolIP();
        this.dataServerPort=jobDesc.getDataPool().getPoolPort();
        userId=jobDesc.getDataPool().getLoginName();
        userPwd=jobDesc.getDataPool().getPassword();
    	
    }
}