From dda98127df553def41fb332f714c2f91858a7ea3 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 31 Mar 2010 16:52:50 +0000 Subject: 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 --- cpp/src/qpid/cluster/Cluster.cpp | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) (limited to 'cpp/src/qpid/cluster/Cluster.cpp') 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); -- cgit v1.2.1