summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/SessionManager.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-10-18 14:11:14 +0000
committerGordon Sim <gsim@apache.org>2007-10-18 14:11:14 +0000
commit7f325f32bf02007add378df60c50c554f37567af (patch)
treea21693dcd332b89f66d42e8b16ec39bfcae50a5b /cpp/src/qpid/broker/SessionManager.cpp
parent07969f395f233bf940029304f06fa0fd7bfcd193 (diff)
downloadqpid-python-7f325f32bf02007add378df60c50c554f37567af.tar.gz
Lock active session id map when removing id for closed session.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@585968 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/SessionManager.cpp')
-rw-r--r--cpp/src/qpid/broker/SessionManager.cpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/SessionManager.cpp b/cpp/src/qpid/broker/SessionManager.cpp
index e422e50657..303687c788 100644
--- a/cpp/src/qpid/broker/SessionManager.cpp
+++ b/cpp/src/qpid/broker/SessionManager.cpp
@@ -82,6 +82,12 @@ std::auto_ptr<SessionState> SessionManager::resume(
return state;
}
+void SessionManager::erase(const framing::Uuid& id)
+{
+ Mutex::ScopedLock l(lock);
+ active.erase(id);
+}
+
void SessionManager::eraseExpired() {
// Called with lock held.
if (!suspended.empty()) {