Changeset 143 for xssim/trunk/src

Timestamp:

03/15/12 16:06:56 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/trunk/src/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java (modified) (8 diffs)

xssim/trunk/src/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java

@@ -15 +15 @@
 import schedframe.scheduling.events.SchedulingEvent;
 import schedframe.scheduling.events.TaskFinishedEvent;
+import schedframe.scheduling.events.TaskRequestedTimeExpiredEvent;
 import schedframe.scheduling.plugin.grid.ModuleList;
 import schedframe.scheduling.utils.ResourceParameterName;
@@ -33 +34 @@
 public class FCFSCPUFreqScalingClusterLocalPlugin extends BaseLocalPlugin {
 
+        List<CPU> allocatedCPUs;
         public FCFSCPUFreqScalingClusterLocalPlugin () {
+                allocatedCPUs = new ArrayList<CPU>();
         }
 
@@ -79 +82 @@
                         for(ComputingResource res : pes){
                                 processors.add((CPU) res);
+                                allocatedCPUs.add((CPU) res);
                         }
                         adjustFrequency(ResourceStatus.FREE, processors);
@@ -84 +88 @@
                         
                 case TASK_REQUESTED_TIME_EXPIRED:
+                        TaskRequestedTimeExpiredEvent timExpEvent = (TaskRequestedTimeExpiredEvent) event;
+                         subTask = jobRegistry.getSubmittedTask(timExpEvent.getJobId(), timExpEvent.getTaskId());
+                        usedResourcesList = subTask.getUsedResources();
+                        pes = (ProcessingElements)usedResourcesList.get(usedResourcesList.size() - 1).getResourceUnits().get(ResourceParameterName.PROCESSINGELEMENTS);
+                        processors =  new ArrayList<CPU>();
+                        for(ComputingResource res : pes){
+                                allocatedCPUs.remove((CPU) res);
+                        }
                         // check all tasks in queue
                         for (int i = 0; i < q.size(); i++) {
@@ -94 +106 @@
                                         if (choosenResources  != null) {
                                                 addToSchedulingPlan(plan, task, choosenResources);
-                                                 pes = (ProcessingElements)choosenResources.get(ResourceParameterName.PROCESSINGELEMENTS);
+                                                pes = (ProcessingElements)choosenResources.get(ResourceParameterName.PROCESSINGELEMENTS);
                                                 processors =  new ArrayList<CPU>();
                                                 for(ComputingResource res : pes){
                                                         processors.add((CPU) res);
                                                 }
-                                                adjustFrequency(ResourceStatus.BUSY,processors);
+                                                adjustFrequency(ResourceStatus.BUSY, processors);
                                         } 
                                 }
@@ -123 +135 @@
                         List<ComputingResource> choosenResources = null;
                         List<CPU> processors = resourceManager.getProcessors();
+                        processors.removeAll(allocatedCPUs);
                         if (processors.size() < cpuRequest) {
                                 // log.warn("Task requires more cpus than is availiable in this resource.");
@@ -142 +155 @@
                         }
 
-                        ProcessingElements result = new ProcessingElements(processors.get(0).getParent().getParent().getName());
+                        ProcessingElements result = new ProcessingElements();
                         result.addAll(choosenResources);
                         map.put(ResourceParameterName.PROCESSINGELEMENTS, result);
@@ -153 +166 @@
                 case BUSY:
                         for(CPU cpu: processors){
-                                cpu.getPowerInterface().setPState(PStateType.P0);
+                                if(cpu.getPowerInterface().getSupportedPStates().containsKey(PStateType.P0))
+                                        cpu.getPowerInterface().setPState(PStateType.P0);
                         }
                         break;
                 case FREE:
                         for(CPU cpu: processors){
-                                cpu.getPowerInterface().setPState(PStateType.P3);
+                                if(cpu.getPowerInterface().getSupportedPStates().containsKey(PStateType.P3))
+                                        cpu.getPowerInterface().setPState(PStateType.P3);
                         }
                         break;