Changeset 539 for DCWoRMS/trunk/build/classes/schedframe/resources

Timestamp:

10/31/12 13:52:06 (12 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/trunk/build/classes/schedframe/resources

Files:

• computing/ComputingNode.class (modified) (previous)
• computing/ComputingNode.java (modified) (3 diffs)
• computing/ComputingResource$ComputingResourceEventHandler.class (added)
• computing/ComputingResource.class (modified) (previous)
• computing/ComputingResource.java (modified) (12 diffs)
• computing/Core.class (modified) (previous)
• computing/Core.java (modified) (2 diffs)
• computing/DataCenter.class (modified) (previous)
• computing/DataCenter.java (modified) (2 diffs)
• computing/Processor.class (modified) (previous)
• computing/Processor.java (modified) (2 diffs)
• computing/Rack.class (modified) (previous)
• computing/Rack.java (modified) (2 diffs)
• computing/ResourceFactory$1.class (modified) (previous)
• computing/ResourceFactory.class (modified) (previous)
• computing/ResourceFactory.java (modified) (4 diffs)
• computing/profiles/energy/EnergyEventType.class (modified) (previous)
• computing/profiles/energy/EnergyEventType.java (modified) (1 diff)
• computing/profiles/energy/EnergyExtension$1.class (modified) (previous)
• computing/profiles/energy/EnergyExtension.class (modified) (previous)
• computing/profiles/energy/EnergyExtension.java (modified) (6 diffs)
• computing/profiles/energy/MeasurementHistory.class (added)
• computing/profiles/energy/MeasurementHistory.java (added)
• computing/profiles/energy/airthroughput/AirFlowValue.class (added)
• computing/profiles/energy/airthroughput/AirFlowValue.java (added)
• computing/profiles/energy/airthroughput/AirThroughputInterfaceFactory.class (added)
• computing/profiles/energy/airthroughput/AirThroughputInterfaceFactory.java (added)
• computing/profiles/energy/airthroughput/AirThroughputProfile.class (modified) (previous)
• computing/profiles/energy/airthroughput/AirThroughputProfile.java (modified) (4 diffs)
• computing/profiles/energy/airthroughput/ui (added)
• computing/profiles/energy/airthroughput/ui/AirThroughputInterface.class (added)
• computing/profiles/energy/airthroughput/ui/AirThroughputInterface.java (added)
• computing/profiles/energy/airthroughput/ui/DefaultAirThroughputInterface.class (added)
• computing/profiles/energy/airthroughput/ui/DefaultAirThroughputInterface.java (added)
• computing/profiles/energy/power/PowerInterfaceFactory.class (added)
• computing/profiles/energy/power/PowerInterfaceFactory.java (added)
• computing/profiles/energy/power/PowerProfile.class (modified) (previous)
• computing/profiles/energy/power/PowerProfile.java (modified) (2 diffs)
• computing/profiles/energy/power/PowerUsage.class (modified) (previous)
• computing/profiles/energy/power/PowerUsage.java (modified) (1 diff)
• computing/profiles/energy/power/plugin/EnergyEstimationPlugin.class (modified) (previous)
• computing/profiles/energy/power/plugin/EnergyEstimationPlugin.java (modified) (1 diff)
• computing/profiles/energy/power/ui/ComputingNodePowerInterface.class (modified) (previous)
• computing/profiles/energy/power/ui/ComputingNodePowerInterface.java (modified) (3 diffs)
• computing/profiles/energy/power/ui/ComputingResourcePowerInterface.class (added)
• computing/profiles/energy/power/ui/ComputingResourcePowerInterface.java (added)
• computing/profiles/energy/power/ui/DataCenterPowerInterface.class (modified) (previous)
• computing/profiles/energy/power/ui/DataCenterPowerInterface.java (modified) (1 diff)
• computing/profiles/energy/power/ui/PowerInterface.class (modified) (previous)
• computing/profiles/energy/power/ui/PowerInterface.java (modified) (2 diffs)
• computing/profiles/energy/power/ui/ProcessorPowerInterface.class (modified) (previous)
• computing/profiles/energy/power/ui/ProcessorPowerInterface.java (modified) (5 diffs)
• units/AbstractResourceUnit$SimpleResourceUnitProvisioner.class (modified) (previous)
• units/AbstractResourceUnit.class (modified) (previous)
• units/AbstractResourceUnit.java (modified) (1 diff)
• units/ResourceUnit.class (modified) (previous)
• units/ResourceUnit.java (modified) (1 diff)

DCWoRMS/trunk/build/classes/schedframe/resources/computing/ComputingNode.java

@@ -10 +10 @@
 import schedframe.resources.computing.extensions.ExtensionType;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
-import schedframe.resources.computing.profiles.energy.power.PowerProfileFactory;
+import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.ui.ComputingNodePowerInterface;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
@@ -26 +26 @@
                 
                 //extensionList.add(new EnergyExtension(this, resDesc.getPowerInterface(), resDesc.getEnergyEstimationPlugin()));
-                PowerInterface pi = PowerProfileFactory.createPowerInterface(this, resDesc.getPowerProfile());
+                PowerInterface pi = PowerInterfaceFactory.createPowerInterface(this, resDesc.getPowerProfile());
                 accept(new EnergyExtension(pi, resDesc.getPowerProfile()));     
         }
