diff options
Diffstat (limited to 'bitbake')
-rw-r--r-- | bitbake/lib/bb/cooker.py | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py index 938b999b4f..90022f3c35 100644 --- a/bitbake/lib/bb/cooker.py +++ b/bitbake/lib/bb/cooker.py | |||
@@ -2059,18 +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 | # Have to wait for all parsers to have forked | 2069 | # Have to wait for all parsers to have forked |
2071 | jobid = self.jobid_queue.get(True, 5) | 2070 | jobid = self.jobid_queue.get(True, 0.1) |
2072 | except (ValueError, OSError, queue.Empty): | 2071 | except (ValueError, OSError, queue.Empty) as e: |
2073 | havejobs = False | 2072 | pass |
2074 | 2073 | ||
2075 | if jobid is not None: | 2074 | if jobid is not None: |
2076 | job = self.jobs[jobid] | 2075 | job = self.jobs[jobid] |