(addr net.Addr, fn func(*conn) error)
| 365 | } |
| 366 | |
| 367 | func (c *Client) withAddrRw(addr net.Addr, fn func(*conn) error) (err error) { |
| 368 | cn, err := c.getConn(addr) |
| 369 | if err != nil { |
| 370 | return err |
| 371 | } |
| 372 | defer cn.condRelease(&err) |
| 373 | return fn(cn) |
| 374 | } |
| 375 | |
| 376 | func (c *Client) withKeyRw(key string, fn func(*conn) error) error { |
| 377 | return c.withKeyAddr(key, func(addr net.Addr) error { |
no test coverage detected