summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--meta/classes-global/sstate.bbclass6
1 files changed, 5 insertions, 1 deletions
diff --git a/meta/classes-global/sstate.bbclass b/meta/classes-global/sstate.bbclass
index 21959ff13b..77e3ea34e1 100644
--- a/meta/classes-global/sstate.bbclass
+++ b/meta/classes-global/sstate.bbclass
@@ -925,6 +925,8 @@ sstate_unpack_package () {
925BB_HASHCHECK_FUNCTION = "sstate_checkhashes" 925BB_HASHCHECK_FUNCTION = "sstate_checkhashes"
926 926
927def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, **kwargs): 927def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, **kwargs):
928 import itertools
929
928 found = set() 930 found = set()
929 missed = set() 931 missed = set()
930 932
@@ -1019,7 +1021,7 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
1019 connection_cache_pool.put(connection_cache) 1021 connection_cache_pool.put(connection_cache)
1020 1022
1021 if progress: 1023 if progress:
1022 bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d) 1024 bb.event.fire(bb.event.ProcessProgress(msg, next(cnt_tasks_done)), d)
1023 1025
1024 tasklist = [] 1026 tasklist = []
1025 for tid in missed: 1027 for tid in missed:
@@ -1029,6 +1031,8 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
1029 if tasklist: 1031 if tasklist:
1030 nproc = min(int(d.getVar("BB_NUMBER_THREADS")), len(tasklist)) 1032 nproc = min(int(d.getVar("BB_NUMBER_THREADS")), len(tasklist))
1031 1033
1034 ## thread-safe counter
1035 cnt_tasks_done = itertools.count(start = 1)
1032 progress = len(tasklist) >= 100 1036 progress = len(tasklist) >= 100
1033 if progress: 1037 if progress:
1034 msg = "Checking sstate mirror object availability" 1038 msg = "Checking sstate mirror object availability"