2
2
3
3
#include " precompiled.hpp"
4
4
#include " timers.hpp"
5
+ #include " blob.hpp"
5
6
#include " err.hpp"
6
7
7
8
#include < algorithm>
@@ -30,7 +31,7 @@ int zmq::timers_t::add (size_t interval_, timers_timer_fn handler_, void *arg_)
30
31
31
32
uint64_t when = _clock.now_ms () + interval_;
32
33
timer_t timer = {++_next_timer_id, interval_, handler_, arg_};
33
- _timers.insert ( timersmap_t::value_type ( when, timer) );
34
+ _timers.ZMQ_MAP_INSERT_OR_EMPLACE ( when, timer);
34
35
35
36
return timer.timer_id ;
36
37
}
@@ -79,7 +80,7 @@ int zmq::timers_t::set_interval (int timer_id_, size_t interval_)
79
80
timer.interval = interval_;
80
81
uint64_t when = _clock.now_ms () + interval_;
81
82
_timers.erase (it);
82
- _timers.insert ( timersmap_t::value_type ( when, timer) );
83
+ _timers.ZMQ_MAP_INSERT_OR_EMPLACE ( when, timer);
83
84
84
85
return 0 ;
85
86
}
@@ -97,7 +98,7 @@ int zmq::timers_t::reset (int timer_id_)
97
98
timer_t timer = it->second ;
98
99
uint64_t when = _clock.now_ms () + timer.interval ;
99
100
_timers.erase (it);
100
- _timers.insert ( timersmap_t::value_type ( when, timer) );
101
+ _timers.ZMQ_MAP_INSERT_OR_EMPLACE ( when, timer);
101
102
102
103
return 0 ;
103
104
}
@@ -147,8 +148,7 @@ int zmq::timers_t::execute ()
147
148
148
149
timer.handler (timer.timer_id , timer.arg );
149
150
150
- _timers.insert (
151
- timersmap_t::value_type (now + timer.interval , timer));
151
+ _timers.ZMQ_MAP_INSERT_OR_EMPLACE (now + timer.interval , timer);
152
152
}
153
153
}
154
154
_timers.erase (begin, it);
0 commit comments