def add_to_mapping(mapping, key, value, msg):
if key in mapping:
if mapping[key] != value:
- print mapping[key], '!=', value
- print msg
+ print('%s != %s' % (mapping[key], value))
+ print(msg)
found_error[0] = True
else:
mapping[key] = value
import sys
from pylab import hist
import gzip
+import io
def get_next_line(line, output):
val = json.loads(line)
if val['type'] not in output:
output[val['type']] = {}
- for (name, value) in val.iteritems():
+ for (name, value) in val.items():
if name == "type":
continue
if name == "seq":
output[val['type']][name] += [float(value)]
def wrapgz(gfilename):
- def retval():
- gfile = gzip.open(gfilename, 'rb')
- gfile.__exit__ = lambda: gfile.close()
- return gfile
- return (gfilename, retval)
+ gfile = gzip.open(gfilename, 'rb')
+ if sys.version_info[0] >= 3:
+ gfile = io.TextIOWrapper(gfile)
+ return gfile
def read_all_input(filename):
cur = {}
openfn = wrapgz
with openfn(filename) as fh:
for line in fh:
- get_next_line(line, cur);
+ get_next_line(line, cur)
return cur
def write_committed_latency(out, bins, **kwargs):