| 203 | } |
| 204 | |
| 205 | void |
| 206 | ExecCustomScanInitializeWorker(CustomScanState *node, |
| 207 | ParallelWorkerContext *pwcxt) |
| 208 | { |
| 209 | const CustomExecMethods *methods = node->methods; |
| 210 | |
| 211 | if (methods->InitializeWorkerCustomScan) |
| 212 | { |
| 213 | int plan_node_id = node->ss.ps.plan->plan_node_id; |
| 214 | void *coordinate; |
| 215 | |
| 216 | coordinate = shm_toc_lookup(pwcxt->toc, plan_node_id, false); |
| 217 | methods->InitializeWorkerCustomScan(node, pwcxt->toc, coordinate); |
| 218 | } |
| 219 | } |
| 220 | |
| 221 | void |
| 222 | ExecShutdownCustomScan(CustomScanState *node) |
no test coverage detected