diff options
Diffstat (limited to 'yocto-poky/bitbake/lib/bb/server/process.py')
| -rw-r--r-- | yocto-poky/bitbake/lib/bb/server/process.py | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/yocto-poky/bitbake/lib/bb/server/process.py b/yocto-poky/bitbake/lib/bb/server/process.py index 5fca3508b..a3078a873 100644 --- a/yocto-poky/bitbake/lib/bb/server/process.py +++ b/yocto-poky/bitbake/lib/bb/server/process.py @@ -53,10 +53,12 @@ class ServerCommunicator(): while True: # don't let the user ctrl-c while we're waiting for a response try: - if self.connection.poll(20): - return self.connection.recv() - else: - bb.fatal("Timeout while attempting to communicate with bitbake server") + for idx in range(0,4): # 0, 1, 2, 3 + if self.connection.poll(5): + return self.connection.recv() + else: + bb.warn("Timeout while attempting to communicate with bitbake server") + bb.fatal("Gave up; Too many tries: timeout while attempting to communicate with bitbake server") except KeyboardInterrupt: pass @@ -106,6 +108,7 @@ class ProcessServer(Process, BaseImplServer): # the UI and communicated to us self.quitin.close() signal.signal(signal.SIGINT, signal.SIG_IGN) + bb.utils.set_process_name("Cooker") while not self.quit: try: if self.command_channel.poll(): @@ -212,6 +215,7 @@ class ProcessEventQueue(multiprocessing.queues.Queue): def __init__(self, maxsize): multiprocessing.queues.Queue.__init__(self, maxsize) self.exit = False + bb.utils.set_process_name("ProcessEQueue") def setexit(self): self.exit = True @@ -238,7 +242,7 @@ class ProcessEventQueue(multiprocessing.queues.Queue): class BitBakeServer(BitBakeBaseServer): - def initServer(self): + def initServer(self, single_use=True): # establish communication channels. We use bidirectional pipes for # ui <--> server command/response pairs # and a queue for server -> ui event notifications |