Changeset 539 for DCWoRMS/trunk/build/classes/schedframe/resources/computing/ComputingResource.java

Timestamp:

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

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/schedframe/resources/computing/ComputingResource.java (modified) (12 diffs)

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