Changeset 1415 for DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power

Timestamp:

07/15/14 16:26:31 (11 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power

Files:

• StandardPowerStateName.java (modified) (1 diff)
• plugin/EnergyEstimationPlugin.java (modified) (2 diffs)
• plugin/EnergyPluginConfiguration.java (added)
• ui/ComputingResourcePowerInterface.java (modified) (2 diffs)
• ui/NodePowerInterface.java (modified) (4 diffs)
• ui/ProcessorPowerInterface.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/StandardPowerStateName.java

@@ -8 +8 @@
         SLEEP,
         SUSPEND,
-        HIBERNATE;
+        HIBERNATE,
+        BOOT,
+        POWEROFF;
 
         public String getLabel() {

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/plugin/EnergyEstimationPlugin.java

@@ -2 +2 @@
 
 import schedframe.Plugin;
-import schedframe.resources.computing.profiles.energy.EnergyEvent;
+import schedframe.resources.computing.profiles.energy.ResourceEvent;
 import schedframe.resources.devices.PhysicalResource;
 import schedframe.scheduling.manager.tasks.JobRegistry;
@@ -8 +8 @@
 public interface EnergyEstimationPlugin extends Plugin {
         
-        public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource);
+        public double estimatePowerConsumption(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource);
 
-        public double estimateAirflow(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource);
+        public double estimateAirflow(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource);
 
-        public double estimateTemperature(EnergyEvent event, JobRegistry jobRegistry, PhysicalResource resource);
+        public double estimateTemperature(ResourceEvent event, JobRegistry jobRegistry, PhysicalResource resource);
 
 }

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/ui/ComputingResourcePowerInterface.java

@@ -9 +9 @@
 import schedframe.resources.ResourceStatus;
 import schedframe.resources.computing.ComputingResource;
-import schedframe.resources.computing.profiles.energy.EnergyEvent;
-import schedframe.resources.computing.profiles.energy.EnergyEventType;
+import schedframe.resources.computing.profiles.energy.ResourceEvent;
+import schedframe.resources.computing.profiles.energy.ResourceEventType;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
 import schedframe.resources.computing.profiles.energy.power.PowerState;
@@ -49 +49 @@
                         }
                         //notifications from all levels
-                        resource.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, resource.getFullName()));
+                        resource.handleEvent(new ResourceEvent(ResourceEventType.POWER_STATE_CHANGED, resource.getFullName()));
 
                         //notification from last level

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/ui/NodePowerInterface.java

@@ -3 +3 @@
 
 
+import java.util.List;
+
 import schedframe.resources.ResourceStatus;
 import schedframe.resources.computing.ComputingResource;
 import schedframe.resources.computing.Node;
-import schedframe.resources.computing.profiles.energy.EnergyEvent;
-import schedframe.resources.computing.profiles.energy.EnergyEventType;
+import schedframe.resources.computing.profiles.energy.ResourceEvent;
+import schedframe.resources.computing.profiles.energy.ResourceEventType;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
+import schedframe.resources.computing.profiles.energy.power.PowerState;
 import schedframe.resources.computing.profiles.energy.power.PowerStateName;
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
+import schedframe.resources.computing.profiles.energy.power.Transition;
+import simulator.DataCenterWorkloadSimulator;
 
 public class NodePowerInterface extends ComputingResourcePowerInterface{
@@ -26 +31 @@
                         
                         Node node = (Node) resource;
-                        for(ComputingResource child:node.getProcessors()){
+                        for(ComputingResource child: node.getProcessors()){
                                 if(child.getPowerInterface() != null){
                                         child.getPowerInterface().setPowerState(state); 
@@ -39 +44 @@
                         }
         
-                        node.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, node.getFullName()));
+                        node.handleEvent(new ResourceEvent(ResourceEventType.POWER_STATE_CHANGED, node.getFullName()));
 
                         //node.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getName()));
@@ -48 +53 @@
 
         public void turnOn(){
+                /*double timePenalty = getTransitionTime(currentPowerState, StandardPowerStateName.ON);
+                setPowerState(StandardPowerStateName.BOOT);
+                DataCenterWorkloadSimulator.getEventManager().sendToResource(resource.getFullName(), timePenalty, new ResourceEvent(ResourceEventType.UPDATE_POWER_STATE, StandardPowerStateName.ON, resource.getFullName()));*/
                 setPowerState(StandardPowerStateName.ON);
         }
         
         public void turnOff(){
+                /*double timePenalty = getTransitionTime(currentPowerState, StandardPowerStateName.OFF);
+                setPowerState(StandardPowerStateName.POWEROFF);
+                DataCenterWorkloadSimulator.getEventManager().sendToResource(resource.getFullName(), timePenalty, new ResourceEvent(ResourceEventType.UPDATE_POWER_STATE, StandardPowerStateName.OFF, resource.getFullName()));*/
                 setPowerState(StandardPowerStateName.OFF);
         }
 
+        private double getTransitionTime(PowerStateName from, PowerStateName to){
+                List<PowerState> availablePowerStates = getSupportedPowerStates();
+                double timePenalty = 0;
+                for(PowerState ps : availablePowerStates){
+                        if(ps.getName().getLabel().equals(from.getLabel())){
+                                List<Transition> transitions = ps.getTransitions();
+                                for(Transition t: transitions){
+                                        if(t.getTo().getLabel().equals(to)){
+                                                timePenalty = t.getTime();
+                                        }
+                                }
+                        }
+                }
+                return timePenalty;
+        }
 
 

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/profiles/energy/power/ui/ProcessorPowerInterface.java

@@ -6 +6 @@
 import schedframe.resources.ResourceStatus;
 import schedframe.resources.computing.ComputingResource;
-import schedframe.resources.computing.profiles.energy.EnergyEvent;
-import schedframe.resources.computing.profiles.energy.EnergyEventType;
+import schedframe.resources.computing.profiles.energy.ResourceEvent;
+import schedframe.resources.computing.profiles.energy.ResourceEventType;
 import schedframe.resources.computing.profiles.energy.power.PState;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
@@ -33 +33 @@
                                 resource.setStatus(ResourceStatus.FREE);
                         }
-                        resource.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, resource.getFullName()));             
+                        resource.handleEvent(new ResourceEvent(ResourceEventType.POWER_STATE_CHANGED, resource.getFullName()));         
                 }
 
@@ -67 +67 @@
                         //speed.setAmount(Double.valueOf(currentPState.getFrequency()).intValue());
                         //new ResourceEventCommand(resource).execute(EnergyEventType.FREQUENCY_CHANGED);
-                        resource.handleEvent(new EnergyEvent(EnergyEventType.FREQUENCY_CHANGED, resource.getFullName()));
+                        resource.handleEvent(new ResourceEvent(ResourceEventType.CPU_FREQUENCY_CHANGED, resource.getFullName()));
                         //resource.getScheduler().sendInternal(GridSimTags.SCHEDULE_NOW, DCWormsTags.UPDATE, resource.getName());