libzmq  master
ZeroMQ C++ Core Engine (LIBZMQ)
zmq::pipe_t Member List

This is the complete list of members for zmq::pipe_t, including all inherited members.

active enum valuezmq::pipe_tprivate
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_tprotected
compute_lwm(int hwm_)zmq::pipe_tprivatestatic
conflatezmq::pipe_tprivate
connect_pending(const char *addr_, zmq::socket_base_t *bind_socket_)zmq::object_tprotected
credentialzmq::pipe_tprivate
delayzmq::pipe_tprivate
delimiter_received enum valuezmq::pipe_tprivate
destroy_socket(zmq::socket_base_t *socket_)zmq::object_tprotected
find_endpoint(const char *addr_)zmq::object_tprotected
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
hwmzmq::pipe_tprivate
identityzmq::pipe_tprivate
in_activezmq::pipe_tprivate
inhwmboostzmq::pipe_tprivate
inpipezmq::pipe_tprivate
is_delimiter(const msg_t &msg_)zmq::pipe_tprivatestatic
log(const char *format_,...)zmq::object_tprotected
lwmzmq::pipe_tprivate
msgs_readzmq::pipe_tprivate
msgs_writtenzmq::pipe_tprivate
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_tprivate
out_activezmq::pipe_tprivate
outhwmboostzmq::pipe_tprivate
outpipezmq::pipe_tprivate
peerzmq::pipe_tprivate
peers_msgs_readzmq::pipe_tprivate
pend_connection(const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_)zmq::object_tprotected
pipe_t(object_t *parent_, upipe_t *inpipe_, upipe_t *outpipe_, int inhwm_, int outhwm_, bool conflate_)zmq::pipe_tprivate
pipe_t(const pipe_t &)zmq::pipe_tprivate
pipepair(zmq::object_t *parents_[2], zmq::pipe_t *pipes_[2], int hwms_[2], bool conflate_[2])zmq::pipe_tfriend
process_activate_read()zmq::pipe_tprivatevirtual
process_activate_write(uint64_t msgs_read_)zmq::pipe_tprivatevirtual
process_attach(zmq::i_engine *engine_)zmq::object_tprotectedvirtual
process_bind(zmq::pipe_t *pipe_)zmq::object_tprotectedvirtual
process_command(zmq::command_t &cmd_)zmq::object_t
process_delimiter()zmq::pipe_tprivate
process_hiccup(void *pipe_)zmq::pipe_tprivatevirtual
process_own(zmq::own_t *object_)zmq::object_tprotectedvirtual
process_pipe_term()zmq::pipe_tprivatevirtual
process_pipe_term_ack()zmq::pipe_tprivatevirtual
process_plug()zmq::object_tprotectedvirtual
process_reap(zmq::socket_base_t *socket_)zmq::object_tprotectedvirtual
process_reaped()zmq::object_tprotectedvirtual
process_seqnum()zmq::object_tprotectedvirtual
process_stop()zmq::object_tprotectedvirtual
process_term(int linger_)zmq::object_tprotectedvirtual
process_term_ack()zmq::object_tprotectedvirtual
process_term_req(zmq::own_t *object_)zmq::object_tprotectedvirtual
read(msg_t *msg_)zmq::pipe_t
register_endpoint(const char *addr_, const zmq::endpoint_t &endpoint_)zmq::object_tprotected
rollback()zmq::pipe_t
routing_idzmq::pipe_tprivate
send_activate_read(zmq::pipe_t *destination_)zmq::object_tprotected
send_activate_write(zmq::pipe_t *destination_, uint64_t msgs_read_)zmq::object_tprotected
send_attach(zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true)zmq::object_tprotected
send_bind(zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true)zmq::object_t
send_done()zmq::object_tprotected
send_hiccup(zmq::pipe_t *destination_, void *pipe_)zmq::object_tprotected
send_inproc_connected(zmq::socket_base_t *socket_)zmq::object_t
send_own(zmq::own_t *destination_, zmq::own_t *object_)zmq::object_tprotected
send_pipe_term(zmq::pipe_t *destination_)zmq::object_tprotected
send_pipe_term_ack(zmq::pipe_t *destination_)zmq::object_tprotected
send_plug(zmq::own_t *destination_, bool inc_seqnum_=true)zmq::object_tprotected
send_reap(zmq::socket_base_t *socket_)zmq::object_tprotected
send_reaped()zmq::object_tprotected
send_stop()zmq::object_tprotected
send_term(zmq::own_t *destination_, int linger_)zmq::object_tprotected
send_term_ack(zmq::own_t *destination_)zmq::object_tprotected
send_term_req(zmq::own_t *destination_, zmq::own_t *object_)zmq::object_tprotected
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_tprivate
set_routing_id(uint32_t routing_id_)zmq::pipe_t
set_tid(uint32_t id)zmq::object_t
sinkzmq::pipe_tprivate
statezmq::pipe_tprivate
term_ack_sent enum valuezmq::pipe_tprivate
term_req_sent1 enum valuezmq::pipe_tprivate
term_req_sent2 enum valuezmq::pipe_tprivate
terminate(bool delay_)zmq::pipe_t
unregister_endpoint(const std::string &addr_, socket_base_t *socket_)zmq::object_tprotected
unregister_endpoints(zmq::socket_base_t *socket_)zmq::object_tprotected
upipe_t typedefzmq::pipe_tprivate
waiting_for_delimiter enum valuezmq::pipe_tprivate
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_tvirtual
~pipe_t()zmq::pipe_tprivate