- Timestamp:
- 03/26/12 12:03:27 (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
xssim/trunk/src/example/localplugin/FCFSClusterLocalPlugin.java
r169 r192 49 49 case TIMER: 50 50 // our tasks are placed only in first queue (see 51 // BaseLocalPlugin.place TasksInQueues() method)51 // BaseLocalPlugin.placeJobsInQueues() method) 52 52 Queue q = queues.get(0); 53 53 // check all tasks in queue 54 55 54 56 55 for (int i = 0; i < q.size(); i++) { … … 64 63 /****************3 ways to schedule task****************/ 65 64 66 / /1. Choosing particular resources to perform execution65 /****************1. Choosing particular resources to perform execution****************/ 67 66 Map<ResourceParameterName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, subTask); 68 67 if (choosenResources != null) { … … 70 69 } 71 70 72 / /2. Choosing resource scheduler/provider to submit task. If the given resource doesn't contains/isn't73 //a scheduler, random resources from the given resource will be chosen in order to perform execution71 /****************2. Choosing resource scheduler/provider to submit task. If the given resource doesn't contains/isn't 72 a scheduler, random resources from the given resource will be chosen in order to perform execution****************/ 74 73 /*String provName = chooseProviderForExecution(resourceManager); 75 74 if (provName != null) { … … 77 76 }*/ 78 77 79 / /3. Scheduler will choose random resources to perform execution78 /****************3. Scheduler will choose random resources to perform execution****************/ 80 79 //addToSchedulingPlan(plan, task); 81 82 80 } 83 81 } … … 141 139 142 140 if (node.getFreeMemory() >= memoryRequest) { 143 memory = new Memory(node.getMemory (), memoryRequest, memoryRequest);141 memory = new Memory(node.getMemoryUnit(), memoryRequest, memoryRequest); 144 142 } else 145 143 return null; … … 151 149 } 152 150 151 @SuppressWarnings("unchecked") 153 152 private String chooseProviderForExecution(ResourceManagerInterface unitsManager) { 154 153 List<ComputingResource> processingElements;
Note: See TracChangeset
for help on using the changeset viewer.