summaryrefslogtreecommitdiffstats
path: root/bitbake/lib/bb/cooker.py
diff options
context:
space:
mode:
Diffstat (limited to 'bitbake/lib/bb/cooker.py')
-rw-r--r--bitbake/lib/bb/cooker.py7
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):