Codebase list golang-github-vbauerster-mpb / 533b6c9
wait for forceRefresh goroutine Vladimir Bauer 3 years ago
1 changed file(s) with 8 addition(s) and 0 deletion(s). Raw diff Collapse all Expand all
+8
-0
bar.go less more
182182 if s.current >= s.total {
183183 s.current = s.total
184184 s.completed = true
185 b.container.bwg.Add(1)
185186 go b.forceRefresh(s.manualRefresh)
186187 } else {
187188 s.triggerComplete = true
210211 if triggerCompleteNow {
211212 s.current = s.total
212213 s.completed = true
214 b.container.bwg.Add(1)
213215 go b.forceRefresh(s.manualRefresh)
214216 }
215217 }:
228230 if s.triggerComplete && s.current >= s.total {
229231 s.current = s.total
230232 s.completed = true
233 b.container.bwg.Add(1)
231234 go b.forceRefresh(s.manualRefresh)
232235 }
233236 }:
250253 if s.triggerComplete && s.current >= s.total {
251254 s.current = s.total
252255 s.completed = true
256 b.container.bwg.Add(1)
253257 go b.forceRefresh(s.manualRefresh)
254258 }
255259 }:
278282 if s.triggerComplete && s.current >= s.total {
279283 s.current = s.total
280284 s.completed = true
285 b.container.bwg.Add(1)
281286 go b.forceRefresh(s.manualRefresh)
282287 }
283288 }:
308313 if s.triggerComplete && s.current >= s.total {
309314 s.current = s.total
310315 s.completed = true
316 b.container.bwg.Add(1)
311317 go b.forceRefresh(s.manualRefresh)
312318 }
313319 }:
346352 }
347353 s.aborted = true
348354 s.dropOnComplete = drop
355 b.container.bwg.Add(1)
349356 go b.forceRefresh(s.manualRefresh)
350357 }:
351358 case <-b.done:
432439 }
433440
434441 func (b *Bar) forceRefresh(refreshCh chan interface{}) {
442 defer b.container.bwg.Done()
435443 var anyOtherRunning bool
436444 b.container.traverseBars(func(bar *Bar) bool {
437445 anyOtherRunning = b != bar && bar.IsRunning()