[zeromq-dev] zmq_poll versus zloop reactor: different semantics - how to resolve?

Michael Haberler mail17 at mah.priv.at
Tue Sep 25 12:36:18 CEST 2012

I am heading towards a solution, but it involves more than just conditionally ignoring POLLERR in zloop.c - that's easy (new ZMQ_IGNERR flag in pollitem.events and handling code).

The tough cases involve zmq.cpp - the revents coming back are too aggregated to handle these cases properly; currently every flag in revents which isnt a POLLIN|POLLOUT is returned as a ZMQ_POLLERR.

The missing ZMQ_POLL* bits are:

POLLHUP: this is signaled when a named pipe write side is closed, and zloop was monitoring the read side. Can only be handled by closing/reopening the fifo.
POLLPRI (OOB data): signaled by a kernel sysfs_notify() operation on a sysfs path. Can be handled by doing an lseek(fd,0,SEEK_SET) and read(fd,..) without closing/reopening.

To handle those, I'd #define ZMQ_POLLPRI and ZMQ_POLLHUP as bits if the underlying platform has them, else zero

However, there's a user-visible API change because the definition of ZMQ_POLLERR changes to:


meaning: a POLLHUP or POLLPRI on the underlying fd so far reported ZMQ_POLLERR; it will post-change report separate ZMQ_POLLHUP and ZMQ_POLLPRI bits instead of ZMQ_POLLERR. Also, code which uses these bits on a Unix platform will fail on, say, Windows, which I cant test here.


still want me to go ahead with this? I cant quite judge the impact of this change. I'm happy to do the changes, test for Linux, document them and add a test program. 

- Michael

ps: I said 'I did the prototype with libzmq - which worked fine' which in reality wasnt the case.

Am 24.09.2012 um 21:41 schrieb Pieter Hintjens:

> On Mon, Sep 24, 2012 at 2:00 PM, Michael Haberler <mail17 at mah.priv.at> wrote:
>> I have an application where a named pipe, and a sysfs device is monitored. I did the prototype with libzmq - which worked fine - and the switched to czmq, which broke things for me.
>> the issue is: czmq is too agresssive in shutting down a poll handler if a POLLERR is returned.
> Could be.
>> I dont like it, but am unsure what to do; fiddling with the inner loop of the reactor I dont feel confident about yet.
> It's a little involved but not so complex so my advice would be to
> look at the internals, propose a patch.
> You do want to provide a test case so people can see the before/after results.
> -Pieter
> _______________________________________________
> zeromq-dev mailing list
> zeromq-dev at lists.zeromq.org
> http://lists.zeromq.org/mailman/listinfo/zeromq-dev

More information about the zeromq-dev mailing list