#!/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()
|
