[477] | 1 | package schedframe.scheduling.manager.resources; |
---|
| 2 | |
---|
| 3 | import schedframe.scheduling.GridResourceDiscovery; |
---|
| 4 | import schedframe.scheduling.Scheduler; |
---|
| 5 | |
---|
| 6 | public class ResourceManagerFactory { |
---|
| 7 | |
---|
| 8 | public static ResourceManager createResourceManager(Scheduler scheduler, ManagedResources managedResources){ |
---|
| 9 | |
---|
| 10 | ManagedComputingResources managedResource = scheduler.getCompResources(); |
---|
| 11 | |
---|
[966] | 12 | if(managedResources == null || managedResource.getType().getName().equals("DataCenter")) |
---|
[477] | 13 | return new GridResourceDiscovery(scheduler); |
---|
| 14 | else if (managedResource.getType().getName().equals("Rack")) |
---|
| 15 | return new ClusterResourceManager(scheduler.getCompResources(), scheduler.getChildren(), managedResources); |
---|
| 16 | else if (managedResource.getType().getName().equals("ComputingNode")) |
---|
| 17 | return new ClusterResourceManager(scheduler.getCompResources(), scheduler.getChildren(), managedResources); |
---|
| 18 | else if (managedResource.getType().getName().equals("Processor")) |
---|
| 19 | return new ClusterResourceManager(scheduler.getCompResources(), scheduler.getChildren(), managedResources); |
---|
| 20 | else return new ClusterResourceManager(scheduler.getCompResources(), scheduler.getChildren(), managedResources); |
---|
| 21 | //throw new IllegalArgumentException("ResourceType " + managedResource.getType() + " is not supported."); |
---|
| 22 | |
---|
| 23 | /*switch(managedResource.getType()){ |
---|
| 24 | case DataCenter: return new GridResourceDiscovery(scheduler); |
---|
| 25 | case Rack: return new ClusterResourceManager(scheduler.getResources(), scheduler.getChildren()); |
---|
| 26 | case ComputingNode: return new ClusterResourceManager(scheduler.getResources(), scheduler.getChildren()); |
---|
| 27 | case Processor: return new ClusterResourceManager(scheduler.getResources(), scheduler.getChildren()); |
---|
| 28 | default: |
---|
| 29 | throw new IllegalArgumentException("ResourceType " + managedResource.getType() + " is not supported."); |
---|
| 30 | }*/ |
---|
| 31 | } |
---|
| 32 | } |
---|