Hi ,
I was trying to integrate the libzmq3.2 with libev by registering zmq
socket fd to event_loops . I am trying to use inproc zmq_pair sockets
for inter thread communicaton.
I have made some changes in zmq::pipe_t::flush in order to make it work
void zmq::pipe_t::flush ()
{
// The peer does not exist anymore at this point.
if (state == terminating)
return;
if (outpipe && !outpipe->flush ())
send_activate_read (peer);
else
send_activate_read(peer); //changes done for sending the
commands (events) deliberately
}
Can you kindly validate these changes and see if there are any
repercussions in sending the activate_read even if the reader_thread is
active
Regards,
_______________________________________________
zeromq-dev mailing list
[email protected]
http://lists.zeromq.org/mailman/listinfo/zeromq-dev
