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

Function pqPipelineFlush

src/interfaces/libpq/fe-exec.c:3818–3825  ·  view source on GitHub ↗

* pqPipelineFlush * * In pipeline mode, data will be flushed only when the out buffer reaches the * threshold value. In non-pipeline mode, it behaves as stock pqFlush. * * Returns 0 on success. */

Source from the content-addressed store, hash-verified

3816 * Returns 0 on success.
3817 */
3818static int
3819pqPipelineFlush(PGconn *conn)
3820{
3821 if ((conn->pipelineStatus != PQ_PIPELINE_ON) ||
3822 (conn->outCount >= OUTBUFFER_THRESHOLD))
3823 return pqFlush(conn);
3824 return 0;
3825}
3826
3827
3828/*

Callers 4

PQsendQueryInternalFunction · 0.85
PQsendPrepareFunction · 0.85
PQsendQueryGutsFunction · 0.85
PQsendDescribeFunction · 0.85

Calls 1

pqFlushFunction · 0.85

Tested by

no test coverage detected