afonso/core-extra
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

simplify thread daemon usage

Browse source
This commit is contained in:
Blake Harnden 2020-02-26 15:29:19 -08:00
parent 21dfaf7d66
commit e1c9155ba7
4 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
daemon/core/api/grpc/client.py
View file

@ -146,8 +146,9 @@ def start_streamer(stream: Any, handler: Callable[[core_pb2.Event], None]) -> No
:param handler: function that handles an event :param handler: function that handles an event
:return: nothing :return: nothing
""" """
thread = threading.Thread(target=stream_listener, args=(stream, handler)) thread = threading.Thread(
thread.daemon = True target=stream_listener, args=(stream, handler), daemon=True
)
thread.start() thread.start()

2
daemon/core/api/tlv/corehandlers.py
View file

@ -949,8 +949,8 @@ class CoreHandler(socketserver.BaseRequestHandler):
file_name, file_name,
{"__file__": file_name, "coreemu": self.coreemu}, {"__file__": file_name, "coreemu": self.coreemu},
), ),
daemon=True,
) )
thread.daemon = True
thread.start() thread.start()
# allow time for session creation # allow time for session creation
time.sleep(0.25) time.sleep(0.25)

5
daemon/core/emane/emanemanager.py
View file

@ -682,8 +682,9 @@ class EmaneManager(ModelManager):
) )
return return
self.doeventloop = True self.doeventloop = True
self.eventmonthread = threading.Thread(target=self.eventmonitorloop) self.eventmonthread = threading.Thread(
self.eventmonthread.daemon = True target=self.eventmonitorloop, daemon=True
)
self.eventmonthread.start() self.eventmonthread.start()
def stopeventmonitor(self) -> None: def stopeventmonitor(self) -> None:

3
daemon/core/nodes/network.py
View file

@ -70,8 +70,7 @@ class EbtablesQueue:
return return
self.doupdateloop = True self.doupdateloop = True
self.updatethread = threading.Thread(target=self.updateloop) self.updatethread = threading.Thread(target=self.updateloop, daemon=True)
self.updatethread.daemon = True
self.updatethread.start() self.updatethread.start()
def stopupdateloop(self, wlan: "CoreNetwork") -> None: def stopupdateloop(self, wlan: "CoreNetwork") -> None: