Changeset 262

Timestamp:

04/13/12 07:11:40 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/branches/tpiontek/src/test/rewolucja/scheduling/implementation/LocalManagementSystem.java (modified) (4 diffs)

xssim/branches/tpiontek/src/test/rewolucja/scheduling/implementation/LocalManagementSystem.java

@@ -29 +29 @@
 import org.qcg.broker.schemas.schedulingplan.types.AllocationStatus;
 
+import schedframe.resources.PowerState;
 import schedframe.resources.units.ResourceUnit;
 import schedframe.scheduling.events.SchedulingEvent;
@@ -176 +177 @@
                         updateProcessingTimes(ev);
                         break;
+                case GssimTags.START:
+                case GssimTags.SHUTDOWN:
+                        changeResourcePowerState(ev);
+                        if (pluginSupportsEvent(tag)) {
+                                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.POWER_STATE_CHANGED);
+                                SchedulingPlanInterfaceNew decision = schedulingPlugin.schedule(event,
+                                                queues, getJobRegistry(), getResourceManager(), moduleList);
+                                executeSchedulingPlan(decision);
+                        }
+                        break;
                 }
         }
@@ -440 +451 @@
                         return servedEvent.containsKey(SchedulingEventType.TASK_REQUESTED_TIME_EXPIRED);
 
+                case GssimTags.START:
+                        return true;
+                case GssimTags.SHUTDOWN:
+                        return true;
                 default:
                         return false;
@@ -528 +543 @@
         }
 
-        
+        private void changeResourcePowerState(Sim_event ev) {
+                String resName = (String)ev.get_data();
+                ComputingResource resource = null;
+                try {
+                        resource = resourceManager.getResourceByName(resName);
+                } catch (ResourceException e) {
+                        return;
+                }
+                switch(ev.get_tag()){
+                case GssimTags.START:
+                        resource.getPowerInterface().setPowerState(PowerState.ON);
+                        break;
+                case GssimTags.SHUTDOWN:
+                        resource.getPowerInterface().setPowerState(PowerState.OFF);
+                        break;
+                default: break;
+                        
+                }
+                
+        }
 }