![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <poller_base.hpp>
Classes | |
struct | timer_info_t |
Public Member Functions | |
poller_base_t () | |
virtual | ~poller_base_t () |
void | add_timer (int timeout_, zmq::i_poll_events *sink_, int id_) |
void | cancel_timer (zmq::i_poll_events *sink_, int id_) |
int | get_load () |
Protected Member Functions | |
void | adjust_load (int amount_) |
uint64_t | execute_timers () |
Private Types | |
typedef std::multimap< uint64_t, timer_info_t > | timers_t |
Private Member Functions | |
poller_base_t (const poller_base_t &) | |
const poller_base_t & | operator= (const poller_base_t &) |
Private Attributes | |
clock_t | clock |
atomic_counter_t | load |
timers_t | timers |
Definition at line 43 of file poller_base.hpp.
|
private |
Definition at line 82 of file poller_base.hpp.
zmq::poller_base_t::poller_base_t | ( | ) |
Definition at line 35 of file poller_base.cpp.
|
virtual |
Definition at line 39 of file poller_base.cpp.
References get_load(), and zmq_assert.
|
private |
void zmq::poller_base_t::add_timer | ( | int | timeout_, |
zmq::i_poll_events * | sink_, | ||
int | id_ | ||
) |
Definition at line 59 of file poller_base.cpp.
References clock, zmq::clock_t::now_ms(), and timers.
|
protected |
Definition at line 50 of file poller_base.cpp.
References zmq::atomic_counter_t::add(), load, and zmq::atomic_counter_t::sub().
void zmq::poller_base_t::cancel_timer | ( | zmq::i_poll_events * | sink_, |
int | id_ | ||
) |
Definition at line 66 of file poller_base.cpp.
References timers, and zmq_assert.
|
protected |
Definition at line 79 of file poller_base.cpp.
References clock, zmq::clock_t::now_ms(), and timers.
int zmq::poller_base_t::get_load | ( | ) |
Definition at line 45 of file poller_base.cpp.
References zmq::atomic_counter_t::get(), and load.
Referenced by ~poller_base_t().
|
private |
|
private |
Definition at line 74 of file poller_base.hpp.
Referenced by add_timer(), and execute_timers().
|
private |
Definition at line 87 of file poller_base.hpp.
Referenced by adjust_load(), and get_load().
|
private |
Definition at line 83 of file poller_base.hpp.
Referenced by add_timer(), cancel_timer(), and execute_timers().