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

Timestamp:

09/18/14 17:37:54 (11 years ago)

Author:

wojtekp

Message:

 

File:

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

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

@@ -95 +95 @@
 
                 int tag = ev.get_tag();
+                SchedulingEvent event;
+                SchedulingPlanInterface<?> decision;
                 switch (tag) {
-
                 case DCWormsTags.TIMER:
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TIMER);
-                                SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event, 
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
+
+                        event = new SchedulingEvent(SchedulingEventType.TIMER);
+                        decision =  schedulingPlugin.schedule(event, 
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+
                         sendTimerEvent();
                         break;
@@ -111 +112 @@
                         try {
                                 execTask.setStatus(DCWormsTags.READY);
-                                if (pluginSupportsEvent(tag)) {
-                                        SchedulingEvent event = new StartTaskExecutionEvent(execTask.getJobId(), execTask.getId());
-                                        SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event,
-                                                        queues, jobRegistry, getResourceManager(), moduleList);
-                                        executeSchedulingPlan(decision);
-                                }
+
+                                event = new StartTaskExecutionEvent(execTask.getJobId(), execTask.getId());
+                                decision =  schedulingPlugin.schedule(event,
+                                                queues, jobRegistry, getResourceManager(), moduleList);
+                                executeSchedulingPlan(decision);
+
                         } catch (Exception e) {
                                 e.printStackTrace();
@@ -128 +129 @@
                                 finalizeExecutable(execTask);
                                 sendFinishedWorkloadUnit(execTask);
-                                if (pluginSupportsEvent(tag)) {
-                                        SchedulingEvent event = new TaskFinishedEvent(execTask.getJobId(), execTask.getId());
-                                        SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                        queues, jobRegistry, getResourceManager(), moduleList);
-                                        executeSchedulingPlan(decision);
-                                }
+                                event = new TaskFinishedEvent(execTask.getJobId(), execTask.getId());
+                                decision = schedulingPlugin.schedule(event,
+                                                queues, jobRegistry, getResourceManager(), moduleList);
+                                executeSchedulingPlan(decision);
                         }
 
@@ -155 +154 @@
                 case DCWormsTags.TASK_REQUESTED_TIME_EXPIRED:
                         execTask = (Executable) ev.get_data();
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new TaskRequestedTimeExpiredEvent(execTask.getJobId(), execTask.getId());
-                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
+                        event = new TaskRequestedTimeExpiredEvent(execTask.getJobId(), execTask.getId());
+                        decision = schedulingPlugin.schedule(event,
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
                         break;
                         
@@ -167 +164 @@
                         execTask = jobRegistry.getTask(ids[0], ids[1]);
                         pauseTask(execTask);
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new TaskPausedEvent(ids[0], ids[1]);
-                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
-                }
-                break;
+        
+                        event = new TaskPausedEvent(ids[0], ids[1]);
+                        decision = schedulingPlugin.schedule(event,
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+                        }
+                        break;
                 
                 case DCWormsTags.TASK_RESUME:{
@@ -180 +176 @@
                         execTask = jobRegistry.getTask(ids[0], ids[1]);
                         resumeTask(execTask, execTask.getAllocatedResources().getLast().getResourceUnits(), true);
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new TaskResumedEvent(ids[0], ids[1]);
-                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
-                }
-                break;
+                        event = new TaskResumedEvent(ids[0], ids[1]);
+                        decision = schedulingPlugin.schedule(event,
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+                        }
+                        break;
                 
                 case DCWormsTags.TASK_MIGRATE:{
@@ -195 +189 @@
                                         (String)data[1]), execTask, execTask.getAllocatedResources().getLast().getResourceUnits(), (Map<ResourceUnitName, ResourceUnit>)data[2]);
                         scheduler.sendInternal(migrationTime, DCWormsTags.TASK_MOVE, data);
-                }
-                break;
+                        }
+                        break;
                 
                 case DCWormsTags.TASK_MOVE:{
@@ -202 +196 @@
                         execTask = jobRegistry.getTask((String)data[0], (String)data[1]);
                         moveTask(execTask, (Map<ResourceUnitName, ResourceUnit>)data[2]);
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new StartTaskExecutionEvent((String)data[0], (String)data[1]);
-                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
-                }
-                break;
-                        
+
+                        event = new StartTaskExecutionEvent((String)data[0], (String)data[1]);
+                        decision = schedulingPlugin.schedule(event,
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+                        }
+                        break;
+                        
+                case DCWormsTags.RESOURCE_POWER_STATE_CHANGED:
+                        event = new SchedulingEvent(SchedulingEventType.RESOURCE_POWER_STATE_CHANGED);
+                        decision =  schedulingPlugin.schedule(event, 
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+                        break;
+
+                case DCWormsTags.RESOURCE_POWER_LIMIT_EXCEEDED:
+                        event = new SchedulingEvent(SchedulingEventType.RESOURCE_POWER_LIMIT_EXCEEDED);
+                        String source;
+                        try{
+                                source = ev.get_data().toString();
+                        } catch(Exception e){
+                                source = null;
+                        }
+                        event.setSource(source);
+                        decision = schedulingPlugin.schedule(event,
+                                        queues, jobRegistry, getResourceManager(), moduleList);
+                        executeSchedulingPlan(decision);
+                        break;
                 case DCWormsTags.TASK_EXECUTION_CHANGED:
                         execTask = (ExecTask) ev.get_data();
                         updateTaskExecutionPhase(execTask);
                         break;
-
                 case DCWormsTags.UPDATE_PROCESSING:
                         updateProcessingTimes();
                         break;
                         
-                case DCWormsTags.POWER_LIMIT_EXCEEDED:
-                        if (pluginSupportsEvent(tag)) {
-                                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.POWER_LIMIT_EXCEEDED);
-                                String source;
-                                try{
-                                        source = ev.get_data().toString();
-                                } catch(Exception e){
-                                        source = null;
-                                }
-                                event.setSource(source);
-                                SchedulingPlanInterface<?> decision = schedulingPlugin.schedule(event,
-                                                queues, jobRegistry, getResourceManager(), moduleList);
-                                executeSchedulingPlan(decision);
-                        }
-                        break;
                 default:                
-                        
                         break;
                 }
@@ -301 +297 @@
         
         public void notifyReturnedWorkloadUnit(WorkloadUnit wu) {
-                if (pluginSupportsEvent(DCWormsTags.TASK_EXECUTION_FINISHED)) {
-                        SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_FINISHED);
-                        SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event,
-                                        queues, jobRegistry, getResourceManager(), moduleList);
-                        executeSchedulingPlan(decision);
-                }
-                //if(scheduler.getParent() != null){
-                        sendFinishedWorkloadUnit(wu);
-                //}
+
+                SchedulingEvent event = new SchedulingEvent(SchedulingEventType.TASK_FINISHED);
+                SchedulingPlanInterface<?> decision =  schedulingPlugin.schedule(event,
+                                queues, jobRegistry, getResourceManager(), moduleList);
+                executeSchedulingPlan(decision);
+
+        //if(scheduler.getParent() != null){
+                sendFinishedWorkloadUnit(wu);
+        //}
         }