Function asyncCopyDimensionVector

query/aql_processor.go:633–663

helper function for copy dimension vector. Returns the total size of dimension vector.

(toDimVector, fromDimVector unsafe.Pointer, length, offset int, numDimsPerDimWidth queryCom.DimCountsPerDimWidth,
	toVectorCapacity, fromVectorCapacity int, copyFunc cgoutils.AsyncMemCopyFunc,
	stream unsafe.Pointer, device int)

// helper function for copy dimension vector. Returns the total size of dimension vector.
func asyncCopyDimensionVector(toDimVector, fromDimVector unsafe.Pointer, length, offset int, numDimsPerDimWidth queryCom.DimCountsPerDimWidth,
	toVectorCapacity, fromVectorCapacity int, copyFunc cgoutils.AsyncMemCopyFunc,
	stream unsafe.Pointer, device int) {

	ptrFrom, ptrTo := fromDimVector, toDimVector
	numNullVectors := 0
	for _, numDims := range numDimsPerDimWidth {
		numNullVectors += int(numDims)
	}

	dimBytes := 1 << uint(len(numDimsPerDimWidth)-1)
	bytesToCopy := length * dimBytes
	for _, numDim := range numDimsPerDimWidth {
		for i := 0; i < int(numDim); i++ {
			ptrTemp := utils.MemAccess(ptrTo, dimBytes*offset)
			copyFunc(ptrTemp, ptrFrom, bytesToCopy, stream, device)
			ptrTo = utils.MemAccess(ptrTo, dimBytes*toVectorCapacity)
			ptrFrom = utils.MemAccess(ptrFrom, dimBytes*fromVectorCapacity)
		}
		dimBytes >>= 1
		bytesToCopy = length * dimBytes
	}

	// copy null bytes
	for i := 0; i < numNullVectors; i++ {
		ptrTemp := utils.MemAccess(ptrTo, offset)
		copyFunc(ptrTemp, ptrFrom, length, stream, device)
		ptrTo = utils.MemAccess(ptrTo, toVectorCapacity)
		ptrFrom = utils.MemAccess(ptrFrom, fromVectorCapacity)
	}
}

// cleanupDeviceResultBuffers cleans up result buffers and resets result fields.
func (bc *oopkBatchContext) cleanupDeviceResultBuffers() {