Ignore:
Timestamp:
11/28/13 10:54:54 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/example/localplugin
Files:
17 edited

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_ClusterPlugin.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
    14 import schedframe.resources.computing.ComputingNode; 
     14import schedframe.resources.computing.Node; 
    1515import schedframe.resources.computing.ComputingResource; 
    1616import schedframe.resources.computing.Processor; 
    … …  
    8181 
    8282                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    83                 List<ComputingNode> nodes = resourceManager.getComputingNodes(); 
    84                 for (ComputingNode node : nodes) { 
     83                List<Node> nodes = resourceManager.getNodes(); 
     84                for (Node node : nodes) { 
    8585                        int cpuRequest; 
    8686                        try { 

  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_ConsolidationClusterPlugin.java

    r1207 r1247  
    1212import schedframe.events.scheduling.SchedulingEvent; 
    1313import schedframe.resources.ResourceStatus; 
    14 import schedframe.resources.computing.ComputingNode; 
     14import schedframe.resources.computing.Node; 
    1515import schedframe.resources.computing.ComputingResource; 
    1616import schedframe.resources.units.Memory; 
    … …  
    7474        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(ClusterResourceManager resourceManager, TaskInterface<?> task) throws NoSuchFieldException { 
    7575 
    76                 List<ComputingNode> nodes = resourceManager.getComputingNodes(); 
     76                List<Node> nodes = resourceManager.getNodes(); 
    7777                nodes = findSuitableNodes(task, nodes); 
    78                 Collections.sort(nodes, new Comparator<ComputingNode>(){ 
    79                     public int compare(ComputingNode node1, ComputingNode node2){    
     78                Collections.sort(nodes, new Comparator<Node>(){ 
     79                    public int compare(Node node1, Node node2){    
    8080                        return node1.getResourceCharacteristic().getParameters().get("category").get(0).getContent().compareTo(node2.getResourceCharacteristic().getParameters().get("category").get(0).getContent()); 
    8181                    } 
    … …  
    8383                if(nodes.size() > 0) 
    8484                { 
    85                         ComputingNode node = nodes.get(0); 
     85                        Node node = nodes.get(0); 
    8686                        Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    8787                        List<ComputingResource> choosenResources =  new ArrayList<ComputingResource>(); 
    … …  
    117117        } 
    118118         
    119         private List<ComputingNode> findSuitableNodes(TaskInterface<?> task, List<ComputingNode> nodes) throws NoSuchFieldException{ 
     119        private List<Node> findSuitableNodes(TaskInterface<?> task, List<Node> nodes) throws NoSuchFieldException{ 
    120120                int cpuRequest; 
    121121                try { 
    … …  
    130130                        memoryRequest = 0; 
    131131                } 
    132                 List<ComputingNode> suitableNodes = new ArrayList<ComputingNode>(); 
    133                 for(ComputingNode node: nodes){ 
     132                List<Node> suitableNodes = new ArrayList<Node>(); 
     133                for(Node node: nodes){ 
    134134                        if(node.getFreeProcessorsNumber() >= cpuRequest && node.getFreeMemory() >= memoryRequest){ 
    135135                                suitableNodes.add(node); 

  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_FanManagementClusterPlugin.java

    r1207 r1247  
    99import schedframe.events.scheduling.SchedulingEvent; 
    1010import schedframe.resources.StandardResourceType; 
    11 import schedframe.resources.computing.ComputingNode; 
     11import schedframe.resources.computing.Node; 
    1212import schedframe.resources.computing.profiles.energy.airthroughput.StandardAirThroughputStateName; 
    1313import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    … …  
    4646                        // BaseLocalSchedulingPlugin.placeJobsInQueues() method) 
    4747                        TaskQueue q = queues.get(0); 
    48                         List<ComputingNode> notSelectedNodes = resourceManager.getComputingNodes(); 
     48                        List<Node> notSelectedNodes = resourceManager.getNodes(); 
    4949                        // check all tasks in queue 
    5050                        for (int i = 0; i < q.size(); i++) { 
    … …  
    5353                                if (task.getStatus() == DCWormsTags.READY) { 
    5454 
    55                                         ComputingNode node = chooseRandomProvider(resourceManager, task); 
     55                                        Node node = chooseRandomProvider(resourceManager, task); 
    5656                                        if (node != null) { 
    5757                                                //if there are two or more tasks ( running on the given node then 
    … …  
    8383        } 
    8484 
    85         private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 
    86                 List<ComputingNode> nodes = filterNodes(resourceManager.getComputingNodes(), task); 
     85        private Node chooseRandomProvider(ClusterResourceManager resourceManager, TaskInterface<?> task) { 
     86                List<Node> nodes = filterNodes(resourceManager.getNodes(), task); 
    8787                return randomNode(nodes); 
    8888        } 
    8989         
    90         private List<ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){ 
    91                 List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>(); 
    92                 for (ComputingNode node : nodes) { 
     90        private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 
     91                List<Node> filteredNodes = new ArrayList<Node>(); 
     92                for (Node node : nodes) { 
    9393                        int cpuRequest; 
    9494                        try { 
    … …  
    106106        } 
    107107         
    108         private ComputingNode randomNode(List<ComputingNode> nodes){ 
     108        private Node randomNode(List<Node> nodes){ 
    109109                return nodes.get(rand.nextInt(nodes.size())); 
    110110        } 
    111111         
    112         private void adjustOtherFans(List<ComputingNode> nodes){ 
    113                 for(ComputingNode node : nodes){ 
     112        private void adjustOtherFans(List<Node> nodes){ 
     113                for(Node node : nodes){ 
    114114                        List<Device> devices = node.getResourceCharacteristic().getDevices(); 
    115115                        if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 

  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_NodePowerManagementClusterPlugin.java

    r1207 r1247  
    1212import schedframe.events.scheduling.SchedulingEvent; 
    1313import schedframe.resources.ResourceStatus; 
    14 import schedframe.resources.computing.ComputingNode; 
     14import schedframe.resources.computing.Node; 
    1515import schedframe.resources.computing.ComputingResource; 
    1616import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    … …  
    5454                                                addToSchedulingPlan(plan, task, choosenResources); 
    5555                                        } else { 
    56                                                 if(harnessIdleNodesToWork(task, resourceManager.getComputingNodes())) 
     56                                                if(harnessIdleNodesToWork(task, resourceManager.getNodes())) 
    5757                                                        i--; 
    5858                                        } 
    5959                                } 
    6060                        } 
    61                         turnOffIdleNodes(resourceManager.getComputingNodes()); 
     61                        turnOffIdleNodes(resourceManager.getNodes()); 
    6262                        break; 
    6363                } 
    … …  
    6767        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(ClusterResourceManager resourceManager, TaskInterface<?> task) { 
    6868 
    69                 List<ComputingNode> nodes = resourceManager.getComputingNodes(); 
     69                List<Node> nodes = resourceManager.getNodes(); 
    7070                nodes = findSuitableNodes(task, nodes); 
    71                 Collections.sort(nodes, new Comparator<ComputingNode>(){ 
    72                     public int compare(ComputingNode node1, ComputingNode node2){     
     71                Collections.sort(nodes, new Comparator<Node>(){ 
     72                    public int compare(Node node1, Node node2){     
    7373                        return node1.getResourceCharacteristic().getParameters().get("category").get(0).getContent().compareTo(node2.getResourceCharacteristic().getParameters().get("category").get(0).getContent()); 
    7474                    } 
    … …  
    9898        } 
    9999         
    100         private List<ComputingNode> findSuitableNodes(TaskInterface<?> task, List<ComputingNode> nodes){ 
     100        private List<Node> findSuitableNodes(TaskInterface<?> task, List<Node> nodes){ 
    101101                int cpuRequest; 
    102102                try { 
    … …  
    105105                        cpuRequest = 1; 
    106106                } 
    107                 List<ComputingNode> avNodes = new ArrayList<ComputingNode>(); 
    108                 for(ComputingNode node: nodes){ 
     107                List<Node> avNodes = new ArrayList<Node>(); 
     108                for(Node node: nodes){ 
    109109                        if(node.getFreeProcessorsNumber() >= cpuRequest){ 
    110110                                avNodes.add(node); 
    … …  
    114114        } 
    115115 
    116         private void turnOffIdleNodes(List<ComputingNode> nodes){ 
    117                 for(ComputingNode node : nodes){ 
     116        private void turnOffIdleNodes(List<Node> nodes){ 
     117                for(Node node : nodes){ 
    118118                        if(node.getFreeProcessorsNumber() == node.getProcessorsNumber()){ 
    119119                                node.getPowerInterface().setPowerState(StandardPowerStateName.OFF); 
    … …  
    122122        } 
    123123         
    124         private boolean harnessIdleNodesToWork(TaskInterface<?> task, List<ComputingNode> nodes){ 
     124        private boolean harnessIdleNodesToWork(TaskInterface<?> task, List<Node> nodes){ 
    125125                int cpuRequest; 
    126126                try { 
    … …  
    129129                        cpuRequest = 1; 
    130130                } 
    131                 Collections.sort(nodes, new Comparator<ComputingNode>(){ 
    132                     public int compare(ComputingNode node1, ComputingNode node2){     
     131                Collections.sort(nodes, new Comparator<Node>(){ 
     132                    public int compare(Node node1, Node node2){     
    133133                        return node1.getResourceCharacteristic().getParameters().get("category").get(0).getContent().compareTo(node2.getResourceCharacteristic().getParameters().get("category").get(0).getContent()); 
    134134                    } 
    135135                }); 
    136136                for (int i = 0; i < nodes.size() && cpuRequest > 0; i++) { 
    137                         ComputingNode node = nodes.get(i); 
     137                        Node node = nodes.get(i); 
    138138                        if(node.getPowerInterface().getPowerState() == StandardPowerStateName.OFF){ 
    139139                                node.getPowerInterface().setPowerState(StandardPowerStateName.ON); 

  • DCWoRMS/branches/coolemall/src/example/localplugin/FCFSBF_RandomClusterPlugin.java

    r1207 r1247  
    77 
    88import schedframe.events.scheduling.SchedulingEvent; 
    9 import schedframe.resources.computing.ComputingNode; 
     9import schedframe.resources.computing.Node; 
    1010import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    1111import schedframe.scheduling.manager.resources.ResourceManager; 
    … …  
    5959 
    6060        private String chooseRandomProvider(ClusterResourceManager resourceManager) { 
    61                 List<ComputingNode> nodes = resourceManager.getComputingNodes(); 
     61                List<Node> nodes = resourceManager.getNodes(); 
    6262                int nodeIdx = rand.nextInt(nodes.size()); 
    6363                return nodes.get(nodeIdx).getFullName(); 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_ConsolidationAtom_NodePowMan_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Core; 
    1617import schedframe.resources.computing.Processor; 
    17 import schedframe.resources.computing.coolemall.Node; 
    1818import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_Consolidation_NodePowMan_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Core; 
    1617import schedframe.resources.computing.Processor; 
    17 import schedframe.resources.computing.coolemall.Node; 
    1818import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_Consolidation_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Core; 
    16 import schedframe.resources.computing.coolemall.Node; 
    1717import schedframe.resources.units.ProcessingElements; 
    1818import schedframe.resources.units.ResourceUnit; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_LoadBalancing_SP.java

    r1207 r1247  
    66import schedframe.exceptions.ResourceException; 
    77import schedframe.resources.StandardResourceType; 
     8import schedframe.resources.computing.Node; 
    89import schedframe.resources.computing.ComputingResource; 
    9 import schedframe.resources.computing.coolemall.Node; 
    1010import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    1111import schedframe.scheduling.manager.resources.ResourceManager; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox1/CB1_FCFS_Random_SP.java

    r1207 r1247  
    1111import schedframe.resources.ResourceStatus; 
    1212import schedframe.resources.StandardResourceType; 
     13import schedframe.resources.computing.Node; 
    1314import schedframe.resources.computing.ComputingResource; 
    1415import schedframe.resources.computing.Core; 
    15 import schedframe.resources.computing.coolemall.Node; 
    1616import schedframe.resources.units.ProcessingElements; 
    1717import schedframe.resources.units.ResourceUnit; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Consolidation_NodePowMan_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Core; 
    1617import schedframe.resources.computing.Processor; 
    17 import schedframe.resources.computing.coolemall.Node; 
    1818import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    1919import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Consolidation_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Core; 
    16 import schedframe.resources.computing.coolemall.Node; 
    1717import schedframe.resources.units.ProcessingElements; 
    1818import schedframe.resources.units.ResourceUnit; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_LoadBalancing_SP.java

    r1207 r1247  
    66import schedframe.exceptions.ResourceException; 
    77import schedframe.resources.StandardResourceType; 
     8import schedframe.resources.computing.Node; 
    89import schedframe.resources.computing.ComputingResource; 
    9 import schedframe.resources.computing.coolemall.Node; 
    1010import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    1111import schedframe.scheduling.manager.resources.ResourceManager; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/computebox2/CB2_FCFS_Random_SP.java

    r1207 r1247  
    1010import schedframe.exceptions.ResourceException; 
    1111import schedframe.resources.StandardResourceType; 
     12import schedframe.resources.computing.Node; 
    1213import schedframe.resources.computing.ComputingResource; 
    1314import schedframe.resources.computing.Processor; 
    14 import schedframe.resources.computing.coolemall.Node; 
    1515import schedframe.resources.units.ProcessingElements; 
    1616import schedframe.resources.units.ResourceUnit; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Consolidation_SP.java

    r1207 r1247  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
     14import schedframe.resources.computing.Node; 
    1415import schedframe.resources.computing.ComputingResource; 
    1516import schedframe.resources.computing.Processor; 
    16 import schedframe.resources.computing.coolemall.Node; 
    1717import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    1818import schedframe.resources.units.Memory; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_LB_SP.java

    r1207 r1247  
    66import schedframe.exceptions.ResourceException; 
    77import schedframe.resources.StandardResourceType; 
     8import schedframe.resources.computing.Node; 
    89import schedframe.resources.computing.ComputingResource; 
    9 import schedframe.resources.computing.coolemall.Node; 
    1010import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    1111import schedframe.scheduling.manager.resources.ResourceManager; 

  • DCWoRMS/branches/coolemall/src/example/localplugin/coolemall/recs/RECS_FCFS_Random_SP.java

    r1207 r1247  
    1111import schedframe.resources.ResourceStatus; 
    1212import schedframe.resources.StandardResourceType; 
    13 import schedframe.resources.computing.ComputingNode; 
     13import schedframe.resources.computing.Node; 
    1414import schedframe.resources.computing.ComputingResource; 
    1515import schedframe.resources.computing.Core; 
    … …  
    5757                        TaskQueue q = queues.get(0); 
    5858                         
    59                         List<ComputingNode> notSelectedNodes = null; 
     59                        List<Node> notSelectedNodes = null; 
    6060                        try { 
    61                                 notSelectedNodes = (List<ComputingNode>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
     61                                notSelectedNodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    6262                        } catch (ResourceException e) { 
    6363                                // TODO Auto-generated catch block 
    … …  
    8888 
    8989        @SuppressWarnings("unchecked") 
    90         private ComputingNode chooseRandomProvider(ClusterResourceManager resourceManager) { 
    91                 List<ComputingNode> nodes = null; 
     90        private Node chooseRandomProvider(ClusterResourceManager resourceManager) { 
     91                List<Node> nodes = null; 
    9292                try { 
    93                         nodes = (List<ComputingNode>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
     93                        nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    9494                } catch (ResourceException e) { 
    9595                        // TODO Auto-generated catch block 
    … …  
    101101        } 
    102102 
    103         private List<ComputingNode> filterNodes(List<ComputingNode> nodes){ 
    104                 List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>(); 
    105                 for (ComputingNode node : nodes) { 
     103        private List<Node> filterNodes(List<Node> nodes){ 
     104                List<Node> filteredNodes = new ArrayList<Node>(); 
     105                for (Node node : nodes) { 
    106106                        if(node.getFreeProcessors().size() > 0) 
    107107                                filteredNodes.add(node); 
    … …  
    116116                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    117117                 
    118                 List<ComputingNode> nodes = null; 
     118                List<Node> nodes = null; 
    119119                try { 
    120                         nodes = (List<ComputingNode>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
     120                        nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    121121                } catch (ResourceException e1) { 
    122122                        // TODO Auto-generated catch block 
    123123                        e1.printStackTrace(); 
    124124                } 
    125                 List<ComputingNode> avNodes = filterNodes(nodes, task); 
     125                List<Node> avNodes = filterNodes(nodes, task); 
    126126                if(avNodes.size() == 0) 
    127127                        return null; 
    128                 ComputingNode node = randomNode(avNodes); 
     128                Node node = randomNode(avNodes); 
    129129 
    130130                int cpuRequest; 
    … …  
    158158        } 
    159159         
    160         private List<ComputingNode> filterNodes(List<ComputingNode> nodes, TaskInterface<?> task){ 
    161                 List<ComputingNode> filteredNodes = new ArrayList<ComputingNode>(); 
    162                 for (ComputingNode node : nodes) { 
     160        private List<Node> filterNodes(List<Node> nodes, TaskInterface<?> task){ 
     161                List<Node> filteredNodes = new ArrayList<Node>(); 
     162                for (Node node : nodes) { 
    163163                        int cpuRequest; 
    164164                        try { 
    … …  
    194194        } 
    195195         
    196         private ComputingNode randomNode(List<ComputingNode> nodes){ 
     196        private Node randomNode(List<Node> nodes){ 
    197197                return nodes.get(rand.nextInt(nodes.size())); 
    198198        } 
    199199         
    200         private void adjustOtherFans(List<ComputingNode> nodes) { 
    201                 for (ComputingNode node : nodes) { 
     200        private void adjustOtherFans(List<Node> nodes) { 
     201                for (Node node : nodes) { 
    202202                         
    203203                        if (node.getProcessors().size() == node.getFreeProcessorsNumber()) { 
Note: See TracChangeset for help on using the changeset viewer.