(addr net.Addr, cn *conn)
| 213 | } |
| 214 | |
| 215 | func (c *Client) putFreeConn(addr net.Addr, cn *conn) { |
| 216 | c.mu.Lock() |
| 217 | defer c.mu.Unlock() |
| 218 | if c.freeconn == nil { |
| 219 | c.freeconn = make(map[string][]*conn) |
| 220 | } |
| 221 | freelist := c.freeconn[addr.String()] |
| 222 | if len(freelist) >= c.maxIdleConns() { |
| 223 | cn.nc.Close() |
| 224 | return |
| 225 | } |
| 226 | c.freeconn[addr.String()] = append(freelist, cn) |
| 227 | } |
| 228 | |
| 229 | func (c *Client) getFreeConn(addr net.Addr) (cn *conn, ok bool) { |
| 230 | c.mu.Lock() |
no test coverage detected