mirror of
https://github.com/containers/skopeo.git
synced 2025-09-21 01:49:50 +00:00
fix(deps): update github.com/containers/image/v5 digest to 58d5eb6
Signed-off-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com>
This commit is contained in:
27
vendor/github.com/vbauerster/mpb/v8/heap_manager.go
generated
vendored
27
vendor/github.com/vbauerster/mpb/v8/heap_manager.go
generated
vendored
@@ -1,8 +1,6 @@
|
||||
package mpb
|
||||
|
||||
import (
|
||||
"container/heap"
|
||||
)
|
||||
import "container/heap"
|
||||
|
||||
type heapManager chan heapRequest
|
||||
|
||||
@@ -36,6 +34,7 @@ type pushData struct {
|
||||
type fixData struct {
|
||||
bar *Bar
|
||||
priority int
|
||||
lazy bool
|
||||
}
|
||||
|
||||
func (m heapManager) run() {
|
||||
@@ -46,7 +45,6 @@ func (m heapManager) run() {
|
||||
var sync bool
|
||||
|
||||
for req := range m {
|
||||
next:
|
||||
switch req.cmd {
|
||||
case h_push:
|
||||
data := req.data.(pushData)
|
||||
@@ -75,34 +73,35 @@ func (m heapManager) run() {
|
||||
syncWidth(aMatrix, drop)
|
||||
case h_iter:
|
||||
data := req.data.(iterData)
|
||||
drop_iter:
|
||||
for _, b := range bHeap {
|
||||
select {
|
||||
case data.iter <- b:
|
||||
case <-data.drop:
|
||||
close(data.iter)
|
||||
break next
|
||||
break drop_iter
|
||||
}
|
||||
}
|
||||
close(data.iter)
|
||||
case h_drain:
|
||||
data := req.data.(iterData)
|
||||
drop_drain:
|
||||
for bHeap.Len() != 0 {
|
||||
select {
|
||||
case data.iter <- heap.Pop(&bHeap).(*Bar):
|
||||
case <-data.drop:
|
||||
close(data.iter)
|
||||
break next
|
||||
break drop_drain
|
||||
}
|
||||
}
|
||||
close(data.iter)
|
||||
case h_fix:
|
||||
data := req.data.(fixData)
|
||||
bar, priority := data.bar, data.priority
|
||||
if bar.index < 0 {
|
||||
if data.bar.index < 0 {
|
||||
break
|
||||
}
|
||||
bar.priority = priority
|
||||
heap.Fix(&bHeap, bar.index)
|
||||
data.bar.priority = data.priority
|
||||
if !data.lazy {
|
||||
heap.Fix(&bHeap, data.bar.index)
|
||||
}
|
||||
case h_state:
|
||||
ch := req.data.(chan<- bool)
|
||||
ch <- sync || l != bHeap.Len()
|
||||
@@ -137,8 +136,8 @@ func (m heapManager) drain(iter chan<- *Bar, drop <-chan struct{}) {
|
||||
m <- heapRequest{cmd: h_drain, data: data}
|
||||
}
|
||||
|
||||
func (m heapManager) fix(b *Bar, priority int) {
|
||||
data := fixData{b, priority}
|
||||
func (m heapManager) fix(b *Bar, priority int, lazy bool) {
|
||||
data := fixData{b, priority, lazy}
|
||||
m <- heapRequest{cmd: h_fix, data: data}
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user