@@ -39 +39 @@
         
         public ComputingNodePowerInterface getPowerInterface(){
-                ComputingNodePowerInterface powerProfile = null;
+                ComputingNodePowerInterface powerInterface = null;
                 if(extensionList.isExtensionAvailable(ExtensionType.ENERGY_EXTENSION)){
                         EnergyExtension ee = (EnergyExtension)extensionList.getExtension(ExtensionType.ENERGY_EXTENSION);
-                        powerProfile = (ComputingNodePowerInterface)ee.getPowerInterface();
+                        powerInterface = (ComputingNodePowerInterface)ee.getPowerInterface();
                 }
-                return powerProfile;
+                return powerInterface;
         }
 

DCWoRMS/trunk/build/classes/schedframe/resources/computing/ComputingResource.java

@@ -2 +2 @@
 
 import gridsim.GridSimTags;
-import gridsim.gssim.WormsTags;
+import gridsim.dcworms.DCWormsTags;
 
 import java.util.ArrayList;
@@ -28 +28 @@
 import schedframe.resources.computing.profiles.energy.EnergyEventType;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
+import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.resources.computing.properties.DefaultPropertiesBuilder;
@@ -68 +69 @@
         }
 
-        //TODO remove if possible (check if all scenarios can be realized - statistics issue) , since it's temporary method
+        //TODO remove if possible (check if all scenarios can be realized - statistics issue), since it's a temporary method
         private void addFakeProcessors() {
                 if(getResourceCharacteristic().getResourceUnits().get(StandardResourceUnitName.PE) != null){
@@ -145 +146 @@
                 sec.execute(event);
 
-                
                 //old, correctly working method
                 /*if (extensionList != null) {
@@ -157 +157 @@
                 //if(scheduler != null && (parent != null && scheduler != parent.getScheduler())/*scheduler.getResources().contains(this)*/){
                 //      String src = event.getSource() != null ? event.getSource() : name;
-                //      scheduler.sendInternal(GridSimTags.SCHEDULE_NOW, GssimTags.UPDATE, src);
+                //      scheduler.sendInternal(GridSimTags.SCHEDULE_NOW, DCWormsTags.UPDATE, src);
                 //}
                 //triggerEventUp(event);
@@ -188 +188 @@
         }
         
-        protected List<? extends ComputingResource> searchDescendants(List<ResourceValidator> validators, boolean cutoff) {
+        protected List<? extends ComputingResource> searchDescendants(List<ResourceValidator> validators, boolean cutOff) {
 
                 List<ComputingResource> descendants = new ArrayList<ComputingResource>();
@@ -198 +198 @@
                                 ComputingResource resource = toExamine.pop();
                                 List<ComputingResource> resources = resource.getChildren();
-                                /*if (resources == null)
-                                        continue;*/
                                 int numberOfRes = resources.size();
                                 for (int i = 0; i < numberOfRes; i++) {
@@ -205 +203 @@
                                         if (resourceChild.match(validators)) {
                                                 descendants.add(resourceChild);
-                                                if(cutoff == false) {
+                                                if(cutOff == false) {
                                                         toExamine.addLast(resourceChild);
                                                 }
@@ -243 +241 @@
                 return null;
         }
+        
+        public AirThroughputInterface getAirThroughputInterface(){
+                if (extensionList != null) {
+                        for (Extension extension : extensionList) {
+                                if (extension.getType() == ExtensionType.ENERGY_EXTENSION) {
+                                        EnergyExtension ee = (EnergyExtension)extension;
+                                        return ee.getAirThroughputInterface();
+                                }
+                        }
+                }
+                return null;
+        }
 
         public Scheduler getScheduler() {
@@ -257 +267 @@
         }
 
-        class SimpleEventHandler implements EventHandler{
+        class ComputingResourceEventHandler implements EventHandler{
                 
                 public void handleResourceEvent(Event event){
@@ -275 +285 @@
                         if(scheduler != null && (parent != null && scheduler != parent.getScheduler())/*scheduler.getResources().contains(this)*/){
                                 String src = event.getSource() != null ? event.getSource() : name;
-                                scheduler.sendInternal(GridSimTags.SCHEDULE_NOW, WormsTags.UPDATE, src);
+                                scheduler.sendInternal(GridSimTags.SCHEDULE_NOW, DCWormsTags.UPDATE, src);
                         } else if(parent != null)
                                 parent.getEventHandler().handleSchedulingEvent(event);
@@ -282 +292 @@
         
         public EventHandler getEventHandler(){
-                return new SimpleEventHandler();
+                return new ComputingResourceEventHandler();
         }
         
         public void initiate(){
+                
                 ResourceEventCommand rec = new ResourceEventCommand(this);
-                EnergyEvent event = new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, "Resource controller");
+                EnergyEvent event = new EnergyEvent(EnergyEventType.AIRFLOW_STATE_CHANGED, "Resource controller");
                 event.setReason(EventReason.SIM_INIT);
                 rec.execute(event);
+                
+                rec = new ResourceEventCommand(this);
+                event = new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, "Resource controller");
+                event.setReason(EventReason.SIM_INIT);
+                rec.execute(event);
+                
                 //alternative way
+                //getEventHandler().handleResourceEvent(new EnergyEvent(EnergyEventType.AIRFLOW_STATE_CHANGED, "Resource controller"));
                 //getEventHandler().handleResourceEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, "Resource controller"));
         }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/Core.java

@@ -3 +3 @@
 import schedframe.resources.computing.description.ComputingResourceDescription;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
-import schedframe.resources.computing.profiles.energy.power.PowerProfileFactory;
+import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.resources.units.CpuSpeed;
@@ -13 +13 @@
         public Core (ComputingResourceDescription resDesc) {
                 super(resDesc);
-                PowerInterface pi = PowerProfileFactory.createPowerInterface(this, resDesc.getPowerProfile());
+                PowerInterface pi = PowerInterfaceFactory.createPowerInterface(this, resDesc.getPowerProfile());
                 accept(new EnergyExtension(pi, resDesc.getPowerProfile()));     
         }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/DataCenter.java

@@ -3 +3 @@
 import schedframe.resources.computing.description.ComputingResourceDescription;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
-import schedframe.resources.computing.profiles.energy.power.PowerProfileFactory;
+import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 
@@ -11 +11 @@
                 super(resDesc);
                 //extensionList.add(new EnergyExtension(this, resDesc.getPowerInterface(), resDesc.getEnergyEstimationPlugin()));
-                PowerInterface pi = PowerProfileFactory.createPowerInterface(this, resDesc.getPowerProfile());
+                PowerInterface pi = PowerInterfaceFactory.createPowerInterface(this, resDesc.getPowerProfile());
                 accept(new EnergyExtension(pi, resDesc.getPowerProfile()));
         }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/Processor.java

@@ -8 +8 @@
 import schedframe.resources.computing.extensions.ExtensionType;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
-import schedframe.resources.computing.profiles.energy.power.PowerProfileFactory;
+import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.resources.computing.profiles.energy.power.ui.ProcessorPowerInterface;
@@ -22 +22 @@
                 super(resDesc);
                 //extensionList.add(new EnergyExtension(this, resDesc.getPowerInterface(), resDesc.getEnergyEstimationPlugin()));
-                PowerInterface pi = PowerProfileFactory.createPowerInterface(this, resDesc.getPowerProfile());
+                PowerInterface pi = PowerInterfaceFactory.createPowerInterface(this, resDesc.getPowerProfile());
                 accept(new EnergyExtension(pi, resDesc.getPowerProfile()));     
         }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/Rack.java

@@ -6 +6 @@
 import schedframe.resources.computing.description.ComputingResourceDescription;
 import schedframe.resources.computing.profiles.energy.EnergyExtension;
-import schedframe.resources.computing.profiles.energy.power.PowerProfileFactory;
+import schedframe.resources.computing.profiles.energy.power.PowerInterfaceFactory;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 
@@ -14 +14 @@
         public Rack (ComputingResourceDescription resDesc) {
                 super(resDesc);
-                PowerInterface pi = PowerProfileFactory.createPowerInterface(this, resDesc.getPowerProfile());
+                PowerInterface pi = PowerInterfaceFactory.createPowerInterface(this, resDesc.getPowerProfile());
                 accept(new EnergyExtension(pi, resDesc.getPowerProfile()));     
         }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/ResourceFactory.java

@@ -11 +11 @@
 import schedframe.scheduling.policy.local.LocalManagementSystem;
 import schedframe.scheduling.queue.TaskQueueList;
-import simulator.WormsConstants;
+import simulator.DCWormsConstants;
 
 
@@ -20 +20 @@
                 if (resDesc.getType().equals(StandardResourceType.DataCenter))
                         return new DataCenter(resDesc);
+                else if (resDesc.getType().equals(StandardResourceType.Rack))
+                        return  new Rack(resDesc);
                 else if (resDesc.getType().equals(StandardResourceType.ComputingNode))
                         return  new ComputingNode(resDesc);
@@ -46 +48 @@
                         }
                         case LS: {
-                                ms = new LocalManagementSystem(id, WormsConstants.MANAGEMENT_SYSTEM,
+                                ms = new LocalManagementSystem(id, DCWormsConstants.MANAGEMENT_SYSTEM,
                                                 schedulingPlugin, execTimeEstimationPlugin, queues);
                                 return new Scheduler(ms, type, managedResources);
@@ -52 +54 @@
 
                 default:{
-                                ms = new LocalManagementSystem(id, WormsConstants.MANAGEMENT_SYSTEM,
+                                ms = new LocalManagementSystem(id, DCWormsConstants.MANAGEMENT_SYSTEM,
                                                 schedulingPlugin, execTimeEstimationPlugin, queues);
                                 return new Scheduler(ms, type, managedResources);

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/EnergyEventType.java

@@ -15 +15 @@
         FREQUENCY_CHANGED(64),
         VOLTAGE_CHANGED(128),
-        RESOURCE_FAILED(256)
+        
+        AIRFLOW_STATE_CHANGED(256),
+        
+        RESOURCE_FAILED(512)
         ;
 

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/EnergyExtension.java

@@ -11 +11 @@
 import schedframe.resources.computing.extensions.ExtensionException;
 import schedframe.resources.computing.extensions.ExtensionType;
+import schedframe.resources.computing.profiles.energy.airthroughput.AirThroughputProfile;
+import schedframe.resources.computing.profiles.energy.airthroughput.ui.AirThroughputInterface;
 import schedframe.resources.computing.profiles.energy.power.PowerProfile;
 import schedframe.resources.computing.profiles.energy.power.ui.PowerInterface;
 import schedframe.scheduling.manager.tasks.JobRegistryImpl;
 
-public class EnergyExtension implements Extension/*, ResourceVisitor */{
+public class EnergyExtension implements Extension{
 
         private Log log = LogFactory.getLog(EnergyExtension.class);
@@ -21 +23 @@
         protected PowerInterface powerInterface;
         protected PowerProfile powerProfile;
-
+        
+        protected AirThroughputInterface airFlowInterface;
+        protected AirThroughputProfile airFlowProfile;
+        
         protected ComputingResource computingResource;
 
@@ -29 +34 @@
         }
 
-        @Override
+        public EnergyExtension(PowerInterface powerInterface, PowerProfile powerProfile,
+                        AirThroughputInterface airFlowInterface, AirThroughputProfile airFlowProfile) {
+                super();
+                this.powerInterface = powerInterface;
+                this.powerProfile = powerProfile;
+                this.airFlowInterface = airFlowInterface;
+                this.airFlowProfile = airFlowProfile;
+        }
+
         public boolean supportsEvent(Event event) {
 
                 if(powerProfile == null || powerProfile.getEnergyEstimationPlugin() == null)
                         return false;
-                
                 if(event.getType().getName().equals(EnergyEventType.POWER_STATE_CHANGED.getName()))
                         return true;
@@ -43 +55 @@
                 else if(event.getType().getName().equals(EnergyEventType.TASK_FINISHED.getName()))
                         return true;
+                
+                if(airFlowProfile == null)
+                        return false;   
+                if(event.getType().getName().equals(EnergyEventType.AIRFLOW_STATE_CHANGED.getName()))
+                        return true;
+                
                 else return false;
 
         }
-        
 
-        @Override
         public void handleEvent(Event event) {
                 EnergyEvent enEvent = (EnergyEvent)event;
@@ -87 +103 @@
                         //System.out.println(this.resource.getName() + " - ESTIMATED ENERGY:" + power);
                         powerProfile.addToPowerUsageHistory(power);
-
+                        break;
+                case AIRFLOW_STATE_CHANGED:
+                        System.out.println("=====");
+                        double airFlow = powerProfile.getEnergyEstimationPlugin().estimateAirThroughput(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
+                        airFlowProfile.addToPowerUsageHistory(airFlow);
+                        power = powerProfile.getEnergyEstimationPlugin().estimatePowerConsumption(enEvent, new JobRegistryImpl(computingResource.getName()), computingResource);
+                        powerProfile.addToPowerUsageHistory(power);
                         break;
                 }
         }
-        
-        @Override
+
         public void init(Properties properties) throws ExtensionException {
                 // TODO Auto-generated method stub
         }
 
-        @Override
         public ExtensionType getType() {
                 return ExtensionType.ENERGY_EXTENSION;
@@ -118 +138 @@
         }
 
+        public AirThroughputInterface getAirThroughputInterface() {
+                return airFlowInterface;
+        }
+
+        public AirThroughputProfile getAirFlowProfile() {
+                return airFlowProfile;
+        }
 
 }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/airthroughput/AirThroughputProfile.java

@@ -1 +1 @@
 package schedframe.resources.computing.profiles.energy.airthroughput;
 
+import java.util.ArrayList;
 import java.util.List;
+
+import org.joda.time.DateTimeUtils;
 
 import schedframe.Parameters;
@@ -8 +11 @@
 public class AirThroughputProfile {
         
-        AirThroughputEstimationPlugin airThroughputEstimationPlugin;
+        protected List<AirFlowValue> airFlowHistory;
+        
+        protected AirThroughputEstimationPlugin airThroughputEstimationPlugin;
         protected List <AirThroughputState> airThroughputStates;
+        protected Parameters parameters;
 
         public AirThroughputProfile(AirThroughputEstimationPlugin airThroughputEstimationPlugin, List<AirThroughputState> airThroughputStates) {
@@ -15 +21 @@
                 this.airThroughputEstimationPlugin = airThroughputEstimationPlugin;
                 this.airThroughputStates = airThroughputStates;
+                this.airFlowHistory = new ArrayList<AirFlowValue>();
         }
 
@@ -21 +28 @@
         }
         
-        public void init(Parameters parameters){
-                
+        public void addToPowerUsageHistory(double airFlow) {
+
+                if (airFlowHistory.size() == 0) {
+                        AirFlowValue usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow);
+                        airFlowHistory.add(usage);
+                        return;
+                }
+
+                int lastIdx = airFlowHistory.size() - 1;
+                double lastAirFlow = airFlowHistory.get(lastIdx).getValue();
+                if (lastAirFlow != airFlow) {
+                        AirFlowValue usage = airFlowHistory.get(lastIdx);
+                        long currentTime = DateTimeUtils.currentTimeMillis();
+                        if (usage.getTimestamp() == currentTime) {
+                                usage.setValue(airFlow);
+                                if(lastIdx > 0 && airFlowHistory.get(lastIdx - 1).getValue() == airFlow)
+                                        airFlowHistory.remove(usage);
+                        } else {
+                                usage = new AirFlowValue(DateTimeUtils.currentTimeMillis(), airFlow);
+                                airFlowHistory.add(usage);
+                        }
+                }
+        }
+
+        public List<AirFlowValue> getAirThroughputHistory() {
+                return airFlowHistory;
+        }
+        
+        public void init(Parameters params){
+                this.parameters = params;
+        }
+
+        public Parameters getParameters() {
+                return parameters;
         }
 }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/PowerProfile.java

@@ -19 +19 @@
         protected Map<String, PState> supportedPStates;
         
+        protected Parameters parameters;
+        
 
-        public PowerProfile(EnergyEstimationPlugin energyEstimationPlugin, List<schedframe.resources.computing.profiles.energy.power.PowerState> supportedPowerStates) {
+        public PowerProfile(EnergyEstimationPlugin energyEstimationPlugin, List<PowerState> powerStates) {
                 this.energyEstimationPlugin = energyEstimationPlugin;
                 this.powerUsage = new ArrayList<PowerUsage>();
-                this.supportedPowerStates = supportedPowerStates;
+                this.supportedPowerStates = powerStates;
         }
         
-        public PowerProfile(EnergyEstimationPlugin energyEstimationPlugin, List<schedframe.resources.computing.profiles.energy.power.PowerState> supportedPowerStates,  List<schedframe.resources.computing.profiles.energy.power.PState> pStates) {
+        public PowerProfile(EnergyEstimationPlugin energyEstimationPlugin, List<PowerState> powerStates,  List<PState> pStates) {
                 this.energyEstimationPlugin = energyEstimationPlugin;
-                this.supportedPowerStates = supportedPowerStates;
+                this.supportedPowerStates = powerStates;
                 this.powerUsage = new ArrayList<PowerUsage>();
                 if(pStates.size() > 0)
@@ -98 +100 @@
         }
 
-        public void init(Parameters parameters){
-                
+        public void init(Parameters params){
+                this.parameters = params;
+        }
+        
+        public Parameters getParameters() {
+                return parameters;
         }
 
+
 }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/PowerUsage.java

@@ -1 +1 @@
 package schedframe.resources.computing.profiles.energy.power;
 
-public class PowerUsage {
+import schedframe.resources.computing.profiles.energy.MeasurementHistory;
 
-        protected long timestamp;
-        protected double value;
+public class PowerUsage extends MeasurementHistory{
 
         public PowerUsage(long timestamp, double value){
-                this.timestamp = timestamp;
-                this.value = value;
-        }
-        
-        public long getTimestamp() {
-                return timestamp;
-        }
-
-        public double getValue() {
-                return value;
-        }
-        
-        public void setValue(double value) {
-                this.value = value;
+                super(timestamp, value);
         }
         

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/plugin/EnergyEstimationPlugin.java

@@ -10 +10 @@
         public double estimatePowerConsumption(EnergyEvent event, JobRegistry jobRegistry, ComputingResource resource);
 
-        public double estimateEnergyDissipation(EnergyEvent event, JobRegistry jobRegistry, ComputingResource resource);
+        public double estimateAirThroughput(EnergyEvent event, JobRegistry jobRegistry, ComputingResource resource);
 
         public double estimateTemperature(EnergyEvent event, JobRegistry jobRegistry, ComputingResource resource);

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/ui/ComputingNodePowerInterface.java

@@ -10 +10 @@
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
 
-public class ComputingNodePowerInterface extends AbstractPowerInterface{
+public class ComputingNodePowerInterface extends ComputingResourcePowerInterface{
 
         public static long START_TIME = 600000;
@@ -28 +28 @@
                 currentPowerState = state;
                 ComputingNode computingNode = (ComputingNode) resource;
+                boolean pePowerStateChangeStatus = false;
                 if(computingNode.getProcessors() != null)
                 {
                         for(ComputingResource child:computingNode.getProcessors()){
-                                child.getPowerInterface().setPowerState(state);
+                                if(child.getPowerInterface() != null){
+                                        pePowerStateChangeStatus = child.getPowerInterface().setPowerState(state);      
+                                }
                         }
-                } else {
+                } 
+                
+                if(!pePowerStateChangeStatus){
                         computingNode.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, computingNode.getName()));
                 }
-                
+
                 if(state == StandardPowerStateName.OFF){
                         computingNode.setStatus(ResourceStatus.UNAVAILABLE);
@@ -46 +51 @@
                 return true;
         }
-        
-        /*public double getPowerConsumption(PowerState state) {
-                if(currentPowerState == PowerState.OFF)
-                        return 0;
-                else if(currentPowerState == PowerState.ON)
-                        return 750;
-                else return 500;
-        }*/
-
-        /*public boolean supportPowerState(PowerState state) {
-                switch(state){
-                        case ON: 
-                                return true;
-                        case OFF: 
-                                return true;
-                        case SLEEP: 
-                                return true;
-                        case HIBERNATE: 
-                                return true;
-                        default: 
-                                return false;
-                }
-        }
-
-        public List<PowerState> getSupportedPowerStates() {
-                return Arrays.asList(new PowerState[]{PowerState.ON, PowerState.OFF, PowerState.SLEEP, PowerState.HIBERNATE});
-        }*/
 
         public void turnOn(){

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/ui/DataCenterPowerInterface.java

@@ -7 +7 @@
 import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName;
 
-public class DataCenterPowerInterface extends AbstractPowerInterface{
+public class DataCenterPowerInterface extends ComputingResourcePowerInterface{
 
-
-
-        
         public DataCenterPowerInterface(ComputingResource resource, PowerProfile pp){
                 super(resource, pp);

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/ui/PowerInterface.java

@@ -3 +3 @@
 import java.util.List;
 
+import schedframe.Parameters;
 import schedframe.resources.computing.profiles.energy.power.PowerState;
 import schedframe.resources.computing.profiles.energy.power.PowerStateName;
@@ -25 +26 @@
         List<PowerUsage> getPowerUsageHistory();
         
+        public Parameters getParameters();
 }

DCWoRMS/trunk/build/classes/schedframe/resources/computing/profiles/energy/power/ui/ProcessorPowerInterface.java

@@ -1 +1 @@
 package schedframe.resources.computing.profiles.energy.power.ui;
+
+
+import gridsim.GridSimTags;
+import gridsim.dcworms.DCWormsTags;
 
 import java.util.Map;
 
-import schedframe.events.ResourceEventCommand;
 import schedframe.resources.ResourceStatus;
 import schedframe.resources.computing.ComputingResource;
-import schedframe.resources.computing.Processor;
 import schedframe.resources.computing.profiles.energy.EnergyEvent;
 import schedframe.resources.computing.profiles.energy.EnergyEventType;
@@ -16 +18 @@
 import schedframe.resources.units.StandardResourceUnitName;
 
-public class ProcessorPowerInterface extends AbstractPowerInterface {
+public class ProcessorPowerInterface extends ComputingResourcePowerInterface {
 
         protected PState currentPState;
@@ -36 +38 @@
                 if(powerState != currentPowerState){
                         currentPowerState = powerState;
-                        //Processor cpu = (Processor) resource;
                         if(powerState == StandardPowerStateName.OFF){
                                 resource.setStatus(ResourceStatus.UNAVAILABLE);
@@ -42 +43 @@
                                 resource.setStatus(ResourceStatus.FREE);
                         }
-                        resource.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, resource.getName()));
-                        //cpu.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, cpu.getName()));                 
+                        resource.handleEvent(new EnergyEvent(EnergyEventType.POWER_STATE_CHANGED, resource.getName()));         
                 }
 
@@ -79 +79 @@
 
                 if(newPState != currentPState){
-                        double factor = newPState.getFrequency()/currentPState.getFrequency();
+                        //double factor = newPState.getFrequency()/currentPState.getFrequency();
                         currentPState = newPState;
-                        CpuSpeed speed = (CpuSpeed)resource.getResourceCharacteristic().getResourceUnits().get(StandardResourceUnitName.CPUSPEED).get(0);
-                        speed.setAmount(Double.valueOf(currentPState.getFrequency()).intValue());
+                        //CpuSpeed speed = (CpuSpeed)resource.getResourceCharacteristic().getResourceUnits().get(StandardResourceUnitName.CPUSPEED).get(0);
+                        //speed.setAmount(Double.valueOf(currentPState.getFrequency()).intValue());
                         //new ResourceEventCommand(resource).execute(EnergyEventType.FREQUENCY_CHANGED);
                         resource.handleEvent(new EnergyEvent(EnergyEventType.FREQUENCY_CHANGED, resource.getName()));
-                        //resource.getScheduler().sendInternal(GridSimTags.SCHEDULE_NOW, GssimTags.UPDATE, resource.getName());
+                        //resource.getScheduler().sendInternal(GridSimTags.SCHEDULE_NOW, DCWormsTags.UPDATE, resource.getName());
                         return true;
                 }

DCWoRMS/trunk/build/classes/schedframe/resources/units/AbstractResourceUnit.java

@@ -78 +78 @@
         public ResourceUnitProvisioner getProvisioner() {
         return provisioner;
-
+        }
+        
+        public Parameters getParameters(){
+                return null;
         }
 

DCWoRMS/trunk/build/classes/schedframe/resources/units/ResourceUnit.java

@@ -23 +23 @@
         public void init(Parameters parameters);
         
+        public Parameters getParameters();
+        
         public ResourceUnitProvisioner getProvisioner();
 }