(address string)
| 224 | } |
| 225 | |
| 226 | func (w *querierWorker) AddressRemoved(address string) { |
| 227 | level.Info(w.log).Log("msg", "removing connection", "addr", address) |
| 228 | |
| 229 | w.mu.Lock() |
| 230 | p := w.managers[address] |
| 231 | delete(w.managers, address) |
| 232 | // Called with lock. |
| 233 | w.resetConcurrency() |
| 234 | w.mu.Unlock() |
| 235 | |
| 236 | if p != nil { |
| 237 | p.stop() |
| 238 | } |
| 239 | } |
| 240 | |
| 241 | // Must be called with lock. |
| 242 | func (w *querierWorker) resetConcurrency() { |
nothing calls this directly
no test coverage detected