[zeromq-dev] Problem with Intergation of libzmq 3.2 with libev

[Tejaswi, Saikrishna]

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,

 

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <https://lists.zeromq.org/pipermail/zeromq-dev/attachments/20120913/3636e598/attachment.htm>