Changeset 1258 for DCWoRMS/branches


Ignore:
Timestamp:
11/29/13 09:48:39 (11 years ago)
Author:
wojtekp
Message:
 
Location:
DCWoRMS/branches/coolemall/src/example
Files:
1 deleted
13 edited
2 moved

Legend:

Unmodified
Added
Removed

  • DCWoRMS/branches/coolemall/src/example/energy/DataCenterEnergyEstimationPlugin.java

    r1247 r1258  
    1515                double power = 0; 
    1616                DataCenter dataCenter = (DataCenter)resource; 
    17                 for(Node cn:dataCenter.getNodes()){ 
     17                for(Node cn: dataCenter.getNodes()){ 
    1818                        PowerUsage powerUsage = cn.getPowerInterface().getRecentPowerUsage(); 
    1919                        power += (powerUsage == null ? 0 : powerUsage.getValue()); 

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

    r1247 r1258  
    2929import schedframe.scheduling.tasks.TaskInterface; 
    3030 
    31 public class FCFSBF_ConsolidationClusterPlugin extends BaseLocalSchedulingPlugin { 
     31public class Cluster_FCFSBF_ConsolidationPlugin extends BaseLocalSchedulingPlugin { 
    3232 
    33         public FCFSBF_ConsolidationClusterPlugin () { 
     33        public Cluster_FCFSBF_ConsolidationPlugin () { 
    3434        } 
    3535 
    … …  
    5454                                if (task.getStatus() == DCWormsTags.READY) { 
    5555 
    56                                         Map<ResourceUnitName, ResourceUnit> choosenResources = null; 
    57                                         try { 
    58                                                 choosenResources = chooseResourcesForExecution(resourceManager, task); 
    59                                         } catch (NoSuchFieldException e) { 
    60                                                 // TODO Auto-generated catch block 
    61                                                 e.printStackTrace(); 
    62                                         } 
     56                                        Map<ResourceUnitName, ResourceUnit> choosenResources =  chooseResourcesForExecution(resourceManager, task); 
    6357                                        if (choosenResources  != null) { 
    6458                                                addToSchedulingPlan(plan, task, choosenResources); 
    … …  
    7266        } 
    7367         
    74         private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(ClusterResourceManager resourceManager, TaskInterface<?> task) throws NoSuchFieldException { 
     68        private Map<ResourceUnitName, ResourceUnit> chooseResourcesForExecution(ClusterResourceManager resourceManager, TaskInterface<?> task){ 
    7569 
    7670                List<Node> nodes = resourceManager.getNodes(); 
    … …  
    109103                        } 
    110104                        if (memoryRequest != 0) { 
    111                                 Memory memory = new Memory(node.getMemory(), memoryRequest, memoryRequest); 
    112                                 map.put(StandardResourceUnitName.MEMORY, memory); 
     105                                Memory memory; 
     106                                try { 
     107                                        memory = new Memory(node.getMemory(), memoryRequest, memoryRequest); 
     108                                        map.put(StandardResourceUnitName.MEMORY, memory); 
     109                                } catch (NoSuchFieldException e) { 
     110                                        return null; 
     111                                } 
     112 
    113113                        } 
    114114                        return map; 
    … …  
    117117        } 
    118118         
    119         private List<Node> findSuitableNodes(TaskInterface<?> task, List<Node> nodes) throws NoSuchFieldException{ 
     119        private List<Node> findSuitableNodes(TaskInterface<?> task, List<Node> nodes) { 
    120120                int cpuRequest; 
    121121                try { 
    … …  
    132132                List<Node> suitableNodes = new ArrayList<Node>(); 
    133133                for(Node node: nodes){ 
    134                         if(node.getFreeProcessorsNumber() >= cpuRequest && node.getFreeMemory() >= memoryRequest){ 
    135                                 suitableNodes.add(node); 
     134                        try{ 
     135                                if(node.getFreeProcessorsNumber() >= cpuRequest && node.getFreeMemory() >= memoryRequest){ 
     136                                        suitableNodes.add(node); 
     137                                }        
     138                        } catch (NoSuchFieldException e){ 
     139                                 
    136140                        } 
    137141                } 

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

    r1247 r1258  
    1818import schedframe.scheduling.tasks.TaskInterface; 
    1919 
    20 public class FCFSBF_RandomClusterPlugin extends BaseLocalSchedulingPlugin { 
     20public class Cluster_FCFSBF_RandomPlugin extends BaseLocalSchedulingPlugin { 
    2121 
    2222        private Random rand; 
    2323         
    24         public FCFSBF_RandomClusterPlugin() { 
     24        public Cluster_FCFSBF_RandomPlugin() { 
    2525                rand = new Random(5); 
    2626        } 

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

    r1253 r1258  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
    14 import schedframe.resources.computing.Node; 
    1514import schedframe.resources.computing.ComputingResource; 
    1615import schedframe.resources.computing.Core; 
     16import schedframe.resources.computing.Node; 
    1717import schedframe.resources.computing.Processor; 
    1818import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    … …  
    5959                        TaskQueue q = queues.get(0); 
    6060                         
    61                         List<Node> notSelectedNodes = null; 
    62                         try { 
    63                                 notSelectedNodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    64                         } catch (ResourceException e) { 
    65                         } 
     61                        List<Node> notSelectedNodes = resourceManager.getNodes(); 
    6662                         
    6763                        // check all tasks in queue 
    … …  
    9288                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    9389                 
    94                 List<Node> nodes = null; 
    95                 try { 
    96                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    97                 } catch (ResourceException e) { 
    98                         // TODO Auto-generated catch block 
    99                         e.printStackTrace(); 
    100                 } 
     90                List<Node> nodes = resourceManager.getNodes(); 
    10191                List<Node> avNodes = filterNodes(nodes, task); 
    10292                Node node; 

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

    r1253 r1258  
    5959                        TaskQueue q = queues.get(0); 
    6060                         
    61                         List<Node> notSelectedNodes = null; 
    62                         try { 
    63                                 notSelectedNodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    64                         } catch (ResourceException e) { 
    65                         } 
     61                        List<Node> notSelectedNodes = resourceManager.getNodes(); 
    6662                         
    6763                        // check all tasks in queue 
    … …  
    9288                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    9389                 
    94                 List<Node> nodes = null; 
    95                 try { 
    96                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    97                 } catch (ResourceException e) { 
    98                         // TODO Auto-generated catch block 
    99                         e.printStackTrace(); 
    100                 } 
     90                List<Node> nodes = resourceManager.getNodes(); 
    10191                List<Node> avNodes = filterNodes(nodes, task); 
    10292                Node node; 

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

    r1253 r1258  
    99 
    1010import schedframe.events.scheduling.SchedulingEvent; 
    11 import schedframe.exceptions.ResourceException; 
    1211import schedframe.resources.ResourceStatus; 
    13 import schedframe.resources.StandardResourceType; 
    14 import schedframe.resources.computing.Node; 
    1512import schedframe.resources.computing.ComputingResource; 
    1613import schedframe.resources.computing.Core; 
     14import schedframe.resources.computing.Node; 
    1715import schedframe.resources.units.ProcessingElements; 
    1816import schedframe.resources.units.ResourceUnit; 
    … …  
    7876                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    7977                 
    80                 List<Node> nodes = null; 
    81                 try { 
    82                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    83                 } catch (ResourceException e) { 
    84                         // TODO Auto-generated catch block 
    85                         e.printStackTrace(); 
    86                 } 
     78                List<Node> nodes = resourceManager.getNodes(); 
    8779                List<Node> avNodes = filterNodes(nodes, task); 
    8880                Collections.sort(avNodes, new FavourableNodeComparator()); 

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

    r1247 r1258  
    44 
    55import schedframe.events.scheduling.SchedulingEvent; 
    6 import schedframe.exceptions.ResourceException; 
    7 import schedframe.resources.StandardResourceType; 
    86import schedframe.resources.computing.Node; 
    9 import schedframe.resources.computing.ComputingResource; 
    107import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    118import schedframe.scheduling.manager.resources.ResourceManager; 
    … …  
    5956        @SuppressWarnings("unchecked") 
    6057        private String chooseProvider(ClusterResourceManager resourceManager) { 
    61                 List<ComputingResource> nodes = null; 
    62                 try { 
    63                         nodes = (List<ComputingResource>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    64                 } catch (ResourceException e) { 
    65                         // TODO Auto-generated catch block 
    66                         e.printStackTrace(); 
    67                 } 
     58                List<Node> nodes = resourceManager.getNodes(); 
    6859                int nodeIdx = findLeastLoadedResourceIdx(nodes); 
    6960                return nodes.get(nodeIdx).getFullName(); 
    7061        } 
    7162         
    72         private int findLeastLoadedResourceIdx(List<ComputingResource> nodes ){ 
     63        private int findLeastLoadedResourceIdx(List<Node> nodes ){ 
    7364                int resourceIdx = -1; 
    7465                int minLoad = Integer.MAX_VALUE; 
    7566                 
    7667                for(int i = 0; i < nodes.size(); i++){ 
    77                         Node node = (Node) nodes.get(i); 
     68                        Node node = nodes.get(i); 
    7869                        JobRegistry jr = new JobRegistryImpl(node.getFullName()); 
    7970                        int totalLoad = jr.getRunningTasks().size();  

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

    r1253 r1258  
    88 
    99import schedframe.events.scheduling.SchedulingEvent; 
    10 import schedframe.exceptions.ResourceException; 
    1110import schedframe.resources.ResourceStatus; 
    12 import schedframe.resources.StandardResourceType; 
    13 import schedframe.resources.computing.Node; 
    1411import schedframe.resources.computing.ComputingResource; 
    1512import schedframe.resources.computing.Core; 
     13import schedframe.resources.computing.Node; 
    1614import schedframe.resources.units.ProcessingElements; 
    1715import schedframe.resources.units.ResourceUnit; 
    … …  
    7876                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    7977                 
    80                 List<Node> nodes = null; 
    81                 try { 
    82                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    83                 } catch (ResourceException e) { 
    84                         // TODO Auto-generated catch block 
    85                         e.printStackTrace(); 
    86                 } 
     78                List<Node> nodes = resourceManager.getNodes(); 
    8779                List<Node> avNodes = filterNodes(nodes, task); 
    8880                if(avNodes.size() == 0) 

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

    r1253 r1258  
    1212import schedframe.resources.ResourceStatus; 
    1313import schedframe.resources.StandardResourceType; 
    14 import schedframe.resources.computing.Node; 
    1514import schedframe.resources.computing.ComputingResource; 
    1615import schedframe.resources.computing.Core; 
     16import schedframe.resources.computing.Node; 
    1717import schedframe.resources.computing.Processor; 
    1818import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    … …  
    5959                        TaskQueue q = queues.get(0); 
    6060                         
    61                         List<Node> notSelectedNodes = null; 
    62                         try { 
    63                                 notSelectedNodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    64                         } catch (ResourceException e) { 
    65                         } 
     61                        List<Node> notSelectedNodes = resourceManager.getNodes(); 
    6662                         
    6763                        // check all tasks in queue 
    … …  
    9288                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    9389                 
    94                 List<Node> nodes = null; 
    95                 try { 
    96                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    97                 } catch (ResourceException e) { 
    98                         // TODO Auto-generated catch block 
    99                         e.printStackTrace(); 
    100                 } 
     90                List<Node> nodes = resourceManager.getNodes(); 
    10191                List<Node> avNodes = filterNodes(nodes, task); 
    10292                Node node; 

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

    r1253 r1258  
    99 
    1010import schedframe.events.scheduling.SchedulingEvent; 
    11 import schedframe.exceptions.ResourceException; 
    1211import schedframe.resources.ResourceStatus; 
    13 import schedframe.resources.StandardResourceType; 
    14 import schedframe.resources.computing.Node; 
    1512import schedframe.resources.computing.ComputingResource; 
    1613import schedframe.resources.computing.Core; 
     14import schedframe.resources.computing.Node; 
    1715import schedframe.resources.units.ProcessingElements; 
    1816import schedframe.resources.units.ResourceUnit; 
    … …  
    7876                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    7977                 
    80                 List<Node> nodes = null; 
    81                 try { 
    82                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    83                 } catch (ResourceException e) { 
    84                         // TODO Auto-generated catch block 
    85                         e.printStackTrace(); 
    86                 } 
     78                List<Node> nodes = resourceManager.getNodes(); 
    8779                List<Node> avNodes = filterNodes(nodes, task); 
    8880                Collections.sort(avNodes, new FavourableNodeComparator()); 

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

    r1247 r1258  
    44 
    55import schedframe.events.scheduling.SchedulingEvent; 
    6 import schedframe.exceptions.ResourceException; 
    7 import schedframe.resources.StandardResourceType; 
    86import schedframe.resources.computing.Node; 
    9 import schedframe.resources.computing.ComputingResource; 
    107import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    118import schedframe.scheduling.manager.resources.ResourceManager; 
    … …  
    5956        @SuppressWarnings("unchecked") 
    6057        private String chooseProvider(ClusterResourceManager resourceManager) { 
    61                 List<ComputingResource> nodes = null; 
    62                 try { 
    63                         nodes = (List<ComputingResource>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    64                 } catch (ResourceException e) { 
    65                         // TODO Auto-generated catch block 
    66                         e.printStackTrace(); 
    67                 } 
     58                List<Node> nodes = resourceManager.getNodes(); 
    6859                int nodeIdx = findLeastLoadedResourceIdx(nodes); 
    6960                return nodes.get(nodeIdx).getFullName(); 
    7061        } 
    7162         
    72         private int findLeastLoadedResourceIdx(List<ComputingResource> nodes ){ 
     63        private int findLeastLoadedResourceIdx(List<Node> nodes ){ 
    7364                int resourceIdx = -1; 
    7465                int minLoad = Integer.MAX_VALUE; 
    7566                 
    7667                for(int i = 0; i < nodes.size(); i++){ 
    77                         Node node = (Node) nodes.get(i); 
     68                        Node node = nodes.get(i); 
    7869                        JobRegistry jr = new JobRegistryImpl(node.getFullName()); 
    7970                        int totalLoad = jr.getRunningTasks().size();  

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

    r1253 r1258  
    88 
    99import schedframe.events.scheduling.SchedulingEvent; 
    10 import schedframe.exceptions.ResourceException; 
    11 import schedframe.resources.StandardResourceType; 
     10import schedframe.resources.computing.ComputingResource; 
    1211import schedframe.resources.computing.Node; 
    13 import schedframe.resources.computing.ComputingResource; 
    1412import schedframe.resources.computing.Processor; 
    1513import schedframe.resources.units.ProcessingElements; 
    … …  
    8179                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    8280                 
    83                 List<Node> nodes = null; 
    84                 try { 
    85                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    86                 } catch (ResourceException e) { 
    87                         // TODO Auto-generated catch block 
    88                         e.printStackTrace(); 
    89                 } 
     81                List<Node> nodes = resourceManager.getNodes(); 
    9082                List<Node> avNodes = filterNodes(nodes, task); 
    9183                if(avNodes.size() == 0) 

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

    r1247 r1258  
    99 
    1010import schedframe.events.scheduling.SchedulingEvent; 
    11 import schedframe.exceptions.ResourceException; 
    1211import schedframe.resources.ResourceStatus; 
    13 import schedframe.resources.StandardResourceType; 
     12import schedframe.resources.computing.ComputingResource; 
    1413import schedframe.resources.computing.Node; 
    15 import schedframe.resources.computing.ComputingResource; 
    1614import schedframe.resources.computing.Processor; 
    1715import schedframe.resources.computing.profiles.energy.power.StandardPowerStateName; 
    … …  
    5351                        TaskQueue q = queues.get(0); 
    5452                        // check all tasks in queue 
    55                         List<Node> nodes; 
    56                         try { 
    57                                 nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    58                         } catch (ResourceException e) { 
    59                                 break; 
    60                         } 
     53                        List<Node> nodes = resourceManager.getNodes(); 
    6154                        for (int i = 0; i < q.size(); i++) { 
    6255                                TaskInterface<?> task = q.get(i); 

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

    r1247 r1258  
    44 
    55import schedframe.events.scheduling.SchedulingEvent; 
    6 import schedframe.exceptions.ResourceException; 
    7 import schedframe.resources.StandardResourceType; 
    86import schedframe.resources.computing.Node; 
    9 import schedframe.resources.computing.ComputingResource; 
    107import schedframe.scheduling.manager.resources.ClusterResourceManager; 
    118import schedframe.scheduling.manager.resources.ResourceManager; 
    … …  
    6057        @SuppressWarnings("unchecked") 
    6158        private String chooseProvider(ClusterResourceManager resourceManager) { 
    62                 List<ComputingResource> nodes = null; 
    63                 try { 
    64                         nodes = (List<ComputingResource>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    65                 } catch (ResourceException e) { 
    66                         // TODO Auto-generated catch block 
    67                         e.printStackTrace(); 
    68                 } 
     59                List<Node> nodes = resourceManager.getNodes(); 
     60                 
    6961                int nodeIdx = findLeastLoadedResourceIdx(nodes); 
    7062                return nodes.get(nodeIdx).getFullName(); 
    7163        } 
    7264         
    73         private int findLeastLoadedResourceIdx(List<ComputingResource> nodes ){ 
     65        private int findLeastLoadedResourceIdx(List<Node> nodes ){ 
    7466                int resourceIdx = -1; 
    7567                int minLoad = Integer.MAX_VALUE; 
    7668                 
    7769                for(int i = 0; i < nodes.size(); i++){ 
    78                         Node node = (Node) nodes.get(i); 
     70                        Node node = nodes.get(i); 
    7971                        JobRegistry jr = new JobRegistryImpl(node.getFullName()); 
    8072                        int totalLoad = jr.getRunningTasks().size();  

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

    r1253 r1258  
    88 
    99import schedframe.events.scheduling.SchedulingEvent; 
    10 import schedframe.exceptions.ResourceException; 
    1110import schedframe.resources.ResourceStatus; 
    12 import schedframe.resources.StandardResourceType; 
    13 import schedframe.resources.computing.Node; 
    1411import schedframe.resources.computing.ComputingResource; 
    1512import schedframe.resources.computing.Core; 
     13import schedframe.resources.computing.Node; 
    1614import schedframe.resources.computing.profiles.energy.airthroughput.UserAirThroughputStateName; 
    1715import schedframe.resources.devices.Device; 
    … …  
    5755                        TaskQueue q = queues.get(0); 
    5856                         
    59                         List<Node> notSelectedNodes = null; 
    60                         try { 
    61                                 notSelectedNodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    62                         } catch (ResourceException e) { 
    63                                 // TODO Auto-generated catch block 
    64                                 e.printStackTrace(); 
    65                         } 
     57                        List<Node> notSelectedNodes = resourceManager.getNodes(); 
    6658                        // check all tasks in queue 
    6759                        for (int i = 0; i < q.size(); i++) { 
    … …  
    8981        @SuppressWarnings("unchecked") 
    9082        private Node chooseRandomProvider(ClusterResourceManager resourceManager) { 
    91                 List<Node> nodes = null; 
    92                 try { 
    93                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    94                 } catch (ResourceException e) { 
    95                         // TODO Auto-generated catch block 
    96                         e.printStackTrace(); 
    97                 } 
     83                List<Node> nodes = resourceManager.getNodes(); 
    9884                nodes = filterNodes(nodes); 
    9985                int nodeIdx = rand.nextInt(nodes.size()); 
    … …  
    116102                Map<ResourceUnitName, ResourceUnit> map = new HashMap<ResourceUnitName, ResourceUnit>(); 
    117103                 
    118                 List<Node> nodes = null; 
    119                 try { 
    120                         nodes = (List<Node>) resourceManager.getResourcesOfType(StandardResourceType.Node); 
    121                 } catch (ResourceException e1) { 
    122                         // TODO Auto-generated catch block 
    123                         e1.printStackTrace(); 
    124                 } 
     104                List<Node> nodes = resourceManager.getNodes(); 
    125105                List<Node> avNodes = filterNodes(nodes, task); 
    126106                if(avNodes.size() == 0) 
Note: See TracChangeset for help on using the changeset viewer.