Psion-fanatic/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Put the join back on CommandStream.__exit__.

Browse source 
We want to give the process a bit of slack between the terminate and the
close, or we'll be guaranteed to get race conditions upon close.
This commit is contained in:
Fabio Manganiello 2023-09-04 11:01:34 +02:00
parent 6ee064cb89
commit f1acff00e9
Signed by untrusted user: blacklight
GPG key ID: D90FBA7F76362774
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
platypush/commands/_stream.py
View file

@ -34,7 +34,7 @@ class CommandStream(ControllableProcess):
super().__init__(name='platypush:cmd:stream')
self.path = os.path.abspath(os.path.expanduser(path or self._default_sock_path))
self._sock: Optional[socket.socket] = None
self._cmd_queue: Queue["Command"] = Queue()
self._cmd_queue = Queue()
self._close_lock = RLock()
def reset(self):
@ -71,16 +71,21 @@ class CommandStream(ControllableProcess):
def __exit__(self, *_, **__):
with self._close_lock:
self.terminate()
self.join(1)
try:
self.close()
except Exception as e:
self.logger.warning(str(e))
self.logger.warning(
'%s on command stream close: %s', type(e).__name__, str(e)
)
try:
self.kill()
except Exception as e:
self.logger.warning(str(e))
self.logger.debug(
'%s on command stream kill: %s', type(e).__name__, str(e)
)
def _serve(self, sock: socket.socket):
"""