generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-02-20 22:31:34 +01:00
Code Issues Projects Releases Wiki Activity

msg_t::rm_refs closes the message when number of refs drops to 0 (issue 245)

Browse Source 
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
This commit is contained in:
Martin Sustrik 2011-09-02 13:44:22 +02:00
parent 82ab08d871
commit 2910a728dc
2 changed files with 16 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/msg.cpp
View File

@ -257,17 +257,25 @@ void zmq::msg_t::add_refs (int refs_)
}
}
void zmq::msg_t::rm_refs (int refs_)
bool zmq::msg_t::rm_refs (int refs_)
{
zmq_assert (refs_ >= 0);
// No copies required.
if (!refs_)
return;
return true;
// If there's only one reference close the message.
if (u.base.type != type_lmsg || !(u.lmsg.flags & msg_t::shared)) {
close ();
return false;
}
// The only message type that needs special care are long messages.
if (u.base.type == type_lmsg) {
zmq_assert (u.lmsg.flags & msg_t::shared);
u.lmsg.content->refcnt.sub (refs_);
if (!u.lmsg.content->refcnt.sub (refs_)) {
close ();
return false;
}
return true;
}

5
src/msg.hpp
View File

@ -73,8 +73,9 @@ namespace zmq
// refs_ times. No need to call copy.
void add_refs (int refs_);
// Removes references previously added by add_refs.
void rm_refs (int refs_);
// Removes references previously added by add_refs. If the number of
// references drops to 0, the message is closed and false is returned.
bool rm_refs (int refs_);
private: