diff options
author | Alan Conway <aconway@apache.org> | 2010-06-16 20:32:04 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2010-06-16 20:32:04 +0000 |
commit | a6801aa6ac2c6d97b6747ef7bd7d2264be9c58ab (patch) | |
tree | d4368c5338c635d2cd7a7c40c576636b18098ed6 /cpp/src/qpid/cluster/Cluster.cpp | |
parent | 2273c62236d666ab677d964591f564f81908d6ad (diff) | |
download | qpid-python-a6801aa6ac2c6d97b6747ef7bd7d2264be9c58ab.tar.gz |
Bug 603835 - cluster_tests.test_management failing.
Clean up connections causing extra connection objects in the mangement agent map.
- update connection was not being closed.
- connections belonging to members that left the cluster were not fully cleaned up
Also fixed test errors making failover_soak fail sporadically.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@955370 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.cpp')
-rw-r--r-- | cpp/src/qpid/cluster/Cluster.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.cpp b/cpp/src/qpid/cluster/Cluster.cpp index 9ca6fbf2bf..5d13c1ad8f 100644 --- a/cpp/src/qpid/cluster/Cluster.cpp +++ b/cpp/src/qpid/cluster/Cluster.cpp @@ -361,7 +361,6 @@ void Cluster::erase(const ConnectionId& id) { // Called by Connection::deliverClose() in deliverFrameQueue thread. void Cluster::erase(const ConnectionId& id, Lock&) { - QPID_LOG(info, *this << " connection closed " << id); connections.erase(id); decoder.erase(id); } @@ -1024,7 +1023,7 @@ void Cluster::memberUpdate(Lock& l) { ConnectionMap::iterator j = i++; MemberId m = j->second->getId().getMember(); if (m != self && !map.isMember(m)) { - j->second->getBrokerConnection().closed(); + j->second->close(); erase(j->second->getId(), l); } } |