Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
#! /usr/bin/env nix-shell
#! nix-shell -i python -p "python.withPackages (ps: [ ps.treq ])"
# Apply a very minimal load to a PaymentServer via the redemption endpoint.
#
# This requires a PaymentServer run something like:
#
# $ ./result/bin/PaymentServer-exe --issuer Trivial --http-port 8080 --stripe-key-path ../stripe.secret --database SQLite3 --database-path ./vouchers.db
#
# It also requires some vouchers to be marked as paid somehow. The vouchers
# are aaa0 through aaaN where N is the PARALLELISM you select. You can
# accomplish this by:
#
# $ for n in $(seq 0 30); do sqlite3 vouchers.db "insert into vouchers (name) values ('aaa$n')"; done
#
# Then the test can be run as many times as necessary. Repeated redemptions
# are allowed since the same tokens are used on every run.
#
# Originally written for https://github.com/PrivateStorageio/PaymentServer/issues/60
from __future__ import division
from time import (
time,
)
from json import (
dumps,
)
from treq.client import (
HTTPClient,
)
from twisted.web.client import (
Agent,
readBody,
)
from twisted.internet.task import (
react,
)
from twisted.internet.defer import (
inlineCallbacks,
gatherResults,
returnValue,
)
PARALLELISM = 30
@inlineCallbacks
def redeem(client, index):
times = []
for i in range(16):
before = time()
response = yield client.post(
url="http://127.0.0.1:8080/v1/redeem",
data=dumps({
"redeemVoucher": "aaa{}".format(index),
"redeemTokens": ["foo-{}-{}".format(index, i)],
"redeemCounter": i,
}),
headers={"content-type": "application/json"},
)
after = time()
duration = int((after - before) * 1000)
print("Request complete in {}ms".format(duration))
body = yield readBody(response)
assert response.code == 200, (response.code, body)
times.append(duration)
returnValue(times)
def mean(xs):
return sum(xs) / len(xs)
def percentile(n, xs):
return sorted(xs)[int(len(xs) / 100 * 95)]
def median(xs):
return percentile(50, xs)
@react
@inlineCallbacks
def main(reactor):
client = HTTPClient(Agent(reactor))
ds = list(
redeem(client, i)
for i
in range(PARALLELISM)
)
times = []
for result in (yield gatherResults(ds)):
times.extend(result)
print("min: {}".format(min(times)))
print("max: {}".format(max(times)))
print("mean: {}".format(mean(times)))
print("median: {}".format(median(times)))
print("95th: {}".format(percentile(95, times)))