Changeset 1247 for DCWoRMS/branches/coolemall/src/test/article/recs/plugins/scheduling/RecsExclusivenessDFSSP.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/RecsExclusivenessDFSSP.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; … … 75 75 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 76 76 77 List< ComputingNode> nodes = resourceManager.getComputingNodes();78 List< ComputingNode> avNodes = filterNodes(nodes, task);77 List<Node> nodes = resourceManager.getNodes(); 78 List<Node> avNodes = filterNodes(nodes, task); 79 79 if(avNodes.size() == 0) 80 80 return null; 81 ComputingNode node = randomNode(avNodes);81 Node node = randomNode(avNodes); 82 82 83 83 int cpuRequest; … … 111 111 } 112 112 113 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){114 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();115 for ( ComputingNode node : nodes) {113 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 114 List<Node> filteredNodes = new ArrayList<Node>(); 115 for (Node node : nodes) { 116 116 int cpuRequest; 117 117 try { … … 154 154 } 155 155 156 private ComputingNode randomNode(List<ComputingNode> nodes){156 private Node randomNode(List<Node> nodes){ 157 157 return nodes.get(rand.nextInt(nodes.size())); 158 158 }
Note: See TracChangeset
for help on using the changeset viewer.