Commit a8a42543 authored by Cristian Simarro's avatar Cristian Simarro
Browse files

Merge branch 'hotfix-summary' into 'ecmwf'

fixed several bugs with files POSIX+STDIO

See merge request !2
parents e92521ac 451a3654
......@@ -239,23 +239,32 @@ def main():
nseeks=int(value)
if nseeks > 0:
totals['tnseeks']+=nseeks
fileaccess[rank][fname]['nseeks']=nseeks
if 'nseeks' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['nseeks']=nseeks
else:
fileaccess[rank][fname]['nseeks']+=nseeks
elif metric in ['POSIX_F_READ_TIME','STDIO_F_READ_TIME']: # or metric == 'POSIX_F_MPI_READ_TIME':
readtime=float(value)
if readtime > 0:
totals['treadtime']+=readtime
totals['tfile_reads']+=1
fileaccess[rank][fname]['readtime']=readtime
if 'readtime' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['readtime']=readtime
else:
fileaccess[rank][fname]['readtime']+=readtime
elif metric in ['POSIX_F_WRITE_TIME','STDIO_F_WRITE_TIME']: # or metric == 'POSIX_F_MPI_WRITE_TIME':
writetime=float(value)
if writetime > 0:
if not fileaccess[rank][fname]['nwrites']:
totals['tfsynctime']+=writetme
totals['tfsynctime']+=writetime
fileaccess[rank][fname]['fsynctime']=writetime
else:
totals['twritetime']+=writetime
totals['tfile_writes']+=1
fileaccess[rank][fname]['writetime']=writetime
if 'writetime' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['writetime']=writetime
else:
fileaccess[rank][fname]['writetime']+=writetime
elif metric == 'POSIX_WRITES':
nwrites=int(value)
if nwrites > 0:
......@@ -286,20 +295,29 @@ def main():
totals['tnfreads']+=nreads
fileaccess[rank][fname]['nreads']+=nreads
fileaccess[rank][fname]['nfreads']=nreads
elif metric == 'POSIX_FSYNCS' or metric == 'POSIX_FDSYNCS':
elif metric in ['POSIX_FSYNCS','POSIX_FDSYNCS']:
fsyncs=int(value)
if fsyncs > 0:
totals['tnfsyncs']+=fsyncs
fileaccess[rank][fname]['fsyncs']=fsyncs
elif metric == 'POSIX_FLUSHES' or metric == 'STDIO_FLUSHES':
if 'fsyncs' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['fsyncs']=fsyncs
else:
fileaccess[rank][fname]['fsyncs']+=fsyncs
elif metric in ['POSIX_FLUSHES','STDIO_FLUSHES']:
flushes=int(value)
if flushes > 0:
totals['tnflushes']+=flushes
fileaccess[rank][fname]['flushes']=flushes
if 'flushes' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['flushes']=flushes
else:
fileaccess[rank][fname]['flushes']+=flushes
elif metric in ['POSIX_F_META_TIME','POSIX_F_MPI_META_TIME','STDIO_F_META_TIME']:
metatime=float(value)
if metatime > 0:
fileaccess[rank][fname]['metatime']=metatime
if 'metatime' not in fileaccess[rank][fname]:
fileaccess[rank][fname]['metatime']=metatime
else:
fileaccess[rank][fname]['metatime']+=metatime
totals['tmetatime']+=metatime
elif metric.startswith("LUSTRE_"):
if fname not in lustrefile:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment