libzmq master
The Intelligent Transport Layer

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]
distzmq::xsub_t [private]
find_endpoint(const char *addr_)zmq::object_t [protected]
fqzmq::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_messagezmq::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]
messagezmq::xsub_t [private]
morezmq::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]
optionszmq::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
subscriptionszmq::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
 All Classes Files Functions Variables Typedefs Enumerations Enumerator Friends Defines