extend benchmark to run both upload and download tests

This commit is contained in:
Arvid Norberg 2013-09-10 21:04:56 +00:00
parent aace9e68e9
commit 730bc38515
1 changed files with 39 additions and 31 deletions

View File

@ -4,8 +4,6 @@ import shutil
import subprocess import subprocess
import sys import sys
port = (int(time.time()) % 50000) + 2000
toolset = '' toolset = ''
if len(sys.argv) > 1: if len(sys.argv) > 1:
toolset = sys.argv[1] toolset = sys.argv[1]
@ -23,21 +21,28 @@ if not os.path.exists('cpu_benchmark.torrent'):
print 'ERROR: connection_tester failed: %d' % ret print 'ERROR: connection_tester failed: %d' % ret
sys.exit(1) sys.exit(1)
try: shutil.rmtree('torrent_storage') try: shutil.rmtree('t')
except: pass except: pass
def run_test(name, test_cmd, client_arg, num_peers):
output_dir = 'logs_%s' % name
try: os.mkdir(output_dir)
except: pass
port = (int(time.time()) % 50000) + 2000
try: shutil.rmtree('session_stats') try: shutil.rmtree('session_stats')
except: pass except: pass
try: shutil.rmtree('session_stats_report')
try: os.mkdir('logs')
except: pass except: pass
start = time.time(); start = time.time();
client_cmd = '../examples/client_test -p %d cpu_benchmark.torrent -k -0 -z -H -X -q 120' % port client_cmd = '../examples/client_test -p %d cpu_benchmark.torrent -k -z -H -X -q 120 %s -h -c %d -T %d' \
test_cmd = '../examples/connection_tester upload -c 50 -d 127.0.0.1 -p %d -t cpu_benchmark.torrent' % port % (port, client_arg, num_peers *2, num_peers*2)
test_cmd = '../examples/connection_tester %s -c %d -d 127.0.0.1 -p %d -t cpu_benchmark.torrent' % (test_cmd, num_peers, port)
client_out = open('logs/client.out', 'w+') client_out = open('%s/client.out' % output_dir, 'w+')
test_out = open('logs/test.out', 'w+') test_out = open('%s/test.out' % output_dir, 'w+')
print client_cmd print client_cmd
c = subprocess.Popen(client_cmd.split(' '), stdout=client_out, stderr=client_out, stdin=subprocess.PIPE) c = subprocess.Popen(client_cmd.split(' '), stdout=client_out, stderr=client_out, stdin=subprocess.PIPE)
time.sleep(2) time.sleep(2)
@ -52,13 +57,16 @@ end = time.time();
print 'runtime %d seconds' % (end - start) print 'runtime %d seconds' % (end - start)
print 'analyzing proile...' print 'analyzing proile...'
os.system('gprof ../examples/client_test >logs/gprof.out') os.system('gprof ../examples/client_test >%s/gprof.out' % output_dir)
print 'generating profile graph...' print 'generating profile graph...'
os.system('python gprof2dot.py <logs/gprof.out | dot -Tpng -o logs/cpu_profile.png') os.system('python gprof2dot.py <%s/gprof.out | dot -Tps -o %s/cpu_profile.ps' % (output_dir, output_dir))
os.system('python parse_session_stats.py session_stats/*.log') os.system('python parse_session_stats.py session_stats/*.log')
try: os.rename('session_stats_report', 'logs/session_stats_report') try: shutil.move('session_stats_report', '%s/session_stats_report' % output_dir)
except: pass except: pass
try: os.rename('session_stats', 'logs/session_stats') try: shutil.move('session_stats', '%s/session_stats' % output_dir)
except: pass except: pass
run_test('download', 'upload', '', 50)
run_test('upload', 'download', '-G', 5)