summaryrefslogtreecommitdiff
path: root/src/socket_base.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-08-24 11:19:22 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-08-25 15:39:21 +0200
commit9b8993efb48ccbe3df917338cc078129b5af495b (patch)
treec9234c0c67d26818cb5691951bbffd9c1cd015b0 /src/socket_base.cpp
parent46d70555659c05a0c8d95c6d7aa8c7e0cc5ebc66 (diff)
elementary fixes to the named session
Diffstat (limited to 'src/socket_base.cpp')
-rw-r--r--src/socket_base.cpp12
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;