Compute proportional graph response times.

1 files changed, 5 insertions, 3 deletions

diff --git a/parse/sched.py b/parse/sched.py
index 83004f2..11a614e 100644
--- a/parse/sched.py
+++ b/parse/sched.py
@@ -86,7 +86,7 @@ PgmTaskParams = namedtuple('PgmTaskParams', ['node_type', 'gid'])
 TaskData    = recordtype('TaskData',    ['params', 'pgm_params', 'jobs', 'blocks',
                                          'response', 'lateness', 'misses',
                                          'pgm_response', 'pgm_lateness', 'pgm_misses'])
-GraphParams = recordtype('GraphParams', ['gid', 'src', 'sink'])
+GraphParams = recordtype('GraphParams', ['gid', 'src', 'sink', 'etoe'])
 GraphData   = recordtype('GraphData',   ['params', 'jobs', 'response'])
 
 PGM_NOT_A_NODE = 0
@@ -297,7 +297,7 @@ class SysReleaseRecord(SchedRecord):
         pass
 
 class PgmParamRecord(SchedRecord):
-    FIELDS = [('node_type', c_uint32), ('graph_pid', c_uint16)]
+    FIELDS = [('node_type', c_uint32), ('graph_pid', c_uint16), ('unused2', c_uint16), ('etoe', c_uint64)]
 
     def process(self, task_dict):
         pass
@@ -309,7 +309,7 @@ class PgmParamRecord(SchedRecord):
         if self.node_type == PGM_SRC or self.node_type == PGM_SINK or self.node_type == PGM_SRC_SINK:
             graph_data = graph_dict[self.graph_pid]
             if not graph_data.params:
-                graph_data.params = GraphParams(self.graph_pid, 0, 0)
+                graph_data.params = GraphParams(self.graph_pid, 0, 0, self.etoe)
             if self.node_type == PGM_SRC:
                 assert graph_data.params.src == 0
                 graph_data.params.src = self.pid
@@ -472,6 +472,8 @@ def extract_sched_data(result, data_dir, work_dir):
 
         gstat_data["graph-response-max"].append(float(response.max)/NSEC_PER_MSEC)
         gstat_data["graph-response-avg"].append(response.avg/NSEC_PER_MSEC)
+        gstat_data["graph-response-prop-max"].append(float(response.max) / gdata.params.etoe)
+        gstat_data["graph-response-prop-avg"].append(response.avg / gdata.params.etoe)
 
     # Summarize value groups
     for name, data in stat_data.iteritems():