Fix bogus coding in ExecAppendAsyncEventWait().

No configured-by-FDW events would result in "return" directly out of a
PG_TRY block, making the exception stack dangling.  Repair.

Oversight in commit 501cfd07d; back-patch to v14, like that commit, but
as we do not have this issue in HEAD (cf. commit 50c67c201), no need to
apply this patch to it.

In passing, improve a comment about the handling of in-process requests
in a postgres_fdw.c function called from this function.

Alexander Pyhalov, with comment adjustment/improvement by me.

Discussion: https://postgr.es/m/425fa29a429b21b0332737c42a4fdc70%40postgrespro.ru
REL_16_STABLE
Etsuro Fujita 1 year ago
parent bafad43c37
commit f6f61a4bd9
  1. 18
      contrib/postgres_fdw/postgres_fdw.c
  2. 31
      src/backend/executor/nodeAppend.c

@ -7174,14 +7174,16 @@ postgresForeignAsyncConfigureWait(AsyncRequest *areq)
{ {
/* /*
* This is the case when the in-process request was made by another * This is the case when the in-process request was made by another
* Append. Note that it might be useless to process the request, * Append. Note that it might be useless to process the request made
* because the query might not need tuples from that Append anymore. * by that Append, because the query might not need tuples from that
* If there are any child subplans of the same parent that are ready * Append anymore; so we avoid processing it to begin a fetch for the
* for new requests, skip the given request. Likewise, if there are * given request if possible. If there are any child subplans of the
* any configured events other than the postmaster death event, skip * same parent that are ready for new requests, skip the given
* it. Otherwise, process the in-process request, then begin a fetch * request. Likewise, if there are any configured events other than
* to configure the event below, because we might otherwise end up * the postmaster death event, skip it. Otherwise, process the
* with no configured events other than the postmaster death event. * in-process request, then begin a fetch to configure the event
* below, because we might otherwise end up with no configured events
* other than the postmaster death event.
*/ */
if (!bms_is_empty(requestor->as_needrequest)) if (!bms_is_empty(requestor->as_needrequest))
return; return;

@ -1043,26 +1043,25 @@ ExecAppendAsyncEventWait(AppendState *node)
} }
/* /*
* No need for further processing if there are no configured events * If there are no configured events other than the postmaster death
* other than the postmaster death event. * event, we don't need to wait or poll.
*/ */
if (GetNumRegisteredWaitEvents(node->as_eventset) == 1) if (GetNumRegisteredWaitEvents(node->as_eventset) == 1)
noccurred = 0;
else
{ {
FreeWaitEventSet(node->as_eventset); /* Return at most EVENT_BUFFER_SIZE events in one call. */
node->as_eventset = NULL; if (nevents > EVENT_BUFFER_SIZE)
return; nevents = EVENT_BUFFER_SIZE;
}
/* Return at most EVENT_BUFFER_SIZE events in one call. */ /*
if (nevents > EVENT_BUFFER_SIZE) * If the timeout is -1, wait until at least one event occurs. If
nevents = EVENT_BUFFER_SIZE; * the timeout is 0, poll for events, but do not wait at all.
*/
/* noccurred = WaitEventSetWait(node->as_eventset, timeout,
* If the timeout is -1, wait until at least one event occurs. If the occurred_event, nevents,
* timeout is 0, poll for events, but do not wait at all. WAIT_EVENT_APPEND_READY);
*/ }
noccurred = WaitEventSetWait(node->as_eventset, timeout, occurred_event,
nevents, WAIT_EVENT_APPEND_READY);
} }
PG_FINALLY(); PG_FINALLY();
{ {

Loading…
Cancel
Save