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

Function getMessageFromLeader

src/bin/pg_dump/parallel.c:1520–1524  ·  view source on GitHub ↗

* Read one command message from the leader, blocking if necessary * until one is available, and return it as a malloc'd string. * On EOF, return NULL. * * This function is executed in worker processes. */

Source from the content-addressed store, hash-verified

1518 * This function is executed in worker processes.
1519 */
1520static char *
1521getMessageFromLeader(int pipefd[2])
1522{
1523 return readMessageFromPipe(pipefd[PIPE_READ]);
1524}
1525
1526/*
1527 * Send a status message to the leader.

Callers 1

WaitForCommandsFunction · 0.85

Calls 1

readMessageFromPipeFunction · 0.85

Tested by

no test coverage detected