Changeset 531 for DCWoRMS/trunk/src/example/localplugin/FCFSBF_DFSClusterPlugin.java

Timestamp:

10/30/12 11:11:14 (12 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/trunk/src/example/localplugin/FCFSBF_DFSClusterPlugin.java (modified) (5 diffs)

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

@@ -28 +28 @@
 public class FCFSBF_DFSClusterPlugin extends BaseLocalSchedulingPlugin {
 
-        List<Processor> allocatedCPUs;
-        public FCFSBF_DFSClusterPlugin () {
-                allocatedCPUs = new ArrayList<Processor>();
-        }
-
         public SchedulingPlanInterface<?> schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
                         ResourceManager resManager, ModuleList modules) {
@@ -39 +34 @@
                 SchedulingPlan plan = new SchedulingPlan();
                 // our tasks are placed only in first queue (see
-                // BaseLocalPlugin.placeJobsInQueues() method)
+                // BaseLocalSchedulingPlugin.placeJobsInQueues() method)
                 TaskQueue q = queues.get(0);
                 // chose the events types to serve.
@@ -73 +68 @@
                         cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
                 } catch (NoSuchFieldException e) {
-                        cpuRequest = 1;
+                        cpuRequest = 0;
                 }
 
@@ -79 +74 @@
                         List<ComputingResource> choosenResources = null;
                         List<Processor> processors = resourceManager.getProcessors();
-                        processors.removeAll(allocatedCPUs);
                         if (processors.size() < cpuRequest) {
                                 // log.warn("Task requires more cpus than is availiable in this resource.");
@@ -117 +111 @@
                                         cpu.getPowerInterface().setPState("P0");
                         }
-
                 }
-
         }
 
-
 }