summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Cluster.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-03-31 16:52:50 +0000
committerAlan Conway <aconway@apache.org>2010-03-31 16:52:50 +0000
commitdda98127df553def41fb332f714c2f91858a7ea3 (patch)
tree85ce770251b694656176e4e29e055194293f430d /cpp/src/qpid/cluster/Cluster.cpp
parentf6f1900eb98cc1773a88a3ec309afa646438a384 (diff)
downloadqpid-python-dda98127df553def41fb332f714c2f91858a7ea3.tar.gz
Cluster: remove un-necessary code for config-seq.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@929616 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster.cpp')
-rw-r--r--cpp/src/qpid/cluster/Cluster.cpp6
1 files changed, 1 insertions, 5 deletions
diff --git a/cpp/src/qpid/cluster/Cluster.cpp b/cpp/src/qpid/cluster/Cluster.cpp
index 858900be9e..0520503ad4 100644
--- a/cpp/src/qpid/cluster/Cluster.cpp
+++ b/cpp/src/qpid/cluster/Cluster.cpp
@@ -638,8 +638,6 @@ void Cluster::initMapCompleted(Lock& l) {
}
else { // I can go ready.
discarding = false;
- map.resetConfigSeq(); // Start from config-seq = 0
- store.setConfigSeq(map.getConfigSeq());
setReady(l);
memberUpdate(l);
mcast.mcastControl(ClusterReadyBody(ProtocolVersion(), myUrl.str()), self);
@@ -658,8 +656,7 @@ void Cluster::configChange(const MemberId&,
MemberSet members = decodeMemberSet(membersStr);
MemberSet left = decodeMemberSet(leftStr);
MemberSet joined = decodeMemberSet(joinedStr);
- QPID_LOG(notice, *this << " Membership update " << map.getConfigSeq() << ": "
- << members);
+ QPID_LOG(notice, *this << " Membership update: " << members);
QPID_LOG_IF(notice, !left.empty(), *this << " Members left: " << left);
QPID_LOG_IF(notice, !joined.empty(), *this << " Members joined: " << joined);
@@ -671,7 +668,6 @@ void Cluster::configChange(const MemberId&,
return;
}
bool memberChange = map.configChange(members);
- store.setConfigSeq(map.getConfigSeq());
// Update initital status for members joining or leaving.
initMap.configChange(members);