()
| 272 | } |
| 273 | |
| 274 | func (hm *Manager) maintNotificationsConnSnapshot() []*pool.Conn { |
| 275 | var conns []*pool.Conn |
| 276 | hm.maintNotificationsConns.Range(func(_, value interface{}) bool { |
| 277 | if cn, ok := value.(*pool.Conn); ok { |
| 278 | conns = append(conns, cn) |
| 279 | } |
| 280 | return true |
| 281 | }) |
| 282 | return conns |
| 283 | } |
| 284 | |
| 285 | func (hm *Manager) retireMaintNotificationsConns(ctx context.Context) { |
| 286 | conns := hm.maintNotificationsConnSnapshot() |
no outgoing calls
no test coverage detected