zmq::pipe_t Member List

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

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_read()	zmq::pipe_t
check_write(msg_t *msg_)	zmq::pipe_t
choose_io_thread(uint64_t affinity_)	zmq::object_t	[protected]
compute_lwm(int hwm_)	zmq::pipe_t	[private, static]
delay	zmq::pipe_t	[private]
delimit()	zmq::pipe_t	[private]
delimited enum value	zmq::pipe_t	[private]
destroy_socket(class socket_base_t *socket_)	zmq::object_t	[protected]
double_terminated enum value	zmq::pipe_t	[private]
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_ctx()	zmq::object_t
get_identity()	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]
inpipe	zmq::pipe_t	[private]
is_delimiter(msg_t &msg_)	zmq::pipe_t	[private, static]
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(class 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]
outpipe	zmq::pipe_t	[private]
peer	zmq::pipe_t	[private]
peers_msgs_read	zmq::pipe_t	[private]
pending enum value	zmq::pipe_t	[private]
pipe_t(object_t *parent_, upipe_t *inpipe_, upipe_t *outpipe_, int inhwm_, int outhwm_, bool delay_)	zmq::pipe_t	[private]
pipe_t(const pipe_t &)	zmq::pipe_t	[private]
pipepair(class object_t *parents_[2], class pipe_t *pipes_[2], int hwms_[2], bool delays_[2])	zmq::pipe_t	[friend]
process_activate_read()	zmq::pipe_t	[private, virtual]
process_activate_write(uint64_t msgs_read_)	zmq::pipe_t	[private, virtual]
process_attach(struct i_engine *engine_)	zmq::object_t	[protected, virtual]
process_bind(class pipe_t *pipe_)	zmq::object_t	[protected, virtual]
process_command(struct command_t &cmd_)	zmq::object_t
process_hiccup(void *pipe_)	zmq::pipe_t	[private, virtual]
process_own(class own_t *object_)	zmq::object_t	[protected, virtual]
process_pipe_term()	zmq::pipe_t	[private, virtual]
process_pipe_term_ack()	zmq::pipe_t	[private, virtual]
process_plug()	zmq::object_t	[protected, virtual]
process_reap(class socket_base_t *socket_)	zmq::object_t	[protected, virtual]
process_reaped()	zmq::object_t	[protected, virtual]
process_seqnum()	zmq::object_t	[protected, virtual]
process_stop()	zmq::object_t	[protected, virtual]
process_term(int linger_)	zmq::object_t	[protected, virtual]
process_term_ack()	zmq::object_t	[protected, virtual]
process_term_req(class own_t *object_)	zmq::object_t	[protected, virtual]
read(msg_t *msg_)	zmq::pipe_t
register_endpoint(const char *addr_, struct endpoint_t &endpoint_)	zmq::object_t	[protected]
rollback()	zmq::pipe_t
send_activate_read(class pipe_t *destination_)	zmq::object_t	[protected]
send_activate_write(class pipe_t *destination_, uint64_t msgs_read_)	zmq::object_t	[protected]
send_attach(class session_base_t *destination_, struct i_engine *engine_, bool inc_seqnum_=true)	zmq::object_t	[protected]
send_bind(class own_t *destination_, class pipe_t *pipe_, bool inc_seqnum_=true)	zmq::object_t	[protected]
send_done()	zmq::object_t	[protected]
send_hiccup(class pipe_t *destination_, void *pipe_)	zmq::object_t	[protected]
send_own(class own_t *destination_, class own_t *object_)	zmq::object_t	[protected]
send_pipe_term(class pipe_t *destination_)	zmq::object_t	[protected]
send_pipe_term_ack(class pipe_t *destination_)	zmq::object_t	[protected]
send_plug(class own_t *destination_, bool inc_seqnum_=true)	zmq::object_t	[protected]
send_reap(class socket_base_t *socket_)	zmq::object_t	[protected]
send_reaped()	zmq::object_t	[protected]
send_stop()	zmq::object_t	[protected]
send_term(class own_t *destination_, int linger_)	zmq::object_t	[protected]
send_term_ack(class own_t *destination_)	zmq::object_t	[protected]
send_term_req(class own_t *destination_, class 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_identity(const blob_t &identity_)	zmq::pipe_t
set_peer(pipe_t *pipe_)	zmq::pipe_t	[private]
sink	zmq::pipe_t	[private]
state	zmq::pipe_t	[private]
terminate(bool delay_)	zmq::pipe_t
terminated enum value	zmq::pipe_t	[private]
terminating enum value	zmq::pipe_t	[private]
unregister_endpoints(class socket_base_t *socket_)	zmq::object_t	[protected]
upipe_t typedef	zmq::pipe_t	[private]
write(msg_t *msg_)	zmq::pipe_t
array_item_t< 1 >::~array_item_t()	zmq::array_item_t< 1 >	[inline, virtual]
array_item_t< 2 >::~array_item_t()	zmq::array_item_t< 2 >	[inline, virtual]
array_item_t< 3 >::~array_item_t()	zmq::array_item_t< 3 >	[inline, virtual]
~object_t()	zmq::object_t	[virtual]
~pipe_t()	zmq::pipe_t	[private]