Changeset 1377 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager

Timestamp:

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

Author:

wojtekp

Message:

 

Location:

DCWoRMS/branches/coolemall/src/schedframe/scheduling/manager/resources

Files:

• LocalResourceManager.java (modified) (3 diffs)
• ResourceAllocation.java (modified) (1 diff)

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()){

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

@@ -1 +1 @@
 package schedframe.scheduling.manager.resources;
 
-import java.util.List;
+import java.util.Map;
 
-import schedframe.resources.computing.ComputingResource;
+import schedframe.resources.units.ResourceUnit;
+import schedframe.resources.units.ResourceUnitName;
 
 public interface ResourceAllocation {
-        public void allocateResources(List<ComputingResource> resources);
+        
+        /**
+         * Allocates resource units( marks as used) on the basis of given resource
+         * units.
+         * 
+         * @param freeRes
+         *            resource units to be consumed
+         * @param exclusive
+         *           allocate resources in exclusive mode
+         */
+        public boolean allocateResources(Map<ResourceUnitName, ResourceUnit> freeRes, boolean exclusive);
 
+        /**
+         * Frees given resource units.
+         * 
+         * @param lastUsedResources
+         *            resource units to be free
+         * @param exclusive
+         *            free resources allocated in exclusive mode
+         */
+        public void freeResources(Map<ResourceUnitName, ResourceUnit> lastUsedResources, boolean exclusive);
 
-        public void freeResources(List<ComputingResource> resources);
         
 }