postgres.git / summary / log / commit / refs

commit    2bdfcb52c5d1446a1f19cc8bf16d44911658bcac
Author:   Robert Haas <rhaas@postgresql.org>
Date:     Fri Dec 18 17:37:43 2015 +0000
First released in: 9.6.0

    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 d625b0d800b..276956e3f14 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)


[parent: 4496226782c4]