![]() |
libzmq master
The Intelligent Transport Layer
|
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] |
find_endpoint(const char *addr_) | zmq::object_t | [protected] |
fq | zmq::pull_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_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] |
object_t(class ctx_t *ctx_, uint32_t tid_) | zmq::object_t | |
object_t(object_t *parent_) | zmq::object_t | |
operator=(const pull_t &) | zmq::pull_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] |
pull_t(class ctx_t *parent_, uint32_t tid_) | zmq::pull_t | |
pull_t(const pull_t &) | zmq::pull_t | [private] |
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_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 | |
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::pull_t | [protected, virtual] |
xhas_in() | zmq::pull_t | [protected, virtual] |
xhas_out() | zmq::socket_base_t | [protected, virtual] |
xhiccuped(pipe_t *pipe_) | zmq::socket_base_t | [protected, virtual] |
xread_activated(class pipe_t *pipe_) | zmq::pull_t | [protected, virtual] |
xrecv(class msg_t *msg_, int flags_) | zmq::pull_t | [protected, virtual] |
xsend(class msg_t *msg_, int flags_) | zmq::socket_base_t | [protected, virtual] |
xsetsockopt(int option_, const void *optval_, size_t optvallen_) | zmq::socket_base_t | [protected, virtual] |
xterminated(class pipe_t *pipe_) | zmq::pull_t | [protected, virtual] |
xwrite_activated(pipe_t *pipe_) | zmq::socket_base_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] |
~pull_t() | zmq::pull_t | |
~socket_base_t() | zmq::socket_base_t | [protected, virtual] |