Changeset 137 for xssim/trunk/src

Timestamp:

03/15/12 13:32:43 (13 years ago)

Author:

wojtekp

Message:

 

File:

• xssim/trunk/src/gridsim/gssim/SubmittedTask.java (modified) (6 diffs)

xssim/trunk/src/gridsim/gssim/SubmittedTask.java

@@ -18 +18 @@
 import schedframe.scheduling.TaskInterface;
 import schedframe.scheduling.utils.ResourceParameterName;
+import test.rewolucja.resources.ProcessingElements;
+import test.rewolucja.resources.physical.base.ComputingResource;
 
 /**
@@ -29 +31 @@
         protected int estimatedDuration;
         protected List<ResourceHistoryItem> usedResources;
+        protected List<String> visitedResources;
         
         public SubmittedTask(AbstractExecutable gridlet) {
@@ -36 +39 @@
                 if(gridlet.requireReservation())
                         this.reservID_ = Integer.valueOf(gridlet.getReservationId());
+                this.visitedResources = new ArrayList<String>();
         }
 
@@ -194 +198 @@
                 (prevStatus == Gridlet.PAUSED && status == Gridlet.RESUMED) )
             {
+                
                 startExecTime_ = clock;
                 gridlet_.setExecStartTime(startExecTime_);
+                        ProcessingElements pes = (ProcessingElements) getUsedResources().get(getUsedResources().size()-1).getResourceUnits().get(ResourceParameterName.PROCESSINGELEMENTS);
+                        for (ComputingResource resource : pes) {
+
+                                visitResource(resource.getName());
+                                ComputingResource parent = resource.getParent();
+
+                                while (parent != null && !getVisitedResources().contains(parent.getName())) {
+                                        visitResource(parent.getName());
+                                        parent = parent.getParent();
+                                }
+                        }
             }
         }
@@ -236 +252 @@
         }
         
-        public void addToResPath(String resName){
+        /*public void addToResPath(String resName){
                 task.addToResPath(resName);
 
@@ -243 +259 @@
         public String getResPath(){
                 return task.getResPath();
+        }*/
+        
+        public void visitResource(String resName){
+                task.visitResource(resName);
+        }
+        
+        public List<String> getVisitedResources(){
+                return task.getVisitedResources();
         }
 }