refactoring: b.done to b.bsOk
Vladimir Bauer
1 year, 10 months ago
| 18 | 18 | priority int // used by heap |
| 19 | 19 | frameCh chan *renderFrame |
| 20 | 20 | operateState chan func(*bState) |
| 21 | done chan struct{} | |
| 22 | 21 | container *Progress |
| 23 | 22 | bs *bState |
| 23 | bsOk chan struct{} | |
| 24 | 24 | ctx context.Context |
| 25 | 25 | cancel func() |
| 26 | 26 | } |
| 70 | 70 | priority: bs.priority, |
| 71 | 71 | frameCh: make(chan *renderFrame, 1), |
| 72 | 72 | operateState: make(chan func(*bState)), |
| 73 | done: make(chan struct{}), | |
| 73 | bsOk: make(chan struct{}), | |
| 74 | 74 | container: container, |
| 75 | 75 | ctx: ctx, |
| 76 | 76 | cancel: cancel, |
| 121 | 121 | select { |
| 122 | 122 | case b.operateState <- func(s *bState) { result <- s.id }: |
| 123 | 123 | return <-result |
| 124 | case <-b.done: | |
| 124 | case <-b.bsOk: | |
| 125 | 125 | return b.bs.id |
| 126 | 126 | } |
| 127 | 127 | } |
| 132 | 132 | select { |
| 133 | 133 | case b.operateState <- func(s *bState) { result <- s.current }: |
| 134 | 134 | return <-result |
| 135 | case <-b.done: | |
| 135 | case <-b.bsOk: | |
| 136 | 136 | return b.bs.current |
| 137 | 137 | } |
| 138 | 138 | } |
| 351 | 351 | select { |
| 352 | 352 | case b.operateState <- func(s *bState) { result <- s.aborted }: |
| 353 | 353 | return <-result |
| 354 | case <-b.done: | |
| 354 | case <-b.bsOk: | |
| 355 | 355 | return b.bs.aborted |
| 356 | 356 | } |
| 357 | 357 | } |
| 362 | 362 | select { |
| 363 | 363 | case b.operateState <- func(s *bState) { result <- s.completed }: |
| 364 | 364 | return <-result |
| 365 | case <-b.done: | |
| 365 | case <-b.bsOk: | |
| 366 | 366 | return b.bs.completed |
| 367 | 367 | } |
| 368 | 368 | } |
| 392 | 392 | bs.aborted = !bs.completed |
| 393 | 393 | bs.decoratorShutdownNotify() |
| 394 | 394 | b.bs = bs |
| 395 | close(b.done) | |
| 395 | close(b.bsOk) | |
| 396 | 396 | return |
| 397 | 397 | } |
| 398 | 398 | } |
| 426 | 426 | } |
| 427 | 427 | select { |
| 428 | 428 | case b.operateState <- fn: |
| 429 | case <-b.done: | |
| 429 | case <-b.bsOk: | |
| 430 | 430 | fn(b.bs) |
| 431 | 431 | } |
| 432 | 432 | } |
| 467 | 467 | select { |
| 468 | 468 | case b.operateState <- func(s *bState) { result <- s.wSyncTable() }: |
| 469 | 469 | return <-result |
| 470 | case <-b.done: | |
| 470 | case <-b.bsOk: | |
| 471 | 471 | return b.bs.wSyncTable() |
| 472 | 472 | } |
| 473 | 473 | } |