Codebase list golang-github-vbauerster-mpb / 29feceb
forceRefreshImpl Vladimir Bauer 3 years ago
1 changed file(s) with 12 addition(s) and 14 deletion(s). Raw diff Collapse all Expand all
+12
-14
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)
186 go b.forceRefresh(s.manualRefresh)
185 b.forceRefresh(s.manualRefresh)
187186 } else {
188187 s.triggerComplete = true
189188 }
211210 if triggerCompleteNow {
212211 s.current = s.total
213212 s.completed = true
214 b.container.bwg.Add(1)
215 go b.forceRefresh(s.manualRefresh)
213 b.forceRefresh(s.manualRefresh)
216214 }
217215 }:
218216 case <-b.done:
230228 if s.triggerComplete && s.current >= s.total {
231229 s.current = s.total
232230 s.completed = true
233 b.container.bwg.Add(1)
234 go b.forceRefresh(s.manualRefresh)
231 b.forceRefresh(s.manualRefresh)
235232 }
236233 }:
237234 case <-b.done:
253250 if s.triggerComplete && s.current >= s.total {
254251 s.current = s.total
255252 s.completed = true
256 b.container.bwg.Add(1)
257 go b.forceRefresh(s.manualRefresh)
253 b.forceRefresh(s.manualRefresh)
258254 }
259255 }:
260256 case <-b.done:
282278 if s.triggerComplete && s.current >= s.total {
283279 s.current = s.total
284280 s.completed = true
285 b.container.bwg.Add(1)
286 go b.forceRefresh(s.manualRefresh)
281 b.forceRefresh(s.manualRefresh)
287282 }
288283 }:
289284 case <-b.done:
313308 if s.triggerComplete && s.current >= s.total {
314309 s.current = s.total
315310 s.completed = true
316 b.container.bwg.Add(1)
317 go b.forceRefresh(s.manualRefresh)
311 b.forceRefresh(s.manualRefresh)
318312 }
319313 }:
320314 case <-b.done:
352346 }
353347 s.aborted = true
354348 s.dropOnComplete = drop
355 b.container.bwg.Add(1)
356 go b.forceRefresh(s.manualRefresh)
349 b.forceRefresh(s.manualRefresh)
357350 }:
358351 case <-b.done:
359352 }
439432 }
440433
441434 func (b *Bar) forceRefresh(refreshCh chan interface{}) {
435 b.container.bwg.Add(1)
436 go b.forceRefreshImpl(refreshCh)
437 }
438
439 func (b *Bar) forceRefreshImpl(refreshCh chan interface{}) {
442440 defer b.container.bwg.Done()
443441 var anyOtherRunning bool
444442 b.container.traverseBars(func(bar *Bar) bool {