summaryrefslogtreecommitdiffstats
path: root/meta/classes/sstate.bbclass
diff options
context:
space:
mode:
Diffstat (limited to 'meta/classes/sstate.bbclass')
-rw-r--r--meta/classes/sstate.bbclass4
1 files changed, 4 insertions, 0 deletions
diff --git a/meta/classes/sstate.bbclass b/meta/classes/sstate.bbclass
index 6f0c791fe5..172384b376 100644
--- a/meta/classes/sstate.bbclass
+++ b/meta/classes/sstate.bbclass
@@ -851,15 +851,19 @@ def sstate_checkhashes(sq_fn, sq_task, sq_hash, sq_hashfn, d, siginfo=False):
851 851
852 if tasklist: 852 if tasklist:
853 bb.event.fire(bb.event.ProcessStarted("Checking sstate mirror object availability", len(tasklist)), d) 853 bb.event.fire(bb.event.ProcessStarted("Checking sstate mirror object availability", len(tasklist)), d)
854
854 import multiprocessing 855 import multiprocessing
855 nproc = min(multiprocessing.cpu_count(), len(tasklist)) 856 nproc = min(multiprocessing.cpu_count(), len(tasklist))
856 857
858 bb.event.enable_threadlock()
857 pool = oe.utils.ThreadedPool(nproc, len(tasklist), 859 pool = oe.utils.ThreadedPool(nproc, len(tasklist),
858 worker_init=checkstatus_init, worker_end=checkstatus_end) 860 worker_init=checkstatus_init, worker_end=checkstatus_end)
859 for t in tasklist: 861 for t in tasklist:
860 pool.add_task(checkstatus, t) 862 pool.add_task(checkstatus, t)
861 pool.start() 863 pool.start()
862 pool.wait_completion() 864 pool.wait_completion()
865 bb.event.disable_threadlock()
866
863 bb.event.fire(bb.event.ProcessFinished("Checking sstate mirror object availability"), d) 867 bb.event.fire(bb.event.ProcessFinished("Checking sstate mirror object availability"), d)
864 if whitelist and missing: 868 if whitelist and missing:
865 bb.fatal('Required artifacts were unavailable - exiting') 869 bb.fatal('Required artifacts were unavailable - exiting')