Function mapRecvMsgError

internal/transport/handler_server.go:493–506

mapRecvMsgError returns the non-nil err into the appropriate error value as expected by callers of *grpc.parser.recvMsg. In particular, in can only be: - io.EOF - io.ErrUnexpectedEOF - of type transport.ConnectionError - an error from the status package

(err error)

//   - of type transport.ConnectionError
//   - an error from the status package
func mapRecvMsgError(err error) error {
	if err == io.EOF || err == io.ErrUnexpectedEOF {
		return err
	}
	if se, ok := err.(http2.StreamError); ok {
		if code, ok := http2ErrConvTab[se.Code]; ok {
			return status.Error(code, se.Error())
		}
	}
	if strings.Contains(err.Error(), "body closed by handler") {
		return status.Error(codes.Canceled, err.Error())
	}
	return connectionErrorf(true, err, "%s", err.Error())
}