diff --git a/libp2p/__init__.py b/libp2p/__init__.py index 11378aca7..912f3f1af 100644 --- a/libp2p/__init__.py +++ b/libp2p/__init__.py @@ -361,7 +361,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 6b7eb1d35..a1f48c509 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,6 +213,7 @@ async def new_stream( self, peer_id: ID, protocol_ids: Sequence[TProtocol], + negotiate_timeout: int = DEFAULT_NEGOTIATE_TIMEOUT, ) -> INetStream: """ :param peer_id: peer_id that host is connecting 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: