Mirror/liamcottle___reticulum-meshchat
1
0
Fork 0
mirror of https://github.com/liamcottle/reticulum-meshchat.git synced 2026-04-28 00:20:48 +00:00
Code Issues Projects Releases Packages Wiki Activity

add timeout for establishing link for downloads

Browse source
This commit is contained in:
liamcottle 2024-05-29 03:37:44 +12:00
commit 5ace093e04
1 changed files with 13 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

15
web.py
View file

@ -1246,7 +1246,7 @@ class NomadnetDownloader:
self.on_progress_update = on_progress_update
# setup link to destination and request download
async def download(self, path_lookup_timeout: int = 15):
async def download(self, path_lookup_timeout: int = 15, link_establishment_timeout: int = 15):
# determine when to timeout
timeout_after_seconds = time.time() + path_lookup_timeout
@ -1277,7 +1277,18 @@ class NomadnetDownloader:
)
# create link to destination
RNS.Link(destination, established_callback=self.link_established)
link = RNS.Link(destination, established_callback=self.link_established)
# determine when to timeout
timeout_after_seconds = time.time() + link_establishment_timeout
# wait until we have established a link, or give up after the configured timeout
while link.status is not RNS.Link.ACTIVE and time.time() < timeout_after_seconds:
await asyncio.sleep(0.1)
# if we still haven't established a link, bail out
if link.status is not RNS.Link.ACTIVE:
self.on_download_failure("Could not establish link to destination.")
# link to destination was established, we should now request the download
def link_established(self, link):