Changeset 1377 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/resources/LocalResourceManager.java

Timestamp:

06/06/14 10:48:32 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/resources/LocalResourceManager.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/resources/LocalResourceManager.java

@@ -29 +29 @@
 import schedframe.resources.units.StandardResourceUnitName;
 import schedframe.scheduling.Scheduler;
-import schedframe.scheduling.plugin.local.ResourceAllocation;
 
 
@@ -297 +296 @@
         }
         
-        public boolean allocateResources(Map<ResourceUnitName, ResourceUnit> resources) {
+
+        public boolean allocateResources(Map<ResourceUnitName, ResourceUnit> resources, boolean exclusive) {
                 
                 if (resources == null) {
@@ -303 +303 @@
                 }
                 
-                for(ResourceUnitName resUnitName: resources.keySet()){
-                        ResourceUnit resUnit = resources.get(resUnitName);
-                        resUnit.getProvisioner().setState(ResourceUnitState.BUSY);
-                }
-                return true;
-        }
-
-
-        public void freeResources(Map<ResourceUnitName, ResourceUnit> resources) {
+                if(exclusive){
+                        for(ResourceUnitName resUnitName: resources.keySet()){
+                                ResourceUnit resUnit = resources.get(resUnitName);
+                                if(resUnit.getName().getName().equals(StandardResourceUnitName.PE.getName())){
+                                        ProcessingElements pe = (ProcessingElements)resUnit;
+                                        for(ComputingResource cr: pe){
+                                                if(cr.getStatus().equals(ResourceStatus.BUSY)){
+                                                        return false;
+                                                }
+                                        }
+                                }
+                                resUnit.getProvisioner().setState(ResourceUnitState.BUSY);
+                        }
+                        
+                        return true;
+                } else {
+                        for(ResourceUnitName resUnitName: resources.keySet()){
+                                ResourceUnit resUnit = resources.get(resUnitName);
+                                resUnit.getProvisioner().setState(ResourceUnitState.BUSY);
+                        }
+                        return true;    
+                }
+        }
+
+        public void freeResources(Map<ResourceUnitName, ResourceUnit> resources, boolean exclusive) {
                 
                 for(ResourceUnitName resUnitName: resources.keySet()){