- Timestamp:
- 11/28/13 10:54:54 (11 years ago)
- Location:
- DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2
- Files:
-
- 4 edited
-
RecsIn2OutSP.java (modified) (8 diffs)
-
RecsLeft2RightSP.java (modified) (8 diffs)
-
RecsOut2InSP.java (modified) (8 diffs)
-
RecsRandomSP.java (modified) (7 diffs)
Legend:
- Unmodified
- Added
- Removed
-
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsIn2OutSP.java
r1211 r1247 15 15 import schedframe.events.scheduling.SchedulingEvent; 16 16 import schedframe.resources.ResourceStatus; 17 import schedframe.resources.computing. ComputingNode;17 import schedframe.resources.computing.Node; 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; … … 53 53 TaskQueue q = queues.get(0); 54 54 55 List< ComputingNode> notSelectedNodes = resourceManager.getComputingNodes();55 List<Node> notSelectedNodes = resourceManager.getNodes(); 56 56 // check all tasks in queue 57 57 for (int i = 0; i < q.size(); i++) { … … 59 59 // if status of the tasks in READY 60 60 if (task.getStatus() == DCWormsTags.READY) { 61 ComputingNode node = chooseProvider(resourceManager, task);61 Node node = chooseProvider(resourceManager, task); 62 62 if (node != null) { 63 63 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); … … 73 73 } 74 74 75 private ComputingNode chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {76 List< ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);75 private Node chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 76 List<Node> nodes = filterNodes(resourceManager.getNodes(), task); 77 77 Collections.sort(nodes, new ResourceIdComparator()); 78 for( ComputingNode node: nodes){78 for(Node node: nodes){ 79 79 Integer id = Integer.parseInt(node.getName().split("_")[1]); 80 80 if((id >= START_ID && id <= END_ID)){ … … 88 88 89 89 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 90 ComputingNode node, TaskInterface<?> task) {90 Node node, TaskInterface<?> task) { 91 91 92 92 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); … … 122 122 } 123 123 124 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){125 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();126 for ( ComputingNode node : nodes) {124 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 125 List<Node> filteredNodes = new ArrayList<Node>(); 126 for (Node node : nodes) { 127 127 int cpuRequest; 128 128 try { … … 165 165 } 166 166 167 private void adjustOtherFans(List< ComputingNode> nodes){168 for( ComputingNode node : nodes){167 private void adjustOtherFans(List<Node> nodes){ 168 for(Node node : nodes){ 169 169 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 170 170 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); … … 175 175 } 176 176 177 class ResourceIdComparator implements Comparator< ComputingNode> {178 179 public int compare( ComputingNode node1, ComputingNode node2) {177 class ResourceIdComparator implements Comparator<Node> { 178 179 public int compare(Node node1, Node node2) { 180 180 Integer id1 = Integer.parseInt(node1.getName().split("_")[1]); 181 181 Integer id2 = Integer.parseInt(node2.getName().split("_")[1]); -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsLeft2RightSP.java
r1211 r1247 15 15 import schedframe.events.scheduling.SchedulingEvent; 16 16 import schedframe.resources.ResourceStatus; 17 import schedframe.resources.computing. ComputingNode;17 import schedframe.resources.computing.Node; 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; … … 54 54 TaskQueue q = queues.get(0); 55 55 56 List< ComputingNode> notSelectedNodes = resourceManager.getComputingNodes();56 List<Node> notSelectedNodes = resourceManager.getNodes(); 57 57 // check all tasks in queue 58 58 for (int i = 0; i < q.size(); i++) { … … 60 60 // if status of the tasks in READY 61 61 if (task.getStatus() == DCWormsTags.READY) { 62 ComputingNode node = chooseProvider(resourceManager, task);62 Node node = chooseProvider(resourceManager, task); 63 63 if (node != null) { 64 64 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); … … 74 74 } 75 75 76 private ComputingNode chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {77 List< ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);76 private Node chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 77 List<Node> nodes = filterNodes(resourceManager.getNodes(), task); 78 78 Collections.sort(nodes, new ResourceIdComparator()); 79 for ( ComputingNode node : nodes) {79 for (Node node : nodes) { 80 80 Integer id = Integer.parseInt(node.getName().split("_")[1]); 81 81 if ((id >= START_ID && id <= END_ID)) { … … 88 88 } 89 89 90 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( ComputingNode node, TaskInterface<?> task) {90 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(Node node, TaskInterface<?> task) { 91 91 92 92 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); … … 122 122 } 123 123 124 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task) {125 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();126 for ( ComputingNode node : nodes) {124 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task) { 125 List<Node> filteredNodes = new ArrayList<Node>(); 126 for (Node node : nodes) { 127 127 int cpuRequest; 128 128 try { … … 165 165 } 166 166 167 private void adjustOtherFans(List< ComputingNode> nodes) {168 for ( ComputingNode node : nodes) {167 private void adjustOtherFans(List<Node> nodes) { 168 for (Node node : nodes) { 169 169 if (node.getFreeProcessorsNumber() == node.getProcessorsNumber()) { 170 170 // node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); … … 175 175 } 176 176 177 class ResourceIdComparator implements Comparator< ComputingNode> {177 class ResourceIdComparator implements Comparator<Node> { 178 178 179 public int compare( ComputingNode node1, ComputingNode node2) {179 public int compare(Node node1, Node node2) { 180 180 Integer id1 = Integer.parseInt(node1.getName().split("_")[1]); 181 181 Integer id2 = Integer.parseInt(node2.getName().split("_")[1]); -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsOut2InSP.java
r1211 r1247 15 15 import schedframe.events.scheduling.SchedulingEvent; 16 16 import schedframe.resources.ResourceStatus; 17 import schedframe.resources.computing. ComputingNode;17 import schedframe.resources.computing.Node; 18 18 import schedframe.resources.computing.ComputingResource; 19 19 import schedframe.resources.computing.Core; … … 53 53 TaskQueue q = queues.get(0); 54 54 55 List< ComputingNode> notSelectedNodes = resourceManager.getComputingNodes();55 List<Node> notSelectedNodes = resourceManager.getNodes(); 56 56 // check all tasks in queue 57 57 for (int i = 0; i < q.size(); i++) { … … 59 59 // if status of the tasks in READY 60 60 if (task.getStatus() == DCWormsTags.READY) { 61 ComputingNode node = chooseProvider(resourceManager, task);61 Node node = chooseProvider(resourceManager, task); 62 62 if (node != null) { 63 63 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); … … 73 73 } 74 74 75 private ComputingNode chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {76 List< ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);75 private Node chooseProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 76 List<Node> nodes = filterNodes(resourceManager.getNodes(), task); 77 77 Collections.sort(nodes, new ResourceIdComparator()); 78 for( ComputingNode node: nodes){78 for(Node node: nodes){ 79 79 Integer id = Integer.parseInt(node.getName().split("_")[1]); 80 80 if((id >= START_ID && id <= END_ID)){ … … 87 87 88 88 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 89 ComputingNode node, TaskInterface<?> task) {89 Node node, TaskInterface<?> task) { 90 90 91 91 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); … … 121 121 } 122 122 123 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){124 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();125 for ( ComputingNode node : nodes) {123 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 124 List<Node> filteredNodes = new ArrayList<Node>(); 125 for (Node node : nodes) { 126 126 int cpuRequest; 127 127 try { … … 164 164 } 165 165 166 private void adjustOtherFans(List< ComputingNode> nodes){167 for( ComputingNode node : nodes){166 private void adjustOtherFans(List<Node> nodes){ 167 for(Node node : nodes){ 168 168 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 169 169 //node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.FAN_OFF); … … 174 174 } 175 175 176 class ResourceIdComparator implements Comparator< ComputingNode> {176 class ResourceIdComparator implements Comparator<Node> { 177 177 178 public int compare( ComputingNode node1, ComputingNode node2) {178 public int compare(Node node1, Node node2) { 179 179 Integer id1 = Integer.parseInt(node1.getName().split("_")[1]); 180 180 Integer id2 = Integer.parseInt(node2.getName().split("_")[1]); -
DCWoRMS/branches/coolemall/src/test/article2/recs/plugins/scheduling/exp2/RecsRandomSP.java
r1211 r1247 11 11 import schedframe.events.scheduling.SchedulingEvent; 12 12 import schedframe.resources.ResourceStatus; 13 import schedframe.resources.computing. ComputingNode;13 import schedframe.resources.computing.Node; 14 14 import schedframe.resources.computing.ComputingResource; 15 15 import schedframe.resources.computing.Core; … … 50 50 TaskQueue q = queues.get(0); 51 51 52 List< ComputingNode> notSelectedNodes = resourceManager.getComputingNodes();52 List<Node> notSelectedNodes = resourceManager.getNodes(); 53 53 // check all tasks in queue 54 54 for (int i = 0; i < q.size(); i++) { … … 56 56 // if status of the tasks in READY 57 57 if (task.getStatus() == DCWormsTags.READY) { 58 ComputingNode node = chooseRandomProvider(resourceManager, task);58 Node node = chooseRandomProvider(resourceManager, task); 59 59 if (node != null) { 60 60 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.ON); … … 70 70 } 71 71 72 private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) {73 List< ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task);72 private Node chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 73 List<Node> nodes = filterNodes(resourceManager.getNodes(), task); 74 74 if(nodes.size() > 0) 75 75 return randomNode(nodes); … … 78 78 79 79 private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution( 80 ComputingNode node, TaskInterface<?> task) {80 Node node, TaskInterface<?> task) { 81 81 82 82 Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); … … 112 112 } 113 113 114 private List< ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){115 List< ComputingNode> filteredNodes = new ArrayList<ComputingNode>();116 for ( ComputingNode node : nodes) {114 private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 115 List<Node> filteredNodes = new ArrayList<Node>(); 116 for (Node node : nodes) { 117 117 int cpuRequest; 118 118 try { … … 145 145 } 146 146 147 private ComputingNode randomNode(List<ComputingNode> nodes){147 private Node randomNode(List<Node> nodes){ 148 148 return nodes.get(rand.nextInt(nodes.size())); 149 149 } 150 150 151 private void adjustOtherFans(List< ComputingNode> nodes){152 for( ComputingNode node : nodes){151 private void adjustOtherFans(List<Node> nodes){ 152 for(Node node : nodes){ 153 153 if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 154 154 node.getAirThroughputInterface().setAirThroughputState(StandardAirThroughputStateName.OFF);
Note: See TracChangeset
for help on using the changeset viewer.
