| 172 | } |
| 173 | |
| 174 | void |
| 175 | ExecCustomScanInitializeDSM(CustomScanState *node, ParallelContext *pcxt) |
| 176 | { |
| 177 | const CustomExecMethods *methods = node->methods; |
| 178 | |
| 179 | if (methods->InitializeDSMCustomScan) |
| 180 | { |
| 181 | int plan_node_id = node->ss.ps.plan->plan_node_id; |
| 182 | void *coordinate; |
| 183 | |
| 184 | coordinate = shm_toc_allocate(pcxt->toc, node->pscan_len); |
| 185 | methods->InitializeDSMCustomScan(node, pcxt, coordinate); |
| 186 | shm_toc_insert(pcxt->toc, plan_node_id, coordinate); |
| 187 | } |
| 188 | } |
| 189 | |
| 190 | void |
| 191 | ExecCustomScanReInitializeDSM(CustomScanState *node, ParallelContext *pcxt) |
no test coverage detected