Changeset 497 for DCWoRMS/trunk/src/example/localplugin/FCFSRandomClusterLocalPlugin.java

Timestamp:

10/11/12 09:07:11 (13 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/example/localplugin/FCFSRandomClusterLocalPlugin.java (modified) (3 diffs)

DCWoRMS/trunk/src/example/localplugin/FCFSRandomClusterLocalPlugin.java

@@ -41 +41 @@
                         // BaseLocalPlugin.placeJobsInQueues() method)
                         TaskQueue q = queues.get(0);
+                        
                         // check all tasks in queue
-
                         for (int i = 0; i < q.size(); i++) {
                                 WorkloadUnit job = q.get(i);
@@ -48 +48 @@
                                 // if status of the tasks in READY
                                 if (task.getStatus() == DCWormsTags.READY) {
-                                        /*for(ResourceUnitName key:resManager.getSharedResourceUnits().keySet()){
-                                                System.out.println(key.getName());
-                                        }*/
-                                        addToSchedulingPlan(plan, task);
-                                        /*String nodeName = chooseRandomProvider(resourceManager);
+
+                                        String nodeName = chooseRandomProvider(resourceManager);
                                         if (nodeName != null) {
                                                 addToSchedulingPlan(plan, task, nodeName);
-                                        }*/
+                                        }
                                 }
                         }
@@ -68 +65 @@
                 return nodes.get(nodeIdx).getName();
         }
-        
-        public String getName() {
-                return getClass().getName();
-        }
-
 
 }