mirror of
https://github.com/zeromq/libzmq.git
synced 2025-10-30 21:50:49 +01:00
Revive reader on pipe termination
This commit is contained in:
@@ -204,7 +204,7 @@ void zmq::writer_t::term ()
|
|||||||
msg.content = (void*) (offset + ZMQ_DELIMITER);
|
msg.content = (void*) (offset + ZMQ_DELIMITER);
|
||||||
msg.flags = 0;
|
msg.flags = 0;
|
||||||
pipe->write (msg, false);
|
pipe->write (msg, false);
|
||||||
pipe->flush ();
|
flush ();
|
||||||
}
|
}
|
||||||
|
|
||||||
void zmq::writer_t::process_reader_info (uint64_t msgs_read_)
|
void zmq::writer_t::process_reader_info (uint64_t msgs_read_)
|
||||||
|
|||||||
Reference in New Issue
Block a user