---------------------------------------------------------------- * ExecForeignScanReInitializeDSM * * Reset shared state before beginning a fresh scan. * ---------------------------------------------------------------- */
| 416 | * ---------------------------------------------------------------- |
| 417 | */ |
| 418 | void |
| 419 | ExecForeignScanReInitializeDSM(ForeignScanState *node, ParallelContext *pcxt) |
| 420 | { |
| 421 | FdwRoutine *fdwroutine = node->fdwroutine; |
| 422 | |
| 423 | if (fdwroutine->ReInitializeDSMForeignScan) |
| 424 | { |
| 425 | int plan_node_id = node->ss.ps.plan->plan_node_id; |
| 426 | void *coordinate; |
| 427 | |
| 428 | coordinate = shm_toc_lookup(pcxt->toc, plan_node_id, false); |
| 429 | fdwroutine->ReInitializeDSMForeignScan(node, pcxt, coordinate); |
| 430 | } |
| 431 | } |
| 432 | |
| 433 | /* ---------------------------------------------------------------- |
| 434 | * ExecForeignScanInitializeWorker |
no test coverage detected