MCPcopy Create free account
hub / github.com/apache/cloudberry / ExecShutdownGatherWorkers

Function ExecShutdownGatherWorkers

src/backend/executor/nodeGather.c:400–410  ·  view source on GitHub ↗

---------------------------------------------------------------- * ExecShutdownGatherWorkers * * Stop all the parallel workers. * ---------------------------------------------------------------- */

Source from the content-addressed store, hash-verified

398 * ----------------------------------------------------------------
399 */
400static void
401ExecShutdownGatherWorkers(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

Callers 3

gather_readnextFunction · 0.85
ExecShutdownGatherFunction · 0.85
ExecReScanGatherFunction · 0.85

Calls 2

ExecParallelFinishFunction · 0.85
pfreeFunction · 0.50

Tested by

no test coverage detected