From 306114207d6ff6c3ec6d63f5ab6b4ff9e1dd7d4e Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Tue, 27 Jan 2009 02:08:25 +0000 Subject: Cluster rename: dump -> update, newbie -> joiner git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737971 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Multicaster.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'cpp/src/qpid/cluster/Multicaster.cpp') diff --git a/cpp/src/qpid/cluster/Multicaster.cpp b/cpp/src/qpid/cluster/Multicaster.cpp index 847088435c..446722745c 100644 --- a/cpp/src/qpid/cluster/Multicaster.cpp +++ b/cpp/src/qpid/cluster/Multicaster.cpp @@ -23,6 +23,7 @@ #include "Cpg.h" #include "qpid/log/Statement.h" #include "qpid/sys/LatencyMetric.h" +#include "qpid/framing/AMQBody.h" namespace qpid { namespace cluster { @@ -40,12 +41,14 @@ Multicaster::Multicaster(Cpg& cpg_, size_t mcastMax_, } void Multicaster::mcastControl(const framing::AMQBody& body, const ConnectionId& id) { + QPID_LOG(trace, "MCAST " << id << ": " << body); mcast(Event::control(body, id)); } void Multicaster::mcastBuffer(const char* data, size_t size, const ConnectionId& id) { Event e(DATA, id, size); memcpy(e.getData(), data, size); + QPID_LOG(trace, "MCAST " << e); mcast(e); } @@ -54,7 +57,6 @@ void Multicaster::mcast(const Event& e) { sys::Mutex::ScopedLock l(lock); if (e.getType() == DATA && e.isConnection() && holding) { holdingQueue.push_back(e); - QPID_LOG(trace, " MCAST held: " << e ); return; } } @@ -85,7 +87,6 @@ void Multicaster::sendMcast(PollableEventQueue::Queue& values) { } break; } - QPID_LOG(trace, " MCAST " << *i); ++i; } values.erase(values.begin(), i); // Erase sent events. -- cgit v1.2.1