Changeset 1207 for DCWoRMS/branches/coolemall/src/dcworms

Timestamp:

11/26/13 11:56:07 (11 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/dcworms/schedframe/scheduling

Files:

• ExecTask.java (modified) (2 diffs)
• Executable.java (modified) (11 diffs)
• utils/ApplicationProfileDescription.java (added)

DCWoRMS/branches/coolemall/src/dcworms/schedframe/scheduling/ExecTask.java

@@ -5 +5 @@
 import schedframe.scheduling.tasks.TaskInterface;
 import schedframe.scheduling.tasks.phases.ResourceConsumption;
+import schedframe.scheduling.tasks.phases.ResourceConsumptionProfile;
 import schedframe.scheduling.tasks.requirements.ResourceParameterName;
 
@@ -15 +16 @@
         public List<String> getVisitedResources();
         
+        public ResourceConsumptionProfile getResourceConsumptionProfile();
         public ResourceConsumption getCurrentResourceConsumption();
 }

DCWoRMS/branches/coolemall/src/dcworms/schedframe/scheduling/Executable.java

@@ -2 +2 @@
 
 
+import example.energy.coolemall.CoolEmAllTestbedMeasurements;
 import gridsim.GridSim;
 import gridsim.dcworms.DCWormsTags;
@@ -7 +8 @@
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
@@ -14 +16 @@
 import org.joda.time.DateTimeUtilsExt;
 import org.joda.time.ReadableDuration;
+import org.qcg.broker.schemas.resreqs.ResourceConsumptionProfileType;
+import org.qcg.broker.schemas.resreqs.ResourceConsumptionType;
+import org.qcg.broker.schemas.resreqs.StringParameterType;
 
 import qcg.shared.constants.BrokerConstants;
 
 import schedframe.resources.computing.ComputingResource;
+import schedframe.resources.units.PEUnit;
 import schedframe.resources.units.ProcessingElements;
 import schedframe.resources.units.StandardResourceUnitName;
@@ -30 +36 @@
 import schedframe.scheduling.tasks.phases.ResourceConsumptionProfile;
 import schedframe.scheduling.tasks.requirements.ResourceParameterName;
