![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <dish.hpp>
Public Member Functions | |
dish_session_t (zmq::io_thread_t *io_thread_, bool connect_, zmq::socket_base_t *socket_, const options_t &options_, address_t *addr_) | |
~dish_session_t () | |
int | pull_msg (msg_t *msg_) |
int | push_msg (msg_t *msg_) |
void | reset () |
![]() | |
void | attach_pipe (zmq::pipe_t *pipe_) |
void | engine_error (zmq::stream_engine_t::error_reason_t reason) |
void | flush () |
socket_base_t * | get_socket () |
void | hiccuped (zmq::pipe_t *pipe_) |
void | pipe_terminated (zmq::pipe_t *pipe_) |
void | read_activated (zmq::pipe_t *pipe_) |
int | read_zap_msg (msg_t *msg_) |
void | write_activated (zmq::pipe_t *pipe_) |
int | write_zap_msg (msg_t *msg_) |
int | zap_connect () |
bool | zap_enabled () |
![]() | |
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) |
![]() | |
io_object_t (zmq::io_thread_t *io_thread_=NULL) | |
~io_object_t () | |
void | plug (zmq::io_thread_t *io_thread_) |
void | unplug () |
![]() | |
virtual | ~i_poll_events () |
![]() | |
virtual | ~i_pipe_events () |
Private Types | |
enum | { group, body } |
Private Member Functions | |
dish_session_t (const dish_session_t &) | |
const dish_session_t & | operator= (const dish_session_t &) |
Private Attributes | |
msg_t | group_msg |
enum zmq::dish_session_t:: { ... } | state |
Additional Inherited Members | |
![]() | |
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 |
zmq::dish_session_t::dish_session_t | ( | zmq::io_thread_t * | io_thread_, |
bool | connect_, | ||
zmq::socket_base_t * | socket_, | ||
const options_t & | options_, | ||
address_t * | addr_ | ||
) |
|
private |
|
private |
Reimplemented from zmq::session_base_t.
Definition at line 319 of file dish.cpp.
References zmq::msg_t::close(), zmq::msg_t::command, zmq::msg_t::data, errno_assert, zmq::msg_t::group, zmq::msg_t::init_size(), zmq::msg_t::is_join(), zmq::msg_t::is_leave(), zmq::session_base_t::pull_msg(), and zmq::msg_t::set_flags().
Reimplemented from zmq::session_base_t.
Definition at line 274 of file dish.cpp.
References body, zmq::msg_t::close(), zmq::msg_t::data, errno_assert, zmq::msg_t::flags, group, group_msg, zmq::msg_t::init(), zmq::msg_t::more, zmq::session_base_t::push_msg(), zmq::msg_t::set_group(), zmq::msg_t::size, size, state, and ZMQ_GROUP_MAX_LENGTH.
|
virtual |
Reimplemented from zmq::session_base_t.
Definition at line 363 of file dish.cpp.
References group, zmq::session_base_t::reset(), and state.
|
private |
Definition at line 117 of file dish.hpp.
Referenced by push_msg().
enum { ... } zmq::dish_session_t::state |
Referenced by push_msg(), and reset().