35 #include "platform.hpp" 42 poller =
new (std::nothrow) poller_t (*ctx_);
72 return poller->get_load ();
83 while (rc == 0 || errno == EINTR) {
#define LIBZMQ_DELETE(p_object)
poller_t::handle_t mailbox_handle
void process_command(zmq::command_t &cmd_)
int recv(command_t *cmd_, int timeout_)
zmq::object_t * destination
void timer_event(int id_)
io_thread_t(zmq::ctx_t *ctx_, uint32_t tid_)
mailbox_t * get_mailbox()