diff options
| author | Gordon Sim <gsim@apache.org> | 2008-10-09 08:36:25 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-10-09 08:36:25 +0000 |
| commit | cd1bbd2d0ed63e274b59489248d7099f36414c71 (patch) | |
| tree | 34f0558e2b4f2be101b66d686bf4fe29155aa32b /cpp/src/qpid/broker/Queue.h | |
| parent | dcfeb1fcd3acda0903bf117bb88e324075231d11 (diff) | |
| download | qpid-python-cd1bbd2d0ed63e274b59489248d7099f36414c71.tar.gz | |
Minor indentation fixes
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703102 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.h | 37 |
1 files changed, 20 insertions, 17 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 213a36d59d..9a7c90181c 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -77,12 +77,12 @@ namespace qpid { bool lastValueQueue; bool optimisticConsume; bool persistLastNode; - bool inLastNodeFailure; + bool inLastNodeFailure; std::string traceId; std::vector<std::string> traceExclude; Listeners listeners; Messages messages; - LVQ lvq; + LVQ lvq; mutable qpid::sys::Mutex consumerLock; mutable qpid::sys::Mutex messageLock; mutable qpid::sys::Mutex ownershipLock; @@ -109,26 +109,29 @@ namespace qpid { void dequeued(const QueuedMessage& msg); void popAndDequeue(); - inline void mgntEnqStats(const boost::intrusive_ptr<Message>& msg){ + + inline void mgntEnqStats(const boost::intrusive_ptr<Message>& msg) + { if (mgmtObject != 0) { mgmtObject->inc_msgTotalEnqueues (); mgmtObject->inc_byteTotalEnqueues (msg->contentSize ()); if (msg->isPersistent ()) { - mgmtObject->inc_msgPersistEnqueues (); - mgmtObject->inc_bytePersistEnqueues (msg->contentSize ()); - } + mgmtObject->inc_msgPersistEnqueues (); + mgmtObject->inc_bytePersistEnqueues (msg->contentSize ()); + } + } + } + inline void mgntDeqStats(const boost::intrusive_ptr<Message>& msg) + { + if (mgmtObject != 0){ + mgmtObject->inc_msgTotalDequeues (); + mgmtObject->inc_byteTotalDequeues (msg->contentSize()); + if (msg->isPersistent ()){ + mgmtObject->inc_msgPersistDequeues (); + mgmtObject->inc_bytePersistDequeues (msg->contentSize()); + } } - }; - inline void mgntDeqStats(const boost::intrusive_ptr<Message>& msg){ - if (mgmtObject != 0){ - mgmtObject->inc_msgTotalDequeues (); - mgmtObject->inc_byteTotalDequeues (msg->contentSize()); - if (msg->isPersistent ()){ - mgmtObject->inc_msgPersistDequeues (); - mgmtObject->inc_bytePersistDequeues (msg->contentSize()); - } - } - }; + } public: |