* [RFC][PATCH] server/process: Avoid hanging if a parser process is terminated
@ 2022-03-26 5:18 Peter Kjellerstedt
0 siblings, 0 replies; 2+ messages in thread
From: Peter Kjellerstedt @ 2022-03-26 5:18 UTC (permalink / raw)
To: openembedded-core
If a parser process is terminated while holding a write lock, then it
will lead to a deadlock (see
https://docs.python.org/3/library/multiprocessing.html#multiprocessing.Process.terminate).
Signed-off-by: Peter Kjellerstedt <peter.kjellerstedt@axis.com>
---
After the discussion on IRC about the hanging parsing processes, I
just had to understand the code and what happens. This is a solution to
the problem, though I am not sure it is THE solution. It may also be
that the rlock in ConnectionReader should be handled the same way.
Anyway, even if this is not accepted as a solution to the problem, I now
at least know a lot more about how the parsing processes in bitbake
work... :)
bitbake/lib/bb/server/process.py | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/bitbake/lib/bb/server/process.py b/bitbake/lib/bb/server/process.py
index 1636616660..544b00f2cd 100644
--- a/bitbake/lib/bb/server/process.py
+++ b/bitbake/lib/bb/server/process.py
@@ -20,6 +20,7 @@ import os
import sys
import time
import select
+import signal
import socket
import subprocess
import errno
@@ -728,6 +729,10 @@ class ConnectionReader(object):
def close(self):
return self.reader.close()
+terminated = False
+def catch_sigterm(signum, frame):
+ global terminated
+ terminated = True
class ConnectionWriter(object):
@@ -739,8 +744,12 @@ class ConnectionWriter(object):
def send(self, obj):
obj = multiprocessing.reduction.ForkingPickler.dumps(obj)
+ oldsig = signal.signal(signal.SIGTERM, catch_sigterm)
with self.wlock:
self.writer.send_bytes(obj)
+ signal.signal(signal.SIGTERM, oldsig)
+ if terminated:
+ os.kill(os.getpid(), signal.SIGTERM)
def fileno(self):
return self.writer.fileno()
^ permalink raw reply related [flat|nested] 2+ messages in thread
* [RFC][PATCH] server/process: Avoid hanging if a parser process is terminated
@ 2022-03-26 5:21 Peter Kjellerstedt
0 siblings, 0 replies; 2+ messages in thread
From: Peter Kjellerstedt @ 2022-03-26 5:21 UTC (permalink / raw)
To: bitbake-devel
If a parser process is terminated while holding a write lock, then it
will lead to a deadlock (see
https://docs.python.org/3/library/multiprocessing.html#multiprocessing.Process.terminate).
Signed-off-by: Peter Kjellerstedt <peter.kjellerstedt@axis.com>
---
After the discussion on IRC about the hanging parsing processes, I
just had to understand the code and what happens. This is a solution to
the problem, though I am not sure it is THE solution. It may also be
that the rlock in ConnectionReader should be handled the same way.
Anyway, even if this is not accepted as a solution to the problem, I now
at least know a lot more about how the parsing processes in bitbake
work... :)
bitbake/lib/bb/server/process.py | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/bitbake/lib/bb/server/process.py b/bitbake/lib/bb/server/process.py
index 1636616660..544b00f2cd 100644
--- a/bitbake/lib/bb/server/process.py
+++ b/bitbake/lib/bb/server/process.py
@@ -20,6 +20,7 @@ import os
import sys
import time
import select
+import signal
import socket
import subprocess
import errno
@@ -728,6 +729,10 @@ class ConnectionReader(object):
def close(self):
return self.reader.close()
+terminated = False
+def catch_sigterm(signum, frame):
+ global terminated
+ terminated = True
class ConnectionWriter(object):
@@ -739,8 +744,12 @@ class ConnectionWriter(object):
def send(self, obj):
obj = multiprocessing.reduction.ForkingPickler.dumps(obj)
+ oldsig = signal.signal(signal.SIGTERM, catch_sigterm)
with self.wlock:
self.writer.send_bytes(obj)
+ signal.signal(signal.SIGTERM, oldsig)
+ if terminated:
+ os.kill(os.getpid(), signal.SIGTERM)
def fileno(self):
return self.writer.fileno()
^ permalink raw reply related [flat|nested] 2+ messages in thread
end of thread, other threads:[~2022-03-26 5:22 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2022-03-26 5:18 [RFC][PATCH] server/process: Avoid hanging if a parser process is terminated Peter Kjellerstedt
2022-03-26 5:21 Peter Kjellerstedt
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.