Changeset 1551 for DCWoRMS/branches

Timestamp:

02/25/15 11:52:48 (10 years ago)

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src

Files:

• schedframe/scheduling/manager/tasks/AbstractJobRegistry.java (modified) (1 diff)
• simulator/EventManager.java (modified) (1 diff)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/tasks/AbstractJobRegistry.java

@@ -135 +135 @@
                         data[1] = new String(taskId);
                         data[2] = choosenResources;
-                        DataCenterWorkloadSimulator.getEventManager().sendToAllSchedulers(0, DCWormsTags.TASK_MIGRATE, data);
+                        DataCenterWorkloadSimulator.getEventManager().sendToScheduler(execTask.getSchedulerName(), 0, DCWormsTags.TASK_MIGRATE, data);
                         return true;    
                 }

DCWoRMS/branches/coolemall/src/simulator/EventManager.java

@@ -121 +121 @@
         }
         
+        public void sendToScheduler(String name, double delay, int tag, Object data){
+                Scheduler scheduler = null;
+                if(simEnv.getScheduler().getFullName().equals(name))
+                        scheduler = simEnv.getScheduler();
+                else if (simEnv.getScheduler().getChildren() != null) {
+                        LinkedList<Scheduler> toExamine = new LinkedList<Scheduler>();
+                        toExamine.push(simEnv.getScheduler());
+
+                        while (!toExamine.isEmpty()) {
+                                Scheduler sched = toExamine.pop();
+                                List<Scheduler> schedulers = sched.getChildren();
+                                int numberOfSched = schedulers.size();
+                                for (int i = 0; i < numberOfSched; i++) {
+                                        Scheduler schedulerChild = schedulers.get(i);
+                                        toExamine.addLast(schedulerChild);
+                                        if(schedulerChild.getFullName().equals(name)){
+                                                scheduler = schedulerChild;
+                                                break;
+                                        }
+                                }
+                        }
+                }
+                if(scheduler != null){
+                        super.send(scheduler.get_id(), delay, tag, data);
+                }
+
+        }
+        
         public void sendToResources(ResourceType type, double delay, ResourceEvent event){
                 List<ComputingResource> computingResources = new ArrayList<ComputingResource>();