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

Function pqCommandQueueAdvance

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

* pqCommandQueueAdvance * Remove one query from the command queue, when we receive * all results from the server that pertain to it. */

Source from the content-addressed store, hash-verified

3012 * all results from the server that pertain to it.
3013 */
3014void
3015pqCommandQueueAdvance(PGconn *conn)
3016{
3017 PGcmdQueueEntry *prevquery;
3018
3019 if (conn->cmd_queue_head == NULL)
3020 return;
3021
3022 /* delink from queue */
3023 prevquery = conn->cmd_queue_head;
3024 conn->cmd_queue_head = conn->cmd_queue_head->next;
3025
3026 /* and make it recyclable */
3027 prevquery->next = NULL;
3028 pqRecycleCmdQueueEntry(conn, prevquery);
3029}
3030
3031/*
3032 * pqPipelineProcessQueue: subroutine for PQgetResult

Callers 2

pqParseInput3Function · 0.85
PQgetResultFunction · 0.85

Calls 1

pqRecycleCmdQueueEntryFunction · 0.85

Tested by

no test coverage detected