diff --git a/pkg/cluster/rings.go b/pkg/cluster/rings.go index 721fdcf..c6083b2 100644 --- a/pkg/cluster/rings.go +++ b/pkg/cluster/rings.go @@ -205,14 +205,11 @@ func (r *Ring) AddPeer(p *Machine) bool { } func (r *Ring) setRingZeroAllowedIPs(rp *RingPeer) { - regionID, zoneID, _, _ := r.Decode(rp.Address) - - // everyone on ring0 is a gateway to ring1 - subnet, _ := rings.RingOnePrefix(regionID, zoneID) - rp.AllowSubnet(subnet) - - // peer + // ring0 peer rp.AllowCIDR(rp.Address, 32) + + // everyone on ring0 has a leg on ring1 + rp.AllowCIDR(rp.Node.RingOneAddress(), 32) } func (r *Ring) setRingOneGatewayAllowedIPs(rp *RingPeer) {