|
static session_base_t * | create (zmq::io_thread_t *io_thread_, bool active_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_) |
|
typedef poller_t::handle_t | handle_t |
|
| session_base_t (zmq::io_thread_t *io_thread_, bool active_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_) |
|
virtual | ~session_base_t () |
|
virtual | ~own_t () |
|
bool | is_terminating () |
|
void | launch_child (own_t *object_) |
|
virtual void | process_destroy () |
|
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_bind (zmq::pipe_t *pipe_) |
|
virtual void | process_hiccup (void *pipe_) |
|
virtual void | process_pipe_term () |
|
virtual void | process_pipe_term_ack () |
|
virtual void | process_reap (zmq::socket_base_t *socket_) |
|
virtual void | process_reaped () |
|
virtual void | process_stop () |
|
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_) |
|
handle_t | add_fd (fd_t fd_) |
|
void | add_timer (int timout_, int id_) |
|
void | cancel_timer (int id_) |
|
void | in_event () |
|
void | out_event () |
|
void | reset_pollin (handle_t handle_) |
|
void | reset_pollout (handle_t handle_) |
|
void | rm_fd (handle_t handle_) |
|
void | set_pollin (handle_t handle_) |
|
void | set_pollout (handle_t handle_) |
|
options_t | options |
|
Definition at line 94 of file req.hpp.