+import simulator.stats.implementation.ResourceUsefulWorkStats;
 
 /**
@@ -60 +67 @@
         protected double finishTime; 
         
+        private ResourceConsumptionProfile resourceConsumptionProfile;
+        
         public Executable(Task t){
                 this.task = t;
@@ -83 +92 @@
                 this.submissionTime =  currentTime;
         this.totalCompletionTime = 0.0;
+        preparePhases(null);
          }
         
@@ -168 +178 @@
         
         if(status == DCWormsTags.INEXEC){
+                loadResourceConsumptionProfile();
                 task.setStatus((int) BrokerConstants.TASK_STATUS_RUNNING);
         } else if(status == DCWormsTags.QUEUED){
@@ -202 +213 @@
                 for (ComputingResource resource : pes) {
 
-                        trackResource(resource.getName());
+                        trackResource(resource.getFullName());
                         
                         ComputingResource parent = resource.getParent();
                                 List<String> visitedResource = getVisitedResources();
                                 String [] visitedResourcesArray = visitedResource.toArray(new String[visitedResource.size()]);
-                        while (parent != null && !ArrayUtils.contains(visitedResourcesArray, parent.getName())) {
-                                trackResource(parent.getName());
+                        while (parent != null && !ArrayUtils.contains(visitedResourcesArray, parent.getFullName())) {
+                                trackResource(parent.getFullName());
                                 parent = parent.getParent();
                         }
@@ -218 +229 @@
                         status = DCWormsTags.INEXEC;
                         setCompletionPercentage(0);
-                        task.getResourceConsumptionProfile().setCurrentPhase(task.getResourceConsumptionProfile().getCurrentPhase() + 1);
+                        resourceConsumptionProfile.setCurrentPhase(resourceConsumptionProfile.getCurrentPhase() + 1);
                         
                         DateTime currentDateTime = new DateTime();
@@ -386 +397 @@
         
         public ResourceConsumptionProfile getResourceConsumptionProfile(){
-                return task.getResourceConsumptionProfile();
+                return resourceConsumptionProfile;
         }
 
         public ResourceConsumption getCurrentResourceConsumption(){
-                return task.getResourceConsumptionProfile().getCurrentResourceConsumption();
+                return resourceConsumptionProfile.getCurrentResourceConsumption();
         }
         
@@ -396 +407 @@
                 return task.getApplicationName();
         }
-
+        
+        private void preparePhases(String resourceType) {
+                LinkedList<ResourceConsumption> resourceConsumptionList = new LinkedList<ResourceConsumption>();
+                
+                long usefulWork = -1;
+                
+                if(task.getDescription().getExecution() == null || task.getDescription().getExecution().getResourceConsumptionProfile() == null
+                                || task.getDescription().getExecution().getResourceConsumptionProfile().length == 0 ){
+                        ResourceConsumption resConsumption = null;
+                        try {
+                                resConsumption = new ResourceConsumption(getLength(), task.getComputingResourceRequirements());
+                        } catch (NoSuchFieldException e) {
+                                // TODO Auto-generated catch block
+                                e.printStackTrace();
+                        }
+                        resourceConsumptionList.add(resConsumption);
+                }else{
+                        boolean found = false;
+                        if(resourceType != null){
+                                for(ResourceConsumptionProfileType resConsumptioProfile: task.getDescription().getExecution().getResourceConsumptionProfile()){
+                                        if(resConsumptioProfile.getType() != null && resConsumptioProfile.getType().equals(resourceType)){
+                                                for(ResourceConsumptionType resConsumption: resConsumptioProfile.getResourceConsumption()){
+                                                        ResourceConsumption resourceConsumption = new ResourceConsumption(resConsumption);
+                                                        resourceConsumptionList.add(resourceConsumption);
+                                                }
+                                                for(StringParameterType prop: resConsumptioProfile.getProperties()){
+                                                        if(prop.getName().equals("usefulWork")){
+                                                                usefulWork = Double.valueOf(prop.getContent()).longValue();
+                                                                break;
+                                                        }
+                                                }
+                                                found = true;
+                                                break;
+                                        }
+                                }       
+                        }                       
+                        if(!found){
+                                for(ResourceConsumptionType resConsumption: task.getDescription().getExecution().getResourceConsumptionProfile()[0].getResourceConsumption()){
+                                        ResourceConsumption resourceConsumption = new ResourceConsumption(resConsumption);
+                                        resourceConsumptionList.add(resourceConsumption);
+                                }
+                                
+                                for(StringParameterType prop: task.getDescription().getExecution().getResourceConsumptionProfile()[0].getProperties()){
+                                        if(prop.getName().equals("usefulWork")){
+                                                usefulWork = Double.valueOf(prop.getContent()).longValue();
+                                                break;
+                                        }
+                                }
+                        }
+                }
+                
+                usefulWork = (usefulWork != -1) ? usefulWork : this.getLength();
+                this.resourceConsumptionProfile = new ResourceConsumptionProfile(resourceConsumptionList);
+                this.resourceConsumptionProfile.setUsefulWork(usefulWork);
+
+        }
+
+        private boolean loadResourceConsumptionProfile(){
+
+                PEUnit peUnit = (PEUnit)getUsedResources().getLast().getResourceUnits()
+                                .get(StandardResourceUnitName.PE);
+                if(peUnit instanceof ProcessingElements){
+                        ProcessingElements pes = (ProcessingElements) peUnit;
+                        for (ComputingResource resource : pes) {
+                                while(resource != null && resource.getResourceCharacteristic().getParameters().get("product") == null){
+                                        resource = resource.getParent();
+                                }
+                                if(resource != null) {
+                                        String productName = resource.getResourceCharacteristic().getParameters().get("product").get(0).getContent();
+                                        if(productName.equals("Fusion G - T40N"))
+                                                preparePhases("amdf");
+                                        else if(productName.equals("Atom - D510"))
+                                                preparePhases("atom64");
+                                        else if(productName.equals("Atom - N2600"))
+                                                preparePhases("atom64");
+                                        else if(productName.equals("Core i7 - 2715QE"))
+                                                preparePhases("i7-2715QE");
+                                        else if(productName.equals("Core i7 - 3615QE"))
+                                                preparePhases("i7-3615QE");
+                                }
+                                return true;
+                        }
+                }
+                return false;
+                
+        }
 }