zmq::ipc_listener_t Class Reference

#include <ipc_listener.hpp>

Inheritance diagram for zmq::ipc_listener_t:

Collaboration diagram for zmq::ipc_listener_t:

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_)
Public Member Functions inherited from zmq::own_t
	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 ()
Public Member Functions inherited from zmq::object_t
	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)
Public Member Functions inherited from zmq::io_object_t
	io_object_t (zmq::io_thread_t *io_thread_=NULL)
	~io_object_t ()
void	plug (zmq::io_thread_t *io_thread_)
void	unplug ()
Public Member Functions inherited from zmq::i_poll_events
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
Protected Types inherited from zmq::io_object_t
typedef poller_t::handle_t	handle_t
Protected Member Functions inherited from zmq::own_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 ()
Protected Member Functions inherited from zmq::object_t
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_)
Protected Member Functions inherited from zmq::io_object_t
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_)
Protected Attributes inherited from zmq::own_t
options_t	options

Detailed Description

Definition at line 50 of file ipc_listener.hpp.

Constructor & Destructor Documentation

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.

zmq::ipc_listener_t::ipc_listener_t ( const ipc_listener_t &  )

private

Member Function Documentation

zmq::fd_t zmq::ipc_listener_t::accept ( )

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().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::ipc_listener_t::close ( )

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().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::ipc_listener_t::create_wildcard_address ( std::string &  path_, std::string &  file_  )

staticprivate

Definition at line 74 of file ipc_listener.cpp.

References close(), and tmp_env_vars.

Referenced by set_address().

Here is the call graph for this function:

Here is the caller graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::ipc_listener_t::in_event ( )

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().

Here is the call graph for this function:

const ipc_listener_t& zmq::ipc_listener_t::operator= ( const ipc_listener_t &  )

private

void zmq::ipc_listener_t::process_plug ( )

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().

Here is the call graph for this function:

void zmq::ipc_listener_t::process_term ( int  linger_ )

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().

Here is the call graph for this function:

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().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

std::string zmq::ipc_listener_t::endpoint

private

Definition at line 111 of file ipc_listener.hpp.

Referenced by close(), in_event(), and set_address().

std::string zmq::ipc_listener_t::filename

private

Definition at line 99 of file ipc_listener.hpp.

Referenced by close(), and set_address().

handle_t zmq::ipc_listener_t::handle

private

Definition at line 105 of file ipc_listener.hpp.

Referenced by process_plug(), and process_term().

bool zmq::ipc_listener_t::has_file

private

Definition at line 92 of file ipc_listener.hpp.

Referenced by close(), and set_address().

fd_t zmq::ipc_listener_t::s

private

Definition at line 102 of file ipc_listener.hpp.

Referenced by accept(), close(), get_address(), process_plug(), set_address(), and ~ipc_listener_t().

zmq::socket_base_t* zmq::ipc_listener_t::socket

private

Definition at line 108 of file ipc_listener.hpp.

Referenced by close(), in_event(), and set_address().

const char * zmq::ipc_listener_t::tmp_env_vars

staticprivate

Initial value:

= {
  "TMPDIR",
  "TEMPDIR",
  "TMP",
  0  
}

Definition at line 114 of file ipc_listener.hpp.

Referenced by create_wildcard_address().

std::string zmq::ipc_listener_t::tmp_socket_dirname

private

Definition at line 96 of file ipc_listener.hpp.

Referenced by close(), and set_address().