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

Modify the `KademliaServer` so that lack of port lets the OS choose a free one

Browse Source
This commit is contained in:
Alex Stokes 2019-11-05 17:06:54 -08:00
parent 700209c50a
commit 5cb4479534
No known key found for this signature in database
GPG Key ID: 51CE1721B245C086
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libp2p/kademlia/network.py
View File

@ -55,7 +55,7 @@ class KademliaServer:
def _create_protocol(self): def _create_protocol(self):
return self.protocol_class(self.node, self.storage, self.ksize) return self.protocol_class(self.node, self.storage, self.ksize)
async def listen(self, port, interface="0.0.0.0"): async def listen(self, port=0, interface="0.0.0.0"):
""" """
Start listening on the given port. Start listening on the given port.
@ -65,8 +65,15 @@ class KademliaServer:
listen = loop.create_datagram_endpoint( listen = loop.create_datagram_endpoint(
self._create_protocol, local_addr=(interface, port) self._create_protocol, local_addr=(interface, port)
) )
log.info("Node %i listening on %s:%i", self.node.xor_id, interface, port)
self.transport, self.protocol = await listen self.transport, self.protocol = await listen
socket = self.transport.get_extra_info("socket")
self.address = socket.getsockname()
log.info(
"Node %i listening on %s:%i",
self.node.xor_id,
self.address[0],
self.address[1],
)
# finally, schedule refreshing table # finally, schedule refreshing table
self.refresh_table() self.refresh_table()