(write func(time.Time, int32) error, read func(time.Time, int) error)
| 1329 | } |
| 1330 | |
| 1331 | func (c *Conn) writeOperation(write func(time.Time, int32) error, read func(time.Time, int) error) error { |
| 1332 | return c.do(&c.wdeadline, write, read) |
| 1333 | } |
| 1334 | |
| 1335 | func (c *Conn) enter() { |
| 1336 | atomic.AddInt32(&c.inflight, +1) |
no test coverage detected