diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-08-24 11:19:22 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-08-25 15:39:21 +0200 |
commit | 9b8993efb48ccbe3df917338cc078129b5af495b (patch) | |
tree | c9234c0c67d26818cb5691951bbffd9c1cd015b0 /src/socket_base.cpp | |
parent | 46d70555659c05a0c8d95c6d7aa8c7e0cc5ebc66 (diff) |
elementary fixes to the named session
Diffstat (limited to 'src/socket_base.cpp')
-rw-r--r-- | src/socket_base.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/socket_base.cpp b/src/socket_base.cpp index 0103618..76dfc46 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -564,29 +564,29 @@ bool zmq::socket_base_t::has_out () return xhas_out (); } -bool zmq::socket_base_t::register_session (const blob_t &peer_identity_, +bool zmq::socket_base_t::register_session (const blob_t &name_, session_t *session_) { sessions_sync.lock (); bool registered = sessions.insert ( - std::make_pair (peer_identity_, session_)).second; + std::make_pair (name_, session_)).second; sessions_sync.unlock (); return registered; } -void zmq::socket_base_t::unregister_session (const blob_t &peer_identity_) +void zmq::socket_base_t::unregister_session (const blob_t &name_) { sessions_sync.lock (); - sessions_t::iterator it = sessions.find (peer_identity_); + sessions_t::iterator it = sessions.find (name_); zmq_assert (it != sessions.end ()); sessions.erase (it); sessions_sync.unlock (); } -zmq::session_t *zmq::socket_base_t::find_session (const blob_t &peer_identity_) +zmq::session_t *zmq::socket_base_t::find_session (const blob_t &name_) { sessions_sync.lock (); - sessions_t::iterator it = sessions.find (peer_identity_); + sessions_t::iterator it = sessions.find (name_); if (it == sessions.end ()) { sessions_sync.unlock (); return NULL; |