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

Function ExecAsyncResponse

src/backend/executor/execAsync.c:116–129  ·  view source on GitHub ↗

* Call the requestor back when an asynchronous node has produced a result. */

Source from the content-addressed store, hash-verified

114 * Call the requestor back when an asynchronous node has produced a result.
115 */
116void
117ExecAsyncResponse(AsyncRequest *areq)
118{
119 switch (nodeTag(areq->requestor))
120 {
121 case T_AppendState:
122 ExecAsyncAppendResponse(areq);
123 break;
124 default:
125 /* If the node doesn't support async, caller messed up. */
126 elog(ERROR, "unrecognized node type: %d",
127 (int) nodeTag(areq->requestor));
128 }
129}
130
131/*
132 * A requestee node should call this function to deliver the tuple to its

Callers 4

process_pending_requestFunction · 0.85
complete_pending_requestFunction · 0.85
ExecAsyncRequestFunction · 0.85
ExecAsyncNotifyFunction · 0.85

Calls 1

ExecAsyncAppendResponseFunction · 0.85

Tested by

no test coverage detected