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