()
| 968 | } |
| 969 | |
| 970 | func (g *connGroup) closeIdleConns() { |
| 971 | g.mutex.Lock() |
| 972 | conns := g.idleConns |
| 973 | g.idleConns = nil |
| 974 | g.closed = true |
| 975 | g.mutex.Unlock() |
| 976 | |
| 977 | for _, c := range conns { |
| 978 | c.close() |
| 979 | } |
| 980 | } |
| 981 | |
| 982 | func (g *connGroup) grabConnOrConnect(ctx context.Context) (*conn, error) { |
| 983 | rslv := g.pool.resolver |