(addr net.Addr)
| 267 | } |
| 268 | |
| 269 | func (c *Client) dial(addr net.Addr) (net.Conn, error) { |
| 270 | ctx, cancel := context.WithTimeout(context.Background(), c.netTimeout()) |
| 271 | defer cancel() |
| 272 | |
| 273 | dialerContext := c.DialContext |
| 274 | if dialerContext == nil { |
| 275 | dialer := net.Dialer{ |
| 276 | Timeout: c.netTimeout(), |
| 277 | } |
| 278 | dialerContext = dialer.DialContext |
| 279 | } |
| 280 | |
| 281 | nc, err := dialerContext(ctx, addr.Network(), addr.String()) |
| 282 | if err == nil { |
| 283 | return nc, nil |
| 284 | } |
| 285 | |
| 286 | if ne, ok := err.(net.Error); ok && ne.Timeout() { |
| 287 | return nil, &ConnectTimeoutError{addr} |
| 288 | } |
| 289 | |
| 290 | return nil, err |
| 291 | } |
| 292 | |
| 293 | func (c *Client) getConn(addr net.Addr) (*conn, error) { |
| 294 | cn, ok := c.getFreeConn(addr) |
no test coverage detected