diff options
Diffstat (limited to 'bitbake/lib/bb/cooker.py')
-rw-r--r-- | bitbake/lib/bb/cooker.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py index 93707a250e..427078df0b 100644 --- a/bitbake/lib/bb/cooker.py +++ b/bitbake/lib/bb/cooker.py | |||
@@ -2171,9 +2171,6 @@ class CookerParser(object): | |||
2171 | self.parser_quit = multiprocessing.Event() | 2171 | self.parser_quit = multiprocessing.Event() |
2172 | self.result_queue = multiprocessing.Queue() | 2172 | self.result_queue = multiprocessing.Queue() |
2173 | 2173 | ||
2174 | for jobid in range(len(self.willparse)): | ||
2175 | self.toparse_queue.put(jobid) | ||
2176 | |||
2177 | # Have to pass in willparse at fork time so all parsing processes have the unpickleable data | 2174 | # Have to pass in willparse at fork time so all parsing processes have the unpickleable data |
2178 | # then access it by index from the parse queue. | 2175 | # then access it by index from the parse queue. |
2179 | for i in range(0, self.num_processes): | 2176 | for i in range(0, self.num_processes): |
@@ -2182,6 +2179,8 @@ class CookerParser(object): | |||
2182 | self.process_names.append(parser.name) | 2179 | self.process_names.append(parser.name) |
2183 | self.processes.append(parser) | 2180 | self.processes.append(parser) |
2184 | 2181 | ||
2182 | for jobid in range(len(self.willparse)): | ||
2183 | self.toparse_queue.put(jobid) | ||
2185 | self.toparse_queue.close() | 2184 | self.toparse_queue.close() |
2186 | 2185 | ||
2187 | self.results = itertools.chain(self.results, self.parse_generator()) | 2186 | self.results = itertools.chain(self.results, self.parse_generator()) |
@@ -2292,7 +2291,7 @@ class CookerParser(object): | |||
2292 | yield result | 2291 | yield result |
2293 | 2292 | ||
2294 | if not (self.parsed >= self.toparse): | 2293 | if not (self.parsed >= self.toparse): |
2295 | raise bb.parse.ParseError("Not all recipes parsed, parser thread killed/died? Exiting.", None) | 2294 | raise bb.parse.ParseError("Not all recipes parsed, parser thread killed/died? (%s %s of %s) Exiting." % (len(self.processes), self.parsed, self.toparse), None) |
2296 | 2295 | ||
2297 | 2296 | ||
2298 | def parse_next(self): | 2297 | def parse_next(self): |