You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2009/07/09 22:38:31 UTC
svn commit: r792677 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp
Author: aconway
Date: Thu Jul 9 20:38:31 2009
New Revision: 792677
URL: http://svn.apache.org/viewvc?rev=792677&view=rev
Log:
Minor improvement to cluster logging.
Modified:
qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp?rev=792677&r1=792676&r2=792677&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp Thu Jul 9 20:38:31 2009
@@ -434,13 +434,16 @@
else if (state >= CATCHUP) {
LATENCY_TRACK(LatencyScope ls(processLatency));
map.incrementFrameSeq();
- QPID_LOG(trace, *this << " DLVR " << map.getFrameSeq() << ": " << e);
ConnectionPtr connection = getConnection(e, l);
- if (connection)
+ if (connection) {
+ QPID_LOG(trace, *this << " DLVR " << map.getFrameSeq() << ": " << e);
connection->deliveredFrame(e);
+ }
+ else
+ QPID_LOG(critical, *this << " FIXME DROP (no connection): " << e);
}
else // Drop connection frames while state < CATCHUP
- QPID_LOG(trace, *this << " DROP: " << e);
+ QPID_LOG(trace, *this << " DROP (joining): " << e);
}
// Called in deliverFrameQueue thread
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org