summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2012-03-02 20:51:28 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2012-03-02 20:51:28 +0000
commit26ac9bd724bc9f7dfe49f8166dde597ad8ae344d (patch)
treedcf4a6c06148a5c13b51ad9612d0d0ab610016a4
parent4cd29d042523b98666a6e671037d00271403a302 (diff)
downloadqpid-python-26ac9bd724bc9f7dfe49f8166dde597ad8ae344d.tar.gz
QPID-3875: fix indentation
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1296449 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/broker/Connection.cpp28
-rw-r--r--qpid/cpp/src/qpid/broker/Exchange.cpp26
-rw-r--r--qpid/cpp/src/qpid/broker/Queue.cpp72
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<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->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