summaryrefslogtreecommitdiff
path: root/src/owned.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/owned.cpp')
-rw-r--r--src/owned.cpp10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/owned.cpp b/src/owned.cpp
index d6be444..7d1cf5e 100644
--- a/src/owned.cpp
+++ b/src/owned.cpp
@@ -35,7 +35,7 @@ zmq::owned_t::~owned_t ()
void zmq::owned_t::inc_seqnum ()
{
- // NB: This function may be called from a different thread!
+ // This function may be called from a different thread!
sent_seqnum.add (1);
}
@@ -62,10 +62,16 @@ void zmq::owned_t::finalise ()
{
// If termination request was already received and there are no more
// commands to wait for, terminate the object.
- if (shutting_down && processed_seqnum == sent_seqnum.get ()) {
+ if (shutting_down && processed_seqnum == sent_seqnum.get ()
+ && is_terminable ()) {
process_unplug ();
send_term_ack (owner);
delete this;
}
}
+bool zmq::owned_t::is_terminable ()
+{
+ return true;
+}
+