(gen uint32)
| 573 | } |
| 574 | |
| 575 | func (n *clusterNode) SetGeneration(gen uint32) { |
| 576 | for { |
| 577 | v := atomic.LoadUint32(&n.generation) |
| 578 | if gen < v || atomic.CompareAndSwapUint32(&n.generation, v, gen) { |
| 579 | break |
| 580 | } |
| 581 | } |
| 582 | } |
| 583 | |
| 584 | func (n *clusterNode) SetLastLatencyMeasurement(t time.Time) { |
| 585 | for { |