summaryrefslogtreecommitdiffstats
path: root/meta/classes/sstate.bbclass
diff options
context:
space:
mode:
Diffstat (limited to 'meta/classes/sstate.bbclass')
-rw-r--r--meta/classes/sstate.bbclass12
1 files changed, 8 insertions, 4 deletions
diff --git a/meta/classes/sstate.bbclass b/meta/classes/sstate.bbclass
index b4ffffcd98..faa6470450 100644
--- a/meta/classes/sstate.bbclass
+++ b/meta/classes/sstate.bbclass
@@ -934,9 +934,11 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
934 missed.add(tid) 934 missed.add(tid)
935 bb.debug(2, "SState: Unsuccessful fetch test for %s" % srcuri) 935 bb.debug(2, "SState: Unsuccessful fetch test for %s" % srcuri)
936 pass 936 pass
937 bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d) 937 if len(tasklist) >= min_tasks:
938 bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d)
938 939
939 tasklist = [] 940 tasklist = []
941 min_tasks = 100
940 for tid in sq_data['hash']: 942 for tid in sq_data['hash']:
941 if tid in found: 943 if tid in found:
942 continue 944 continue
@@ -945,8 +947,9 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
945 tasklist.append((tid, sstatefile)) 947 tasklist.append((tid, sstatefile))
946 948
947 if tasklist: 949 if tasklist:
948 msg = "Checking sstate mirror object availability" 950 if len(tasklist) >= min_tasks:
949 bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d) 951 msg = "Checking sstate mirror object availability"
952 bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d)
950 953
951 import multiprocessing 954 import multiprocessing
952 nproc = min(multiprocessing.cpu_count(), len(tasklist)) 955 nproc = min(multiprocessing.cpu_count(), len(tasklist))
@@ -960,7 +963,8 @@ def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
960 pool.wait_completion() 963 pool.wait_completion()
961 bb.event.disable_threadlock() 964 bb.event.disable_threadlock()
962 965
963 bb.event.fire(bb.event.ProcessFinished(msg), d) 966 if len(tasklist) >= min_tasks:
967 bb.event.fire(bb.event.ProcessFinished(msg), d)
964 968
965 # Likely checking an individual task hash again for multiconfig sharing of sstate tasks so skip reporting 969 # Likely checking an individual task hash again for multiconfig sharing of sstate tasks so skip reporting
966 if len(sq_data['hash']) == 1: 970 if len(sq_data['hash']) == 1: