Changeset 1247 for DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomSP.java
- Timestamp:
- 11/28/13 10:54:54 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessRandomSP.java
r734 r1247 14 14 import schedframe.events.scheduling.SchedulingEvent; 15 15 import schedframe.resources.ResourceStatus; 16 import schedframe.resources.computing. ComputingNode;16 import schedframe.resources.computing.Node; 17 17 import schedframe.resources.computing.ComputingResource; 18 18 import schedframe.resources.computing.Core; … … 73 73 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 74 74 75 List< ComputingNode> nodes = resourceManager.getComputingNodes();76 List< ComputingNode> avNodes = filterNodes(nodes, task);75 List<Node> nodes = resourceManager.getNodes(); 76 List<Node> avNodes = filterNodes(nodes, task); 77 77 if(avNodes.size() == 0) 78 78 return null; 79 ComputingNode node = randomNode(avNodes);79 Node node = randomNode(avNodes); 80 80 81 81 int cpuRequest; … … 109 109 } 110 110 111 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){112 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();113 for ( ComputingNode node : nodes) {111 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 112 List<Node> filteredNodes = new ArrayList<Node>(); 113 for (Node node : nodes) { 114 114 int cpuRequest; 115 115 try { … … 152 152 } 153 153 154 private ComputingNode randomNode(List<ComputingNode> nodes){154 private Node randomNode(List<Node> nodes){ 155 155 return nodes.get(rand.nextInt(nodes.size())); 156 156 }
Note: See TracChangeset
for help on using the changeset viewer.