(chk *chunk.Chunk, err error)
| 258 | } |
| 259 | |
| 260 | func (e *ParallelNestedLoopApplyExec) putResult(chk *chunk.Chunk, err error) (exit bool) { |
| 261 | select { |
| 262 | case e.resultChkCh <- result{chk, err}: |
| 263 | return false |
| 264 | case <-e.exit: |
| 265 | return true |
| 266 | } |
| 267 | } |
| 268 | |
| 269 | func (e *ParallelNestedLoopApplyExec) handleWorkerPanic(ctx context.Context, wg *sync.WaitGroup) { |
| 270 | if r := recover(); r != nil { |
no outgoing calls
no test coverage detected