Author: kgiusti
Date: Fri Mar 2 20:51:28 2012
New Revision: 1296449
URL: http://svn.apache.org/viewvc?rev=1296449&view=rev
Log:
QPID-3875: fix indentation
Modified:
qpid/trunk/qpid/cpp/src/qpid/broker/Connection.cpp
qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp
qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Connection.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Connection.cpp?rev=1296449&r1=1296448&r2=1296449&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Connection.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Connection.cpp Fri Mar 2 20:51:28 2012
@@ -185,13 +185,13 @@ void Connection::recordFromServer(const
// 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
// 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();
}
}
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp?rev=1296449&r1=1296448&r2=1296449&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Exchange.cpp Fri Mar 2 20:51:28 2012
@@ -135,23 +135,23 @@ void Exchange::doRoute(Deliverable& msg,
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;
}
}
}
Modified: qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=1296449&r1=1296448&r2=1296449&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Fri Mar 2 20:51:28 2012
@@ -93,48 +93,48 @@ inline void mgntEnqStats(const boost::in
_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<Message>& 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
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
