Changeset 1434 for DCWoRMS/branches/coolemall/src/schedframe/scheduling/ResourceItem.java

Timestamp:

09/15/14 17:00:03 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/schedframe/scheduling/ResourceItem.java (modified) (3 diffs)

DCWoRMS/branches/coolemall/src/schedframe/scheduling/ResourceItem.java

@@ -17 +17 @@
         protected Map<ResourceUnitName, ResourceUnit> usedResources;
         protected Set<String> resourceNames;
+        protected Set<ComputingResource> compResource;
 
         public ResourceItem(Map<ResourceUnitName, ResourceUnit> usedResources){
                 this.usedResources = usedResources;
                 this.resourceNames = saveResourceNames();
+                this.compResource = saveResources();
         }
         
@@ -29 +31 @@
         public Set<String> getResourceNames(){
                 return resourceNames;
+        }
+        
+        public Set<ComputingResource> getResources(){
+                return compResource;
         }
         
@@ -57 +63 @@
                 return resourceNames;
         }
+        
+        private Set<ComputingResource> saveResources(){
+                Set<ComputingResource> compResources;
+                ProcessingElements pes = (ProcessingElements) usedResources.get(StandardResourceUnitName.PE);
+                compResources = new HashSet<ComputingResource>(pes.size(), 1);
+                for (ComputingResource resource: pes) {
+
+                        LinkedList<ComputingResource> toExamine = new LinkedList<ComputingResource>();
+                        toExamine.push(resource);
+
+                        while (!toExamine.isEmpty()) {
+                                ComputingResource compResource = toExamine.pop();
+                                List<ComputingResource> resources = compResource.getChildren();
+                                if(resources.isEmpty()){
+                                        if(!compResources.contains(compResource)){
+                                                compResources.add(compResource);
+                                        }
+                                } else {
+                                        for (int i = 0; i < resources.size(); i++) {
+                                                ComputingResource resourceChild = resources.get(i);
+                                                toExamine.addLast(resourceChild);
+                                        }
+                                }
+                        }
+                }
+                return compResources;
+        }
 }