![]() |
libzmq master
The Intelligent Transport Layer
|
| choose_io_thread(uint64_t affinity_) | zmq::object_t | [protected] |
| destroy_socket(class socket_base_t *socket_) | zmq::object_t | [protected] |
| find_endpoint(const char *addr_) | zmq::object_t | [protected] |
| get_ctx() | zmq::object_t | |
| get_load() | zmq::io_thread_t | |
| get_mailbox() | zmq::io_thread_t | |
| get_poller() | zmq::io_thread_t | |
| get_tid() | zmq::object_t | |
| in_event() | zmq::io_thread_t | [virtual] |
| io_thread_t(class ctx_t *ctx_, uint32_t tid_) | zmq::io_thread_t | |
| io_thread_t(const io_thread_t &) | zmq::io_thread_t | [private] |
| log(const char *format_,...) | zmq::object_t | [protected] |
| mailbox | zmq::io_thread_t | [private] |
| mailbox_handle | zmq::io_thread_t | [private] |
| object_t(class ctx_t *ctx_, uint32_t tid_) | zmq::object_t | |
| object_t(object_t *parent_) | zmq::object_t | |
| operator=(const io_thread_t &) | zmq::io_thread_t | [private] |
| out_event() | zmq::io_thread_t | [virtual] |
| poller | zmq::io_thread_t | [private] |
| 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_bind(class pipe_t *pipe_) | zmq::object_t | [protected, virtual] |
| process_command(struct command_t &cmd_) | zmq::object_t | |
| process_hiccup(void *pipe_) | zmq::object_t | [protected, virtual] |
| process_own(class own_t *object_) | 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] |
| process_seqnum() | zmq::object_t | [protected, virtual] |
| process_stop() | zmq::io_thread_t | [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] |
| register_endpoint(const char *addr_, struct endpoint_t &endpoint_) | zmq::object_t | [protected] |
| 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] |
| start() | zmq::io_thread_t | |
| stop() | zmq::io_thread_t | |
| timer_event(int id_) | zmq::io_thread_t | [virtual] |
| unregister_endpoints(class socket_base_t *socket_) | zmq::object_t | [protected] |
| ~i_poll_events() | zmq::i_poll_events | [inline, virtual] |
| ~io_thread_t() | zmq::io_thread_t | |
| ~object_t() | zmq::object_t | [virtual] |
1.7.3