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

Function ParallelSlotsTerminate

src/fe_utils/parallel_slot.c:450–464  ·  view source on GitHub ↗

* ParallelSlotsTerminate * Clean up a set of parallel slots * * Iterate through all connections in a given set of ParallelSlots and * terminate all connections. */

Source from the content-addressed store, hash-verified

448 * terminate all connections.
449 */
450void
451ParallelSlotsTerminate(ParallelSlotArray *sa)
452{
453 int i;
454
455 for (i = 0; i < sa->numslots; i++)
456 {
457 PGconn *conn = sa->slots[i].connection;
458
459 if (conn == NULL)
460 continue;
461
462 disconnectDatabase(conn);
463 }
464}
465
466/*
467 * ParallelSlotsWaitCompletion

Callers 3

mainFunction · 0.85
vacuum_one_databaseFunction · 0.85
reindex_one_databaseFunction · 0.85

Calls 1

disconnectDatabaseFunction · 0.85

Tested by

no test coverage detected