Skip to content
Snippets Groups Projects
Commit abede1e7 authored by Adrien Béraud's avatar Adrien Béraud
Browse files

pingpong: print execution time

parent 859d8dc9
No related branches found
No related tags found
No related merge requests found
...@@ -35,13 +35,21 @@ pong_node.ping(ping_node.getBound()) ...@@ -35,13 +35,21 @@ pong_node.ping(ping_node.getBound())
loc_ping = dht.InfoHash.get("toto99") loc_ping = dht.InfoHash.get("toto99")
loc_pong = dht.InfoHash.get(str(loc_ping)) loc_pong = dht.InfoHash.get(str(loc_ping))
net = []
for i in range(1,10):
node = dht.DhtRunner()
node.run(config=config)
node.ping(ping_node.getBound())
net.append(node)
i = 0 i = 0
MAX = 2048 MAX = 2048
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
def done(h, ok): def done(h, ok):
print(h, "over", ok) pass
#print(h, "over", ok)
def ping(node, h): def ping(node, h):
global i global i
...@@ -52,13 +60,20 @@ def ping(node, h): ...@@ -52,13 +60,20 @@ def ping(node, h):
loop.stop() loop.stop()
def pong(node, h): def pong(node, h):
print(node.getNodeId().decode(), "got ping", h, i) #print(node.getNodeId().decode(), "got ping", h, i)
loop.call_soon_threadsafe(ping, node, h) loop.call_soon_threadsafe(ping, node, h)
return True return True
t1 = time.time()
ping_node.listen(loc_ping, lambda v, e: pong(pong_node, loc_pong) if not e else True) ping_node.listen(loc_ping, lambda v, e: pong(pong_node, loc_pong) if not e else True)
pong_node.listen(loc_pong, lambda v, e: pong(ping_node, loc_ping) if not e else True) pong_node.listen(loc_pong, lambda v, e: pong(ping_node, loc_ping) if not e else True)
ping(pong_node, loc_ping) ping(pong_node, loc_ping)
loop.run_forever() loop.run_forever()
t2 = time.time()
print(MAX, "ping-pong done, took", t2 - t1, "s")
print(1000 * (t2 - t1)/MAX, "ms per rt", MAX/(t2 - t1), "rt per s")
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment