This is the complete list of members for zmq::router_t, including all inherited members.
_anonymous_pipes | zmq::router_t | private |
_array_index | zmq::array_item_t<> | private |
_clock | zmq::socket_base_t | private |
_connect_routing_id | zmq::routing_socket_base_t | private |
_ctx | zmq::object_t | private |
_ctx_terminated | zmq::socket_base_t | private |
_current_in | zmq::router_t | private |
_current_out | zmq::router_t | private |
_destroyed | zmq::socket_base_t | private |
_disconnected | zmq::socket_base_t | private |
_endpoints | zmq::socket_base_t | private |
_fq | zmq::router_t | private |
_handle | zmq::socket_base_t | private |
_handover | zmq::router_t | private |
_inprocs | zmq::socket_base_t | private |
_last_endpoint | zmq::socket_base_t | private |
_last_tsc | zmq::socket_base_t | private |
_mailbox | zmq::socket_base_t | private |
_mandatory | zmq::router_t | private |
_monitor_events | zmq::socket_base_t | private |
_monitor_socket | zmq::socket_base_t | private |
_monitor_sync | zmq::socket_base_t | private |
_more_in | zmq::router_t | private |
_more_out | zmq::router_t | private |
_next_integral_routing_id | zmq::router_t | private |
_out_pipes | zmq::routing_socket_base_t | private |
_owned | zmq::own_t | private |
_owner | zmq::own_t | private |
_pipes | zmq::socket_base_t | private |
_poller | zmq::socket_base_t | private |
_prefetched | zmq::router_t | private |
_prefetched_id | zmq::router_t | private |
_prefetched_msg | zmq::router_t | private |
_probe_router | zmq::router_t | private |
_processed_seqnum | zmq::own_t | private |
_raw_socket | zmq::router_t | private |
_rcvmore | zmq::socket_base_t | private |
_reaper_signaler | zmq::socket_base_t | private |
_routing_id_sent | zmq::router_t | private |
_sent_seqnum | zmq::own_t | private |
_sync | zmq::socket_base_t | protected |
_tag | zmq::socket_base_t | private |
_term_acks | zmq::own_t | private |
_terminate_current_in | zmq::router_t | private |
_terminating | zmq::own_t | private |
_thread_safe | zmq::socket_base_t | private |
_ticks | zmq::socket_base_t | private |
_tid | zmq::object_t | private |
add_endpoint(const endpoint_uri_pair_t &endpoint_pair_, own_t *endpoint_, pipe_t *pipe_) | zmq::socket_base_t | private |
add_out_pipe(blob_t routing_id_, pipe_t *pipe_) | zmq::routing_socket_base_t | protected |
add_signaler(signaler_t *s_) | zmq::socket_base_t | |
any_of_out_pipes(Func func_) | zmq::routing_socket_base_t | inlineprotected |
array_item_t() | zmq::array_item_t<> | inline |
attach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_=false, bool locally_initiated_=false) | zmq::socket_base_t | private |
bind(const char *endpoint_uri_) | zmq::socket_base_t | |
check_destroy() | zmq::socket_base_t | private |
check_protocol(const std::string &protocol_) const | zmq::socket_base_t | private |
check_tag() const | zmq::socket_base_t | |
check_term_acks() | zmq::own_t | private |
choose_io_thread(uint64_t affinity_) const | zmq::object_t | protected |
close() | zmq::socket_base_t | |
connect(const char *endpoint_uri_) | zmq::socket_base_t | |
connect_internal(const char *endpoint_uri_) | zmq::socket_base_t | protected |
connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_) | zmq::object_t | protected |
connect_routing_id_is_set() const | zmq::routing_socket_base_t | protected |
create(int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_) | zmq::socket_base_t | static |
destroy_socket(zmq::socket_base_t *socket_) | zmq::object_t | protected |
endpoint_pipe_t typedef | zmq::socket_base_t | private |
endpoints_t typedef | zmq::socket_base_t | private |
erase_out_pipe(const pipe_t *pipe_) | zmq::routing_socket_base_t | protected |
event(const endpoint_uri_pair_t &endpoint_uri_pair_, uint64_t values_[], uint64_t values_count_, uint64_t type_) | zmq::socket_base_t | private |
event_accept_failed(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_accepted(const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_) | zmq::socket_base_t | |
event_bind_failed(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_close_failed(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_closed(const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_) | zmq::socket_base_t | |
event_connect_delayed(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_connect_retried(const endpoint_uri_pair_t &endpoint_uri_pair_, int interval_) | zmq::socket_base_t | |
event_connected(const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_) | zmq::socket_base_t | |
event_disconnected(const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_) | zmq::socket_base_t | |
event_handshake_failed_auth(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_handshake_failed_no_detail(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_handshake_failed_protocol(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_handshake_succeeded(const endpoint_uri_pair_t &endpoint_uri_pair_, int err_) | zmq::socket_base_t | |
event_listening(const endpoint_uri_pair_t &endpoint_uri_pair_, zmq::fd_t fd_) | zmq::socket_base_t | |
extract_connect_routing_id() | zmq::routing_socket_base_t | protected |
extract_flags(const msg_t *msg_) | zmq::socket_base_t | private |
find_endpoint(const char *addr_) const | zmq::object_t | protected |
get_array_index() const | zmq::array_item_t<> | inline |
get_ctx() const | zmq::object_t | |
get_mailbox() const | zmq::socket_base_t | |
get_peer_state(const void *routing_id_, size_t routing_id_size_) const ZMQ_FINAL | zmq::router_t | virtual |
get_tid() const | zmq::object_t | |
getsockopt(int option_, void *optval_, size_t *optvallen_) | zmq::socket_base_t | |
has_in() | zmq::socket_base_t | |
has_out() | zmq::socket_base_t | |
has_out_pipe(const blob_t &routing_id_) const | zmq::routing_socket_base_t | protected |
hiccuped(pipe_t *pipe_) ZMQ_FINAL | zmq::socket_base_t | |
zmq::i_pipe_events::hiccuped(zmq::pipe_t *pipe_)=0 | zmq::i_pipe_events | pure virtual |
identify_peer(pipe_t *pipe_, bool locally_initiated_) | zmq::router_t | private |
in_event() ZMQ_FINAL | zmq::socket_base_t | virtual |
inc_seqnum() | zmq::own_t | |
is_disconnected() const | zmq::socket_base_t | |
is_terminating() const | zmq::own_t | protected |
is_thread_safe() const | zmq::socket_base_t | |
join(const char *group_) | zmq::socket_base_t | |
launch_child(own_t *object_) | zmq::own_t | protected |
leave(const char *group_) | zmq::socket_base_t | |
lock() | zmq::socket_base_t | |
log(const char *format_,...) | zmq::object_t | protected |
lookup_out_pipe(const blob_t &routing_id_) | zmq::routing_socket_base_t | protected |
lookup_out_pipe(const blob_t &routing_id_) const | zmq::routing_socket_base_t | protected |
monitor(const char *endpoint_, uint64_t events_, int event_version_, int type_) | zmq::socket_base_t | |
monitor_event(uint64_t event_, const uint64_t values_[], uint64_t values_count_, const endpoint_uri_pair_t &endpoint_uri_pair_) const | zmq::socket_base_t | private |
object_t(zmq::ctx_t *ctx_, uint32_t tid_) | zmq::object_t | |
object_t(object_t *parent_) | zmq::object_t | |
options | zmq::own_t | protected |
out_event() ZMQ_FINAL | zmq::socket_base_t | virtual |
out_pipes_t typedef | zmq::routing_socket_base_t | private |
own_t(zmq::ctx_t *parent_, uint32_t tid_) | zmq::own_t | |
own_t(zmq::io_thread_t *io_thread_, const options_t &options_) | zmq::own_t | |
owned_t typedef | zmq::own_t | private |
parse_uri(const char *uri_, std::string &protocol_, std::string &path_) | zmq::socket_base_t | privatestatic |
pend_connection(const std::string &addr_, const endpoint_t &endpoint_, pipe_t **pipes_) | zmq::object_t | protected |
pipe_terminated(pipe_t *pipe_) ZMQ_FINAL | zmq::socket_base_t | |
zmq::i_pipe_events::pipe_terminated(zmq::pipe_t *pipe_)=0 | zmq::i_pipe_events | pure virtual |
pipes_t typedef | zmq::socket_base_t | private |
process_activate_read() | zmq::object_t | protectedvirtual |
process_activate_write(uint64_t msgs_read_) | zmq::object_t | protectedvirtual |
process_attach(zmq::i_engine *engine_) | zmq::object_t | protectedvirtual |
process_bind(zmq::pipe_t *pipe_) ZMQ_FINAL | zmq::socket_base_t | privatevirtual |
process_command(const zmq::command_t &cmd_) | zmq::object_t | |
process_commands(int timeout_, bool throttle_) | zmq::socket_base_t | private |
process_conn_failed() | zmq::object_t | protectedvirtual |
process_destroy() ZMQ_FINAL | zmq::socket_base_t | protectedvirtual |
process_hiccup(void *pipe_) | zmq::object_t | protectedvirtual |
process_own(own_t *object_) ZMQ_OVERRIDE | zmq::own_t | privatevirtual |
process_pipe_hwm(int inhwm_, int outhwm_) | zmq::object_t | protectedvirtual |
process_pipe_peer_stats(uint64_t queue_count_, zmq::own_t *socket_base_, endpoint_uri_pair_t *endpoint_pair_) | zmq::object_t | protectedvirtual |
process_pipe_stats_publish(uint64_t outbound_queue_count_, uint64_t inbound_queue_count_, endpoint_uri_pair_t *endpoint_pair_) ZMQ_FINAL | zmq::socket_base_t | privatevirtual |
process_pipe_term() | zmq::object_t | protectedvirtual |
process_pipe_term_ack() | zmq::object_t | protectedvirtual |
process_plug() | zmq::object_t | protectedvirtual |
process_reap(zmq::socket_base_t *socket_) | zmq::object_t | protectedvirtual |
process_reaped() | zmq::object_t | protectedvirtual |
process_seqnum() ZMQ_OVERRIDE | zmq::own_t | privatevirtual |
process_stop() ZMQ_FINAL | zmq::socket_base_t | privatevirtual |
process_term(int linger_) ZMQ_FINAL | zmq::socket_base_t | privatevirtual |
process_term_ack() ZMQ_OVERRIDE | zmq::own_t | privatevirtual |
process_term_endpoint(std::string *endpoint_) ZMQ_FINAL | zmq::socket_base_t | privatevirtual |
process_term_req(own_t *object_) ZMQ_OVERRIDE | zmq::own_t | privatevirtual |
query_pipes_stats() | zmq::socket_base_t | |
read_activated(pipe_t *pipe_) ZMQ_FINAL | zmq::socket_base_t | |
zmq::i_pipe_events::read_activated(zmq::pipe_t *pipe_)=0 | zmq::i_pipe_events | pure virtual |
recv(zmq::msg_t *msg_, int flags_) | zmq::socket_base_t | |
register_endpoint(const char *addr_, const zmq::endpoint_t &endpoint_) | zmq::object_t | protected |
register_term_acks(int count_) | zmq::own_t | |
remove_signaler(signaler_t *s_) | zmq::socket_base_t | |
resolve_tcp_addr(std::string endpoint_uri_, const char *tcp_address_) | zmq::socket_base_t | private |
rollback() | zmq::router_t | protected |
router_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_) | zmq::router_t | |
routing_socket_base_t(class ctx_t *parent_, uint32_t tid_, int sid_) | zmq::routing_socket_base_t | protected |
send(zmq::msg_t *msg_, int flags_) | zmq::socket_base_t | |
send_activate_read(zmq::pipe_t *destination_) | zmq::object_t | protected |
send_activate_write(zmq::pipe_t *destination_, uint64_t msgs_read_) | zmq::object_t | protected |
send_attach(zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true) | zmq::object_t | protected |
send_bind(zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true) | zmq::object_t | |
send_command(const command_t &cmd_) | zmq::object_t | private |
send_conn_failed(zmq::session_base_t *destination_) | zmq::object_t | protected |
send_done() | zmq::object_t | protected |
send_hiccup(zmq::pipe_t *destination_, void *pipe_) | zmq::object_t | protected |
send_inproc_connected(zmq::socket_base_t *socket_) | zmq::object_t | |
send_own(zmq::own_t *destination_, zmq::own_t *object_) | zmq::object_t | protected |
send_pipe_hwm(zmq::pipe_t *destination_, int inhwm_, int outhwm_) | zmq::object_t | protected |
send_pipe_peer_stats(zmq::pipe_t *destination_, uint64_t queue_count_, zmq::own_t *socket_base, endpoint_uri_pair_t *endpoint_pair_) | zmq::object_t | protected |
send_pipe_stats_publish(zmq::own_t *destination_, uint64_t outbound_queue_count_, uint64_t inbound_queue_count_, endpoint_uri_pair_t *endpoint_pair_) | zmq::object_t | protected |
send_pipe_term(zmq::pipe_t *destination_) | zmq::object_t | protected |
send_pipe_term_ack(zmq::pipe_t *destination_) | zmq::object_t | protected |
send_plug(zmq::own_t *destination_, bool inc_seqnum_=true) | zmq::object_t | protected |
send_reap(zmq::socket_base_t *socket_) | zmq::object_t | protected |
send_reaped() | zmq::object_t | protected |
send_stop() | zmq::object_t | protected |
send_term(zmq::own_t *destination_, int linger_) | zmq::object_t | protected |
send_term_ack(zmq::own_t *destination_) | zmq::object_t | protected |
send_term_endpoint(own_t *destination_, std::string *endpoint_) | zmq::object_t | protected |
send_term_req(zmq::own_t *destination_, zmq::own_t *object_) | zmq::object_t | protected |
set_array_index(int index_) | zmq::array_item_t<> | inline |
set_owner(own_t *owner_) | zmq::own_t | private |
set_tid(uint32_t id_) | zmq::object_t | |
setsockopt(int option_, const void *optval_, size_t optvallen_) | zmq::socket_base_t | |
socket_base_t(zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false) | zmq::socket_base_t | protected |
start_reaping(poller_t *poller_) | zmq::socket_base_t | |
stop() | zmq::socket_base_t | |
stop_monitor(bool send_monitor_stopped_event_=true) | zmq::socket_base_t | private |
term_child(own_t *object_) | zmq::own_t | protected |
term_endpoint(const char *endpoint_uri_) | zmq::socket_base_t | |
terminate() | zmq::own_t | protected |
timer_event(int id_) ZMQ_FINAL | zmq::socket_base_t | virtual |
try_erase_out_pipe(const blob_t &routing_id_) | zmq::routing_socket_base_t | protected |
unlock() | zmq::socket_base_t | |
unregister_endpoint(const std::string &addr_, socket_base_t *socket_) | zmq::object_t | protected |
unregister_endpoints(zmq::socket_base_t *socket_) | zmq::object_t | protected |
unregister_term_ack() | zmq::own_t | |
update_pipe_options(int option_) | zmq::socket_base_t | private |
write_activated(pipe_t *pipe_) ZMQ_FINAL | zmq::socket_base_t | |
zmq::i_pipe_events::write_activated(zmq::pipe_t *pipe_)=0 | zmq::i_pipe_events | pure virtual |
xattach_pipe(zmq::pipe_t *pipe_, bool subscribe_to_all_, bool locally_initiated_) ZMQ_FINAL | zmq::router_t | virtual |
xgetsockopt(int option_, void *optval_, size_t *optvallen_) | zmq::socket_base_t | protectedvirtual |
xhas_in() ZMQ_OVERRIDE | zmq::router_t | virtual |
xhas_out() ZMQ_OVERRIDE | zmq::router_t | virtual |
xhiccuped(pipe_t *pipe_) | zmq::socket_base_t | protectedvirtual |
xjoin(const char *group_) | zmq::socket_base_t | protectedvirtual |
xleave(const char *group_) | zmq::socket_base_t | protectedvirtual |
xpipe_terminated(zmq::pipe_t *pipe_) ZMQ_FINAL | zmq::router_t | |
zmq::routing_socket_base_t::xpipe_terminated(pipe_t *pipe_)=0 | zmq::socket_base_t | protectedpure virtual |
xread_activated(zmq::pipe_t *pipe_) ZMQ_FINAL | zmq::router_t | |
zmq::routing_socket_base_t::xread_activated(pipe_t *pipe_) | zmq::socket_base_t | protectedvirtual |
xrecv(zmq::msg_t *msg_) ZMQ_OVERRIDE | zmq::router_t | virtual |
xsend(zmq::msg_t *msg_) ZMQ_OVERRIDE | zmq::router_t | virtual |
xsetsockopt(int option_, const void *optval_, size_t optvallen_) ZMQ_FINAL | zmq::router_t | virtual |
xwrite_activated(pipe_t *pipe_) ZMQ_FINAL | zmq::routing_socket_base_t | protectedvirtual |
~array_item_t() ZMQ_DEFAULT | zmq::array_item_t<> | virtual |
~i_pipe_events() ZMQ_DEFAULT | zmq::i_pipe_events | virtual |
~i_poll_events() ZMQ_DEFAULT | zmq::i_poll_events | virtual |
~object_t() | zmq::object_t | virtual |
~own_t() ZMQ_OVERRIDE | zmq::own_t | protected |
~router_t() ZMQ_OVERRIDE | zmq::router_t | |
~routing_socket_base_t() ZMQ_OVERRIDE | zmq::routing_socket_base_t | protected |
~socket_base_t() ZMQ_OVERRIDE | zmq::socket_base_t | protected |