summaryrefslogtreecommitdiffstats
path: root/bitbake/lib
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib')
-rw-r--r--bitbake/lib/bb/cooker.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py
index d46e1eb62b..90022f3c35 100644
--- a/bitbake/lib/bb/cooker.py
+++ b/bitbake/lib/bb/cooker.py
@@ -2059,17 +2059,17 @@ class Parser(multiprocessing.Process):
2059 multiprocessing.util.Finalize(None, bb.fetch.fetcher_parse_save, exitpriority=1) 2059 multiprocessing.util.Finalize(None, bb.fetch.fetcher_parse_save, exitpriority=1)
2060 2060
2061 pending = [] 2061 pending = []
2062 havejobs = True
2063 try: 2062 try:
2064 while (havejobs or pending) and not self.exit: 2063 while pending or not self.exit:
2065 if self.quit.is_set(): 2064 if self.quit.is_set():
2066 break 2065 break
2067 2066
2068 jobid = None 2067 jobid = None
2069 try: 2068 try:
2070 jobid = self.jobid_queue.get(True, 0.5) 2069 # Have to wait for all parsers to have forked
2070 jobid = self.jobid_queue.get(True, 0.1)
2071 except (ValueError, OSError, queue.Empty) as e: 2071 except (ValueError, OSError, queue.Empty) as e:
2072 havejobs = False 2072 pass
2073 2073
2074 if jobid is not None: 2074 if jobid is not None:
2075 job = self.jobs[jobid] 2075 job = self.jobs[jobid]