Method loadAnyWithLock

runtime/vcache/primitive.go:49–108

(loader *loader)

}

func (p *primitive) loadAnyWithLock(loader *loader) any {
	bytes := make([]byte, p.meta.Location.MemLength)
	if err := p.meta.Location.Read(loader.r, bytes); err != nil {
		panic(err)
	}
	length := p.length()
	it := scode.Iter(bytes)
	switch p.meta.Typ.(type) {
	case *super.TypeOfUint8, *super.TypeOfUint16, *super.TypeOfUint32, *super.TypeOfUint64, *super.TypeEnum:
		values := make([]uint64, 0, length)
		for range length {
			values = append(values, super.DecodeUint(it.Next()))
		}
		return values
	case *super.TypeOfInt8, *super.TypeOfInt16, *super.TypeOfInt32, *super.TypeOfInt64, *super.TypeOfDuration, *super.TypeOfTime:
		values := make([]int64, 0, length)
		for range length {
			values = append(values, super.DecodeInt(it.Next()))
		}
		return values
	case *super.TypeOfFloat16, *super.TypeOfFloat32, *super.TypeOfFloat64:
		values := make([]float64, 0, length)
		for range length {
			values = append(values, super.DecodeFloat(it.Next()))
		}
		return values
	case *super.TypeOfBool:
		bits := bitvec.NewFalse(length)
		for slot := range length {
			if super.DecodeBool(it.Next()) {
				bits.Set(slot)
			}
		}
		return bits
	case *super.TypeOfBytes, *super.TypeOfString, *super.TypeOfType:
		var bytes []byte
		// First offset is always zero.
		offs := make([]uint32, 1, length+1)
		for range length {
			bytes = append(bytes, it.Next()...)
			offs = append(offs, uint32(len(bytes)))
		}
		return vector.NewBytesTable(offs, bytes)
	case *super.TypeOfIP:
		values := make([]netip.Addr, 0, length)
		for range length {
			values = append(values, super.DecodeIP(it.Next()))
		}
		return values
	case *super.TypeOfNet:
		values := make([]netip.Prefix, 0, length)
		for range length {
			values = append(values, super.DecodeNet(it.Next()))
		}
		return values
	case *super.TypeOfNull:
		return nil
	}