diff options
Diffstat (limited to 'meta/classes/sstate.bbclass')
| -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') |
