From: Chris Larson <chris_larson@mentor.com>
Date: Tue, 23 Nov 2010 14:20:08 +0000 (-0700)
Subject: cooker: get number of threads in constructor
X-Git-Tag: 2011-1~3108
X-Git-Url: https://code.ossystems.io/gitweb?a=commitdiff_plain;h=f4a06aac980f73702a04d2c2f0728c09ebfb7786;p=openembedded-core.git

cooker: get number of threads in constructor

(Bitbake rev: e7fd259d1528f48b0812fb7b0a54dd6d5d22f4a9)

Signed-off-by: Chris Larson <chris_larson@mentor.com>
Signed-off-by: Richard Purdie <rpurdie@linux.intel.com>
---

diff --git a/bitbake/lib/bb/cooker.py b/bitbake/lib/bb/cooker.py
index 4b52108eaf..69098ccf91 100644
--- a/bitbake/lib/bb/cooker.py
+++ b/bitbake/lib/bb/cooker.py
@@ -998,6 +998,8 @@ class CookerParser(object):
         self.result_queue = None
         self.fromcache = None
         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):
         self.task_queue = multiprocessing.Queue()
@@ -1018,9 +1020,7 @@ class CookerParser(object):
                 output.put(infos)
 
         self.processes = []
-        num_processes = int(self.cfgdata.getVar("BB_NUMBER_PARSE_THREADS", True) or
-                            multiprocessing.cpu_count())
-        for i in xrange(num_processes):
+        for i in xrange(self.num_processes):
             process = multiprocessing.Process(target=worker,
                                               args=(self.task_queue,
                                                     self.result_queue,