diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Connection.cpp')
-rw-r--r-- | qpid/cpp/src/qpid/broker/Connection.cpp | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/qpid/cpp/src/qpid/broker/Connection.cpp b/qpid/cpp/src/qpid/broker/Connection.cpp index aca3c26a4f..5e339cec03 100644 --- a/qpid/cpp/src/qpid/broker/Connection.cpp +++ b/qpid/cpp/src/qpid/broker/Connection.cpp @@ -185,13 +185,13 @@ void Connection::recordFromServer(const framing::AMQFrame& frame) // Don't record management stats in cluster-unsafe contexts if (mgmtObject != 0 && isClusterSafe()) { - qmf::org::apache::qpid::broker::Connection::PerThreadStats *cStats = mgmtObject->getStatistics(); - cStats->framesToClient += 1; - cStats->bytesToClient += frame.encodedSize(); - if (isMessage(frame.getMethod())) { - cStats->msgsToClient += 1; - } - mgmtObject->statisticsUpdated(); + qmf::org::apache::qpid::broker::Connection::PerThreadStats *cStats = mgmtObject->getStatistics(); + cStats->framesToClient += 1; + cStats->bytesToClient += frame.encodedSize(); + if (isMessage(frame.getMethod())) { + cStats->msgsToClient += 1; + } + mgmtObject->statisticsUpdated(); } } @@ -200,13 +200,13 @@ void Connection::recordFromClient(const framing::AMQFrame& frame) // Don't record management stats in cluster-unsafe contexts if (mgmtObject != 0 && isClusterSafe()) { - qmf::org::apache::qpid::broker::Connection::PerThreadStats *cStats = mgmtObject->getStatistics(); - cStats->framesFromClient += 1; - cStats->bytesFromClient += frame.encodedSize(); - if (isMessage(frame.getMethod())) { - cStats->msgsFromClient += 1; - } - mgmtObject->statisticsUpdated(); + qmf::org::apache::qpid::broker::Connection::PerThreadStats *cStats = mgmtObject->getStatistics(); + cStats->framesFromClient += 1; + cStats->bytesFromClient += frame.encodedSize(); + if (isMessage(frame.getMethod())) { + cStats->msgsFromClient += 1; + } + mgmtObject->statisticsUpdated(); } } |