X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fbench%2Fsmalliobenchprocessor.py;fp=src%2Fceph%2Fsrc%2Ftest%2Fbench%2Fsmalliobenchprocessor.py;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=7286db9640155c1ddd7573c8b0b511f2c544f77c;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/bench/smalliobenchprocessor.py b/src/ceph/src/test/bench/smalliobenchprocessor.py deleted file mode 100644 index 7286db9..0000000 --- a/src/ceph/src/test/bench/smalliobenchprocessor.py +++ /dev/null @@ -1,43 +0,0 @@ -import json -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.items(): - if name == "type": - continue - if name == "seq": - continue - if name not in output[val['type']]: - output[val['type']][name] = [] - output[val['type']][name] += [float(value)] - -def wrapgz(gfilename): - gfile = gzip.open(gfilename, 'rb') - if sys.version_info[0] >= 3: - gfile = io.TextIOWrapper(gfile) - return gfile - -def read_all_input(filename): - cur = {} - openfn = open - if ".gz" in filename: - openfn = wrapgz - with openfn(filename) as fh: - for line in fh: - get_next_line(line, cur) - return cur - -def write_committed_latency(out, bins, **kwargs): - hist(out['write_committed']['latency'], bins, **kwargs) - -def read_latency(out): - hist(out['read']['latency'], 100) - -def com(out): return out['write_committed']['latency'] -def app(out): return out['write_applied']['latency']