Changeset 497 for DCWoRMS/trunk/src/example/localplugin

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/trunk/src/example/localplugin

Files:

• FCFSCPUFreqScalingClusterLocalPlugin.java (modified) (1 diff)
• FCFSClusterLocalPlugin.java (modified) (3 diffs)
• FCFSConsolidationClusterLocalPlugin.java (modified) (1 diff)
• FCFSEnergyAwareClusterLocalPlugin.java (deleted)
• FCFSNodePowerManagementClusterLocalPlugin.java (modified) (3 diffs)
• FCFSRackLocalPlugin.java (moved) (moved from DCWoRMS/trunk/src/example/localplugin/RackLocalPlugin.java) (2 diffs)
• FCFSRandomClusterLocalPlugin.java (modified) (3 diffs)

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

@@ -187 +187 @@
                 }
         }
-        
-        public String getName() {
-                return getClass().getName();
-        }
 
 }

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

@@ -57 +57 @@
                                         
                                         /****************1. Choosing particular resources to perform execution****************/
-                                        Map<ResourceUnitName, ResourceUnit> choosenResources = chooseResourcesForExecution2(resourceManager, task);
+                                        Map<ResourceUnitName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, task);
                                         if (choosenResources != null) {
                                                 addToSchedulingPlan(plan, task, choosenResources);
@@ -80 +80 @@
 
         private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(
-                        ClusterResourceManager resourceManager, TaskInterface<?> task) {
-
-                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>();
-
-                int cpuRequest;
-                try {
-                        cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
-                } catch (NoSuchFieldException e) {
-                        cpuRequest = 1;
-                }
-
-                if (cpuRequest != 0) {
-                        List<ComputingResource> choosenResources = null;
-                        List<Processor> processors = null;
-                        processors = resourceManager.getProcessors();
-                        if (processors.size() < cpuRequest) {
-                                // log.warn("Task requires more cpus than is availiable in this resource.");
-                                return null;
-                        }
-
-                        choosenResources = new ArrayList<ComputingResource>();
-
-                        for (int i = 0; i < processors.size() && cpuRequest > 0; i++) {
-                                if (processors.get(i).getStatus() == ResourceStatus.FREE) {
-                                        choosenResources.add(processors.get(i));
-                                        cpuRequest--;
-                                }
-                        }
-                        if (cpuRequest > 0) {
-                                // log.info("Task " + task.getJobId() + "_" + task.getId() +
-                                // " requires more cpus than is availiable in this moment.");
-                                return null;
-                        }
-
-                        ProcessingElements result = new ProcessingElements(processors.get(0).getParent().getName());
-                        result.addAll(choosenResources);
-                        map.put(StandardResourceUnitName.PE, result);
-
-                }
-                int memoryRequest;
-                try {
-                        memoryRequest = Double.valueOf(task.getMemoryRequest()).intValue();
-                } catch (NoSuchFieldException e) {
-                        memoryRequest = 0;
-                }
-                if (memoryRequest != 0) {
-                        List<ComputingNode> nodes = resourceManager.getComputingNodes();
-
-                        Memory memory = null;
-                        for (ComputingNode node : nodes) {
-                                try{
-                                        if (node.getFreeMemory() >= memoryRequest) {            
-                                                memory = new Memory(node.getMemory(), memoryRequest, memoryRequest);
-                                        }               
-                                } catch(NoSuchFieldException e){
-                                        memory = null;
-                                }
-                        }
-                        if(memory != null)
-                                map.put(StandardResourceUnitName.MEMORY, memory);
-                        else return null;
-                }
-
-                return map;
-        }
-
-
-        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution2(
                         ClusterResourceManager resourceManager, TaskInterface<?> task) {
 
@@ -204 +136 @@
                                                 return map;
                                         }
-                                }
+                                } else return map;
                         }
                 }

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

@@ -140 +140 @@
                 return suitableNodes;
         }
-        
-        public String getName() {
-                return getClass().getName();
-        }
 
 }

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

@@ -40 +40 @@
                 ClusterResourceManager resourceManager = (ClusterResourceManager) resManager;
                 SchedulingPlan plan = new SchedulingPlan();
-                // chose the events types to serve.
-                // Different actions for different events are possible.
+
                 switch (event.getType()) {
                 case START_TASK_EXECUTION:
                 case TASK_FINISHED:
-                        // our tasks are placed only in first queue (see
-                        // 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);
                                 TaskInterface<?> task = (TaskInterface<?>) job;
-                                // if status of the tasks in READY
                                 if (task.getStatus() == DCWormsTags.READY) {
 
@@ -65 +61 @@
                                 }
                         }
-
                         turnOffIdleNodes(resourceManager.getComputingNodes());
-
                         break;
                 }
@@ -151 +145 @@
                 return cpuRequest > 0 ? false : true;
         }
-        
-        public String getName() {
-                return getClass().getName();
-        }
-
 
 }

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

@@ -14 +14 @@
 import schedframe.scheduling.tasks.WorkloadUnit;
 
-public class RackLocalPlugin  extends BaseLocalSchedulingPlugin {
+public class FCFSRackLocalPlugin  extends BaseLocalSchedulingPlugin {
 
-        public RackLocalPlugin() {
+        public FCFSRackLocalPlugin() {
         }
 
@@ -53 +53 @@
         }
 
-        
-        public String getName() {
-                return getClass().getName();
-        }
-
 
 }

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();
-        }
-
 
 }