Hi, I'm the maintainer of perl ZMQ modules.<br>I'm away fron my computer atm, so can only guess, but does it work if you put a <br><br>AnyEvent::Util::fh_nonblocking($fd)<br><br>before creating the IO watcher?<br><br>
and yes, for new code you should be using ZMQ::LibMQ2.<br><br>2012年9月22日土曜日 Robert Olson <a href="mailto:olson@mcs.anl.gov">olson@mcs.anl.gov</a>:<br>><br>> On Sep 21, 2012, at 5:31 PM, Pedro Melo wrote:<br>><br>
>> Hi,<br>>><br>>> On Fri, Sep 21, 2012 at 9:11 PM, Robert Olson <<a href="mailto:olson@mcs.anl.gov">olson@mcs.anl.gov</a>> wrote:<br>>>> On Sep 21, 2012, at 2:30 PM, Robert Olson wrote:<br>
>>>> However, in my client, if I set up AnyEvent to wait for the reply from the broker I am never notified. The client works perfectly if I use a synchronous receive on the socket.<br>>>><br>>>> Interesting: in the async code if I issue a nonblocking recv() before I drop into the AnyEvent wait code, it works properly. Is this the expected behavior?<br>
>><br>>> My gut felling when I read your code was that it was correct, it would<br>>> be the code I would write in this situation. Adding that nonblocking<br>>> read seems to be clearing some flag that signals the socket as<br>
>> "nothing more to read at the moment" but I don't remember the<br>>> existence of such a flag…<br>>><br>>> I would do one thing though: move from ZeroMQ binding to the new ZMQ<br>>> bindings. The second ones are written as a direct map to the C API<br>
>> (like ZeroMQ::Raw) but are supported, where as ZeroMQ has several open<br>>> bugs without answers. One particular problem is with ZeroMQ and<br>>> fork's, you'll get a libzmq assertion. Fixed in ZMQ.<br>
><br>> Ah, excellent - I hadn't come across the ZMQ bindings. I'll look into that.<br>><br>> Thanks.<br>><br>> --bob<br>><br>> _______________________________________________<br>> zeromq-dev mailing list<br>
> <a href="mailto:zeromq-dev@lists.zeromq.org">zeromq-dev@lists.zeromq.org</a><br>> <a href="http://lists.zeromq.org/mailman/listinfo/zeromq-dev">http://lists.zeromq.org/mailman/listinfo/zeromq-dev</a><br>>