| 188 | } |
| 189 | |
| 190 | void |
| 191 | ExecCustomScanReInitializeDSM(CustomScanState *node, ParallelContext *pcxt) |
| 192 | { |
| 193 | const CustomExecMethods *methods = node->methods; |
| 194 | |
| 195 | if (methods->ReInitializeDSMCustomScan) |
| 196 | { |
| 197 | int plan_node_id = node->ss.ps.plan->plan_node_id; |
| 198 | void *coordinate; |
| 199 | |
| 200 | coordinate = shm_toc_lookup(pcxt->toc, plan_node_id, false); |
| 201 | methods->ReInitializeDSMCustomScan(node, pcxt, coordinate); |
| 202 | } |
| 203 | } |
| 204 | |
| 205 | void |
| 206 | ExecCustomScanInitializeWorker(CustomScanState *node, |
no test coverage detected