Method reportTimingForCurrentBatch

query/stats.go:160–169

reportTimingForCurrentBatch will first wait for current cuda stream if the debug mode is set and change the timing stat accordingly. It will add to the total timing as well. Therefore this function should only be called one time for each stage.

(stream unsafe.Pointer, start *time.Time, name stageName)

// reportTimingForCurrentBatch will first wait for current cuda stream if the debug mode is set and change the timing stat accordingly.
// It will add to the total timing as well. Therefore this function should only be called one time for each stage.
func (qc *AQLQueryContext) reportTimingForCurrentBatch(stream unsafe.Pointer, start *time.Time, name stageName) {
	if qc.Debug {
		cgoutils.WaitForCudaStream(stream, qc.Device)
		now := utils.Now()
		value := now.Sub(*start).Seconds() * 1000
		qc.OOPK.currentBatch.stats.timings[name] = value
		qc.OOPK.currentBatch.stats.totalTiming += value
		*start = now
	}
}

// reportTiming is similar to reportTimingForCurrentBatch except that it modifies the query stats for the
// whole query. It's usually should be called once for each stage