Changeset 539 for DCWoRMS/trunk/build/classes/example/globalplugin/GridFCFSLoadBalancingPlugin.java

Timestamp:

10/31/12 13:52:06 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/build/classes/example/globalplugin/GridFCFSLoadBalancingPlugin.java (modified) (4 diffs)

DCWoRMS/trunk/build/classes/example/globalplugin/GridFCFSLoadBalancingPlugin.java

@@ -19 +19 @@
 import schedframe.scheduling.plugin.grid.ModuleList;
 import schedframe.scheduling.plugin.grid.ResourceDiscovery;
+import schedframe.scheduling.queue.QueueDescription;
 import schedframe.scheduling.queue.TaskQueue;
-import schedframe.scheduling.queue.QueueDescription;
 import schedframe.scheduling.queue.TaskQueueList;
 import schedframe.scheduling.tasks.TaskInterface;
@@ -29 +29 @@
         private Log log = LogFactory.getLog(GridFCFSLoadBalancingPlugin.class);
         
-        public SchedulingPlanInterface schedule(SchedulingEvent event,
+        public SchedulingPlanInterface<?> schedule(SchedulingEvent event,
                         TaskQueueList queues, 
                         JobRegistry jobRegistry,
@@ -53 +53 @@
                 
                 for(int i = 0; i < size; i++) {
-                        WorkloadUnit<?> job = q.remove(0);
+                        WorkloadUnit job = q.remove(0);
                         TaskInterface<?> task = (TaskInterface<?>)job;
 
@@ -74 +74 @@
         }
 
-        public String getName() {
-                return getClass().getName();
-        }
-
-        public void init(Properties properties) {
-                // no extra initialization is expected.
-        }
-        
         private int findLeastLoadedResourceIdx(List<SchedulerDescription> availableResources){
-                
                 int resourceIdx = -1;
                 long minLoad = Long.MAX_VALUE;
+                
                 for(int i = 0; i < availableResources.size(); i++){
                         SchedulerDescription sd = availableResources.get(i);