Changeset 1357 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy

Timestamp:

04/23/14 14:35:44 (11 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy

Files:

• global/GlobalManagementSystem.java (modified) (1 diff)
• local/LocalManagementSystem.java (modified) (4 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/policy/global/GlobalManagementSystem.java

@@ -250 +250 @@
         }
 
-        class GlobalWorkloadUnitHandler implements  WorkloadUnitHandler{
+        class GlobalWorkloadUnitHandler implements WorkloadUnitHandler{
 
                 public void handleJob(JobInterface<?> job){

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

@@ -256 +256 @@
                 
                 PEUnit peUnit = (PEUnit)choosenResources.get(StandardResourceUnitName.PE);
-                notifyComputingResources(peUnit, EnergyEventType.TASK_STARTED, exec);
+                updateComputingResources(peUnit, EnergyEventType.TASK_STARTED, exec);
                 
                 updateTaskExecution(exec, SchedulingEventType.START_TASK_EXECUTION);
@@ -311 +311 @@
                 
                 PEUnit peUnit = (PEUnit)lastUsed.get(StandardResourceUnitName.PE);
-                notifyComputingResources(peUnit, EnergyEventType.TASK_FINISHED, exec);
+                updateComputingResources(peUnit, EnergyEventType.TASK_FINISHED, exec);
         }
         
@@ -342 +342 @@
         }
         
-        private void notifyComputingResources(PEUnit peUnit, EnergyEventType eventType, Object obj){
+        private void updateComputingResources(PEUnit peUnit, EnergyEventType eventType, Object obj){
                 if(peUnit instanceof ProcessingElements){
                         ProcessingElements pes = (ProcessingElements) peUnit;
@@ -427 +427 @@
                                 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);
+                                updateComputingResources(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);
+                                updateComputingResources(peUnit, EnergyEventType.RESOURCE_UTILIZATION_CHANGED, exec);
                         }
                 }