| 291 | } |
| 292 | |
| 293 | func (c *Client) getConn(addr net.Addr) (*conn, error) { |
| 294 | cn, ok := c.getFreeConn(addr) |
| 295 | if ok { |
| 296 | cn.extendDeadline() |
| 297 | return cn, nil |
| 298 | } |
| 299 | nc, err := c.dial(addr) |
| 300 | if err != nil { |
| 301 | return nil, err |
| 302 | } |
| 303 | cn = &conn{ |
| 304 | nc: nc, |
| 305 | addr: addr, |
| 306 | rw: bufio.NewReadWriter(bufio.NewReader(nc), bufio.NewWriter(nc)), |
| 307 | c: c, |
| 308 | } |
| 309 | cn.extendDeadline() |
| 310 | return cn, nil |
| 311 | } |
| 312 | |
| 313 | func (c *Client) onItem(item *Item, fn func(*Client, *bufio.ReadWriter, *Item) error) error { |
| 314 | addr, err := c.selector.PickServer(item.Key) |