Changeset 1207 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local

Timestamp:

11/26/13 11:56:07 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java (modified) (6 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/local/LocalManagementSystem.java

@@ -24 +24 @@
 
 import qcg.shared.constants.BrokerConstants;
-import schedframe.ResourceController;
+import schedframe.SimulatedEnvironment;
 import schedframe.events.scheduling.SchedulingEvent;
 import schedframe.events.scheduling.SchedulingEventType;
@@ -323 +323 @@
                         ExecTask task = iter.next();
                         Executable exec = (Executable)task;
-                        //exec.setCompletionPercentage(exec.getCompletionPercentage() + 100 * timeSpan/exec.getEstimatedDuration());
                         exec.setCompletionPercentage(exec.getCompletionPercentage() + 100 * (timeSpan / exec.getEstimatedDuration()));
                         UsedResourcesList usedResourcesList = exec.getUsedResources();
@@ -338 +337 @@
                         for (ComputingResource resource : pes) {
                                 resource.handleEvent(new EnergyEvent(eventType, obj));
+                                //DataCenterWorkloadSimulator.getEventManager().sendToResources(resource.getType(), 0, new EnergyEvent(eventType, obj));
                         }
                         /*try {
@@ -350 +350 @@
                         ComputingResource resource = null;
                         try {
-                                resource = ResourceController.getComputingResourceByName(peUnit.getResourceId());
+                                resource = SimulatedEnvironment.getComputingResourceByName(peUnit.getResourceId());
                         } catch (ResourceException e) {
                                 return;
@@ -428 +428 @@
                         if(exec.getResourceConsumptionProfile().getCurrentResourceConsumption() == exec.getResourceConsumptionProfile().getResourceConsumptionList().getLast()){
                                 scheduler.sendInternal(phaseDuration, DCWormsTags.TASK_EXECUTION_FINISHED, execTask);
+                                PEUnit peUnit = (PEUnit)exec.getUsedResources().getLast().getResourceUnits().get(StandardResourceUnitName.PE);
+                                notifyComputingResources(peUnit, EnergyEventType.RESOURCE_UTILIZATION_CHANGED, exec);
                         } else {
                                 scheduler.sendInternal(phaseDuration, DCWormsTags.TASK_EXECUTION_CHANGED, execTask);
+                                PEUnit peUnit = (PEUnit)exec.getUsedResources().getLast().getResourceUnits().get(StandardResourceUnitName.PE);
+                                notifyComputingResources(peUnit, EnergyEventType.RESOURCE_UTILIZATION_CHANGED, exec);
                         }
                 }
@@ -540 +544 @@
                                         job.setStatus((int)BrokerConstants.JOB_STATUS_SUBMITTED);
                         } catch (Exception e) {
-                                // TODO Auto-generated catch block
                                 e.printStackTrace();
                         }