[zeromq-dev] Perl question: ZMQ + AnyEvent

[Robert Olson]

I'm working on a Majordomo implementation in Perl using the ZeroMQ-0.21 wrapper and have a mystery concerning AnyEvent support with it.

I'm using AE to drive the broker (using AE I/O watchers for incoming traffic on the worker and client sockets, and setting up AE timers to handle heartbeats and worker expiration) and it is working great.

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.

The client script is here: http://pastebin.com/mzb4m47x

strace output for synchronous (working) is here: http://pastebin.com/Cz3dPx26
strace output for async (broken) is here: http://pastebin.com/Vhy5XN19

The interesting thing in the trace is the action taken when the message is received by the I/O thread. In the sync case:

5544  recvfrom(17, "\7\1MDPC02\2\1\4\t\1test_svc\2\0011\t\0OK 27609", 8192, 0, NULL, NULL) = 34
5544  sendto(14, "\0", 1, 0, NULL, 0)   = 1
5542  <... poll resumed> )              = 1 ([{fd=15, revents=POLLIN}])
5544  epoll_wait(11,  <unfinished ...>
5542  recvfrom(15, "\0", 1, 0, NULL, NULL) = 1
5542  poll([{fd=15, events=POLLIN}], 1, 0) = 0 (Timeout)
5542  write(1, "Rcv: MDPC02\n", 12)     = 12
5542  write(1, "Rcv: 0x04\n", 10)       = 10
5542  write(1, "Rcv: test_svc\n", 14)   = 14
5542  write(1, "Rcv: 1\n", 7)           = 7
5542  write(1, "Rcv: OK 27609\n", 14)   = 14

We receive the message on fd 17 with the response (the OK message), and send a byte down the notification pipe which wakes up the main thread (5542) and it writes the output. However, in the async case:

6496  recvfrom(17, "\7\1MDPC02\2\1\4\t\1test_svc\2\0011\t\0OK 27609", 8192, 0, NULL, NULL) = 34
6496  epoll_wait(11,  <unfinished ...>
6494  <... epoll_wait resumed> 201fdce0, 64, 59743) = -1 EINTR (Interrupted system call)
6494  --- SIGINT (Interrupt) @ 0 (0) ---

the I/O thread receives the message, and goes back to waiting, not sending a notification. 

It seems like I must be missing some setup here, but the structure of the broker messaging is much the same. There I have a ZeroMQ::Poller in place, but the behavior here does not change if I create the poller object (I never get the AnyEvent notification so the poller never would have been invoked anyway).

Thanks for any pointers,
--bob