logos-messaging/logos-messaging-simulator
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-simulator.git synced 2026-01-04 06:53:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve send time waiting

Browse Source
This commit is contained in:
stubbsta 2025-10-22 10:21:56 +02:00
parent 464147876a
commit 273af46ea9
No known key found for this signature in database
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
tools/rest-traffic/traffic.py
View File

@ -81,21 +81,24 @@ for node in nodes:
while True:
# calls are blocking
# limited by the time it takes the REST API to reply
time_to_sleep = args.delay_seconds
send_start_time = time.time()
if args.single_node != None:
send_waku_msg(args.single_node, args.msg_size_kbytes, args.pubsub_topic, args.content_topic)
if args.multiple_nodes != None:
#get time before sending to all nodes
send_start_time = time.time()
for node in nodes:
send_waku_msg(node, args.msg_size_kbytes, args.pubsub_topic, args.content_topic)
send_elapsed = time.time() - send_start_time
logging.info("Time taken to send to all nodes: %.4f seconds", send_elapsed)
time_to_sleep = args.delay_seconds - send_elapsed
if time_to_sleep > 0:
logging.info("Sleeping %.4f seconds to maintain delay of %d seconds between rounds", time_to_sleep, args.delay_seconds)
else:
logging.info("No sleep needed to maintain delay of %d seconds between rounds", args.delay_seconds)
time.sleep(time_to_sleep)
send_elapsed = time.time() - send_start_time
if args.multiple_nodes != None:
logging.info("Time taken to send to all nodes: %.4f seconds", send_elapsed)
else:
logging.info("Time taken to send to single node: %.4f seconds", send_elapsed)
time_to_sleep = args.delay_seconds - send_elapsed
if time_to_sleep > 0:
logging.info("Sleeping %.4f seconds to maintain delay of %d seconds between rounds", time_to_sleep, args.delay_seconds)
else:
logging.info("No sleep needed to maintain delay of %d seconds between rounds", args.delay_seconds)
time.sleep(max(0, time_to_sleep))