mirror of
https://github.com/internetarchive/warcprox.git
synced 2025-01-18 13:22:09 +01:00
update benchmarks
This commit is contained in:
parent
4cb8e0d5dc
commit
04957dcba1
@ -1 +1 @@
|
|||||||
aiohttp==2.0.7
|
aiohttp==3.8.5
|
||||||
|
@ -55,11 +55,9 @@ async def do_get(request):
|
|||||||
bs = rando + b'x' * 49 + b'\n'
|
bs = rando + b'x' * 49 + b'\n'
|
||||||
else:
|
else:
|
||||||
bs = b'x' * 79 + b'\n'
|
bs = b'x' * 79 + b'\n'
|
||||||
response.write(bs)
|
await response.write(bs)
|
||||||
await response.drain()
|
|
||||||
if n % 80 > 0:
|
if n % 80 > 0:
|
||||||
response.write(b'x' * (n % 80 - 1) + b'\n')
|
await response.write(b'x' * (n % 80 - 1) + b'\n')
|
||||||
await response.drain()
|
|
||||||
|
|
||||||
return response
|
return response
|
||||||
|
|
||||||
@ -124,7 +122,7 @@ async def fetch(session, url, proxy=None):
|
|||||||
async def benchmarking_client(
|
async def benchmarking_client(
|
||||||
base_url, requests=200, payload_size=100000, proxy=None):
|
base_url, requests=200, payload_size=100000, proxy=None):
|
||||||
start = time.time()
|
start = time.time()
|
||||||
connector = aiohttp.TCPConnector(verify_ssl=False)
|
connector = aiohttp.TCPConnector(ssl=False)
|
||||||
n_urls = 0
|
n_urls = 0
|
||||||
n_bytes = 0
|
n_bytes = 0
|
||||||
url = '%s/%s' % (base_url, payload_size)
|
url = '%s/%s' % (base_url, payload_size)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user