single term ack counting mechanism for every socket (no separate mechanisms for fq_t and lb_t)

This commit is contained in:
Martin Sustrik
2010-09-18 07:37:36 +02:00
parent fb6ce536d9
commit 4c6d07d366
15 changed files with 32 additions and 119 deletions

View File

@@ -49,17 +49,10 @@ void zmq::sub_t::xattach_pipes (class reader_t *inpipe_,
void zmq::sub_t::process_term ()
{
register_term_acks (1);
fq.terminate ();
socket_base_t::process_term ();
}
void zmq::sub_t::terminated ()
{
unregister_term_ack ();
}
int zmq::sub_t::xsetsockopt (int option_, const void *optval_,
size_t optvallen_)
{