()
| 1341 | } |
| 1342 | |
| 1343 | func (c *Conn) concurrency() int { |
| 1344 | return int(atomic.LoadInt32(&c.inflight)) |
| 1345 | } |
| 1346 | |
| 1347 | func (c *Conn) do(d *connDeadline, write func(time.Time, int32) error, read func(time.Time, int) error) error { |
| 1348 | id, err := c.doRequest(d, write) |