LBRYFoundation/lbry-sdk
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbry-sdk.git synced 2025-09-02 18:25:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

allow node udp interface to be configured

Browse source
This commit is contained in:
Jack Robison 2018-07-17 17:13:33 -04:00
parent 75829812f3
commit ec51333b56
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lbrynet/dht/node.py
View file

@ -99,7 +99,7 @@ class Node(MockKademliaHelper):
routingTableClass=None, networkProtocol=None, routingTableClass=None, networkProtocol=None,
externalIP=None, peerPort=3333, listenUDP=None, externalIP=None, peerPort=3333, listenUDP=None,
callLater=None, resolve=None, clock=None, peer_finder=None, callLater=None, resolve=None, clock=None, peer_finder=None,
peer_manager=None): peer_manager=None, interface=''):
""" """
@param dataStore: The data store to use. This must be class inheriting @param dataStore: The data store to use. This must be class inheriting
from the C{DataStore} interface (or providing the from the C{DataStore} interface (or providing the
@ -128,6 +128,7 @@ class Node(MockKademliaHelper):
MockKademliaHelper.__init__(self, clock, callLater, resolve, listenUDP) MockKademliaHelper.__init__(self, clock, callLater, resolve, listenUDP)
self.node_id = node_id or self._generateID() self.node_id = node_id or self._generateID()
self.port = udpPort self.port = udpPort
self._listen_interface = interface
self._change_token_lc = self.get_looping_call(self.change_token) self._change_token_lc = self.get_looping_call(self.change_token)
self._refresh_node_lc = self.get_looping_call(self._refreshNode) self._refresh_node_lc = self.get_looping_call(self._refreshNode)
self._refresh_contacts_lc = self.get_looping_call(self._refreshContacts) self._refresh_contacts_lc = self.get_looping_call(self._refreshContacts)
@ -171,7 +172,7 @@ class Node(MockKademliaHelper):
def start_listening(self): def start_listening(self):
if not self._listeningPort: if not self._listeningPort:
try: try:
self._listeningPort = self.reactor_listenUDP(self.port, self._protocol) self._listeningPort = self.reactor_listenUDP(self.port, self._protocol, interface=self._listen_interface)
except error.CannotListenError as e: except error.CannotListenError as e:
import traceback import traceback
log.error("Couldn't bind to port %d. %s", self.port, traceback.format_exc()) log.error("Couldn't bind to port %d. %s", self.port, traceback.format_exc())