diff options
-rwxr-xr-x | bitbake/bin/bitbake-worker | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/bitbake/bin/bitbake-worker b/bitbake/bin/bitbake-worker index 96a4d4cdec..c429dc76d7 100755 --- a/bitbake/bin/bitbake-worker +++ b/bitbake/bin/bitbake-worker | |||
@@ -295,13 +295,12 @@ class BitbakeWorker(object): | |||
295 | def serve(self): | 295 | def serve(self): |
296 | while True: | 296 | while True: |
297 | (ready, _, _) = select.select([self.input] + [i.input for i in self.build_pipes.values()], [] , [], 1) | 297 | (ready, _, _) = select.select([self.input] + [i.input for i in self.build_pipes.values()], [] , [], 1) |
298 | if self.input in ready or len(self.queue): | 298 | if self.input in ready: |
299 | start = len(self.queue) | ||
300 | try: | 299 | try: |
301 | self.queue = self.queue + self.input.read() | 300 | self.queue = self.queue + self.input.read() |
302 | except (OSError, IOError): | 301 | except (OSError, IOError): |
303 | pass | 302 | pass |
304 | end = len(self.queue) | 303 | if len(self.queue): |
305 | self.handle_item("cookerconfig", self.handle_cookercfg) | 304 | self.handle_item("cookerconfig", self.handle_cookercfg) |
306 | self.handle_item("workerdata", self.handle_workerdata) | 305 | self.handle_item("workerdata", self.handle_workerdata) |
307 | self.handle_item("runtask", self.handle_runtask) | 306 | self.handle_item("runtask", self.handle_runtask) |