summaryrefslogtreecommitdiff
path: root/mblock/src/lib/mb_timer_queue.cc
diff options
context:
space:
mode:
Diffstat (limited to 'mblock/src/lib/mb_timer_queue.cc')
-rw-r--r--mblock/src/lib/mb_timer_queue.cc14
1 files changed, 7 insertions, 7 deletions
diff --git a/mblock/src/lib/mb_timer_queue.cc b/mblock/src/lib/mb_timer_queue.cc
index 1293e8a4c..dbdcc4ce1 100644
--- a/mblock/src/lib/mb_timer_queue.cc
+++ b/mblock/src/lib/mb_timer_queue.cc
@@ -24,17 +24,17 @@
#endif
#include <mb_timer_queue.h>
-static pmt_t
+static gruel::pmt_t
make_handle()
{
static long counter = 0;
- pmt_t n = pmt_from_long(counter++);
- return pmt_list1(n); // guaranteed to be a unique object
+ gruel::pmt_t n = gruel::pmt_from_long(counter++);
+ return gruel::pmt_list1(n); // guaranteed to be a unique object
}
// one-shot constructor
mb_timeout::mb_timeout(const mb_time &abs_time,
- pmt_t user_data, mb_msg_accepter_sptr accepter)
+ gruel::pmt_t user_data, mb_msg_accepter_sptr accepter)
: d_when(abs_time), d_is_periodic(false),
d_user_data(user_data), d_handle(make_handle()), d_accepter(accepter)
{
@@ -42,19 +42,19 @@ mb_timeout::mb_timeout(const mb_time &abs_time,
// periodic constructor
mb_timeout::mb_timeout(const mb_time &first_abs_time, const mb_time &delta_time,
- pmt_t user_data, mb_msg_accepter_sptr accepter)
+ gruel::pmt_t user_data, mb_msg_accepter_sptr accepter)
: d_when(first_abs_time), d_delta(delta_time), d_is_periodic(true),
d_user_data(user_data), d_handle(make_handle()), d_accepter(accepter)
{
}
void
-mb_timer_queue::cancel(pmt_t handle)
+mb_timer_queue::cancel(gruel::pmt_t handle)
{
container_type::iterator it;
for (it = c.begin(); it != c.end();){
- if (pmt_equal((*it)->handle(), handle))
+ if (gruel::pmt_equal((*it)->handle(), handle))
it = c.erase(it);
else
++it;