StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix transport.dial in swarm

Browse Source
This commit is contained in:
mhchia 2019-09-11 17:13:21 +08:00
parent cb1a25f94c
commit c1ffc0ab07
No known key found for this signature in database
GPG Key ID: 389EFBEA1362589A
2 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/network/swarm.py
View File

@ -119,7 +119,7 @@ class Swarm(INetwork):
multiaddr = self.router.find_peer(peer_id) multiaddr = self.router.find_peer(peer_id)
# Dial peer (connection to peer does not yet exist) # Dial peer (connection to peer does not yet exist)
# Transport dials peer (gets back a raw conn) # Transport dials peer (gets back a raw conn)
raw_conn = await self.transport.dial(multiaddr, self.self_id) raw_conn = await self.transport.dial(multiaddr)
logger.debug("dialed peer %s over base transport", peer_id) logger.debug("dialed peer %s over base transport", peer_id)

3
libp2p/transport/transport_interface.py
View File

@ -3,7 +3,6 @@ from abc import ABC, abstractmethod
from multiaddr import Multiaddr from multiaddr import Multiaddr
from libp2p.network.connection.raw_connection_interface import IRawConnection from libp2p.network.connection.raw_connection_interface import IRawConnection
from libp2p.peer.id import ID
from .listener_interface import IListener from .listener_interface import IListener
from .typing import THandler from .typing import THandler
@ -11,7 +10,7 @@ from .typing import THandler
class ITransport(ABC): class ITransport(ABC):
@abstractmethod @abstractmethod
async def dial(self, maddr: Multiaddr, self_id: ID) -> IRawConnection: async def dial(self, maddr: Multiaddr) -> IRawConnection:
""" """
dial a transport to peer listening on multiaddr dial a transport to peer listening on multiaddr
:param multiaddr: multiaddr of peer :param multiaddr: multiaddr of peer