summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/ErrorCheck.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-11-17 18:09:21 +0000
committerAlan Conway <aconway@apache.org>2009-11-17 18:09:21 +0000
commit8b58b19ec3989b676cd5a1584089040caee14289 (patch)
treee0ca831f7fac0b26a4dcfa679b574e9a5dfafe06 /cpp/src/qpid/cluster/ErrorCheck.cpp
parentef7728a725272b88c3cd2f81f81ee60ed00cde90 (diff)
downloadqpid-python-8b58b19ec3989b676cd5a1584089040caee14289.tar.gz
Integrated InitialStatusMap into cluster code.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@881423 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/ErrorCheck.cpp')
-rw-r--r--cpp/src/qpid/cluster/ErrorCheck.cpp7
1 files changed, 1 insertions, 6 deletions
diff --git a/cpp/src/qpid/cluster/ErrorCheck.cpp b/cpp/src/qpid/cluster/ErrorCheck.cpp
index 5b7011047b..d66db8551d 100644
--- a/cpp/src/qpid/cluster/ErrorCheck.cpp
+++ b/cpp/src/qpid/cluster/ErrorCheck.cpp
@@ -39,11 +39,6 @@ ErrorCheck::ErrorCheck(Cluster& c)
: cluster(c), mcast(c.getMulticast()), frameSeq(0), type(ERROR_TYPE_NONE), connection(0)
{}
-ostream& operator<<(ostream& o, const ErrorCheck::MemberSet& ms) {
- copy(ms.begin(), ms.end(), ostream_iterator<MemberId>(o, " "));
- return o;
-}
-
void ErrorCheck::error(
Connection& c, ErrorType t, framing::SequenceNumber seq, const MemberSet& ms,
const std::string& msg)
@@ -115,7 +110,7 @@ ErrorCheck::FrameQueue::iterator ErrorCheck::review(const FrameQueue::iterator&
const ClusterConfigChangeBody* configChange =
static_cast<const ClusterConfigChangeBody*>(method);
if (configChange) {
- MemberSet members(ClusterMap::decode(configChange->getCurrent()));
+ MemberSet members(decodeMemberSet(configChange->getCurrent()));
QPID_LOG(debug, cluster << " apply config change to error "
<< frameSeq << ": " << members);
MemberSet intersect;