diff --git a/src/lladd/fifo.c b/src/lladd/fifo.c index 30fe425..4f38207 100644 --- a/src/lladd/fifo.c +++ b/src/lladd/fifo.c @@ -91,7 +91,7 @@ int lladdFifoPool_iterator_next(int xid, void * it) { pthread_cond_wait(&(impl->readOK), &(impl->mutex)); } - if(impl->eof) { + if(impl->eof && impl->last == NULL) { pthread_mutex_unlock(&(impl->mutex)); return 0; }