(m recvMsg, header []byte)
| 252 | } |
| 253 | |
| 254 | func (r *recvBufferReader) readMessageHeaderAdditional(m recvMsg, header []byte) (n int, err error) { |
| 255 | r.recv.load() |
| 256 | if m.err != nil { |
| 257 | if m.buffer != nil { |
| 258 | m.buffer.Free() |
| 259 | } |
| 260 | return 0, m.err |
| 261 | } |
| 262 | |
| 263 | n, r.last = mem.ReadUnsafe(header, m.buffer) |
| 264 | |
| 265 | return n, nil |
| 266 | } |
| 267 | |
| 268 | func (r *recvBufferReader) readAdditional(m recvMsg, n int) (b mem.Buffer, err error) { |
| 269 | r.recv.load() |
no test coverage detected