diff options
Diffstat (limited to 'bitbake/lib')
-rw-r--r-- | bitbake/lib/bb/cooker.py | 8 |
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] |