fix(deps): update module github.com/vbauerster/mpb/v8 to v8.10.1

Signed-off-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
This commit is contained in:
renovate[bot]
2025-05-13 15:58:27 +00:00
committed by GitHub
parent 76e11cf5fc
commit fe84fbae72
8 changed files with 44 additions and 64 deletions

View File

@@ -41,7 +41,7 @@ func (m heapManager) run() {
var bHeap priorityQueue
var pMatrix, aMatrix map[int][]chan int
var len int
var l int
var sync bool
for req := range m {
@@ -51,7 +51,7 @@ func (m heapManager) run() {
heap.Push(&bHeap, data.bar)
sync = sync || data.sync
case h_sync:
if sync || len != bHeap.Len() {
if sync || l != bHeap.Len() {
pMatrix = make(map[int][]chan int)
aMatrix = make(map[int][]chan int)
for _, b := range bHeap {
@@ -64,7 +64,7 @@ func (m heapManager) run() {
}
}
sync = false
len = bHeap.Len()
l = bHeap.Len()
}
drop := req.data.(<-chan struct{})
syncWidth(pMatrix, drop)
@@ -106,7 +106,7 @@ func (m heapManager) run() {
}
case h_state:
ch := req.data.(chan<- bool)
ch <- sync || len != bHeap.Len()
ch <- sync || l != bHeap.Len()
case h_end:
ch := req.data.(chan<- interface{})
if ch != nil {