Changeset 1440 for DCWoRMS/branches/coolemall/src/schedframe/resources

Timestamp:

09/18/14 17:37:54 (11 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/schedframe/resources/computing

Files:

• ComputingResource.java (modified) (2 diffs)
• profiles/energy/power/ui/ComputingResourcePowerInterface.java (modified) (4 diffs)
• profiles/energy/power/ui/NodePowerInterface.java (modified) (2 diffs)

DCWoRMS/branches/coolemall/src/schedframe/resources/computing/ComputingResource.java

@@ -268 +268 @@
                                 }
                         }
-
                 }
                 
@@ -290 +289 @@
                                                 break;
                                         }
+                                        case POWER_STATE_CHANGED: {
+                                                scheduler.sendInternal(GridSimTags.SCHEDULE_NOW, DCWormsTags.RESOURCE_POWER_STATE_CHANGED, src);
+                                                break;
+                                        }
                                 }
 

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

@@ -15 +15 @@
 import schedframe.resources.computing.profiles.energy.power.PowerUsage;
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
+import schedframe.resources.computing.profiles.energy.power.Transition;
+import simulator.DataCenterWorkloadSimulator;
 
 public class ComputingResourcePowerInterface implements PowerInterface{
@@ -28 +30 @@
         }
         
-        public boolean setPowerState(PowerStateName state) {
-                if(!supportPowerState(state))
+        public boolean setPowerState(PowerStateName newState) {
+                if(!supportPowerState(newState))
                         return false;
                         
-                if(state != currentPowerState){
-                        currentPowerState = state;
+                if(newState != currentPowerState){
 
-                        for(ComputingResource child:resource.getChildren()){
-                                if(child.getPowerInterface().supportPowerState(state)){
-                                        child.getPowerInterface().setPowerState(state);
+                        Transition t = getTransition(currentPowerState, newState);
+                        if(t == null){
+                                currentPowerState = newState;
+                        } else{
+                                if(t.getTime() <= 0 ){
+                                        currentPowerState = newState;
+                                } else {
+                                        currentPowerState = t.getName();
+                                        DataCenterWorkloadSimulator.getEventManager().sendToResource(resource.getFullName(), t.getTime(), new ResourceEvent(ResourceEventType.UPDATE_POWER_STATE, newState, resource.getFullName()));
                                 }
                         }
 
-                        if(state == StandardPowerStateName.OFF){
+                        for(ComputingResource child:resource.getChildren()){
+                                if(child.getPowerInterface() != null){
+                                        child.getPowerInterface().setPowerState(currentPowerState);
+                                }
+                        }
+
+                        if(currentPowerState == StandardPowerStateName.OFF || currentPowerState == StandardPowerStateName.POWEROFF || currentPowerState == StandardPowerStateName.BOOT){
                                 resource.setStatus(ResourceStatus.UNAVAILABLE);
                         }
-                        else if(state == StandardPowerStateName.ON){
+                        else if(currentPowerState == StandardPowerStateName.ON){
                                 resource.setStatus(ResourceStatus.FREE);
                         }
@@ -74 +87 @@
                 }
                 return false;
-                
         }
         
@@ -114 +126 @@
         }
 
+        protected Transition getTransition(PowerStateName from, PowerStateName to){
+                List<PowerState> availablePowerStates = getSupportedPowerStates();
+                Transition transition = null;
+                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.getLabel())){
+                                                transition = t;
+                                                break;
+                                        }
+                                }
+                        }
+                }
+                return transition;
+        }
 }

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

@@ -2 +2 @@
 
 
-import java.util.List;
-
-
-import schedframe.resources.ResourceStatus;
 import schedframe.resources.computing.ComputingResource;
-import schedframe.resources.computing.Node;
-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{
@@ -24 +13 @@
         }
 
-        public boolean setPowerState(PowerStateName state){
-                if(!supportPowerState(state))
-                        return false;
-                if(state != currentPowerState){
-                        currentPowerState = state;
-                        
-                        Node node = (Node) resource;
-                        for(ComputingResource child: node.getProcessors()){
-                                if(child.getPowerInterface() != null){
-                                        child.getPowerInterface().setPowerState(state); 
-                                }
-                        }
-
-                        if(state == StandardPowerStateName.OFF || state == StandardPowerStateName.POWEROFF || state == StandardPowerStateName.BOOT){
-                                node.setStatus(ResourceStatus.UNAVAILABLE);
-                        }
-                        else if(state == StandardPowerStateName.ON ){
-                                node.setStatus(ResourceStatus.FREE);
-                        }
-        
-                        node.handleEvent(new ResourceEvent(ResourceEventType.POWER_STATE_CHANGED, node.getFullName()));
-
-                        //node.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getName()));
-                        //ResourceController.traceResource(new DateTime().getMillis(), resource.getFullName(), "POWER_STATE_CHANGED", state.getName()); 
-                }
-                return true;
-        }
-
         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 time = 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)){
-                                                time = t.getTime();
-                                        }
-                                }
-                        }
-                }
-                return time;
-        }
-
-
 }