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
(stream unsafe.Pointer, start *time.Time, name stageName)
| 171 | // reportTiming is similar to reportTimingForCurrentBatch except that it modifies the query stats for the |
| 172 | // whole query. It's usually should be called once for each stage |
| 173 | func (qc *AQLQueryContext) reportTiming(stream unsafe.Pointer, start *time.Time, name stageName) { |
| 174 | if qc.Debug { |
| 175 | if stream != nil { |
| 176 | cgoutils.WaitForCudaStream(stream, qc.Device) |
| 177 | } |
| 178 | now := utils.Now() |
| 179 | value := now.Sub(*start).Seconds() * 1000 |
| 180 | queryStats := &qc.OOPK.LiveBatchStats |
| 181 | queryStats.applyStageStats(name, value) |
| 182 | *start = now |
| 183 | } |
| 184 | } |
| 185 | |
| 186 | // applyStageStats applies the stage stats to the overall query stats and compute max,minCallName and total for that |
| 187 | // stage. |
no test coverage detected