Changeset 481 for DCWoRMS/trunk/src/schedframe/scheduling/Scheduler.java

Timestamp:

10/08/12 10:23:45 (13 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/schedframe/scheduling/Scheduler.java (modified) (6 diffs)

DCWoRMS/trunk/src/schedframe/scheduling/Scheduler.java

@@ -8 +8 @@
 import gridsim.GridSimTags;
 import gridsim.IO_data;
-import gridsim.gssim.WormsTags;
+import gridsim.gssim.DCWormsTags;
 
 import java.util.ArrayList;
@@ -28 +28 @@
 import schedframe.scheduling.manager.resources.ManagedResources;
 import schedframe.scheduling.policy.AbstractManagementSystem;
+import schedframe.scheduling.queue.QueueDescription;
 import schedframe.scheduling.queue.TaskQueue;
-import schedframe.scheduling.queue.QueueDescription;
 import schedframe.scheduling.tasks.WorkloadUnit;
 
@@ -117 +117 @@
                                 if (obj != null) {
                                         int delay = (Integer) obj;
-                                        send(this.get_id(), delay, WormsTags.TIMER);
+                                        send(this.get_id(), delay, DCWormsTags.TIMER);
                                 }
                         }
@@ -174 +174 @@
         protected void processOtherRequest(Sim_event ev) {
                 switch (ev.get_tag()) {
-                case WormsTags.QUERY_RESOURCE_DESC:
+                case DCWormsTags.QUERY_RESOURCE_DESC:
                         SchedulerDescription desc = new SchedulerDescription(new LocalSystem(get_name(), null, null));
                         Map<ResourceUnitName, List<ResourceUnit>> units = managementSystem.getResourceManager().getSharedResourceUnits();
@@ -181 +181 @@
 
                         IO_data data = new IO_data(desc, 0, ev.get_src());
-                        send(ev.get_src(), GridSimTags.SCHEDULE_NOW, WormsTags.QUERY_RESOURCE_DESC_RESULT, data);
+                        send(ev.get_src(), GridSimTags.SCHEDULE_NOW, DCWormsTags.QUERY_RESOURCE_DESC_RESULT, data);
                         break;
 
@@ -271 +271 @@
         public List<QueueDescription> getQueuesDescription(){
                 List<QueueDescription> queues = new ArrayList<QueueDescription>();
-                for(TaskQueue queue: managementSystem.getAccessQueues()){
+                for(TaskQueue queue: managementSystem.getQueues()){
                         QueueDescription qd;
                         try {