From 2bdfcb52c5d1446a1f19cc8bf16d44911658bcac Mon Sep 17 00:00:00 2001 From: Robert Haas Date: Fri, 18 Dec 2015 12:37:43 -0500 Subject: [PATCH] Fix TupleQueueReaderNext not to ignore its nowait argument. This was a silly goof on my (rhaas's) part. Report and fix by Rushabh Lathia. --- src/backend/executor/tqueue.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/backend/executor/tqueue.c b/src/backend/executor/tqueue.c index d625b0d800..276956e3f1 100644 --- a/src/backend/executor/tqueue.c +++ b/src/backend/executor/tqueue.c @@ -535,7 +535,7 @@ TupleQueueReaderNext(TupleQueueReader *reader, bool nowait, bool *done) void *data; /* Attempt to read a message. */ - result = shm_mq_receive(reader->queue, &nbytes, &data, true); + result = shm_mq_receive(reader->queue, &nbytes, &data, nowait); /* If queue is detached, set *done and return NULL. */ if (result == SHM_MQ_DETACHED) -- 2.40.0