varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-11 15:40:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set default-negotiate-timeout = 5 sec

Browse Source
This commit is contained in:
lla-dane
2025-06-25 00:32:33 +05:30
parent 6d8f695778
commit 621ea321ab
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
libp2p/protocol_muxer/multiselect.py
View File

@ -16,7 +16,7 @@ from .exceptions import (
MULTISELECT_PROTOCOL_ID = "/multistream/1.0.0" MULTISELECT_PROTOCOL_ID = "/multistream/1.0.0"
PROTOCOL_NOT_FOUND_MSG = "na" PROTOCOL_NOT_FOUND_MSG = "na"
DEFAULT_NEGOTIATE_TIMEOUT = 60 DEFAULT_NEGOTIATE_TIMEOUT = 5
class Multiselect(IMultiselectMuxer): class Multiselect(IMultiselectMuxer):
@ -63,7 +63,10 @@ class Multiselect(IMultiselectMuxer):
while True: while True:
try: try:
command = await communicator.read() with trio.fail_after(DEFAULT_NEGOTIATE_TIMEOUT):
command = await communicator.read()
except trio.TooSlowError:
raise MultiselectError("handshake read timeout")
except MultiselectCommunicatorError as error: except MultiselectCommunicatorError as error:
raise MultiselectError() from error raise MultiselectError() from error

2
libp2p/protocol_muxer/multiselect_client.py
View File

@ -19,7 +19,7 @@ from .exceptions import (
MULTISELECT_PROTOCOL_ID = "/multistream/1.0.0" MULTISELECT_PROTOCOL_ID = "/multistream/1.0.0"
PROTOCOL_NOT_FOUND_MSG = "na" PROTOCOL_NOT_FOUND_MSG = "na"
DEFAULT_NEGOTIATE_TIMEOUT = 60 DEFAULT_NEGOTIATE_TIMEOUT = 5
class MultiselectClient(IMultiselectClient): class MultiselectClient(IMultiselectClient):