summaryrefslogtreecommitdiffstats
path: root/bitbake/bin/bitbake-worker
diff options
context:
space:
mode:
authorRichard Purdie <richard.purdie@linuxfoundation.org>2015-09-08 23:36:49 +0100
committerRichard Purdie <richard.purdie@linuxfoundation.org>2015-09-09 14:27:56 +0100
commit3195cd92eb5caee027623617dbbf8790bcc76c56 (patch)
tree536081c765d36bdb1d6bc063f2e59c2da277d527 /bitbake/bin/bitbake-worker
parent85256c8fa986f2a3258e75a22bb8d0656ffa41bf (diff)
downloadpoky-3195cd92eb5caee027623617dbbf8790bcc76c56.tar.gz
bitbake: bitbake-worker: Simple code cleanup
start/end are unused here and we can improve the code conditional blocks. (Bitbake rev: 68f53dd77fe0bbfa044bd037a9484e0e1c9088b4) Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'bitbake/bin/bitbake-worker')
-rwxr-xr-xbitbake/bin/bitbake-worker5
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)