42 poller =
new (std::nothrow) poller_t (*ctx_);
90 if (rc != 0 && errno == EINTR)
92 if (rc != 0 && errno == EAGAIN)
void process_reap(zmq::socket_base_t *socket_)
#define LIBZMQ_DELETE(p_object)
void process_command(zmq::command_t &cmd_)
void start_reaping(poller_t *poller_)
int recv(command_t *cmd_, int timeout_)
mailbox_t * get_mailbox()
reaper_t(zmq::ctx_t *ctx_, uint32_t tid_)
zmq::object_t * destination
poller_t::handle_t mailbox_handle
void timer_event(int id_)