---------------------------------------------------------------- * ExecShutdownGatherWorkers * * Stop all the parallel workers. * ---------------------------------------------------------------- */
| 398 | * ---------------------------------------------------------------- |
| 399 | */ |
| 400 | static void |
| 401 | ExecShutdownGatherWorkers(GatherState *node) |
| 402 | { |
| 403 | if (node->pei != NULL) |
| 404 | ExecParallelFinish(node->pei); |
| 405 | |
| 406 | /* Flush local copy of reader array */ |
| 407 | if (node->reader) |
| 408 | pfree(node->reader); |
| 409 | node->reader = NULL; |
| 410 | } |
| 411 | |
| 412 | /* ---------------------------------------------------------------- |
| 413 | * ExecShutdownGather |
no test coverage detected