Mirrors/meshcore_py
1
0
Fork 0
mirror of https://github.com/meshcore-dev/meshcore_py.git synced 2026-06-11 11:56:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

adds more min_timeout when fetching lots of neighbours

Browse Source
This commit is contained in:
Florent
2026-03-29 07:55:32 -04:00
parent fe5096eb9e
commit be3aa103c5
2 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/meshcore/commands/binary.py
View File

@@ -225,6 +225,7 @@ class BinaryCommandHandler(CommandHandlerBase):
del res["tag"]
tries = 0
while results_count < neighbours_count:
#await asyncio.sleep(2) # wait 2s before next fetch
next_res = await self.req_neighbours_sync(contact,
@@ -233,15 +234,18 @@ class BinaryCommandHandler(CommandHandlerBase):
order_by=order_by,
pubkey_prefix_length=pubkey_prefix_length,
timeout=timeout,
min_timeout=min_timeout+5) # requests are close, so let's have some more timeout
min_timeout=min_timeout+25) # requests are close and responses big,
#so let's have some more timeout for duty cycle
if next_res is None :
return res # caller should check it has everything
results_count = results_count + next_res["results_count"]
res["results_count"] = results_count
res["neighbours"] += next_res["neighbours"]
if tries > 0:
return res # caller should check it has everything
else:
tries += 1
else:
tries = 0
results_count += next_res["results_count"]
res["results_count"] = results_count
res["neighbours"] += next_res["neighbours"]
return res