From a2a56cf9a7483e165fb579d0b519b284d02009e3 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 24 Sep 2008 17:34:08 +0000 Subject: Cluster replicates session command sequence state and consumers to newcomers. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@698666 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/MemberHandler.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/MemberHandler.cpp') diff --git a/cpp/src/qpid/cluster/MemberHandler.cpp b/cpp/src/qpid/cluster/MemberHandler.cpp index ec9e7790c5..0f600a4995 100644 --- a/cpp/src/qpid/cluster/MemberHandler.cpp +++ b/cpp/src/qpid/cluster/MemberHandler.cpp @@ -34,7 +34,8 @@ using namespace framing; MemberHandler::MemberHandler(Cluster& c) : ClusterHandler(c) {} MemberHandler::~MemberHandler() { - if (dumpThread.id()) dumpThread.join(); // Join the last dumpthread. + if (dumpThread.id()) + dumpThread.join(); // Join the last dumpthread. } void MemberHandler::configChange( @@ -62,7 +63,8 @@ void MemberHandler::dumpRequest(const MemberId& dumpee, const std::string& urlSt assert(!cluster.connectionEventQueue.isStopped()); // Not currently stalled. cluster.stall(); - if (dumpThread.id()) dumpThread.join(); // Join the last dumpthread. + if (dumpThread.id()) + dumpThread.join(); // Join the previous dumpthread. dumpThread = Thread(new DumpClient(Url(urlStr), cluster, boost::bind(&MemberHandler::dumpSent, this), boost::bind(&MemberHandler::dumpError, this, _1))); -- cgit v1.2.1