diff options
Diffstat (limited to 'meta/classes/sstate.bbclass')
-rw-r--r-- | meta/classes/sstate.bbclass | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/meta/classes/sstate.bbclass b/meta/classes/sstate.bbclass index 849723d4dc..3f6a1fe99f 100644 --- a/meta/classes/sstate.bbclass +++ b/meta/classes/sstate.bbclass | |||
@@ -996,11 +996,11 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, | |||
996 | bb.debug(2, "SState: Unsuccessful fetch test for %s (%s)" % (srcuri, e)) | 996 | bb.debug(2, "SState: Unsuccessful fetch test for %s (%s)" % (srcuri, e)) |
997 | except Exception as e: | 997 | except Exception as e: |
998 | bb.error("SState: cannot test %s: %s" % (srcuri, e)) | 998 | bb.error("SState: cannot test %s: %s" % (srcuri, e)) |
999 | if len(tasklist) >= min_tasks: | 999 | |
1000 | if progress: | ||
1000 | bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d) | 1001 | bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d) |
1001 | 1002 | ||
1002 | tasklist = [] | 1003 | tasklist = [] |
1003 | min_tasks = 100 | ||
1004 | for tid in sq_data['hash']: | 1004 | for tid in sq_data['hash']: |
1005 | if tid in found: | 1005 | if tid in found: |
1006 | continue | 1006 | continue |
@@ -1011,7 +1011,8 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, | |||
1011 | if tasklist: | 1011 | if tasklist: |
1012 | nproc = min(int(d.getVar("BB_NUMBER_THREADS")), len(tasklist)) | 1012 | nproc = min(int(d.getVar("BB_NUMBER_THREADS")), len(tasklist)) |
1013 | 1013 | ||
1014 | if len(tasklist) >= min_tasks: | 1014 | progress = len(tasklist) >= 100 |
1015 | if progress: | ||
1015 | msg = "Checking sstate mirror object availability" | 1016 | msg = "Checking sstate mirror object availability" |
1016 | bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d) | 1017 | bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d) |
1017 | 1018 | ||
@@ -1024,7 +1025,7 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, | |||
1024 | pool.wait_completion() | 1025 | pool.wait_completion() |
1025 | bb.event.disable_threadlock() | 1026 | bb.event.disable_threadlock() |
1026 | 1027 | ||
1027 | if len(tasklist) >= min_tasks: | 1028 | if progress: |
1028 | bb.event.fire(bb.event.ProcessFinished(msg), d) | 1029 | bb.event.fire(bb.event.ProcessFinished(msg), d) |
1029 | 1030 | ||
1030 | inheritlist = d.getVar("INHERIT") | 1031 | inheritlist = d.getVar("INHERIT") |