source: DCWoRMS/branches/coolemall/src/schedframe/resources/computing/StandardResourceFactory.java @ 1247

package schedframe.resources.computing;

import schedframe.resources.StandardResourceType;
import schedframe.resources.computing.description.ComputingResourceDescription;
import schedframe.scheduling.Scheduler;
import schedframe.scheduling.manager.resources.ManagedResources;
import schedframe.scheduling.plugin.SchedulingPlugin;
import schedframe.scheduling.plugin.estimation.ExecutionTimeEstimationPlugin;
import schedframe.scheduling.policy.AbstractManagementSystem;
import schedframe.scheduling.policy.global.GridBroker;
import schedframe.scheduling.policy.local.LocalManagementSystem;
import schedframe.scheduling.queue.TaskQueueList;
import simulator.DCWormsConstants;

public class StandardResourceFactory implements ResourceFactory {
        
        public ComputingResource createComputingResource(ComputingResourceDescription resDesc){
                
                if (resDesc.getType().equals(StandardResourceType.DataCenter))
                        return new DataCenter(resDesc);
                else if (resDesc.getType().equals(StandardResourceType.Rack))
                        return new Rack(resDesc);
                else if (resDesc.getType().equals(StandardResourceType.Node))
                        return new Node(resDesc);
                else if (resDesc.getType().equals(StandardResourceType.Processor))
                        return new Processor(resDesc);
                else if (resDesc.getType().equals(StandardResourceType.Core))
                        return new Core(resDesc);
                else
                        return new ComputingResource(resDesc);

        }

        public Scheduler createScheduler(StandardResourceType type, String id, SchedulingPlugin schedulingPlugin, ExecutionTimeEstimationPlugin execTimeEstimationPlugin, TaskQueueList queues, ManagedResources managedResources) throws Exception{
                AbstractManagementSystem ms;
                switch(type){
                        case GS: {
                                ms = new GridBroker("grid",
                                                schedulingPlugin, execTimeEstimationPlugin, queues);
                                return new Scheduler(ms, type, managedResources);
                        }
                        case LS: {
                                ms = new LocalManagementSystem(id, DCWormsConstants.MANAGEMENT_SYSTEM,
                                                schedulingPlugin, execTimeEstimationPlugin, queues);
                                return new Scheduler(ms, type, managedResources);
                        }

                default:{
                                ms = new LocalManagementSystem(id, DCWormsConstants.MANAGEMENT_SYSTEM,
                                                schedulingPlugin, execTimeEstimationPlugin, queues);
                                return new Scheduler(ms, type, managedResources);
                        }
                }
        }
}