summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--meta/classes/sstate.bbclass5
1 files changed, 2 insertions, 3 deletions
diff --git a/meta/classes/sstate.bbclass b/meta/classes/sstate.bbclass
index 2175ace4c4..d7f1b3f26e 100644
--- a/meta/classes/sstate.bbclass
+++ b/meta/classes/sstate.bbclass
@@ -971,13 +971,12 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
971 tasklist.append((tid, sstatefile)) 971 tasklist.append((tid, sstatefile))
972 972
973 if tasklist: 973 if tasklist:
974 nproc = min(int(d.getVar("BB_NUMBER_THREADS")), len(tasklist))
975
974 if len(tasklist) >= min_tasks: 976 if len(tasklist) >= min_tasks:
975 msg = "Checking sstate mirror object availability" 977 msg = "Checking sstate mirror object availability"
976 bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d) 978 bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d)
977 979
978 import multiprocessing
979 nproc = min(multiprocessing.cpu_count(), len(tasklist))
980
981 bb.event.enable_threadlock() 980 bb.event.enable_threadlock()
982 pool = oe.utils.ThreadedPool(nproc, len(tasklist), 981 pool = oe.utils.ThreadedPool(nproc, len(tasklist),
983 worker_init=checkstatus_init, worker_end=checkstatus_end) 982 worker_init=checkstatus_init, worker_end=checkstatus_end)