diff options
author | drebs <drebs@riseup.net> | 2018-01-08 21:37:16 -0200 |
---|---|---|
committer | drebs <drebs@riseup.net> | 2018-01-08 21:37:16 -0200 |
commit | dffcd8a954225dedc51beae01baf0966ce92e155 (patch) | |
tree | edfff05dc22d0147b58e5318e44204f709604606 /blobs-multiprocess/request.py | |
parent | 3e8df5c794656e8bad5e620673d457af86de745d (diff) |
use ab in blobs multiprocess test
Diffstat (limited to 'blobs-multiprocess/request.py')
-rwxr-xr-x | blobs-multiprocess/request.py | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/blobs-multiprocess/request.py b/blobs-multiprocess/request.py index 9f35ca0..e533308 100755 --- a/blobs-multiprocess/request.py +++ b/blobs-multiprocess/request.py @@ -11,8 +11,8 @@ from uuid import uuid4 BASE_URI = 'http://127.0.0.1:8000/' -BLOBS_URI = urljoin(BASE_URI, - 'blobs/{}/'.format(time.strftime('%Y-%m-%d_%H-%M-%s'))) +BLOBS_URI = urljoin(BASE_URI, 'blobs/user/') +# 'blobs/{}/'.format(time.strftime('%Y-%m-%d_%H-%M-%s'))) CONCURRENT = 10 @@ -45,9 +45,9 @@ def parse_args(): return args -def _finished(_, start): +def _finished(_, start, amount): end = time.time() - print(end - start) + print(float(amount) / (end - start)) reactor.stop() @@ -56,12 +56,12 @@ def _error(failure): reactor.stop() -def main(generator): +def main(generator, amount): cooperator = task.Cooperator() cooptask = cooperator.cooperate(generator) start = time.time() d = cooptask.whenDone() - d.addCallback(_finished, start) + d.addCallback(_finished, start, amount) d.addErrback(_error) return d @@ -86,8 +86,6 @@ def requests_generator(args): deferreds = [] for i in xrange(args.amount): if args.baseline: - import pdb - pdb.set_trace() d = _client.get(BASE_URI) elif args.list: @@ -116,5 +114,5 @@ def requests_generator(args): if __name__ == "__main__": args = parse_args() generator = requests_generator(args) - d = main(generator) + d = main(generator, args.amount) reactor.run() |