Changeset 1207 for DCWoRMS/branches/coolemall/src/simulator/stats/implementation/TaskStats.java

Timestamp:

11/26/13 11:56:07 (11 years ago)

Author:

wojtekp

Message:

 

File:

• DCWoRMS/branches/coolemall/src/simulator/stats/implementation/TaskStats.java (modified) (6 diffs)

DCWoRMS/branches/coolemall/src/simulator/stats/implementation/TaskStats.java

@@ -2 +2 @@
 
 
-import java.util.List;
-
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+
+
+import schedframe.resources.computing.ComputingNode;
+import schedframe.resources.computing.ComputingResource;
+import schedframe.resources.computing.Core;
+import schedframe.resources.computing.Processor;
+import simulator.stats.implementation.out.StatsSerializer;
 import dcworms.schedframe.scheduling.Executable;
-
-import simulator.stats.implementation.out.StatsSerializer;
 
 /**
@@ -14 +20 @@
  */
 public class TaskStats implements StatsInterface {
-        protected List<String> processorsName;
+        protected Set<ComputingResource> processingElements;
         protected double reservationStartDate;
         protected double reservationFinishDate;
@@ -26 +32 @@
                         "ExecutionTime", "ReadyTime", "StartTime", "FlowTime",
                         "WaitingTime", "GQ_WaitingTime", "Lateness", "Tardiness",
-                        "ReservStartDate", "ReservFinishDate", "ProcessorName", "Energy"};
+                        "ReservStartDate", "ReservFinishDate", "HostNames", "ProcessorName", "Energy", "AppName",};
 
         public TaskStats(Executable task, long startSimulationTime) {
@@ -147 +153 @@
         }
 
-        public void setProcessorsName(List<String> value) {
-                this.processorsName = value;
+        public void setProcessors(Set<ComputingResource> value) {
+                this.processingElements = value;
         }
 
@@ -159 +165 @@
         }
 
-        public List<String> getProcessorsName() {
-                return processorsName;
-        }
-
+        public Set<String> getProcessingElementsName() {
+                Set<String> processingElementsNames = new HashSet<String>();
+                Iterator<ComputingResource> it = processingElements.iterator();
+                while(it.hasNext()) {
+                        ComputingResource compRes = it.next();
+                        processingElementsNames.add(compRes.getFullName());
+                }
+                return processingElementsNames;
+        }
+
+        public Set<String> getHostName() {
+                Set<String> hostNames = new HashSet<String>();
+                Iterator<ComputingResource> it = processingElements.iterator();
+                while(it.hasNext()) {
+                        ComputingResource compRes = it.next();
+                        ComputingNode node = null;
+                        if(compRes instanceof Core){
+                                Core core =(Core) compRes;
+                                node = (ComputingNode)core.getNode();
+                        } else if(compRes instanceof Processor){
+                                Processor proc = (Processor) compRes;
+                                node = (ComputingNode)proc.getNode();
+                        } else if(compRes instanceof ComputingNode){
+                                node = (ComputingNode)compRes;
+                        }
+                        if(node != null)
+                                hostNames.add(node.getFullName());
+                }
+                return hostNames;
+        }
+        
         public double getReservationStartDate() {
                 return reservationStartDate;
@@ -170 +203 @@
                 return reservationFinishDate;
         }
+        
+        public String getExecName() {
+                String execName = null;
+                if(task.getDescription().getExecution() != null) {
+                        if(task.getDescription().getExecution().getStdin()!= null && task.getDescription().getExecution().getStdin().length > 0)
+                                execName = task.getDescription().getExecution().getStdin()[0].getName();
+                        else if(task.getDescription().getExecution().getExecutable() != null && task.getDescription().getExecution().getExecutable().getApplication() != null)
+                                execName = task.getDescription().getExecution().getExecutable().getApplication().getName();
+                }
+                return execName;
+        }
 
         public String[] getHeaders() {