active enum value | zmq::pipe_t | private |
array_item_t< 1 >::array_item_t() | zmq::array_item_t< 1 > | inline |
array_item_t< 2 >::array_item_t() | zmq::array_item_t< 2 > | inline |
array_item_t< 3 >::array_item_t() | zmq::array_item_t< 3 > | inline |
check_hwm() const | zmq::pipe_t | |
check_read() | zmq::pipe_t | |
check_write() | zmq::pipe_t | |
choose_io_thread(uint64_t affinity_) | zmq::object_t | protected |
compute_lwm(int hwm_) | zmq::pipe_t | privatestatic |
conflate | zmq::pipe_t | private |
connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_) | zmq::object_t | protected |
credential | zmq::pipe_t | private |
delay | zmq::pipe_t | private |
delimiter_received enum value | zmq::pipe_t | private |
destroy_socket(zmq::socket_base_t *socket_) | zmq::object_t | protected |
find_endpoint(const char *addr_) | zmq::object_t | protected |
flush() | zmq::pipe_t | |
array_item_t< 1 >::get_array_index() | zmq::array_item_t< 1 > | inline |
array_item_t< 2 >::get_array_index() | zmq::array_item_t< 2 > | inline |
array_item_t< 3 >::get_array_index() | zmq::array_item_t< 3 > | inline |
get_credential() const | zmq::pipe_t | |
get_ctx() | zmq::object_t | |
get_identity() | zmq::pipe_t | |
get_routing_id() | zmq::pipe_t | |
get_tid() | zmq::object_t | |
hiccup() | zmq::pipe_t | |
hwm | zmq::pipe_t | private |
identity | zmq::pipe_t | private |
in_active | zmq::pipe_t | private |
inhwmboost | zmq::pipe_t | private |
inpipe | zmq::pipe_t | private |
is_delimiter(const msg_t &msg_) | zmq::pipe_t | privatestatic |
log(const char *format_,...) | zmq::object_t | protected |
lwm | zmq::pipe_t | private |
msgs_read | zmq::pipe_t | private |
msgs_written | zmq::pipe_t | private |
object_t(zmq::ctx_t *ctx_, uint32_t tid_) | zmq::object_t | |
object_t(object_t *parent_) | zmq::object_t | |
operator=(const pipe_t &) | zmq::pipe_t | private |
out_active | zmq::pipe_t | private |
outhwmboost | zmq::pipe_t | private |
outpipe | zmq::pipe_t | private |
peer | zmq::pipe_t | private |
peers_msgs_read | zmq::pipe_t | private |
pend_connection(const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_) | zmq::object_t | protected |
pipe_t(object_t *parent_, upipe_t *inpipe_, upipe_t *outpipe_, int inhwm_, int outhwm_, bool conflate_) | zmq::pipe_t | private |
pipe_t(const pipe_t &) | zmq::pipe_t | private |
pipepair(zmq::object_t *parents_[2], zmq::pipe_t *pipes_[2], int hwms_[2], bool conflate_[2]) | zmq::pipe_t | friend |
process_activate_read() | zmq::pipe_t | privatevirtual |
process_activate_write(uint64_t msgs_read_) | zmq::pipe_t | privatevirtual |
process_attach(zmq::i_engine *engine_) | zmq::object_t | protectedvirtual |
process_bind(zmq::pipe_t *pipe_) | zmq::object_t | protectedvirtual |
process_command(zmq::command_t &cmd_) | zmq::object_t | |
process_delimiter() | zmq::pipe_t | private |
process_hiccup(void *pipe_) | zmq::pipe_t | privatevirtual |
process_own(zmq::own_t *object_) | zmq::object_t | protectedvirtual |
process_pipe_term() | zmq::pipe_t | privatevirtual |
process_pipe_term_ack() | zmq::pipe_t | privatevirtual |
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::object_t | protectedvirtual |
process_stop() | zmq::object_t | protectedvirtual |
process_term(int linger_) | zmq::object_t | protectedvirtual |
process_term_ack() | zmq::object_t | protectedvirtual |
process_term_req(zmq::own_t *object_) | zmq::object_t | protectedvirtual |
read(msg_t *msg_) | zmq::pipe_t | |
register_endpoint(const char *addr_, const zmq::endpoint_t &endpoint_) | zmq::object_t | protected |
rollback() | zmq::pipe_t | |
routing_id | zmq::pipe_t | private |
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_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_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_req(zmq::own_t *destination_, zmq::own_t *object_) | zmq::object_t | protected |
array_item_t< 1 >::set_array_index(int index_) | zmq::array_item_t< 1 > | inline |
array_item_t< 2 >::set_array_index(int index_) | zmq::array_item_t< 2 > | inline |
array_item_t< 3 >::set_array_index(int index_) | zmq::array_item_t< 3 > | inline |
set_event_sink(i_pipe_events *sink_) | zmq::pipe_t | |
set_hwms(int inhwm_, int outhwm_) | zmq::pipe_t | |
set_hwms_boost(int inhwmboost_, int outhwmboost_) | zmq::pipe_t | |
set_identity(const blob_t &identity_) | zmq::pipe_t | |
set_nodelay() | zmq::pipe_t | |
set_peer(pipe_t *pipe_) | zmq::pipe_t | private |
set_routing_id(uint32_t routing_id_) | zmq::pipe_t | |
set_tid(uint32_t id) | zmq::object_t | |
sink | zmq::pipe_t | private |
state | zmq::pipe_t | private |
term_ack_sent enum value | zmq::pipe_t | private |
term_req_sent1 enum value | zmq::pipe_t | private |
term_req_sent2 enum value | zmq::pipe_t | private |
terminate(bool delay_) | zmq::pipe_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 |
upipe_t typedef | zmq::pipe_t | private |
waiting_for_delimiter enum value | zmq::pipe_t | private |
write(msg_t *msg_) | zmq::pipe_t | |
array_item_t< 1 >::~array_item_t() | zmq::array_item_t< 1 > | inlinevirtual |
array_item_t< 2 >::~array_item_t() | zmq::array_item_t< 2 > | inlinevirtual |
array_item_t< 3 >::~array_item_t() | zmq::array_item_t< 3 > | inlinevirtual |
~object_t() | zmq::object_t | virtual |
~pipe_t() | zmq::pipe_t | private |