- Timestamp:
- 10/31/12 13:52:06 (12 years ago)
- Location:
- DCWoRMS/trunk/build/classes/schedframe/scheduling/manager/resources
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/trunk/build/classes/schedframe/scheduling/manager/resources/LocalResourceManager.java
r477 r539 13 13 import java.util.Properties; 14 14 import java.util.Set; 15 import java.util.Stack;16 15 17 16 import schedframe.exceptions.ResourceException; … … 175 174 return resourceUnit; 176 175 } 177 /*public List<AbstractResourceUnit> getAvailableResourceUnits(String resourceName) throws Exception {178 ComputingResource resource = getResourceByName(resourceName);179 List<AbstractResourceUnit> resourceUnits = new ArrayList<AbstractResourceUnit>();180 while(resource != null){181 for(List<AbstractResourceUnit> resUnits: resource.getResourceCharacteristic().getResourceUnits().values())182 resUnits.addAll(resourceUnits);183 resource = resource.getParent();184 }185 186 return resourceUnits;187 }*/188 176 189 177 public List<? extends ComputingResource> filterResources(Properties properties) { … … 242 230 computingResources = (List<ComputingResource>) getResourcesOfType(StandardResourceType.Core); 243 231 } catch (ResourceException e) { 244 throw new RuntimeException(" GSSIMinternal error");232 throw new RuntimeException("DCWorms internal error"); 245 233 } 246 234 PEUnit peUnit = new ProcessingElements(computingResources); … … 253 241 computingResources = (List<ComputingResource>) getResourcesOfType(StandardResourceType.Processor); 254 242 } catch (ResourceException e) { 255 throw new RuntimeException(" GSSIMinternal error");243 throw new RuntimeException("DCWorms internal error"); 256 244 } 257 245 PEUnit peUnit = new ProcessingElements(computingResources); … … 318 306 return false; 319 307 } 320 /*ResourceUnit peUnit = resources.get(StandardResourceUnitName.PE);321 322 if (peUnit != null) {323 if (peUnit instanceof ProcessingElements) {324 ProcessingElements choosenProcessors = (ProcessingElements) peUnit;325 326 for (int i = 0; i < choosenProcessors.size(); i++) {327 choosenProcessors.get(i).setStatus(ResourceStatus.BUSY);328 }329 }330 }*/331 332 /*Memory m = (Memory) resources.get(StandardResourceUnitName.MEMORY);333 if (m != null) {334 m.getProvisioner().setState(ResourceUnitState.BUSY);335 }*/336 308 337 309 for(ResourceUnitName resUnitName: resources.keySet()){ … … 345 317 public void freeResources(Map<ResourceUnitName, ResourceUnit> resources) { 346 318 347 /*ResourceUnit peUnit = resources.get(StandardResourceUnitName.PE);348 349 if (peUnit instanceof ProcessingElements) {350 ProcessingElements processingElements = (ProcessingElements) peUnit;351 352 for (int i = 0; i < processingElements.size(); i++) {353 processingElements.get(i).setStatus(ResourceStatus.FREE);354 }355 }*/356 357 /*Memory m = (Memory) resources.get(StandardResourceUnitName.MEMORY);358 if (m != null) {359 m.getProvisioner().setState(ResourceUnitState.FREE);360 }*/361 362 319 for(ResourceUnitName resUnitName: resources.keySet()){ 363 320 ResourceUnit resUnit = resources.get(resUnitName); … … 366 323 } 367 324 368 369 325 }
Note: See TracChangeset
for help on using the changeset viewer.