Changeset 495 for DCWoRMS/trunk/src/schedframe/resources/computing/ComputingResource.java

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/schedframe/resources/computing/ComputingResource.java (modified) (9 diffs)

DCWoRMS/trunk/src/schedframe/resources/computing/ComputingResource.java

@@ -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) {
@@ -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){
@@ -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"));
         }