Hi Kiu, That was just a copy paste error in mail. I do have poll_items[1] initialized. Do you see any issue why zmq_poll API just returns only the first message received on each socket.
Thanks Badhri Sent from my iPhone On Aug 18, 2014, at 5:31 PM, KIU Shueng Chuan <[email protected]> wrote: > Your snippet neither initializes nor checks poll_items[1]. But no, revents > field doesn't need to be reset (nor initialized). > > > On Tue, Aug 19, 2014 at 8:14 AM, Badhrinath Manoharan <[email protected]> > wrote: >> Hi, >> >> I have the following topology >> >> Client ---> Broker ----> Server >> >> Both the client and server are sockets of type ZMQ_REQ while the Broker has >> a socket connected to client and another Socket Connected to Server both are >> of type ZMQ_BROKER. >> >> void *frontend = zmq_socket (context, ZMQ_ROUTER); >> void *backend = zmq_socket (context, ZMQ_ROUTER); >> >> zmq_bind(frontend, "ipc:///users/badmanoh/frontend.ipc"); >> zmq_bind(backend, "ipc:///users/badmanoh/backend.ipc"); >> >> poll_items[0].socket = frontend; >> poll_items[0].fd = 0; >> poll_items[0].events = ZMQ_POLLIN; >> poll_items[0].revents = 0; >> >> poll_items[0].socket = backend; >> poll_items[0].fd = 0; >> poll_items[0].events = ZMQ_POLLIN; >> poll_items[0].revents = 0; >> >> while (1) { >> ret = zmq_poll(poll_items, 2, -1); >> if (ret == -1) { >> printf("zmq_poll returned -1. Error: %d\n", errno); >> return 0; >> } >> if (poll_items[0].revents & ZMQ_POLLIN) { >> } >> if (poll_items[0].revents & ZMQ_POLLIN) { >> } >> } >> >> On the broker code, I have a zmq_poll(poll_items, 2, -1) on a while loop. I >> see the zmq_poll notifying the first message from each socket. However >> subsequent messages from both the client or server sockets are not at all >> returned and the zmq_poll just stays in an infinite loop. Could you let us >> know if I am missing anything? Do I need to reset the revents value as part >> of the first notification? >> >> Thanks >> Badhri >> >> _______________________________________________ >> zeromq-dev mailing list >> [email protected] >> http://lists.zeromq.org/mailman/listinfo/zeromq-dev > > _______________________________________________ > zeromq-dev mailing list > [email protected] > http://lists.zeromq.org/mailman/listinfo/zeromq-dev
_______________________________________________ zeromq-dev mailing list [email protected] http://lists.zeromq.org/mailman/listinfo/zeromq-dev
