Function skipCollection

go/fory/skip.go:236–305

skipCollection skips a collection (list/set) value Uses context error state for deferred error checking.

(ctx *ReadContext, fieldDef FieldDef)

// skipCollection skips a collection (list/set) value
// Uses context error state for deferred error checking.
func skipCollection(ctx *ReadContext, fieldDef FieldDef) {
	err := ctx.Err()
	length := uint32(ctx.ReadCollectionLength())
	if ctx.HasError() || length == 0 {
		return
	}

	header := ctx.buffer.ReadByte(err)
	if ctx.HasError() {
		return
	}

	hasNull := (header & CollectionHasNull) != 0
	isSameType := (header & CollectionIsSameType) != 0
	trackRef := (header & CollectionTrackingRef) != 0
	isDeclared := (header & CollectionIsDeclElementType) != 0

	var elemDef FieldDef
	var elemTypeInfo *TypeInfo
	if isSameType && !isDeclared {
		// ReadData element type info - first read the typeID from buffer
		typeID := uint32(ctx.buffer.ReadUint8(err))
		if ctx.HasError() {
			return
		}
		elemTypeInfo = readKnownTypeInfoForSkip(ctx, typeID)
		if ctx.HasError() {
			return
		}
		elemDef = FieldDef{
			typeSpec: NewSimpleTypeSpec(TypeId(elemTypeInfo.TypeID)),
			nullable: hasNull,
		}
	} else if isDeclared {
		// Use declared element type from the collection's field type
		if fieldDef.typeSpec != nil && fieldDef.typeSpec.elementType != nil {
			elemDef = FieldDef{
				typeSpec: fieldDef.typeSpec.elementType,
				nullable: hasNull,
			}
		} else {
			// Fallback: use unknown type
			elemDef = FieldDef{
				typeSpec: NewSimpleTypeSpec(UNKNOWN),
				nullable: true,
			}
		}
	} else {
		// Not same type - each element has its own type info, use unknown
		elemDef = FieldDef{
			typeSpec: NewSimpleTypeSpec(UNKNOWN),
			nullable: true,
		}
	}

	ctx.depth++
	if ctx.depth > ctx.maxDepth {
		ctx.SetError(MaxDepthExceededError(ctx.depth))