Patchwork [bitbake-devel] process: Further improve robustness against server shutdown

mail settings
Submitter Richard Purdie
Date Aug. 21, 2014, 9:27 a.m.
Message ID <1408613230.1669.111.camel@ted>
Download mbox | patch
Permalink /patch/78737/
State New
Headers show


Richard Purdie - Aug. 21, 2014, 9:27 a.m.
Currently, if an exception occurs in an event handler, the server shuts
down but the UI simply hangs. This happens in two places, firstly waiting
for events and secondly, sending events to a server which no longer exists.

The latter does time out, the former does not. These patches improve
both code sections to check if the main server process is alive and if not,
trigger things to shut down gracefully. This avoids the timeout in the
command sending case too.

This resolves various cases where the UI would simply hang indefintely.

Signed-off-by: Richard Purdie <>


diff --git a/bitbake/lib/bb/server/ b/bitbake/lib/bb/server/
index 7fdf964..cb2a56a 100644
--- a/bitbake/lib/bb/server/
+++ b/bitbake/lib/bb/server/
@@ -38,14 +38,18 @@  from . import BitBakeBaseServer, BitBakeBaseServerConnection, BaseImplServer
 logger = logging.getLogger('BitBake')
 class ServerCommunicator():
-    def __init__(self, connection, event_handle):
+    def __init__(self, connection, event_handle, server):
         self.connection = connection
         self.event_handle = event_handle
+        self.server = server
     def runCommand(self, command):
         # @todo try/except
+        if not self.server.is_alive():
+            raise SystemExit
         while True:
             # don't let the user ctrl-c while we're waiting for a response
@@ -160,7 +164,7 @@  class BitBakeProcessServerConnection(BitBakeBaseServerConnection):
         self.procserver = serverImpl
         self.ui_channel = ui_channel
         self.event_queue = event_queue
-        self.connection = ServerCommunicator(self.ui_channel, self.procserver.event_handle)
+        self.connection = ServerCommunicator(self.ui_channel, self.procserver.event_handle, self.procserver) = self.event_queue
     def sigterm_terminate(self):
@@ -199,14 +203,20 @@  class ProcessEventQueue(multiprocessing.queues.Queue):
     def waitEvent(self, timeout):
         if self.exit:
-            raise KeyboardInterrupt()
+            raise SystemExit
+            if not self.server.is_alive():
+                self.setexit()
+                return None
             return self.get(True, timeout)
         except Empty:
             return None
     def getEvent(self):
+            if not self.server.is_alive():
+                self.setexit()
+                return None
             return self.get(False)
         except Empty:
             return None
@@ -221,6 +231,7 @@  class BitBakeServer(BitBakeBaseServer):
         self.ui_channel, self.server_channel = Pipe()
         self.event_queue = ProcessEventQueue(0)
         self.serverImpl = ProcessServer(self.server_channel, self.event_queue, None)
+        self.event_queue.server = self.serverImpl
     def detach(self):