(closer *z.Closer)
| 711 | } |
| 712 | |
| 713 | func (n *node) updateZeroMembershipPeriodically(closer *z.Closer) { |
| 714 | defer closer.Done() |
| 715 | ticker := time.Tick(10 * time.Second) |
| 716 | |
| 717 | for { |
| 718 | select { |
| 719 | case <-ticker: |
| 720 | n.server.updateZeroLeader() |
| 721 | n.reconcileZeroAddresses() |
| 722 | case <-closer.HasBeenClosed(): |
| 723 | return |
| 724 | } |
| 725 | } |
| 726 | } |
| 727 | |
| 728 | // reconcileZeroAddresses detects mismatches between the current --my address |
| 729 | // (or transport-layer peer addresses) and what is stored in MembershipState, |
no test coverage detected