Changeset 257 for xssim/branches/tpiontek/src/example/localplugin/FCFSPreferedRandomClusterLocalPlugin.java

Timestamp:

04/12/12 14:52:29 (13 years ago)

Author:

piontek

Message:

 

File:

• xssim/branches/tpiontek/src/example/localplugin/FCFSPreferedRandomClusterLocalPlugin.java (modified) (8 diffs)

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

@@ -31 +31 @@
         private boolean init = true;
         
+        int scenario = 1;
+        String prefered = null;
+        
         public FCFSPreferedRandomClusterLocalPlugin() {
                 rand = new Random(5);
@@ -37 +40 @@
         public SchedulingPlanInterfaceNew schedule(SchedulingEvent event, QueueList queues, JobRegistryInterface jobRegistry,
                          ResourceManagerInterface resManager, ModuleList modules) {
-                
-                int scenario = 1;
                 
                 ClusterResourceManager resourceManager = (ClusterResourceManager) resManager;
@@ -71 +72 @@
                                 if (task.getStatus() == Gridlet.READY) {
                                         
-                                        ComputingNode node = chooseRandomProvider(resourceManager, task);
+                                        ComputingNode node = chooseRandomProvider(resourceManager, ResourceStatus.FREE, task);
                                         
                                         if (node != null) {
@@ -84 +85 @@
                                                 case 1: break;
                                                 case 2:
-                                                        findSuitableNodes( "", getCpuRequest(task), ResourceStatus.UNAVAILABLE, resourceManager.getComputingNodes());
+                                                        //ComputingNode node = chooseRandomProvider(resourceManager, ResourceStatus.UNAVAILABLE, task);
                                                         break;
                                                 }
                                         }
-                                        
-                                        
                                 }
                         }
@@ -156 +155 @@
         }
         
-        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {
+        private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, ResourceStatus status, TaskInterface<?> task) {
                 
                 int cpuRequest = getCpuRequest(task);
@@ -164 +163 @@
                 String prefered = null;
                 
-                nodes = findSuitableNodes(prefered, cpuRequest, ResourceStatus.FREE, resourceManager.getComputingNodes());
+                nodes = findSuitableNodes(prefered, cpuRequest, status, resourceManager.getComputingNodes());
                 if( nodes.size() > 0)
                 {       
@@ -179 +178 @@
                 if( prefered != null)
                 {       
-                        if( prefered.equals("A"))
-                                prefered = "B";
-                        else
-                                prefered = "A";
-                        
-                        nodes = findSuitableNodes(prefered, cpuRequest, ResourceStatus.FREE, resourceManager.getComputingNodes());
+                        nodes = findSuitableNodes( getUnprefered(), cpuRequest, status, resourceManager.getComputingNodes());
                         if( nodes.size() > 0)
                         {       
@@ -214 +208 @@
                 return cpus.subList(0, cpuRequest);
         }
+        
+        private String getUnprefered()
+        {
+                if( prefered.equals("A"))
+                        return "B";
+                
+                if( prefered.equals("B"))
+                        return "A";
+                
+                return null;
+        }
 
 }