ynerant
/
squinnondation
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

...

This commit is contained in:
Eichhornchen 2021-01-07 15:39:35 +01:00
parent 5ada0920f0
commit 850b4ed78b
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
squinnondation/peers.py
View File

@ -140,6 +140,7 @@ class User(Peer):
self.listener = Listener(self) self.listener = Listener(self)
self.neighbour_manager = PeerManager(self) self.neighbour_manager = PeerManager(self)
self.inondator = Inondator(self) self.inondator = Inondator(self)
self.multicastlistener = Multicastlistener(self)
self.add_system_message(f"Listening on {self.main_address[0]}:{self.main_address[1]}", ignore_debug=True) self.add_system_message(f"Listening on {self.main_address[0]}:{self.main_address[1]}", ignore_debug=True)
self.add_system_message(f"I am {self.id}") self.add_system_message(f"I am {self.id}")
@ -254,10 +255,12 @@ class User(Peer):
self.listener.setDaemon(True) self.listener.setDaemon(True)
self.neighbour_manager.setDaemon(True) self.neighbour_manager.setDaemon(True)
self.inondator.setDaemon(True) self.inondator.setDaemon(True)
self.multicastlistener.setDaemon(True)
self.listener.start() self.listener.start()
self.neighbour_manager.start() self.neighbour_manager.start()
self.inondator.start() self.inondator.start()
self.multicastlistener.start()
def wait_for_key(self) -> None: def wait_for_key(self) -> None:
""" """