zmq::tcp_listener_t Class Reference

#include <tcp_listener.hpp>

Inheritance diagram for zmq::tcp_listener_t:

Collaboration diagram for zmq::tcp_listener_t:

Public Member Functions
	tcp_listener_t (zmq::io_thread_t *io_thread_, zmq::socket_base_t *socket_, const options_t &options_)
	~tcp_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
	tcp_listener_t (const tcp_listener_t &)
fd_t	accept ()
void	close ()
void	in_event ()
const tcp_listener_t &	operator= (const tcp_listener_t &)
void	process_plug ()
void	process_term (int linger_)

Private Attributes
tcp_address_t	address
std::string	endpoint
handle_t	handle
fd_t	s
zmq::socket_base_t *	socket

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	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 46 of file tcp_listener.hpp.

Constructor & Destructor Documentation

zmq::tcp_listener_t::tcp_listener_t	(	zmq::io_thread_t *	io_thread_,
		zmq::socket_base_t *	socket_,
		const options_t &	options_
	)

Definition at line 63 of file tcp_listener.cpp.

zmq::tcp_listener_t::~tcp_listener_t

(

)

Definition at line 73 of file tcp_listener.cpp.

References zmq::retired_fd, s, and zmq_assert.

zmq::tcp_listener_t::tcp_listener_t ( const tcp_listener_t &  )

private

Member Function Documentation

zmq::fd_t zmq::tcp_listener_t::accept ( )

private

Definition at line 265 of file tcp_listener.cpp.

References close(), ECONNABORTED, ENOBUFS, EPROTO, errno_assert, zmq::own_t::options, zmq::retired_fd, s, zmq::set_ip_type_of_service(), zmq::options_t::tcp_accept_filters, zmq::options_t::tos, and zmq_assert.

Referenced by in_event().

Here is the call graph for this function:

Here is the caller graph for this function:

void zmq::tcp_listener_t::close ( )

private

Definition at line 128 of file tcp_listener.cpp.

References endpoint, errno_assert, zmq::socket_base_t::event_closed(), zmq::retired_fd, s, socket, and zmq_assert.

Referenced by accept(), process_term(), and set_address().

Here is the call graph for this function:

Here is the caller graph for this function:

int zmq::tcp_listener_t::get_address

(

std::string &

addr_

)

Definition at line 142 of file tcp_listener.cpp.

References s, and zmq::tcp_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::tcp_listener_t::in_event ( )

privatevirtual

Reimplemented from zmq::io_object_t.

Definition at line 92 of file tcp_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::options_t::tcp_keepalive, zmq::options_t::tcp_keepalive_cnt, zmq::options_t::tcp_keepalive_idle, zmq::options_t::tcp_keepalive_intvl, zmq::options_t::tcp_maxrt, zmq::tune_tcp_keepalives(), zmq::tune_tcp_maxrt(), zmq::tune_tcp_socket(), zmq_assert, and zmq_errno().

Here is the call graph for this function:

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

private

void zmq::tcp_listener_t::process_plug ( )

privatevirtual

Reimplemented from zmq::object_t.

Definition at line 78 of file tcp_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::tcp_listener_t::process_term ( int  linger_ )

privatevirtual

Reimplemented from zmq::own_t.

Definition at line 85 of file tcp_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::tcp_listener_t::set_address

(

const char *

addr_

)

Definition at line 162 of file tcp_listener.cpp.

References zmq::tcp_address_t::addr(), address, zmq::tcp_address_t::addrlen(), zmq::options_t::backlog, bind, close(), EAFNOSUPPORT, zmq::enable_ipv4_mapping(), endpoint, errno_assert, zmq::socket_base_t::event_listening(), zmq::tcp_address_t::family(), zmq::options_t::ipv6, zmq::open_socket(), zmq::own_t::options, zmq::options_t::rcvbuf, zmq::tcp_address_t::resolve(), zmq::retired_fd, s, zmq::set_ip_type_of_service(), zmq::set_tcp_receive_buffer(), zmq::set_tcp_send_buffer(), zmq::options_t::sndbuf, socket, zmq::tcp_address_t::to_string(), zmq::options_t::tos, 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

tcp_address_t zmq::tcp_listener_t::address

private

Definition at line 79 of file tcp_listener.hpp.

Referenced by set_address().

std::string zmq::tcp_listener_t::endpoint

private

Definition at line 91 of file tcp_listener.hpp.

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

handle_t zmq::tcp_listener_t::handle

private

Definition at line 85 of file tcp_listener.hpp.

Referenced by process_plug(), and process_term().

fd_t zmq::tcp_listener_t::s

private

Definition at line 82 of file tcp_listener.hpp.

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

zmq::socket_base_t* zmq::tcp_listener_t::socket

private

Definition at line 88 of file tcp_listener.hpp.

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