Changeset 883 for DCWoRMS/branches/coolemall/src/schedframe/scheduling

Timestamp:

02/26/13 08:41:50 (12 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall

Files:

• . (copied) (copied from DCWoRMS/trunk)
• src/schedframe/scheduling/tasks/Processes.java (modified) (1 diff)
• src/schedframe/scheduling/tasks/Task.java (modified) (6 diffs)
• src/schedframe/scheduling/tasks/phases (added)
• src/schedframe/scheduling/tasks/phases/PhaseBehaviour.java (added)
• src/schedframe/scheduling/tasks/phases/ResourceConsumption.java (added)
• src/schedframe/scheduling/tasks/phases/ResourceConsumptionProfile.java (added)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/tasks/Processes.java

@@ -41 +41 @@
                 CountType countType = choice.getProcessesCount();
                 if(countType != null) {
-                        return countType.getValue().getContent().intValue();
+                        return countType.getValue().getContent();
                 } 
                 

DCWoRMS/branches/coolemall/src/schedframe/scheduling/tasks/Task.java

@@ -6 +6 @@
 import org.qcg.broker.schemas.resreqs.ComputingResourceParameterType;
 import org.qcg.broker.schemas.resreqs.ExecutionTimeType;
+import org.qcg.broker.schemas.resreqs.ExecutionType;
+import org.qcg.broker.schemas.resreqs.PhaseBehaviourType;
 import org.qcg.broker.schemas.resreqs.ProcessesResourceRequirements;
 import org.qcg.broker.schemas.resreqs.Requirements;
+import org.qcg.broker.schemas.resreqs.ResourceConsumptionProfileType;
+import org.qcg.broker.schemas.resreqs.ResourceConsumptionType;
 import org.qcg.broker.schemas.resreqs.TaskResourceRequirements;
 import org.qcg.broker.schemas.resreqs.TimePeriod;
@@ -30 +34 @@
 import schedframe.scheduling.WorkloadUnitHandler;
 import schedframe.scheduling.manager.tasks.JobRegistryImpl;
+import schedframe.scheduling.tasks.phases.ResourceConsumption;
+import schedframe.scheduling.tasks.phases.ResourceConsumptionProfile;
 import schedframe.scheduling.tasks.requirements.ResourceParameterName;
 
@@ -71 +77 @@
         private int senderId;
         private long workloadLogWaitTime;
+        
+        private ResourceConsumptionProfile resourceConsumptionProfile;
 
         public Task(org.qcg.broker.schemas.resreqs.Task task){
@@ -91 +99 @@
         }
 
+        private void preparePhases() {
+                List<ResourceConsumption> resourceConsumptionList = new ArrayList<ResourceConsumption>();
+                
+                if(task.getExecution() == null || task.getExecution().getResourceConsumptionProfile() == null){
+                        ResourceConsumption resConsumption = null;
+                        try {
+                                resConsumption = new ResourceConsumption(this.length, getComputingResourceRequirements());
+                        } catch (NoSuchFieldException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
+                        resourceConsumptionList.add(resConsumption);
+                }
+                else{
+                        for(ResourceConsumptionType resConsumption: task.getExecution().getResourceConsumptionProfile().getResourceConsumption()){
+                                ResourceConsumption resourceConsumption = new ResourceConsumption(resConsumption);
+                                resourceConsumptionList.add(resourceConsumption);
+                        }
+                }
+                this.resourceConsumptionProfile = new ResourceConsumptionProfile(resourceConsumptionList);
+                
+        //      System.out.println("======"+task.getExecution().getExecutable().getApplication().getName());
+        }
+        
         public DateTime getExecutionStartTime() throws NoSuchFieldException {
                 if(this.startTime != null)
@@ -421 +453 @@
         public void setLength(long length) {
                 this.length = length;
+                preparePhases();
         }
 
@@ -485 +518 @@
                 wuh.handleTask(this);
         }
+        
+        public ResourceConsumptionProfile getResourceConsumptionProfile(){
+                return resourceConsumptionProfile;
+        }
+        
+        public String getApplicationName(){
+                return task.getExecution().getExecutable().getApplication().getName();
+        }
 }