diff options
-rw-r--r-- | meta/classes-global/sstate.bbclass | 6 |
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 () { | |||
925 | BB_HASHCHECK_FUNCTION = "sstate_checkhashes" | 925 | BB_HASHCHECK_FUNCTION = "sstate_checkhashes" |
926 | 926 | ||
927 | def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True, **kwargs): | 927 | def 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" |