diff options
| author | Alan Conway <aconway@apache.org> | 2010-08-26 21:12:54 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-08-26 21:12:54 +0000 |
| commit | f32145824299cc519690c700bd5ea8117d4c675b (patch) | |
| tree | cf883fe9c82498246e352ecb3a18942429d66083 /cpp/src/qpid/broker | |
| parent | 9c5d0cf2197a7d8901d3cc2793eb630f17d0d3ee (diff) | |
| download | qpid-python-f32145824299cc519690c700bd5ea8117d4c675b.tar.gz | |
Give timer tasks a name for logging purposes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@989925 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker')
| -rw-r--r-- | cpp/src/qpid/broker/Connection.cpp | 4 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/DtxManager.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/DtxTimeout.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/LinkRegistry.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/QueueCleaner.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/SessionState.cpp | 2 |
6 files changed, 7 insertions, 7 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index 1e4d58032a..33ed032327 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -59,7 +59,7 @@ struct ConnectionTimeoutTask : public sys::TimerTask { Connection& connection; ConnectionTimeoutTask(uint16_t hb, sys::Timer& t, Connection& c) : - TimerTask(Duration(hb*2*TIME_SEC)), + TimerTask(Duration(hb*2*TIME_SEC),"ConnectionTimeout"), timer(t), connection(c) {} @@ -365,7 +365,7 @@ struct ConnectionHeartbeatTask : public sys::TimerTask { sys::Timer& timer; Connection& connection; ConnectionHeartbeatTask(uint16_t hb, sys::Timer& t, Connection& c) : - TimerTask(Duration(hb*TIME_SEC)), + TimerTask(Duration(hb*TIME_SEC), "ConnectionHeartbeat"), timer(t), connection(c) {} diff --git a/cpp/src/qpid/broker/DtxManager.cpp b/cpp/src/qpid/broker/DtxManager.cpp index a2ab20ec44..3caa41c3f4 100644 --- a/cpp/src/qpid/broker/DtxManager.cpp +++ b/cpp/src/qpid/broker/DtxManager.cpp @@ -154,7 +154,7 @@ void DtxManager::timedout(const std::string& xid) } DtxManager::DtxCleanup::DtxCleanup(uint32_t _timeout, DtxManager& _mgr, const std::string& _xid) - : TimerTask(qpid::sys::Duration(_timeout * qpid::sys::TIME_SEC)), mgr(_mgr), xid(_xid) {} + : TimerTask(qpid::sys::Duration(_timeout * qpid::sys::TIME_SEC),"DtxCleanup"), mgr(_mgr), xid(_xid) {} void DtxManager::DtxCleanup::fire() { diff --git a/cpp/src/qpid/broker/DtxTimeout.cpp b/cpp/src/qpid/broker/DtxTimeout.cpp index f5238d0909..c4c52ec40a 100644 --- a/cpp/src/qpid/broker/DtxTimeout.cpp +++ b/cpp/src/qpid/broker/DtxTimeout.cpp @@ -25,7 +25,7 @@ using namespace qpid::broker; DtxTimeout::DtxTimeout(uint32_t _timeout, DtxManager& _mgr, const std::string& _xid) - : TimerTask(qpid::sys::Duration(_timeout * qpid::sys::TIME_SEC)), timeout(_timeout), mgr(_mgr), xid(_xid) + : TimerTask(qpid::sys::Duration(_timeout * qpid::sys::TIME_SEC),"DtxTimeout"), timeout(_timeout), mgr(_mgr), xid(_xid) { } diff --git a/cpp/src/qpid/broker/LinkRegistry.cpp b/cpp/src/qpid/broker/LinkRegistry.cpp index 592b64449d..49e0ec33e5 100644 --- a/cpp/src/qpid/broker/LinkRegistry.cpp +++ b/cpp/src/qpid/broker/LinkRegistry.cpp @@ -64,7 +64,7 @@ LinkRegistry::~LinkRegistry() } LinkRegistry::Periodic::Periodic (LinkRegistry& _links) : - TimerTask (Duration (LINK_MAINT_INTERVAL * TIME_SEC)), links(_links) {} + TimerTask (Duration (LINK_MAINT_INTERVAL * TIME_SEC),"LinkRegistry"), links(_links) {} void LinkRegistry::Periodic::fire () { diff --git a/cpp/src/qpid/broker/QueueCleaner.cpp b/cpp/src/qpid/broker/QueueCleaner.cpp index ed98468490..6cdf506873 100644 --- a/cpp/src/qpid/broker/QueueCleaner.cpp +++ b/cpp/src/qpid/broker/QueueCleaner.cpp @@ -39,7 +39,7 @@ void QueueCleaner::start(qpid::sys::Duration p) timer.add(task); } -QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : sys::TimerTask(d), parent(p) {} +QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : sys::TimerTask(d,"QueueCleaner"), parent(p) {} void QueueCleaner::Task::fire() { diff --git a/cpp/src/qpid/broker/SessionState.cpp b/cpp/src/qpid/broker/SessionState.cpp index 426ef190dd..6f02399795 100644 --- a/cpp/src/qpid/broker/SessionState.cpp +++ b/cpp/src/qpid/broker/SessionState.cpp @@ -213,7 +213,7 @@ struct ScheduledCreditTask : public sys::TimerTask { SessionState& sessionState; ScheduledCreditTask(const qpid::sys::Duration& d, sys::Timer& t, SessionState& s) : - TimerTask(d), + TimerTask(d,"ScheduledCredit"), timer(t), sessionState(s) {} |
