summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/OutputInterceptor.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-06-16 20:32:04 +0000
committerAlan Conway <aconway@apache.org>2010-06-16 20:32:04 +0000
commita6801aa6ac2c6d97b6747ef7bd7d2264be9c58ab (patch)
treed4368c5338c635d2cd7a7c40c576636b18098ed6 /cpp/src/qpid/cluster/OutputInterceptor.cpp
parent2273c62236d666ab677d964591f564f81908d6ad (diff)
downloadqpid-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/OutputInterceptor.cpp')
-rw-r--r--cpp/src/qpid/cluster/OutputInterceptor.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/OutputInterceptor.cpp b/cpp/src/qpid/cluster/OutputInterceptor.cpp
index f80eb9c434..1354dab17b 100644
--- a/cpp/src/qpid/cluster/OutputInterceptor.cpp
+++ b/cpp/src/qpid/cluster/OutputInterceptor.cpp
@@ -83,7 +83,7 @@ void OutputInterceptor::deliverDoOutput(uint32_t limit) {
newLimit = (sendMax + sent) / 2;
}
sent = 0;
- while (sent < limit && parent.getBrokerConnection().doOutput())
+ while (sent < limit && parent.getBrokerConnection()->doOutput())
++sent;
if (sent == limit) sendDoOutput(newLimit);
}