63 timers.insert (timers_t::value_type (expiration, info));
69 for (timers_t::iterator it =
timers.begin (); it !=
timers.end (); ++it)
70 if (it->second.sink == sink_ && it->second.id == id_) {
89 timers_t::iterator it =
timers.begin ();
90 while (it !=
timers.end ()) {
96 if (it->first > current)
97 return it->first - current;
100 it->second.sink->timer_event (it->second.id);
103 timers_t::iterator o = it;
uint64_t execute_timers()
void adjust_load(int amount_)
void add_timer(int timeout_, zmq::i_poll_events *sink_, int id_)
integer_t add(integer_t increment_)
bool sub(integer_t decrement)
void cancel_timer(zmq::i_poll_events *sink_, int id_)