Changeset 129 for xssim/trunk/src/example/localplugin/FCFSClusterLocalPlugin.java

Timestamp:

03/15/12 11:14:52 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/trunk/src/example/localplugin/FCFSClusterLocalPlugin.java (modified) (4 diffs)

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

@@ -62 +62 @@
 
                                         SubmittedTask subTask = (SubmittedTask) task;
-                                        Map<ResourceParameterName, ResourceUnit> choosenResources = null;
-                                        choosenResources = chooseResourcesForExecution(resourceManager, subTask);
-                                        //String provname = chooseProviderForExecution(resourceManager);
+                                        
+                                        /****************3 ways to schedule task****************/
+                                        
+                                        //1. Choosing particular resources to perform execution
+                                        Map<ResourceParameterName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, subTask);
                                         if (choosenResources != null) {
                                                 addToSchedulingPlan(plan, task, choosenResources);
                                         }
+                                        
+                                        //2. Choosing resource scheduler/provider to submit task.  If the given resource doesn't contains/isn't 
+                                        //a scheduler, random resources from the given resource will be chosen in order to perform execution
+                                        /*String provName = chooseProviderForExecution(resourceManager);
+                                        if (provName != null) {
+                                                addToSchedulingPlan(plan, task, provName);
+                                        }*/
+
+                                        //3. Scheduler will choose random resources to perform execution
+                                        //addToSchedulingPlan(plan, task);
 
                                 }
@@ -77 +89 @@
         }
 
-        public HashMap<ResourceParameterName, ResourceUnit> chooseResourcesForExecution(
+        private HashMap<ResourceParameterName, ResourceUnit> chooseResourcesForExecution(
                         ClusterResourceManager resourceManager, ExecTaskInterface task) {
 
@@ -140 +152 @@
         }
 
+        private String chooseProviderForExecution(ResourceManagerInterface unitsManager) {
+                List<ComputingResource> processingElements;
+                Properties properties = new Properties();
+                properties.setProperty("type", ResourceType.COMPUTING_NODE.toString());
+                // properties.setProperty("status", ResourceStatus.FREE.toString());
+                processingElements = (List<ComputingResource>) unitsManager.filterResources(properties);
+                return processingElements.get(0).getName();
+        }
+
         public String getName() {
                 return getClass().getName();
@@ -148 +169 @@
         }
 
-        public String chooseProviderForExecution(ResourceManagerInterface unitsManager) {
-                List<ComputingResource> processingElements;
-                Properties properties = new Properties();
-                properties.setProperty("type", ResourceType.COMPUTING_NODE.toString());
-                // properties.setProperty("status", ResourceStatus.FREE.toString());
-                processingElements = (List<ComputingResource>) unitsManager.filterResources(properties);
-                return processingElements.get(0).getName();
-        }
-
 }