diff options
-rw-r--r-- | meta/classes/sstate.bbclass | 4 |
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') |