source: DCWoRMS/branches/coolemall/src/schedframe/scheduling/tasks/phases/ExecutionPhase.java @ 1415

package schedframe.scheduling.tasks.phases;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.qcg.broker.schemas.resreqs.ComputingResourceBaseTypeItem;
import org.qcg.broker.schemas.resreqs.ComputingResourceParameterType;
import org.qcg.broker.schemas.resreqs.PhaseBehaviourType;
import org.qcg.broker.schemas.resreqs.StringParameterType;

import org.qcg.broker.schemas.resreqs.ResourceConsumptionType;

public class ExecutionPhase {

        protected String id;
    protected Map<String, String> referenceHardware;
    protected long originDuration;
    protected long lenght;
    protected List<PhaseSystemLoad> systemLoad;
    
    public ExecutionPhase(long duration, ComputingResourceBaseTypeItem item[]){
        this.id = null;
        this.referenceHardware = null;
        this.originDuration = duration;
        this.systemLoad = new ArrayList<PhaseSystemLoad>();
        for(ComputingResourceBaseTypeItem compResItem: item){
                ComputingResourceParameterType hostParameter = compResItem.getHostParameter();
                PhaseSystemLoad pb = new PhaseSystemLoad(hostParameter.getName().toString());
                systemLoad.add(pb);
        }
        this.lenght = duration;
    }
    
    public ExecutionPhase(ResourceConsumptionType resConsumptionType){
        this.id = resConsumptionType.getId();
        this.referenceHardware = new HashMap<String, String>();
        this.originDuration = resConsumptionType.getDuration().toLong() / 1000;
        
        double speed = 1;
        if(resConsumptionType.getReferenceHardware() != null){
                for (int i = 0; i < resConsumptionType.getReferenceHardware().getReference().length; i++){
                        StringParameterType spt = resConsumptionType.getReferenceHardware().getReference(i);
                        this.referenceHardware.put(spt.getName(), spt.getContent());
                if(spt.getName().equals("cpu_maxfreq")){
                        speed = new Double(spt.getContent());
                }
                }
        }
        this.systemLoad = new ArrayList<PhaseSystemLoad>();
        int nrOfThreads = 1;
        for(PhaseBehaviourType pbt: resConsumptionType.getBehaviour()){
                PhaseSystemLoad pb = new PhaseSystemLoad(pbt);
                this.systemLoad.add(pb);
                if(pbt.getName().equals("PM_Threads")){
                        nrOfThreads = new Double(pbt.getParameterTypeChoice().getParameterTypeChoiceItem(0).getParameterValue().getContent()).intValue();
                }
        }
        this.lenght = (long) (originDuration * nrOfThreads * speed);
    }
    
        public String getId() {
                return id;
        }

        public void setId(String id) {
                this.id = id;
        }

        public Map<String, String> getReferenceHardware() {
                return referenceHardware;
        }

        public long getDuration() {
                return originDuration;
        }

        public List<PhaseSystemLoad> getSystemLoad() {
                return systemLoad;
        }

        public long getLenght() {
                return lenght;
        }

}