()
| 829 | } |
| 830 | |
| 831 | func (n *node) processTabletSizes() { |
| 832 | defer n.closer.Done() // CLOSER:1 |
| 833 | tick := time.Tick(5 * time.Minute) // Once every 5 minutes seems alright. |
| 834 | |
| 835 | for { |
| 836 | select { |
| 837 | case <-n.closer.HasBeenClosed(): |
| 838 | return |
| 839 | case <-tick: |
| 840 | n.calculateTabletSizes() |
| 841 | } |
| 842 | } |
| 843 | } |
| 844 | |
| 845 | func updateStartTs(p *pb.Proposal) { |
| 846 | switch { |
no test coverage detected