Changeset 192


Ignore:
Timestamp:
03/26/12 12:03:27 (13 years ago)
Author:
wojtekp
Message:
 
Location:
xssim/trunk/src/example/localplugin
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • xssim/trunk/src/example/localplugin/FCFSCPUFreqScalingClusterLocalPlugin.java

    r172 r192  
    4646                SchedulingPlanNew plan = new SchedulingPlanNew(); 
    4747                // our tasks are placed only in first queue (see 
    48                 // BaseLocalPlugin.placeTasksInQueues() method) 
     48                // BaseLocalPlugin.placeJobsInQueues() method) 
    4949                Queue q = queues.get(0); 
    5050                // chose the events types to serve. 

  • xssim/trunk/src/example/localplugin/FCFSClusterLocalPlugin.java

    r169 r192  
    4949                case TIMER: 
    5050                        // our tasks are placed only in first queue (see 
    51                         // BaseLocalPlugin.placeTasksInQueues() method) 
     51                        // BaseLocalPlugin.placeJobsInQueues() method) 
    5252                        Queue q = queues.get(0); 
    5353                        // check all tasks in queue 
    54  
    5554 
    5655                        for (int i = 0; i < q.size(); i++) { 
    … …  
    6463                                        /****************3 ways to schedule task****************/ 
    6564                                         
    66                                         //1. Choosing particular resources to perform execution 
     65                                        /****************1. Choosing particular resources to perform execution****************/ 
    6766                                        Map<ResourceParameterName, ResourceUnit> choosenResources = chooseResourcesForExecution(resourceManager, subTask); 
    6867                                        if (choosenResources != null) { 
    … …  
    7069                                        } 
    7170                                         
    72                                         //2. Choosing resource scheduler/provider to submit task.  If the given resource doesn't contains/isn't  
    73                                         //a scheduler, random resources from the given resource will be chosen in order to perform execution 
     71                                        /****************2. Choosing resource scheduler/provider to submit task.  If the given resource doesn't contains/isn't  
     72                                        a scheduler, random resources from the given resource will be chosen in order to perform execution****************/ 
    7473                                        /*String provName = chooseProviderForExecution(resourceManager); 
    7574                                        if (provName != null) { 
    … …  
    7776                                        }*/ 
    7877 
    79                                         //3. Scheduler will choose random resources to perform execution 
     78                                        /****************3. Scheduler will choose random resources to perform execution****************/ 
    8079                                        //addToSchedulingPlan(plan, task); 
    81  
    8280                                } 
    8381                        } 
    … …  
    141139 
    142140                                if (node.getFreeMemory() >= memoryRequest) { 
    143                                         memory = new Memory(node.getMemory(), memoryRequest, memoryRequest); 
     141                                        memory = new Memory(node.getMemoryUnit(), memoryRequest, memoryRequest); 
    144142                                } else 
    145143                                        return null; 
    … …  
    151149        } 
    152150 
     151        @SuppressWarnings("unchecked") 
    153152        private String chooseProviderForExecution(ResourceManagerInterface unitsManager) { 
    154153                List<ComputingResource> processingElements; 

  • xssim/trunk/src/example/localplugin/FCFSConsolidationClusterLocalPlugin.java

    r163 r192  
    22 
    33import gridsim.Gridlet; 
    4 import gridsim.gssim.ResourceHistoryItem; 
    5 import gridsim.gssim.SubmittedTask; 
    64 
    75import java.util.ArrayList; 
    … …  
    1715import schedframe.scheduling.TaskInterface; 
    1816import schedframe.scheduling.events.SchedulingEvent; 
    19 import schedframe.scheduling.events.TaskFinishedEvent; 
    2017import schedframe.scheduling.plugin.grid.ModuleList; 
    2118import schedframe.scheduling.utils.ResourceParameterName; 
    2219import test.rewolucja.GSSIMJobInterface; 
    23 import test.rewolucja.energy.profile.PStateType; 
    2420import test.rewolucja.resources.ProcessingElements; 
    2521import test.rewolucja.resources.ResourceStatus; 
    26 import test.rewolucja.resources.ResourceType; 
    2722import test.rewolucja.resources.manager.implementation.ClusterResourceManager; 
    2823import test.rewolucja.resources.manager.interfaces.ResourceManagerInterface; 
    2924import test.rewolucja.resources.physical.base.ComputingResource; 
    30 import test.rewolucja.resources.physical.implementation.CPU; 
    3125import test.rewolucja.resources.physical.implementation.ComputingNode; 
    3226import test.rewolucja.scheduling.JobRegistryInterface; 
    … …  
    5246                case TASK_FINISHED: 
    5347                        // our tasks are placed only in first queue (see 
    54                         // BaseLocalPlugin.placeTasksInQueues() method) 
     48                        // BaseLocalPlugin.placeJobsInQueues() method) 
    5549                        Queue q = queues.get(0); 
    5650                        // check all tasks in queue 
    … …  
    111105                        } 
    112106                        if (memoryRequest != 0) { 
    113                                 Memory memory = new Memory(node.getMemory(), memoryRequest, memoryRequest); 
     107                                Memory memory = new Memory(node.getMemoryUnit(), memoryRequest, memoryRequest); 
    114108                                map.put(ResourceParameterName.MEMORY, memory); 
    115109                        } 
    … …  
    132126                        memoryRequest = 0; 
    133127                } 
    134                 List<ComputingNode> avNodes = new ArrayList<ComputingNode>(); 
     128                List<ComputingNode> suitableNodes = new ArrayList<ComputingNode>(); 
    135129                for(ComputingNode node: nodes){ 
    136130                        if(node.getFreeProcessorsNumber() >= cpuRequest && node.getFreeMemory() >= memoryRequest){ 
    137                                 avNodes.add(node); 
     131                                suitableNodes.add(node); 
    138132                        } 
    139133                } 
    140                 return avNodes; 
     134                return suitableNodes; 
    141135        } 
    142136         

  • xssim/trunk/src/example/localplugin/FCFSEnergyAwareClusterLocalPlugin.java

    r163 r192  
    3838                case TASK_FINISHED: 
    3939                        // our tasks are placed only in first queue (see 
    40                         // BaseLocalPlugin.placeTasksInQueues() method) 
     40                        // BaseLocalPlugin.placeJobsInQueues() method) 
    4141                        Queue q = queues.get(0); 
    4242                        // check all tasks in queue 

  • xssim/trunk/src/example/localplugin/FCFSNodePowerManagementClusterLocalPlugin.java

    r163 r192  
    4646                case TASK_FINISHED: 
    4747                        // our tasks are placed only in first queue (see 
    48                         // BaseLocalPlugin.placeTasksInQueues() method) 
     48                        // BaseLocalPlugin.placeJobsInQueues() method) 
    4949                        Queue q = queues.get(0); 
    5050                        // check all tasks in queue 
    … …  
    6060                                                addToSchedulingPlan(plan, task, choosenResources); 
    6161                                        } else { 
    62                                                 if(harnessNodestoWork(task, resourceManager.getComputingNodes())) 
     62                                                if(harnessIdleNodesToWork(task, resourceManager.getComputingNodes())) 
    6363                                                        i--; 
    6464                                        } 
    … …  
    130130        } 
    131131         
    132         private boolean harnessNodestoWork(TaskInterface<?> task, List<ComputingNode> nodes){ 
     132        private boolean harnessIdleNodesToWork(TaskInterface<?> task, List<ComputingNode> nodes){ 
    133133                int cpuRequest; 
    134134                try { 

  • xssim/trunk/src/example/localplugin/FCFSRandomClusterLocalPlugin.java

    r163 r192  
    3939                case TASK_FINISHED: 
    4040                        // our tasks are placed only in first queue (see 
    41                         // BaseLocalPlugin.placeTasksInQueues() method) 
     41                        // BaseLocalPlugin.placeJobsInQueues() method) 
    4242                        Queue q = queues.get(0); 
    4343                        // check all tasks in queue 
Note: See TracChangeset for help on using the changeset viewer.