#include <P_Connection.h>

Inherited by Server.

Collaboration diagram for Connection:

Public Member Functions
int	open (NetVCOptions const &opt=DEFAULT_OPTIONS)
	Create and initialize the socket for this connection.
int	connect (sockaddr const *to, NetVCOptions const &opt=DEFAULT_OPTIONS)
	Connect the socket.
void	setRemote (sockaddr const *remote_addr)
	Set the internal socket address struct.
int	setup_mc_send (sockaddr const mc_addr, sockaddr const my_addr, bool non_blocking=NON_BLOCKING, unsigned char mc_ttl=1, bool mc_loopback=DISABLE_MC_LOOPBACK, Continuation *c=NULL)
int	setup_mc_receive (sockaddr const from, sockaddr const my_addr, bool non_blocking=NON_BLOCKING, Connection sendchan=NULL, Continuation c=NULL)
int	close ()
void	apply_options (NetVCOptions const &opt)
virtual	~Connection ()
	Connection ()
Data Fields
SOCKET	fd
	Socket for connection.
IpEndpoint	addr
	Associated address.
bool	is_bound
	Flag for already bound to a local address.
bool	is_connected
	Flag for already connected.
int	sock_type
Static Public Attributes
static NetVCOptions const	DEFAULT_OPTIONS
	Default options.
Protected Member Functions
void	_cleanup ()

Detailed Description

Definition at line 81 of file P_Connection.h.

Constructor & Destructor Documentation

Connection::~Connection ( ) [virtual]

Definition at line 79 of file Connection.cc.

References close().

Connection::Connection ( )

Definition at line 69 of file Connection.cc.

References addr.

Member Function Documentation

void Connection::_cleanup ( ) [protected]

Definition at line 354 of file UnixConnection.cc.

References close().

Referenced by connect(), and open().

void Connection::apply_options ( NetVCOptions const & opt )

Definition at line 360 of file UnixConnection.cc.

References Debug, fd, NetVCOptions::packet_mark, NetVCOptions::packet_tos, safe_setsockopt(), NetVCOptions::SOCK_OPT_KEEP_ALIVE, NetVCOptions::SOCK_OPT_NO_DELAY, sock_type, NetVCOptions::sockopt_flags, and SOCKOPT_ON.

Referenced by UnixNetVConnection::apply_options(), and open().

int Connection::close ( )

Definition at line 127 of file Connection.cc.

References SocketManager::close(), fd, is_bound, is_connected, NO_FD, and socketManager.

Referenced by _cleanup(), Server::accept(), NetAccept::acceptFastEvent(), NetAccept::cancel(), NetAcceptAction::cancel(), check_emergency_throttle(), close_UnixNetVConnection(), NetAccept::do_blocking_accept(), Server::listen(), Machine::Machine(), Server::setup_fd_for_listen(), setup_mc_receive(), setup_mc_send(), and ~Connection().

int Connection::connect	(	sockaddr const *	to,
		NetVCOptions const &	opt = `DEFAULT_OPTIONS`
	)

Connect the socket.

The socket is connected to the remote addr and port. The opt structure is used to control blocking on the socket. All other options are set via open. It is important to pass the same opt to this method as was passed to open.

Returns:: 0 on success, -ERRNO on failure.

See also:: open

Parameters:

	to	Remote address and port.
	opt	Socket options

Definition at line 320 of file UnixConnection.cc.

References _cleanup(), ats_ip_size(), NetVCOptions::f_blocking, NetVCOptions::f_blocking_connect, fd, ink_assert, is_bound, is_connected, NO_FD, safe_blocking(), safe_nonblocking(), and setRemote().

Referenced by UnixNetVConnection::connectUp().

int Connection::open ( NetVCOptions const & opt = DEFAULT_OPTIONS )

Create and initialize the socket for this connection.

A socket is created and the options specified by opt are set. The socket is not connected.

Note:: It is important to pass the same opt to this method and connect.

Returns:: 0 on success, -ERRNO on failure.

See also:: connect

Parameters:

opt

Socket options.

Definition at line 218 of file UnixConnection.cc.

References _cleanup(), NetVCOptions::addr_binding, apply_options(), IpEndpoint::assign(), ats_ip_size(), ats_is_ip(), Debug, NetVCOptions::f_blocking_connect, IpAddr::family(), fd, NetVCOptions::FOREIGN_ADDR, ink_assert, SocketManager::ink_bind(), ink_release_assert, NetVCOptions::INTF_ADDR, NetVCOptions::ip_family, NetVCOptions::ip_proto, is_bound, IpAddr::isValid(), NetVCOptions::local_ip, NetVCOptions::local_port, NO_FD, IpEndpoint::port(), ROUNDUP, IpEndpoint::sa, safe_nonblocking(), safe_setsockopt(), SocketManager::set_rcvbuf_size(), SocketManager::set_sndbuf_size(), IpEndpoint::setToAnyAddr(), sock_type, SocketManager::socket(), NetVCOptions::socket_recv_bufsize, NetVCOptions::socket_send_bufsize, socketManager, TS_IP_TRANSPARENT, and NetVCOptions::USE_UDP.

Referenced by UnixNetVConnection::connectUp().

void Connection::setRemote ( sockaddr const * remote_addr ) [inline]

Set the internal socket address struct.

Parameters:

remote_addr

Address and port.

Definition at line 122 of file P_Connection.h.

References addr, and ats_ip_copy().

Referenced by connect(), and ICPPeerReadCont::PeerReadStateMachine().

int Connection::setup_mc_receive	(	sockaddr const *	from,
		sockaddr const *	my_addr,
		bool	non_blocking = `NON_BLOCKING`,
		Connection *	sendchan = `NULL`,
		Continuation *	c = `NULL`
	)

Definition at line 109 of file UnixConnection.cc.

References addr, IpEndpoint::assign(), ats_ip4_addr_cast(), ats_ip_port_cast(), ats_ip_size(), ats_is_ip4(), close(), fd, ink_assert, SocketManager::ink_bind(), NO_FD, IpEndpoint::sa, safe_fcntl(), safe_nonblocking(), safe_setsockopt(), SocketManager::socket(), and socketManager.

int Connection::setup_mc_send	(	sockaddr const *	mc_addr,
		sockaddr const *	my_addr,
		bool	non_blocking = `NON_BLOCKING`,
		unsigned char	mc_ttl = `1`,
		bool	mc_loopback = `DISABLE_MC_LOOPBACK`,
		Continuation *	c = `NULL`
	)