summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Cluster.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-08-15 22:40:30 +0000
committerAlan Conway <aconway@apache.org>2008-08-15 22:40:30 +0000
commita89ff937607b452a1b890861700eea08e08e7724 (patch)
treea1bc1cf7404c71a0219a585aaa7aa6dcfbb542d8 /cpp/src/qpid/cluster/Cluster.h
parent828592ed28dc68137c007dbc8ec92d6826cab929 (diff)
downloadqpid-python-a89ff937607b452a1b890861700eea08e08e7724.tar.gz
Fix memory leak in Cluster and enable valgrind in ais_check
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@686409 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.h')
-rw-r--r--cpp/src/qpid/cluster/Cluster.h4
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.h b/cpp/src/qpid/cluster/Cluster.h
index 1c43bdac43..2b40193dd3 100644
--- a/cpp/src/qpid/cluster/Cluster.h
+++ b/cpp/src/qpid/cluster/Cluster.h
@@ -91,11 +91,12 @@ class Cluster : private Cpg::Handler, public RefCounted
// Cluster frame handing functions
void notify(const std::string& url);
void connectionClose();
-
+
private:
typedef Cpg::Id Id;
typedef std::map<Id, Member> MemberMap;
typedef std::map<ShadowConnectionId, ConnectionInterceptor*> ShadowConnectionMap;
+ typedef std::set<ConnectionInterceptor*> LocalConnectionSet;
/** Message sent over the cluster. */
struct Message {
@@ -154,6 +155,7 @@ class Cluster : private Cpg::Handler, public RefCounted
MemberMap members;
Id self;
ShadowConnectionMap shadowConnectionMap;
+ LocalConnectionSet localConnectionSet;
ShadowConnectionOutputHandler shadowOut;
sys::DispatchHandle cpgDispatchHandle;
MessageQueue deliverQueue;