226 i_engine *engine_,
bool inc_seqnum_)
endpoint_t find_endpoint(const char *addr_)
int unregister_endpoint(const std::string &addr_, socket_base_t *socket_)
void pend_connection(const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_)
void destroy_socket(zmq::socket_base_t *socket_)
struct zmq::command_t::args_t::@12 term
void process_command(zmq::command_t &cmd_)
void send_attach(zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true)
struct zmq::command_t::args_t::@14 reap
struct zmq::command_t::args_t::@3 own
virtual void process_activate_write(uint64_t msgs_read_)
zmq::io_thread_t * choose_io_thread(uint64_t affinity_)
void send_command(command_t &cmd_)
virtual void process_term_ack()
void send_own(zmq::own_t *destination_, zmq::own_t *object_)
void pend_connection(const std::string &addr_, const endpoint_t &endpoint_, pipe_t **pipes_)
virtual void process_reap(zmq::socket_base_t *socket_)
virtual void process_activate_read()
void set_tid(uint32_t id)
virtual void process_reaped()
virtual void process_term_req(zmq::own_t *object_)
int unregister_endpoint(const std::string &addr_, socket_base_t *socket_)
virtual void process_bind(zmq::pipe_t *pipe_)
virtual void process_own(zmq::own_t *object_)
int register_endpoint(const char *addr_, const zmq::endpoint_t &endpoint_)
void destroy_socket(zmq::socket_base_t *socket_)
void send_pipe_term_ack(zmq::pipe_t *destination_)
void send_plug(zmq::own_t *destination_, bool inc_seqnum_=true)
union zmq::command_t::args_t args
virtual void process_pipe_term_ack()
virtual void process_pipe_term()
void unregister_endpoints(zmq::socket_base_t *socket_)
void connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_)
zmq::socket_base_t * socket
struct zmq::command_t::args_t::@5 bind
struct zmq::command_t::args_t::@7 activate_write
void send_term_req(zmq::own_t *destination_, zmq::own_t *object_)
struct zmq::command_t::args_t::@8 hiccup
void send_term_ack(zmq::own_t *destination_)
void send_bind(zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true)
void send_term(zmq::own_t *destination_, int linger_)
void send_activate_write(zmq::pipe_t *destination_, uint64_t msgs_read_)
zmq::object_t * destination
virtual void process_hiccup(void *pipe_)
virtual void process_seqnum()
struct zmq::command_t::args_t::@11 term_req
void send_inproc_connected(zmq::socket_base_t *socket_)
void send_command(uint32_t tid_, const command_t &command_)
virtual void process_stop()
zmq::io_thread_t * choose_io_thread(uint64_t affinity_)
enum zmq::command_t::type_t type
virtual void process_term(int linger_)
void send_activate_read(zmq::pipe_t *destination_)
void connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_)
virtual void process_plug()
void send_reap(zmq::socket_base_t *socket_)
int register_endpoint(const char *addr_, const endpoint_t &endpoint_)
void send_pipe_term(zmq::pipe_t *destination_)
zmq::object_t * get_reaper()
struct zmq::command_t::args_t::@4 attach
void send_hiccup(zmq::pipe_t *destination_, void *pipe_)
zmq::endpoint_t find_endpoint(const char *addr_)
object_t(zmq::ctx_t *ctx_, uint32_t tid_)
void unregister_endpoints(zmq::socket_base_t *socket_)
virtual void process_attach(zmq::i_engine *engine_)