(p []byte)
| 138 | } |
| 139 | |
| 140 | func (nc *netConn) Read(p []byte) (int, error) { |
| 141 | nc.readMu.forceLock() |
| 142 | defer nc.readMu.unlock() |
| 143 | |
| 144 | for { |
| 145 | n, err := nc.read(p) |
| 146 | if err != nil { |
| 147 | return n, err |
| 148 | } |
| 149 | if n == 0 { |
| 150 | continue |
| 151 | } |
| 152 | return n, nil |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | func (nc *netConn) read(p []byte) (int, error) { |
| 157 | if nc.readExpired.Load() == 1 { |