(isLastBatch bool, start time.Time)
| 254 | } |
| 255 | |
| 256 | func (e *BatchExecutorImpl) preExec(isLastBatch bool, start time.Time) { |
| 257 | e.isLastBatch = isLastBatch |
| 258 | // initialize index vector. |
| 259 | if !e.qc.OOPK.currentBatch.indexVectorD.isNull() { |
| 260 | initIndexVector(e.qc.OOPK.currentBatch.indexVectorD.getPointer(), 0, e.qc.OOPK.currentBatch.size, e.stream, e.qc.Device) |
| 261 | } |
| 262 | e.qc.reportTimingForCurrentBatch(e.stream, &start, initIndexVectorTiming) |
| 263 | } |
| 264 | |
| 265 | func (e *BatchExecutorImpl) postExec(start time.Time) { |
| 266 | // swap result buffer before next batch |
nothing calls this directly
no test coverage detected