mirrors/poky
1
0
Fork 0
mirror of https://git.yoctoproject.org/poky synced 2026-05-31 12:49:46 +00:00
Code Issues Projects Releases Wiki Activity

cooker: get number of threads in constructor

Browse Source 
(Bitbake rev: e7fd259d1528f48b0812fb7b0a54dd6d5d22f4a9)

Signed-off-by: Chris Larson <chris_larson@mentor.com>
Signed-off-by: Richard Purdie <rpurdie@linux.intel.com>
This commit is contained in:
Chris Larson
2010-11-23 07:20:08 -07:00
committed by Richard Purdie
parent a519031f23
commit f4a06aac98
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bitbake/lib/bb/cooker.py
+3 -3
View File
@@ -998,6 +998,8 @@ class CookerParser(object):
self.result_queue = None self.result_queue = None
self.fromcache = None self.fromcache = None
self.progress_chunk = self.total / 100 self.progress_chunk = self.total / 100
self.num_processes = int(self.cfgdata.getVar("BB_NUMBER_PARSE_THREADS", True) or
multiprocessing.cpu_count())
def launch_processes(self): def launch_processes(self):
self.task_queue = multiprocessing.Queue() self.task_queue = multiprocessing.Queue()
@@ -1018,9 +1020,7 @@ class CookerParser(object):
output.put(infos) output.put(infos)
self.processes = [] self.processes = []
num_processes = int(self.cfgdata.getVar("BB_NUMBER_PARSE_THREADS", True) or for i in xrange(self.num_processes):
multiprocessing.cpu_count())
for i in xrange(num_processes):
process = multiprocessing.Process(target=worker, process = multiprocessing.Process(target=worker,
args=(self.task_queue, args=(self.task_queue,
self.result_queue, self.result_queue,