source: DCWoRMS/branches/coolemall/src/schedframe/resources/CoolEmAllResourceFactory.java @ 1271

package schedframe.resources;

import schedframe.resources.computing.ComputingResource;
import schedframe.resources.computing.Core;
import schedframe.resources.computing.DataCenter;
import schedframe.resources.computing.Node;
import schedframe.resources.computing.Processor;
import schedframe.resources.computing.ResourceFactory;
import schedframe.resources.computing.coolemall.ComputeBox1;
import schedframe.resources.computing.coolemall.NodeGroup;
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.local.LocalManagementSystem;
import schedframe.scheduling.queue.TaskQueueList;
import simulator.DCWormsConstants;

public class CoolEmAllResourceFactory implements ResourceFactory{
        
        public ComputingResource createComputingResource(ComputingResourceDescription resDesc){
                
                if (resDesc.getType().getName().equals(StandardResourceType.DataCenter.getName()))
                        return new DataCenter(resDesc);
                else if (resDesc.getType().getName().equals(StandardResourceType.Rack.getName()))
                        return new ComputeBox1(resDesc);
                else if (resDesc.getType().getName().equals(CoolEmAllResourceType.NodeGroup.getName()))
                        return new NodeGroup(resDesc);
                else if (resDesc.getType().getName().equals(StandardResourceType.Node.getName()))
                        return new Node(resDesc);
                else if (resDesc.getType().getName().equals(StandardResourceType.Processor.getName()))
                        return new Processor(resDesc);
                else if (resDesc.getType().getName().equals(StandardResourceType.Core.getName()))
                        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 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);
                        }
                }
        }
}