Changeset 241 for xssim/branches/tpiontek/src/example/localplugin/FCFSRandomClusterLocalPlugin.java

Timestamp:

04/11/12 16:30:38 (13 years ago)

Author:

piontek

Message:

 

File:

• xssim/branches/tpiontek/src/example/localplugin/FCFSRandomClusterLocalPlugin.java (modified) (6 diffs)

xssim/branches/tpiontek/src/example/localplugin/FCFSRandomClusterLocalPlugin.java

@@ -3 +3 @@
 import gridsim.Gridlet;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Properties;
@@ -11 +12 @@
 import schedframe.scheduling.plugin.grid.ModuleList;
 import test.rewolucja.GSSIMJobInterface;
+import test.rewolucja.energy.profile.PStateType;
 import test.rewolucja.resources.manager.implementation.ClusterResourceManager;
 import test.rewolucja.resources.manager.interfaces.ResourceManagerInterface;
 import test.rewolucja.resources.physical.implementation.ComputingNode;
+import test.rewolucja.resources.physical.implementation.Processor;
 import test.rewolucja.scheduling.JobRegistryInterface;
 import test.rewolucja.scheduling.plan.SchedulingPlanInterfaceNew;
@@ -23 +26 @@
 
         private Random rand;
+        private boolean init = true;
         
         public FCFSRandomClusterLocalPlugin() {
@@ -30 +34 @@
         public SchedulingPlanInterfaceNew schedule(SchedulingEvent event, QueueList queues, JobRegistryInterface jobRegistry,
                          ResourceManagerInterface resManager, ModuleList modules) {
+                
+                ClusterResourceManager resourceManager = (ClusterResourceManager) resManager;
+                
+                if( init)
+                {
+                        List<Processor> cpus = resourceManager.getProcessors();
+                        
+                        for( Processor cpu : cpus)
+                                cpu.getPowerInterface().setPState( PStateType.P3);
+                        
+                        init = false;
+                }
+                
 
-                ClusterResourceManager resourceManager = (ClusterResourceManager) resManager;
+                
                 SchedulingPlanNew plan = new SchedulingPlanNew();
                 // chose the events types to serve.
@@ -48 +65 @@
                                 // if status of the tasks in READY
                                 if (task.getStatus() == Gridlet.READY) {
-                                        String nodeName = chooseRandomProvider(resourceManager);
+                                        String nodeName = chooseRandomProvider(resourceManager, task);
                                         if (nodeName != null) {
                                                 addToSchedulingPlan(plan, task, nodeName);
@@ -59 +76 @@
         }
 
-        private String chooseRandomProvider(ClusterResourceManager resourceManager) {
+        private List<ComputingNode> findSuitableNodes(int cpuRequest, List<ComputingNode> nodes){
+                List<ComputingNode> avNodes = new ArrayList<ComputingNode>();
+                for(ComputingNode node: nodes){
+                        if(node.getFreeProcessorsNumber() >= cpuRequest){
+                                avNodes.add(node);
+                        }
+                }
+                return avNodes;
+        }
+        
+        private String chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {
+                
+                int cpuRequest;
+                try {
+                        cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
+                } catch (NoSuchFieldException e) {
+                        cpuRequest = 1;
+                }
+                
                 List<ComputingNode> nodes = resourceManager.getComputingNodes();
+                
+                nodes = findSuitableNodes(cpuRequest, nodes);
+                
                 int nodeIdx = rand.nextInt(nodes.size());
                 return nodes.get(nodeIdx).getName();