sascha/workload-automation
1
0
Fork 0
mirror of https://github.com/ARM-software/workload-automation.git synced 2025-02-21 12:28:44 +00:00
Code Issues Releases Wiki Activity

Adding ID to overall cpustate reports.

Browse Source
This commit is contained in:
Sergei Trofimov 2015-06-26 10:24:07 +01:00
parent b25f7ec4a3
commit fcb6504f1e
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
wlauto/result_processors/cpustate.py
View File

@ -155,7 +155,7 @@ class CpuStatesProcessor(ResultProcessor):
else: else:
self.logger.debug('Reports generated.') self.logger.debug('Reports generated.')
iteration_id = (context.spec.label, context.current_iteration) iteration_id = (context.spec.id, context.spec.label, context.current_iteration)
self.iteration_reports[iteration_id] = (parallel_report, powerstate_report) self.iteration_reports[iteration_id] = (parallel_report, powerstate_report)
if self.write_iteration_reports: if self.write_iteration_reports:
self.logger.debug('Writing iteration reports') self.logger.debug('Writing iteration reports')
@ -170,26 +170,26 @@ class CpuStatesProcessor(ResultProcessor):
parallel_rows = [] parallel_rows = []
powerstate_rows = [] powerstate_rows = []
for iteration_id, reports in self.iteration_reports.iteritems(): for iteration_id, reports in self.iteration_reports.iteritems():
workload, iteration = iteration_id spec_id, workload, iteration = iteration_id
parallel_report, powerstate_report = reports parallel_report, powerstate_report = reports
for record in parallel_report.values: for record in parallel_report.values:
parallel_rows.append([workload, iteration] + record) parallel_rows.append([spec_id, workload, iteration] + record)
for state in sorted(powerstate_report.state_stats): for state in sorted(powerstate_report.state_stats):
stats = powerstate_report.state_stats[state] stats = powerstate_report.state_stats[state]
powerstate_rows.append([workload, iteration, state] + powerstate_rows.append([spec_id, workload, iteration, state] +
['{:.3f}'.format(s if s is not None else 0) ['{:.3f}'.format(s if s is not None else 0)
for s in stats]) for s in stats])
with open(os.path.join(context.output_directory, 'parallel.csv'), 'w') as wfh: with open(os.path.join(context.output_directory, 'parallel.csv'), 'w') as wfh:
writer = csv.writer(wfh) writer = csv.writer(wfh)
writer.writerow(['workload', 'iteration', 'cluster', writer.writerow(['id', 'workload', 'iteration', 'cluster',
'number_of_cores', 'total_time', 'number_of_cores', 'total_time',
'%time', '%running_time']) '%time', '%running_time'])
writer.writerows(parallel_rows) writer.writerows(parallel_rows)
with open(os.path.join(context.output_directory, 'cpustate.csv'), 'w') as wfh: with open(os.path.join(context.output_directory, 'cpustate.csv'), 'w') as wfh:
writer = csv.writer(wfh) writer = csv.writer(wfh)
headers = ['workload', 'iteration', 'state'] headers = ['id', 'workload', 'iteration', 'state']
headers += ['{} CPU{}'.format(c, i) headers += ['{} CPU{}'.format(c, i)
for i, c in enumerate(powerstate_report.core_names)] for i, c in enumerate(powerstate_report.core_names)]
writer.writerow(headers) writer.writerow(headers)