summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-08-26 21:12:54 +0000
committerAlan Conway <aconway@apache.org>2010-08-26 21:12:54 +0000
commitf32145824299cc519690c700bd5ea8117d4c675b (patch)
treecf883fe9c82498246e352ecb3a18942429d66083 /cpp/src/qpid/broker
parent9c5d0cf2197a7d8901d3cc2793eb630f17d0d3ee (diff)
downloadqpid-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.cpp4
-rw-r--r--cpp/src/qpid/broker/DtxManager.cpp2
-rw-r--r--cpp/src/qpid/broker/DtxTimeout.cpp2
-rw-r--r--cpp/src/qpid/broker/LinkRegistry.cpp2
-rw-r--r--cpp/src/qpid/broker/QueueCleaner.cpp2
-rw-r--r--cpp/src/qpid/broker/SessionState.cpp2
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)
{}