Commit2bdfcb5

committed

Fix TupleQueueReaderNext not to ignore its nowait argument.

This was a silly goof on my (rhaas's) part.Report and fix by Rushabh Lathia.

1 parent4496226 commit2bdfcb5Copy full SHA for 2bdfcb5

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -535,7 +535,7 @@ TupleQueueReaderNext(TupleQueueReader reader, bool nowait, bool done)`
`535`	`535`	`void*data;`
`536`	`536`
`537`	`537`	`/* Attempt to read a message. */`
`538`		`-result=shm_mq_receive(reader->queue,&nbytes,&data,true);`
	`538`	`+result=shm_mq_receive(reader->queue,&nbytes,&data,nowait);`
`539`	`539`
`540`	`540`	`/* If queue is detached, set done and return NULL. /`
`541`	`541`	`if (result==SHM_MQ_DETACHED)`

Comments

(0)