From 14b6d811d63e9dc69c986ef58d4d6e00ceb1c20e Mon Sep 17 00:00:00 2001 From: Harshit Nayan Date: Sun, 7 Sep 2025 01:21:18 +0530 Subject: [PATCH] fix: correct spelling of 'negotiate_timeout' in multiple files --- libp2p/__init__.py | 2 +- libp2p/host/basic_host.py | 8 ++++---- libp2p/protocol_muxer/multiselect_client.py | 6 +++--- 3 files changed, 8 insertions(+), 8 deletions(-) diff --git a/libp2p/__init__.py b/libp2p/__init__.py index 606d31403..0ac41562c 100644 --- a/libp2p/__init__.py +++ b/libp2p/__init__.py @@ -320,7 +320,7 @@ def new_host( network=swarm, enable_mDNS=enable_mDNS, bootstrap=bootstrap, - negotitate_timeout=negotiate_timeout + negotiate_timeout=negotiate_timeout ) diff --git a/libp2p/host/basic_host.py b/libp2p/host/basic_host.py index e370a3de1..b45f29cd3 100644 --- a/libp2p/host/basic_host.py +++ b/libp2p/host/basic_host.py @@ -96,12 +96,12 @@ def __init__( enable_mDNS: bool = False, bootstrap: list[str] | None = None, default_protocols: Optional["OrderedDict[TProtocol, StreamHandlerFn]"] = None, - negotitate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, + negotiate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, ) -> None: self._network = network self._network.set_stream_handler(self._swarm_stream_handler) self.peerstore = self._network.peerstore - self.negotiate_timeout = negotitate_timeout + self.negotiate_timeout = negotiate_timeout # Protocol muxing default_protocols = default_protocols or get_default_protocols(self) self.multiselect = Multiselect(dict(default_protocols.items())) @@ -213,7 +213,7 @@ async def new_stream( self, peer_id: ID, protocol_ids: Sequence[TProtocol], - negotitate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, + negotiate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, ) -> INetStream: """ :param peer_id: peer_id that host is connecting @@ -227,7 +227,7 @@ async def new_stream( selected_protocol = await self.multiselect_client.select_one_of( list(protocol_ids), MultiselectCommunicator(net_stream), - negotitate_timeout, + negotiate_timeout, ) except MultiselectClientError as error: logger.debug("fail to open a stream to peer %s, error=%s", peer_id, error) diff --git a/libp2p/protocol_muxer/multiselect_client.py b/libp2p/protocol_muxer/multiselect_client.py index 90adb251d..ab3c6c64c 100644 --- a/libp2p/protocol_muxer/multiselect_client.py +++ b/libp2p/protocol_muxer/multiselect_client.py @@ -54,21 +54,21 @@ async def select_one_of( self, protocols: Sequence[TProtocol], communicator: IMultiselectCommunicator, - negotitate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, + negotiate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, ) -> TProtocol: """ For each protocol, send message to multiselect selecting protocol and fail if multiselect does not return same protocol. Returns first protocol that multiselect agrees on (i.e. that multiselect selects) - :param protocol: protocol to select + :param protocols: protocols to select from :param communicator: communicator to use to communicate with counterparty :param negotiate_timeout: timeout for negotiation :return: selected protocol :raise MultiselectClientError: raised when protocol negotiation failed """ try: - with trio.fail_after(negotitate_timeout): + with trio.fail_after(negotiate_timeout): await self.handshake(communicator) for protocol in protocols: