106 owned_t::iterator it = std::find (
owned.begin (),
owned.end (), object_);
110 if (it ==
owned.end ())
132 owned.insert (object_);
164 for (owned_t::iterator it =
owned.begin (); it !=
owned.end (); ++it)
void process_own(own_t *object_)
void process_term(int linger_)
void process_term_req(own_t *object_)
own_t(zmq::ctx_t *parent_, uint32_t tid_)
virtual void process_destroy()
void send_own(zmq::own_t *destination_, zmq::own_t *object_)
void register_term_acks(int count_)
void send_plug(zmq::own_t *destination_, bool inc_seqnum_=true)
void send_term_req(zmq::own_t *destination_, zmq::own_t *object_)
void send_term_ack(zmq::own_t *destination_)
void send_term(zmq::own_t *destination_, int linger_)
uint64_t processed_seqnum
atomic_counter_t sent_seqnum
void set_owner(own_t *owner_)
integer_t add(integer_t increment_)
void term_child(own_t *object_)
void launch_child(own_t *object_)
void unregister_term_ack()