![]() |
libzmq
master
ZeroMQ C++ Core Engine (LIBZMQ)
|
#include <ipc_listener.hpp>
Public Member Functions | |
ipc_listener_t (zmq::io_thread_t *io_thread_, zmq::socket_base_t *socket_, const options_t &options_) | |
~ipc_listener_t () | |
int | get_address (std::string &addr_) |
int | set_address (const char *addr_) |
![]() | |
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 () |
Private Member Functions | |
ipc_listener_t (const ipc_listener_t &) | |
fd_t | accept () |
int | close () |
void | in_event () |
const ipc_listener_t & | operator= (const ipc_listener_t &) |
void | process_plug () |
void | process_term (int linger_) |
Static Private Member Functions | |
static int | create_wildcard_address (std::string &path_, std::string &file_) |
Private Attributes | |
std::string | endpoint |
std::string | filename |
handle_t | handle |
bool | has_file |
fd_t | s |
zmq::socket_base_t * | socket |
std::string | tmp_socket_dirname |
Static Private Attributes | |
static const char * | tmp_env_vars [] |
Additional Inherited Members | |
![]() | |
typedef poller_t::handle_t | handle_t |
![]() | |
virtual | ~own_t () |
bool | is_terminating () |
void | launch_child (own_t *object_) |
virtual void | process_destroy () |
void | process_term (int linger_) |
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_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 | 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_) |
void | timer_event (int id_) |
![]() | |
options_t | options |
Definition at line 50 of file ipc_listener.hpp.
zmq::ipc_listener_t::ipc_listener_t | ( | zmq::io_thread_t * | io_thread_, |
zmq::socket_base_t * | socket_, | ||
const options_t & | options_ | ||
) |
Definition at line 133 of file ipc_listener.cpp.
zmq::ipc_listener_t::~ipc_listener_t | ( | ) |
Definition at line 143 of file ipc_listener.cpp.
References zmq::retired_fd, s, and zmq_assert.
|
private |
|
private |
Definition at line 387 of file ipc_listener.cpp.
References close(), ECONNABORTED, EPROTO, errno_assert, zmq::retired_fd, s, and zmq_assert.
Referenced by in_event().
|
private |
Definition at line 289 of file ipc_listener.cpp.
References endpoint, errno_assert, zmq::socket_base_t::event_close_failed(), zmq::socket_base_t::event_closed(), filename, has_file, zmq::own_t::options, zmq::retired_fd, s, size, socket, tmp_socket_dirname, zmq::options_t::use_fd, zmq_assert, and zmq_errno().
Referenced by accept(), create_wildcard_address(), process_term(), and set_address().
|
staticprivate |
Definition at line 74 of file ipc_listener.cpp.
References close(), and tmp_env_vars.
Referenced by set_address().
int zmq::ipc_listener_t::get_address | ( | std::string & | addr_ | ) |
Definition at line 193 of file ipc_listener.cpp.
References s, and zmq::ipc_address_t::to_string().
Referenced by zmq::socket_base_t::bind().
|
privatevirtual |
Reimplemented from zmq::io_object_t.
Definition at line 162 of file ipc_listener.cpp.
References accept(), zmq::options_t::affinity, alloc_assert, zmq::object_t::choose_io_thread(), zmq::session_base_t::create(), endpoint, errno_assert, zmq::socket_base_t::event_accept_failed(), zmq::socket_base_t::event_accepted(), zmq::own_t::inc_seqnum(), zmq::own_t::launch_child(), zmq::own_t::options, zmq::retired_fd, zmq::object_t::send_attach(), socket, zmq_assert, and zmq_errno().
|
private |
|
privatevirtual |
Reimplemented from zmq::object_t.
Definition at line 148 of file ipc_listener.cpp.
References zmq::io_object_t::add_fd(), handle, s, and zmq::io_object_t::set_pollin().
|
privatevirtual |
Reimplemented from zmq::object_t.
Definition at line 155 of file ipc_listener.cpp.
References close(), handle, zmq::own_t::process_term(), and zmq::io_object_t::rm_fd().
int zmq::ipc_listener_t::set_address | ( | const char * | addr_ | ) |
Definition at line 211 of file ipc_listener.cpp.
References zmq::ipc_address_t::addr(), address, zmq::ipc_address_t::addrlen(), zmq::options_t::backlog, bind, close(), create_wildcard_address(), endpoint, zmq::socket_base_t::event_listening(), filename, has_file, zmq::open_socket(), zmq::own_t::options, zmq::ipc_address_t::resolve(), s, socket, tmp_socket_dirname, zmq::ipc_address_t::to_string(), and zmq::options_t::use_fd.
Referenced by zmq::socket_base_t::bind().
|
private |
Definition at line 111 of file ipc_listener.hpp.
Referenced by close(), in_event(), and set_address().
|
private |
Definition at line 99 of file ipc_listener.hpp.
Referenced by close(), and set_address().
|
private |
Definition at line 105 of file ipc_listener.hpp.
Referenced by process_plug(), and process_term().
|
private |
Definition at line 92 of file ipc_listener.hpp.
Referenced by close(), and set_address().
|
private |
Definition at line 102 of file ipc_listener.hpp.
Referenced by accept(), close(), get_address(), process_plug(), set_address(), and ~ipc_listener_t().
|
private |
Definition at line 108 of file ipc_listener.hpp.
Referenced by close(), in_event(), and set_address().
|
staticprivate |
Definition at line 114 of file ipc_listener.hpp.
Referenced by create_wildcard_address().
|
private |
Definition at line 96 of file ipc_listener.hpp.
Referenced by close(), and set_address().