| #!/usr/bin/env python |
| |
| """ |
| chewperf.py: Chew an http perf log |
| bucketize |
| |
| """ |
| |
| import sys, time |
| |
| def resets(): |
| f = open(sys.argv[1]).read() |
| rawLines = f.split('\n') |
| |
| times = [] |
| for x in range(len(rawLines)): |
| line = rawLines[x].split() |
| try: |
| if line[-1] == "SIGNAL_STRENGTH": |
| ts = int(rawLines[x - 1].split()[-1]) |
| times.append(ts) |
| except: |
| pass |
| |
| return times |
| |
| def augment(): |
| f = open(sys.argv[1]).read() |
| rawLines = f.split('\r\n') |
| |
| out = [] |
| t0 = None |
| last = 0 |
| for line in rawLines: |
| if "Pulled" in line: |
| chewed = [int(line.split()[5]), int(line.split()[7])] |
| if not t0: t0 = chewed[1] |
| tm = chewed[1] - t0 |
| out.append("%s %d" % (line, (tm - last))) |
| last = tm |
| else: |
| out.append(line) |
| print "\n".join(out) |
| |
| def chew(): |
| f = open(sys.argv[1]).read() |
| rawLines = f.split('\n') |
| lines = [x for x in rawLines if "Pulled" in x] |
| |
| sidx = lines[0].split().index("Pulled") |
| print "sidx", sidx |
| chewed = [[int(x.split()[sidx + 2]), int(x.split()[sidx + 4])] for x in lines] |
| |
| t0 = chewed[0][1] |
| tLast = chewed[-1][1] |
| chewed = [[x[1] - t0, x[0]] for x in chewed] |
| |
| totalTime = tLast - t0 |
| bytes = sum(x[1] for x in chewed) |
| print "total time", totalTime, "bytes", bytes, "rate", bytes * 1000 / totalTime |
| |
| buckets = {} |
| for x in chewed: |
| bucket = x[0] / 1000 |
| bytes = x[1] |
| if bucket in buckets: |
| buckets[bucket] += bytes |
| else: |
| buckets[bucket] = bytes |
| |
| top = max(buckets.keys()) |
| for x in range(top): |
| if x not in buckets.keys(): |
| buckets[x] = 0 |
| |
| # smooth |
| window = [0 for x in range(5)] |
| |
| for x in range(len(buckets.items())): |
| window[x % len(window)] = buckets.items()[x][1] |
| print "%s\t%s" % (buckets.items()[x][0], sum(window) / len(window)) |
| |
| def main(): |
| chew() |
| |
| if __name__ == '__main__': |
| main() |
