Method prepareRead

read.go:221–240

prepareRead sets the read timeout and checks whether the connection is closed.

(ctx context.Context)

// prepareRead sets the read timeout and checks whether the connection is closed.
func (c *Conn) prepareRead(ctx context.Context) (bool, error) {
	select {
	case <-c.closed:
		return false, net.ErrClosed
	default:
	}
	timeoutSet := c.setupReadTimeout(ctx)

	c.closeStateMu.Lock()
	closeReceivedErr := c.closeReceivedErr
	c.closeStateMu.Unlock()
	if closeReceivedErr != nil {
		if timeoutSet {
			c.clearReadTimeout()
		}
		return false, closeReceivedErr
	}

	return timeoutSet, nil
}

// finishRead clears the read timeout and reports whether the connection or
// operation context ended while the read was in progress.