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

Function ParallelSlotsWaitCompletion

src/fe_utils/parallel_slot.c:472–486  ·  view source on GitHub ↗

* ParallelSlotsWaitCompletion * * Wait for all connections to finish, returning false if at least one * error has been found on the way. */

Source from the content-addressed store, hash-verified

470 * error has been found on the way.
471 */
472bool
473ParallelSlotsWaitCompletion(ParallelSlotArray *sa)
474{
475 int i;
476
477 for (i = 0; i < sa->numslots; i++)
478 {
479 if (sa->slots[i].connection == NULL)
480 continue;
481 if (!consumeQueryResult(&sa->slots[i]))
482 return false;
483 }
484
485 return true;
486}
487
488/*
489 * TableCommandResultHandler

Callers 3

mainFunction · 0.85
vacuum_one_databaseFunction · 0.85
reindex_one_databaseFunction · 0.85

Calls 1

consumeQueryResultFunction · 0.85

Tested by

no test coverage detected