Commit 2bdfcb52 authored by Robert Haas's avatar Robert Haas

Fix TupleQueueReaderNext not to ignore its nowait argument.

This was a silly goof on my (rhaas's) part.

Report and fix by Rushabh Lathia.
parent 44962267
...@@ -535,7 +535,7 @@ TupleQueueReaderNext(TupleQueueReader *reader, bool nowait, bool *done) ...@@ -535,7 +535,7 @@ TupleQueueReaderNext(TupleQueueReader *reader, bool nowait, bool *done)
void *data; void *data;
/* Attempt to read a message. */ /* 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 queue is detached, set *done and return NULL. */
if (result == SHM_MQ_DETACHED) if (result == SHM_MQ_DETACHED)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment