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

Function PQisBusy

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

Source from the content-addressed store, hash-verified

1983 */
1984
1985int
1986PQisBusy(PGconn *conn)
1987{
1988 if (!conn)
1989 return false;
1990
1991 /* Parse any available data, if our state permits. */
1992 parseInput(conn);
1993
1994 /*
1995 * PQgetResult will return immediately in all states except BUSY. Also,
1996 * if we've detected read EOF and dropped the connection, we can expect
1997 * that PQgetResult will fail immediately. Note that we do *not* check
1998 * conn->write_failed here --- once that's become set, we know we have
1999 * trouble, but we need to keep trying to read until we have a complete
2000 * server message or detect read EOF.
2001 */
2002 return conn->asyncStatus == PGASYNC_BUSY && conn->status != CONNECTION_BAD;
2003}
2004
2005/*
2006 * PQgetResult

Callers 15

pgfdw_get_resultFunction · 0.85
pgfdw_get_cleanup_resultFunction · 0.85
dblink_is_busyFunction · 0.85
ftsReceiveFunction · 0.85
ManageCronTaskFunction · 0.85
libpqrcv_PQgetResultFunction · 0.85
cdbCopyEndInternalFunction · 0.85
handlePollSuccessFunction · 0.85
processResultsFunction · 0.85
wait_on_slotsFunction · 0.85
try_complete_stepFunction · 0.85

Calls 1

parseInputFunction · 0.85

Tested by 4

try_complete_stepFunction · 0.68
test_pipelined_insertFunction · 0.68
test_uniqviolFunction · 0.68