Index: zeromq-4.2.3/src/pipe.cpp =================================================================== --- zeromq-4.2.3.orig/src/pipe.cpp +++ zeromq-4.2.3/src/pipe.cpp @@ -484,6 +484,7 @@ void zmq::pipe_t::process_delimiter () if (state == active) state = delimiter_received; else { + rollback(); outpipe = NULL; send_pipe_term_ack (peer); state = term_ack_sent;