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