diff options
| author | Andrew Stitcher <astitcher@apache.org> | 2009-07-30 14:06:49 +0000 |
|---|---|---|
| committer | Andrew Stitcher <astitcher@apache.org> | 2009-07-30 14:06:49 +0000 |
| commit | 9c095c4cd694287151cc1fabcc274fd435944dee (patch) | |
| tree | aea55b408f4461f86cc2087629e71c21247ab392 /cpp/src/qpid/cluster | |
| parent | 20dfc1f76b845a7d6826f9a27923827fd60ea0e9 (diff) | |
| download | qpid-python-9c095c4cd694287151cc1fabcc274fd435944dee.tar.gz | |
Change all broker users of broker::Timer to use sys::Timer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@799273 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster')
| -rw-r--r-- | cpp/src/qpid/cluster/ExpiryPolicy.cpp | 8 | ||||
| -rw-r--r-- | cpp/src/qpid/cluster/ExpiryPolicy.h | 9 |
2 files changed, 10 insertions, 7 deletions
diff --git a/cpp/src/qpid/cluster/ExpiryPolicy.cpp b/cpp/src/qpid/cluster/ExpiryPolicy.cpp index 717e1a47cd..190eeb7293 100644 --- a/cpp/src/qpid/cluster/ExpiryPolicy.cpp +++ b/cpp/src/qpid/cluster/ExpiryPolicy.cpp @@ -19,21 +19,21 @@ * */ +#include "qpid/broker/Message.h" #include "qpid/cluster/ExpiryPolicy.h" #include "qpid/cluster/Multicaster.h" #include "qpid/framing/ClusterMessageExpiredBody.h" #include "qpid/sys/Time.h" -#include "qpid/broker/Message.h" -#include "qpid/broker/Timer.h" +#include "qpid/sys/Timer.h" #include "qpid/log/Statement.h" namespace qpid { namespace cluster { -ExpiryPolicy::ExpiryPolicy(Multicaster& m, const MemberId& id, broker::Timer& t) +ExpiryPolicy::ExpiryPolicy(Multicaster& m, const MemberId& id, sys::Timer& t) : expiryId(0), expiredPolicy(new Expired), mcast(m), memberId(id), timer(t) {} -struct ExpiryTask : public broker::TimerTask { +struct ExpiryTask : public sys::TimerTask { ExpiryTask(const boost::intrusive_ptr<ExpiryPolicy>& policy, uint64_t id, sys::AbsTime when) : TimerTask(when), expiryPolicy(policy), expiryId(id) {} void fire() { expiryPolicy->sendExpire(expiryId); } diff --git a/cpp/src/qpid/cluster/ExpiryPolicy.h b/cpp/src/qpid/cluster/ExpiryPolicy.h index 4ec41c93bc..bdbe3a61dc 100644 --- a/cpp/src/qpid/cluster/ExpiryPolicy.h +++ b/cpp/src/qpid/cluster/ExpiryPolicy.h @@ -33,10 +33,13 @@ namespace qpid { namespace broker { -class Timer; class Message; } +namespace sys { +class Timer; +} + namespace cluster { class Multicaster; @@ -46,7 +49,7 @@ class Multicaster; class ExpiryPolicy : public broker::ExpiryPolicy { public: - ExpiryPolicy(Multicaster&, const MemberId&, broker::Timer&); + ExpiryPolicy(Multicaster&, const MemberId&, sys::Timer&); void willExpire(broker::Message&); bool hasExpired(broker::Message&); @@ -78,7 +81,7 @@ class ExpiryPolicy : public broker::ExpiryPolicy boost::intrusive_ptr<Expired> expiredPolicy; Multicaster& mcast; MemberId memberId; - broker::Timer& timer; + sys::Timer& timer; }; }} // namespace qpid::cluster |
