|
| rep_t (zmq::ctx_t *parent_, uint32_t tid_, int sid) |
|
| ~rep_t () |
|
bool | xhas_in () |
|
bool | xhas_out () |
|
int | xrecv (zmq::msg_t *msg_) |
|
int | xsend (zmq::msg_t *msg_) |
|
| router_t (zmq::ctx_t *parent_, uint32_t tid_, int sid) |
|
| ~router_t () |
|
void | xattach_pipe (zmq::pipe_t *pipe_, bool subscribe_to_all_) |
|
bool | xhas_in () |
|
bool | xhas_out () |
|
void | xpipe_terminated (zmq::pipe_t *pipe_) |
|
void | xread_activated (zmq::pipe_t *pipe_) |
|
int | xrecv (zmq::msg_t *msg_) |
|
int | xsend (zmq::msg_t *msg_) |
|
int | xsetsockopt (int option_, const void *optval_, size_t optvallen_) |
|
void | xwrite_activated (zmq::pipe_t *pipe_) |
|
int | add_signaler (signaler_t *s) |
|
int | bind (const char *addr_) |
|
bool | check_tag () |
|
int | close () |
|
int | connect (const char *addr_) |
|
void | event_accept_failed (const std::string &addr_, int err_) |
|
void | event_accepted (const std::string &addr_, int fd_) |
|
void | event_bind_failed (const std::string &addr_, int err_) |
|
void | event_close_failed (const std::string &addr_, int fd_) |
|
void | event_closed (const std::string &addr_, int fd_) |
|
void | event_connect_delayed (const std::string &addr_, int err_) |
|
void | event_connect_retried (const std::string &addr_, int interval_) |
|
void | event_connected (const std::string &addr_, int fd_) |
|
void | event_disconnected (const std::string &addr_, int fd_) |
|
void | event_listening (const std::string &addr_, int fd_) |
|
i_mailbox * | get_mailbox () |
|
int | getsockopt (int option_, void *optval_, size_t *optvallen_) |
|
bool | has_in () |
|
bool | has_out () |
|
void | hiccuped (pipe_t *pipe_) |
|
void | in_event () |
|
int | join (const char *group) |
|
int | leave (const char *group) |
|
void | lock () |
|
int | monitor (const char *endpoint_, int events_) |
|
void | out_event () |
|
void | pipe_terminated (pipe_t *pipe_) |
|
void | read_activated (pipe_t *pipe_) |
|
int | recv (zmq::msg_t *msg_, int flags_) |
|
int | remove_signaler (signaler_t *s) |
|
int | send (zmq::msg_t *msg_, int flags_) |
|
int | setsockopt (int option_, const void *optval_, size_t optvallen_) |
|
void | start_reaping (poller_t *poller_) |
|
void | stop () |
|
int | term_endpoint (const char *addr_) |
|
void | timer_event (int id_) |
|
void | unlock () |
|
void | write_activated (pipe_t *pipe_) |
|
| own_t (zmq::ctx_t *parent_, uint32_t tid_) |
|
| own_t (zmq::io_thread_t *io_thread_, const options_t &options_) |
|
void | inc_seqnum () |
|
void | register_term_acks (int count_) |
|
void | unregister_term_ack () |
|
| object_t (zmq::ctx_t *ctx_, uint32_t tid_) |
|
| object_t (object_t *parent_) |
|
virtual | ~object_t () |
|
ctx_t * | get_ctx () |
|
uint32_t | get_tid () |
|
void | process_command (zmq::command_t &cmd_) |
|
void | send_bind (zmq::own_t *destination_, zmq::pipe_t *pipe_, bool inc_seqnum_=true) |
|
void | send_inproc_connected (zmq::socket_base_t *socket_) |
|
void | set_tid (uint32_t id) |
|
| array_item_t () |
|
virtual | ~array_item_t () |
|
int | get_array_index () |
|
void | set_array_index (int index_) |
|
virtual | ~i_poll_events () |
|
virtual | ~i_pipe_events () |
|
|
static socket_base_t * | create (int type_, zmq::ctx_t *parent_, uint32_t tid_, int sid_) |
|
blob_t | get_credential () const |
|
int | rollback () |
|
| socket_base_t (zmq::ctx_t *parent_, uint32_t tid_, int sid_, bool thread_safe_=false) |
|
virtual | ~socket_base_t () |
|
void | monitor_event (int event_, int value_, const std::string &addr_) |
|
void | process_destroy () |
|
void | stop_monitor (bool send_monitor_stopped_event_=true) |
|
virtual void | xhiccuped (pipe_t *pipe_) |
|
virtual int | xjoin (const char *group_) |
|
virtual int | xleave (const char *group_) |
|
virtual | ~own_t () |
|
bool | is_terminating () |
|
void | launch_child (own_t *object_) |
|
void | term_child (own_t *object_) |
|
void | terminate () |
|
zmq::io_thread_t * | choose_io_thread (uint64_t affinity_) |
|
void | connect_pending (const char *addr_, zmq::socket_base_t *bind_socket_) |
|
void | destroy_socket (zmq::socket_base_t *socket_) |
|
zmq::endpoint_t | find_endpoint (const char *addr_) |
|
void | log (const char *format_,...) |
|
void | pend_connection (const std::string &addr_, const endpoint_t &endpoint, pipe_t **pipes_) |
|
virtual void | process_activate_read () |
|
virtual void | process_activate_write (uint64_t msgs_read_) |
|
virtual void | process_attach (zmq::i_engine *engine_) |
|
virtual void | process_hiccup (void *pipe_) |
|
virtual void | process_pipe_term () |
|
virtual void | process_pipe_term_ack () |
|
virtual void | process_plug () |
|
virtual void | process_reap (zmq::socket_base_t *socket_) |
|
virtual void | process_reaped () |
|
int | register_endpoint (const char *addr_, const zmq::endpoint_t &endpoint_) |
|
void | send_activate_read (zmq::pipe_t *destination_) |
|
void | send_activate_write (zmq::pipe_t *destination_, uint64_t msgs_read_) |
|
void | send_attach (zmq::session_base_t *destination_, zmq::i_engine *engine_, bool inc_seqnum_=true) |
|
void | send_done () |
|
void | send_hiccup (zmq::pipe_t *destination_, void *pipe_) |
|
void | send_own (zmq::own_t *destination_, zmq::own_t *object_) |
|
void | send_pipe_term (zmq::pipe_t *destination_) |
|
void | send_pipe_term_ack (zmq::pipe_t *destination_) |
|
void | send_plug (zmq::own_t *destination_, bool inc_seqnum_=true) |
|
void | send_reap (zmq::socket_base_t *socket_) |
|
void | send_reaped () |
|
void | send_stop () |
|
void | send_term (zmq::own_t *destination_, int linger_) |
|
void | send_term_ack (zmq::own_t *destination_) |
|
void | send_term_req (zmq::own_t *destination_, zmq::own_t *object_) |
|
int | unregister_endpoint (const std::string &addr_, socket_base_t *socket_) |
|
void | unregister_endpoints (zmq::socket_base_t *socket_) |
|
std::string | connect_rid |
|
options_t | options |
|
Definition at line 43 of file rep.hpp.