134
135
// Stop stops the resolver
137
>
r.listenerLock.Lock()
138
>
defer r.listenerLock.Unlock()
139
>
r.rp.RemoveListener(r)
140
>
r.ringAndHosts.Store(ringAndHosts{
141
>
ring: newHashRing(r.replicaPoints),
142
>
hosts: nil,
143
>
})
144
>
r.listeners = make(map[string]chan<- *membership.ChangedEvent)
145
>
close(r.shutdownCh)
146
>
147
>
if success := common.AwaitWaitGroup(&r.shutdownWG, time.Minute); !success {
148
r.logger.Warn("service resolver timed out on shutdown.")
149
}