From 001d11d9e53ee2f9217bba412e5c7db141e0db11 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 24 Mar 2009 14:07:25 +0000 Subject: QPID-1771: fix as applied to branch as r757807. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@757808 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/cluster/Decoder.cpp | 5 +++-- cpp/src/qpid/cluster/EventFrame.cpp | 4 +++- 2 files changed, 6 insertions(+), 3 deletions(-) (limited to 'cpp/src') diff --git a/cpp/src/qpid/cluster/Decoder.cpp b/cpp/src/qpid/cluster/Decoder.cpp index 4de586d89f..b337ef43f4 100644 --- a/cpp/src/qpid/cluster/Decoder.cpp +++ b/cpp/src/qpid/cluster/Decoder.cpp @@ -47,12 +47,13 @@ void Decoder::decode(const EventHeader& eh, const char* data) { // We must give 1 unit read credit per event. // This event does not complete any frames so // send an empty frame with the read credit. - process(EventFrame(EventHeader(), framing::AMQFrame(), 1)); + process(EventFrame(eh, framing::AMQFrame(), 1)); } } void Decoder::process(const EventFrame& ef) { - if (ef.frame.getMethod() && ef.frame.getMethod()->isA()) + //need to check that this is not the empty frame mentioned above + if (ef.frame.getBody() && ef.frame.getMethod() && ef.frame.getMethod()->isA()) map.erase(ef.connectionId); callback(ef); } diff --git a/cpp/src/qpid/cluster/EventFrame.cpp b/cpp/src/qpid/cluster/EventFrame.cpp index 8259b6da6e..9350c801f5 100644 --- a/cpp/src/qpid/cluster/EventFrame.cpp +++ b/cpp/src/qpid/cluster/EventFrame.cpp @@ -33,7 +33,9 @@ EventFrame::EventFrame(const EventHeader& e, const framing::AMQFrame& f, int rc) } std::ostream& operator<<(std::ostream& o, const EventFrame& e) { - return o << e.frame << " " << e.type << " " << e.connectionId; + if (e.frame.getBody()) o << e.frame; + else o << "null-frame"; + o << " " << e.type << " " << e.connectionId; if (e.readCredit) o << " read-credit=" << e.readCredit; return o; } -- cgit v1.2.1