diff mbox series

[2/2] sstate: use nproc for tasklist size on mirrors

Message ID 20211202220517.2106590-2-quaresma.jose@gmail.com
State New
Headers show
Series [1/2] sstate: don't limit the thread pool size when checking mirrors | expand

Commit Message

Jose Quaresma Dec. 2, 2021, 10:05 p.m. UTC 
Signed-off-by: Jose Quaresma <quaresma.jose@gmail.com>
---
 meta/classes/sstate.bbclass | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
diff mbox series

Patch

diff --git a/meta/classes/sstate.bbclass b/meta/classes/sstate.bbclass
index 5e404d7cd8..9efd334a59 100644
--- a/meta/classes/sstate.bbclass
+++ b/meta/classes/sstate.bbclass
@@ -997,7 +997,7 @@  def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
                 bb.error("SState: cannot test %s: %s" % (srcuri, e))
 
             if progress:
-                bb.event.fire(bb.event.ProcessProgress(msg, len(tasklist) - thread_worker.tasks.qsize()), d)
+                bb.event.fire(bb.event.ProcessProgress(msg, nproc - thread_worker.tasks.qsize()), d)
 
         tasklist = []
         for tid in missed:
@@ -1007,13 +1007,13 @@  def sstate_checkhashes(sq_data, d, siginfo=False, currentcount=0, summary=True,
         if tasklist:
             nproc = len(tasklist)
 
-            progress = len(tasklist) >= 100
+            progress = nproc >= 100
             if progress:
                 msg = "Checking sstate mirror object availability"
-                bb.event.fire(bb.event.ProcessStarted(msg, len(tasklist)), d)
+                bb.event.fire(bb.event.ProcessStarted(msg, nproc), d)
 
             bb.event.enable_threadlock()
-            pool = oe.utils.ThreadedPool(nproc, len(tasklist),
+            pool = oe.utils.ThreadedPool(nproc, nproc,
                     worker_init=checkstatus_init, worker_end=checkstatus_end,
                     name="sstate_checkhashes-")
             for t in tasklist: