(p []byte)
| 138 | } |
| 139 | |
| 140 | func (c *statTrackingConn) Read(p []byte) (n int, err error) { |
| 141 | n, err = c.Conn.Read(p) |
| 142 | statTCPReads.Incr(int64(n)) |
| 143 | if err != nil { |
| 144 | c.once.Do(func() { |
| 145 | statTCPDoneRead.Incr(1) |
| 146 | }) |
| 147 | } |
| 148 | return |
| 149 | } |
| 150 | |
| 151 | func (c *statTrackingConn) Close() error { |
| 152 | c.once.Do(func() { |