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

Function pqWait

src/interfaces/libpq/fe-misc.c:1071–1075  ·  view source on GitHub ↗

* pqWait: wait until we can read or write the connection socket * * JAB: If SSL enabled and used and forRead, buffered bytes short-circuit the * call to select(). * * We also stop waiting and return if the kernel flags an exception condition * on the socket. The actual error condition will be detected and reported * when the caller tries to read or write the socket. */

Source from the content-addressed store, hash-verified

1069 * when the caller tries to read or write the socket.
1070 */
1071int
1072pqWait(int forRead, int forWrite, PGconn *conn)
1073{
1074 return pqWaitTimed(forRead, forWrite, conn, (time_t) -1);
1075}
1076
1077/*
1078 * pqWaitTimed: wait, but not past finish_time.

Callers 5

pqSendSomeFunction · 0.85
pqGetCopyData3Function · 0.85
pqGetline3Function · 0.85
pqFunctionCall3Function · 0.85
PQgetResultFunction · 0.85

Calls 1

pqWaitTimedFunction · 0.85

Tested by

no test coverage detected