From 26ac9bd724bc9f7dfe49f8166dde597ad8ae344d Mon Sep 17 00:00:00 2001 From: Kenneth Anthony Giusti Date: Fri, 2 Mar 2012 20:51:28 +0000 Subject: QPID-3875: fix indentation git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1296449 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/broker/Connection.cpp | 28 ++++++------- qpid/cpp/src/qpid/broker/Exchange.cpp | 26 ++++++------ qpid/cpp/src/qpid/broker/Queue.cpp | 72 ++++++++++++++++----------------- 3 files changed, 63 insertions(+), 63 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(); } } diff --git a/qpid/cpp/src/qpid/broker/Exchange.cpp b/qpid/cpp/src/qpid/broker/Exchange.cpp index bf0dac111f..16a6427a65 100644 --- a/qpid/cpp/src/qpid/broker/Exchange.cpp +++ b/qpid/cpp/src/qpid/broker/Exchange.cpp @@ -135,23 +135,23 @@ void Exchange::doRoute(Deliverable& msg, ConstBindingList b) if (mgmtExchange != 0) { - qmf::org::apache::qpid::broker::Exchange::PerThreadStats *eStats = mgmtExchange->getStatistics(); - uint64_t contentSize = msg.contentSize(); + qmf::org::apache::qpid::broker::Exchange::PerThreadStats *eStats = mgmtExchange->getStatistics(); + uint64_t contentSize = msg.contentSize(); - eStats->msgReceives += 1; - eStats->byteReceives += contentSize; - if (count == 0) + eStats->msgReceives += 1; + eStats->byteReceives += contentSize; + if (count == 0) { - //QPID_LOG(warning, "Exchange " << getName() << " could not route message; no matching binding found"); - eStats->msgDrops += 1; - eStats->byteDrops += contentSize; - if (brokerMgmtObject) - brokerMgmtObject->inc_discardsNoRoute(); + //QPID_LOG(warning, "Exchange " << getName() << " could not route message; no matching binding found"); + eStats->msgDrops += 1; + eStats->byteDrops += contentSize; + if (brokerMgmtObject) + brokerMgmtObject->inc_discardsNoRoute(); } - else + else { - eStats->msgRoutes += count; - eStats->byteRoutes += count * contentSize; + eStats->msgRoutes += count; + eStats->byteRoutes += count * contentSize; } } } diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index ab9560a346..4404bedc24 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -93,48 +93,48 @@ inline void mgntEnqStats(const boost::intrusive_ptr& msg, _qmf::Queue* mgmtObject, _qmf::Broker* brokerMgmtObject) { - if (mgmtObject != 0) { - qmf::org::apache::qpid::broker::Queue::PerThreadStats *qStats = mgmtObject->getStatistics(); - qmf::org::apache::qpid::broker::Broker::PerThreadStats *bStats = brokerMgmtObject->getStatistics(); - - uint64_t contentSize = msg->contentSize(); - qStats->msgTotalEnqueues +=1; - bStats->msgTotalEnqueues += 1; - qStats->byteTotalEnqueues += contentSize; - bStats->byteTotalEnqueues += contentSize; - if (msg->isPersistent ()) { - qStats->msgPersistEnqueues += 1; - bStats->msgPersistEnqueues += 1; - qStats->bytePersistEnqueues += contentSize; - bStats->bytePersistEnqueues += contentSize; - } - mgmtObject->statisticsUpdated(); - brokerMgmtObject->statisticsUpdated(); - } + if (mgmtObject != 0) { + qmf::org::apache::qpid::broker::Queue::PerThreadStats *qStats = mgmtObject->getStatistics(); + qmf::org::apache::qpid::broker::Broker::PerThreadStats *bStats = brokerMgmtObject->getStatistics(); + + uint64_t contentSize = msg->contentSize(); + qStats->msgTotalEnqueues +=1; + bStats->msgTotalEnqueues += 1; + qStats->byteTotalEnqueues += contentSize; + bStats->byteTotalEnqueues += contentSize; + if (msg->isPersistent ()) { + qStats->msgPersistEnqueues += 1; + bStats->msgPersistEnqueues += 1; + qStats->bytePersistEnqueues += contentSize; + bStats->bytePersistEnqueues += contentSize; + } + mgmtObject->statisticsUpdated(); + brokerMgmtObject->statisticsUpdated(); + } } inline void mgntDeqStats(const boost::intrusive_ptr& msg, _qmf::Queue* mgmtObject, _qmf::Broker* brokerMgmtObject) { - if (mgmtObject != 0){ - qmf::org::apache::qpid::broker::Queue::PerThreadStats *qStats = mgmtObject->getStatistics(); - qmf::org::apache::qpid::broker::Broker::PerThreadStats *bStats = brokerMgmtObject->getStatistics(); - uint64_t contentSize = msg->contentSize(); - - qStats->msgTotalDequeues += 1; - bStats->msgTotalDequeues += 1; - qStats->byteTotalDequeues += contentSize; - bStats->byteTotalDequeues += contentSize; - if (msg->isPersistent ()){ - qStats->msgPersistDequeues += 1; - bStats->msgPersistDequeues += 1; - qStats->bytePersistDequeues += contentSize; - bStats->bytePersistDequeues += contentSize; - } - mgmtObject->statisticsUpdated(); - brokerMgmtObject->statisticsUpdated(); - } + if (mgmtObject != 0){ + qmf::org::apache::qpid::broker::Queue::PerThreadStats *qStats = mgmtObject->getStatistics(); + qmf::org::apache::qpid::broker::Broker::PerThreadStats *bStats = brokerMgmtObject->getStatistics(); + uint64_t contentSize = msg->contentSize(); + + qStats->msgTotalDequeues += 1; + bStats->msgTotalDequeues += 1; + qStats->byteTotalDequeues += contentSize; + bStats->byteTotalDequeues += contentSize; + if (msg->isPersistent ()){ + qStats->msgPersistDequeues += 1; + bStats->msgPersistDequeues += 1; + qStats->bytePersistDequeues += contentSize; + bStats->bytePersistDequeues += contentSize; + } + mgmtObject->statisticsUpdated(); + brokerMgmtObject->statisticsUpdated(); + } } } // namespace -- cgit v1.2.1