diff options
Diffstat (limited to 'src/backend/executor/nodeGather.c')
| -rw-r--r-- | src/backend/executor/nodeGather.c | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/backend/executor/nodeGather.c b/src/backend/executor/nodeGather.c index 93a566ba629..438d1b24fc2 100644 --- a/src/backend/executor/nodeGather.c +++ b/src/backend/executor/nodeGather.c @@ -330,8 +330,8 @@ gather_readnext(GatherState *gatherstate) HeapTuple tup; bool readerdone; - /* Make sure we've read all messages from workers. */ - HandleParallelMessages(); + /* Check for async events, particularly messages from workers. */ + CHECK_FOR_INTERRUPTS(); /* Attempt to read a tuple, but don't block if none is available. */ reader = gatherstate->reader[gatherstate->nextreader]; @@ -388,7 +388,6 @@ gather_readnext(GatherState *gatherstate) /* Nothing to do except wait for developments. */ WaitLatch(MyLatch, WL_LATCH_SET, 0); - CHECK_FOR_INTERRUPTS(); ResetLatch(MyLatch); nvisited = 0; } |