Function readDecimalParts

go/fory/decimal.go:124–164

(ctx *ReadContext)

}

func readDecimalParts(ctx *ReadContext) (int32, *big.Int) {
	err := ctx.Err()
	scale := ctx.buffer.ReadVarint32(err)
	header := ctx.buffer.ReadVarUint64(err)
	if ctx.HasError() {
		return 0, nil
	}
	if (header & 1) == 0 {
		return scale, big.NewInt(decodeDecimalZigZag64(header >> 1))
	}

	meta := header >> 1
	length := meta >> 1
	if length == 0 {
		ctx.SetError(DeserializationErrorf("invalid decimal magnitude length %d", length))
		return 0, nil
	}
	if length > uint64(MaxInt) {
		ctx.SetError(DeserializationErrorf("invalid decimal magnitude length %d", length))
		return 0, nil
	}
	magnitudeBytes := ctx.buffer.ReadBytes(int(length), err)
	if ctx.HasError() {
		return 0, nil
	}
	if magnitudeBytes[len(magnitudeBytes)-1] == 0 {
		ctx.SetError(DeserializationError("non-canonical decimal magnitude bytes: trailing zero byte"))
		return 0, nil
	}
	bigEndian := append([]byte(nil), magnitudeBytes...)
	reverseBytes(bigEndian)
	magnitude := new(big.Int).SetBytes(bigEndian)
	if magnitude.Sign() == 0 {
		ctx.SetError(DeserializationError("big decimal encoding must not represent zero"))
		return 0, nil
	}
	if (meta & 1) != 0 {
		magnitude.Neg(magnitude)
	}
	return scale, magnitude
}

func canUseSmallDecimalEncoding(value *big.Int) bool {
	if value == nil {