[zeromq-dev] the reason for zmq_assert (fetched);

hamster YIDIEPXGXGPN at spammotel.com
Mon Aug 2 15:44:55 CEST 2010


hamster <YIDIEPXGXGPN <at> spammotel.com> writes:

> It does not seem to help :( After updating from git it started to crash on
> receive almost immidiately:

The following change of zmq::xrep_t::xrecv helped to get rid off crash:

=====================
int zmq::xrep_t::xrecv (zmq_msg_t *msg_, int flags_)
{

    if (prefetched) {
        zmq_msg_move (msg_, &prefetched_msg); // zmq_msg_close (msg_); inside
        more_in = msg_->flags & ZMQ_MSG_MORE;
        prefetched = false;
        return 0;
    } else {
	    //  Deallocate old content of the message.
    	zmq_msg_close (msg_);
    }

    //  If we are in the middle of reading a message, just grab next part of it.
=====================





More information about the zeromq-dev mailing list