Retry identity REST ports on failure

Tribler · Jun 14, 2024 · 5801e90 · 5801e90
1 parent fb1fd7e
commit 5801e90
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 2 deletions.
diff --git a/doc/basics/identity_tutorial_integration/main.py b/doc/basics/identity_tutorial_integration/main.py
@@ -1,5 +1,6 @@
 from asyncio import run
 from base64 import b64encode
+from time import sleep
 
 from ipv8.configuration import get_default_configuration
 from ipv8.REST.rest_manager import RESTManager
@@ -21,7 +22,15 @@ async def start_community() -> None:
         ipv8 = IPv8(configuration)
         await ipv8.start()
         rest_manager = RESTManager(ipv8)
-        await rest_manager.start(14410 + peer_id)
+
+        # We REALLY want this particular port, keep trying
+        keep_trying = True
+        while keep_trying:
+            try:
+                await rest_manager.start(14410 + peer_id)
+                keep_trying = False
+            except OSError:
+                sleep(1.0)
 
         # Print the peer for reference
         print("Starting peer", b64encode(ipv8.keys["anonymous id"].mid))

diff --git a/doc/deprecated/attestation_tutorial_integration/main.py b/doc/deprecated/attestation_tutorial_integration/main.py
@@ -2,6 +2,7 @@
 from base64 import b64encode
 from binascii import unhexlify
 from sys import argv
+from time import sleep
 
 from ipv8.attestation.identity.community import IdentityCommunity
 from ipv8.attestation.wallet.community import AttestationCommunity
@@ -109,7 +110,15 @@ async def start_communities() -> None:
         })
         await ipv8.start()
         rest_manager = RESTManager(ipv8)
-        await rest_manager.start(14410 + i)
+
+        # We REALLY want this particular port, keep trying
+        keep_trying = True
+        while keep_trying:
+            try:
+                await rest_manager.start(14410 + i)
+                keep_trying = False
+            except OSError:
+                sleep(1.0)
 
         # Print the peer for reference
         print("Starting peer", b64encode(ipv8.keys["anonymous id"].mid))