(ctx context.Context, p []byte)
| 273 | } |
| 274 | |
| 275 | func (c *Conn) readFramePayload(ctx context.Context, p []byte) (_ int, err error) { |
| 276 | timeoutSet, err := c.prepareRead(ctx) |
| 277 | if err != nil { |
| 278 | return 0, err |
| 279 | } |
| 280 | defer c.finishRead(ctx, &err, timeoutSet) |
| 281 | |
| 282 | n, err := io.ReadFull(c.br, p) |
| 283 | if err != nil { |
| 284 | return n, fmt.Errorf("failed to read frame payload: %w", err) |
| 285 | } |
| 286 | |
| 287 | return n, nil |
| 288 | } |
| 289 | |
| 290 | func (c *Conn) handleControl(ctx context.Context, h header) (err error) { |
| 291 | if h.payloadLength < 0 || h.payloadLength > maxControlPayload { |
no test coverage detected