zmq::xsub_t Member List

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

array_item_t()	zmq::array_item_t<>	[inline]
bind(const char *addr_)	zmq::socket_base_t
check_tag()	zmq::socket_base_t
choose_io_thread(uint64_t affinity_)	zmq::object_t	[protected]
close()	zmq::socket_base_t
connect(const char *addr_)	zmq::socket_base_t
create(int type_, class ctx_t *parent_, uint32_t tid_)	zmq::socket_base_t	[static]
destroy_socket(class socket_base_t *socket_)	zmq::object_t	[protected]
dist	zmq::xsub_t	[private]
find_endpoint(const char *addr_)	zmq::object_t	[protected]
fq	zmq::xsub_t	[private]
get_array_index()	zmq::array_item_t<>	[inline]
get_ctx()	zmq::object_t
get_mailbox()	zmq::socket_base_t
get_tid()	zmq::object_t
getsockopt(int option_, void *optval_, size_t *optvallen_)	zmq::socket_base_t
has_in()	zmq::socket_base_t
has_message	zmq::xsub_t	[private]
has_out()	zmq::socket_base_t
hiccuped(pipe_t *pipe_)	zmq::socket_base_t	[virtual]
in_event()	zmq::socket_base_t	[virtual]
inc_seqnum()	zmq::own_t
is_terminating()	zmq::own_t	[protected]
launch_child(own_t *object_)	zmq::own_t	[protected]
launch_sibling(own_t *object_)	zmq::own_t	[protected]
log(const char *format_,...)	zmq::object_t	[protected]
match(class msg_t *msg_)	zmq::xsub_t	[private]
message	zmq::xsub_t	[private]
more	zmq::xsub_t	[private]
object_t(class ctx_t *ctx_, uint32_t tid_)	zmq::object_t
object_t(object_t *parent_)	zmq::object_t
operator=(const xsub_t &)	zmq::xsub_t	[private]
options	zmq::own_t	[protected]
out_event()	zmq::socket_base_t	[virtual]
own_t(class ctx_t *parent_, uint32_t tid_)	zmq::own_t
own_t(class io_thread_t *io_thread_, const options_t &options_)	zmq::own_t
process_activate_read()	zmq::object_t	[protected, virtual]
process_activate_write(uint64_t msgs_read_)	zmq::object_t	[protected, virtual]
process_attach(struct i_engine *engine_)	zmq::object_t	[protected, virtual]
process_command(struct command_t &cmd_)	zmq::object_t
process_destroy()	zmq::socket_base_t	[protected, virtual]
process_hiccup(void *pipe_)	zmq::object_t	[protected, virtual]
process_pipe_term()	zmq::object_t	[protected, virtual]
process_pipe_term_ack()	zmq::object_t	[protected, 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]
read_activated(pipe_t *pipe_)	zmq::socket_base_t	[virtual]
recv(class msg_t *msg_, int flags_)	zmq::socket_base_t
register_endpoint(const char *addr_, struct endpoint_t &endpoint_)	zmq::object_t	[protected]
register_term_acks(int count_)	zmq::own_t
send(class msg_t *msg_, int flags_)	zmq::socket_base_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_subscription(unsigned char *data_, size_t size_, void *arg_)	zmq::xsub_t	[private, static]
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]
set_array_index(int index_)	zmq::array_item_t<>	[inline]
setsockopt(int option_, const void *optval_, size_t optvallen_)	zmq::socket_base_t
socket_base_t(class ctx_t *parent_, uint32_t tid_)	zmq::socket_base_t	[protected]
start_reaping(poller_t *poller_)	zmq::socket_base_t
stop()	zmq::socket_base_t
subscriptions	zmq::xsub_t	[private]
terminate()	zmq::own_t	[protected]
terminated(pipe_t *pipe_)	zmq::socket_base_t	[virtual]
timer_event(int id_)	zmq::socket_base_t	[virtual]
unregister_endpoints(class socket_base_t *socket_)	zmq::object_t	[protected]
unregister_term_ack()	zmq::own_t
write_activated(pipe_t *pipe_)	zmq::socket_base_t	[virtual]
xattach_pipe(class pipe_t *pipe_)	zmq::xsub_t	[protected, virtual]
xhas_in()	zmq::xsub_t	[protected, virtual]
xhas_out()	zmq::xsub_t	[protected, virtual]
xhiccuped(pipe_t *pipe_)	zmq::xsub_t	[protected, virtual]
xread_activated(class pipe_t *pipe_)	zmq::xsub_t	[protected, virtual]
xrecv(class msg_t *msg_, int flags_)	zmq::xsub_t	[protected, virtual]
xsend(class msg_t *msg_, int flags_)	zmq::xsub_t	[protected, virtual]
xsetsockopt(int option_, const void *optval_, size_t optvallen_)	zmq::socket_base_t	[protected, virtual]
xsub_t(class ctx_t *parent_, uint32_t tid_)	zmq::xsub_t
xsub_t(const xsub_t &)	zmq::xsub_t	[private]
xterminated(class pipe_t *pipe_)	zmq::xsub_t	[protected, virtual]
xwrite_activated(class pipe_t *pipe_)	zmq::xsub_t	[protected, virtual]
~array_item_t()	zmq::array_item_t<>	[inline, virtual]
~i_pipe_events()	zmq::i_pipe_events	[inline, virtual]
~i_poll_events()	zmq::i_poll_events	[inline, virtual]
~object_t()	zmq::object_t	[virtual]
~own_t()	zmq::own_t	[protected, virtual]
~socket_base_t()	zmq::socket_base_t	[protected, virtual]
~xsub_t()	zmq::xsub_t