XrdNetLink Class Reference

#include <XrdNetLink.hh>

Collaboration diagram for XrdNetLink:

List of all members.

Public Member Functions
int	Close (int defer=0)
int	FDnum ()
char *	GetLine ()
char *	GetToken (char **rest)
char *	GetToken (void)
void	RetToken (void)
int	isConnected (void)
int	LastError ()
unsigned int	Addr ()
const char *	Moniker ()
const char *	Name ()
const char *	Nick ()
int	OK2Recv (int mills)
void	Recycle ()
int	Send (const char *buff, int blen=0, int tmo=-1)
int	Send (const char *dest, const char *buff, int blen=0, int tmo=-1)
int	Send (const struct iovec iov[], int iovcnt, int tmo=-1)
int	Send (const char *dest, const struct iovec iov[], int iovcnt, int tmo=-1)
int	Send (const void *buff, int blen=0, int tmo=-1)
int	Recv (char *buff, int blen)
void	Set (int maxl)
void	SetOpts (int opts)
	XrdNetLink (XrdSysError *erp, XrdNetBufferQ *bq)
	~XrdNetLink ()
Static Public Member Functions
static XrdNetLink *	Alloc (XrdSysError *erp, XrdNet *Net, XrdNetPeer &Peer, XrdNetBufferQ *bq, int opts=0)
Public Attributes
XrdOucQSItem< XrdNetLink >	LinkLink
Private Member Functions
int	OK2Send (int timeout=0, const char *dest=0)
int	retErr (int ecode, const char *dest=0)
Private Attributes
XrdSysMutex	rdMutex
XrdSysMutex	wrMutex
XrdNetBufferQ *	BuffQ
int	FD
int	noclose
int	isReset
struct sockaddr	InetAddr
char *	Lname
char *	Sname
XrdNetBuffer *	recvbuff
XrdNetBuffer *	sendbuff
XrdOucStream *	Stream
XrdOucTokenizer *	Bucket
XrdSysError *	eDest
Static Private Attributes
static XrdSysMutex	LinkList
static XrdOucStack< XrdNetLink >	LinkStack
static int	size
static int	maxlink = 16
static int	numlink = 0
static int	devNull = open("/dev/null", O_RDONLY)

---

Constructor & Destructor Documentation

XrdNetLink::XrdNetLink	(	XrdSysError *	erp,
		XrdNetBufferQ *	bq
	)			[inline]

References Bucket, BuffQ, eDest, FD, Lname, recvbuff, sendbuff, Sname, and Stream.

Referenced by Alloc().

XrdNetLink::~XrdNetLink

(

)

[inline]

References Close().

---

Member Function Documentation

unsigned int XrdNetLink::Addr

(

)

[inline]

References InetAddr, and XrdNetDNS::IPAddr().

Referenced by XrdOlbManager::AddServer(), XrdOlbServer::do_Try(), XrdOlbServer::Login(), and XrdOlbServer::XrdOlbServer().

XrdNetLink * XrdNetLink::Alloc	(	XrdSysError *	erp,
		XrdNet *	Net,
		XrdNetPeer &	Peer,
		XrdNetBufferQ *	bq,
		int	opts = 0
	)			[static]

References XrdOucStream::Attach(), Bucket, BuffQ, XrdNetBuffer::data, FD, XrdNetPeer::fd, XrdNetDNS::getHostName(), XrdNetPeer::InetAddr, InetAddr, XrdNetPeer::InetBuff, XrdNetPeer::InetName, isReset, LinkList, LinkStack, Lname, XrdSysMutex::Lock(), noclose, numlink, XrdOucStack< T >::Pop(), recvbuff, Recycle(), XrdNetBuffer::Recycle(), sendbuff, Sname, Stream, XrdNet::Trim(), XrdSysMutex::UnLock(), XrdNetLink(), and XRDNETLINK_NOSTREAM.

Referenced by XrdNetWork::Accept(), XrdNetWork::Connect(), and XrdNetWork::Relay().

int XrdNetLink::Close

(

int

defer = 0

)

References Bucket, close, XrdOucStream::Detach(), devNull, FD, isReset, Lname, XrdSysMutex::Lock(), noclose, rdMutex, recvbuff, XrdNetBuffer::Recycle(), sendbuff, Stream, XrdSysMutex::UnLock(), and wrMutex.

Referenced by XrdOlbManager::AddServer(), XrdOlbServer::do_Disc(), XrdOlbServer::do_Try(), XrdOlbManager::MonPing(), Recycle(), XrdOlbManager::Remove_Server(), XrdOdcManager::Send(), XrdOdcManager::whatsUp(), and ~XrdNetLink().

int XrdNetLink::FDnum

(

)

[inline]

References FD.

Referenced by XrdOlbManager::Remove_Manager(), and XrdOlbStartSupervising().

char * XrdNetLink::GetLine

(

)

References Bucket, XrdNetBuffer::data, XrdNetBuffer::dlen, XrdOucTokenizer::GetLine(), XrdOucStream::GetLine(), recvbuff, and Stream.

Referenced by XrdOlbManager::Login(), XrdOlbServer::Receive(), and XrdOdcManager::Receive().

char * XrdNetLink::GetToken

(

char **

rest

)

References Bucket, XrdOucTokenizer::GetToken(), XrdOucStream::GetToken(), and Stream.

Referenced by XrdOlbManager::AddPath(), XrdOlbServer::do_AvKb(), XrdOlbServer::do_Chmod(), XrdOlbServer::do_Gone(), XrdOlbServer::do_Have(), XrdOlbServer::do_Load(), XrdOlbServer::do_Mkdir(), XrdOlbServer::do_Mkpath(), XrdOlbServer::do_Mv(), XrdOlbServer::do_PrepAdd(), XrdOlbServer::do_PrepDel(), XrdOlbServer::do_Rm(), XrdOlbServer::do_Rmdir(), XrdOlbServer::do_Select(), XrdOlbServer::do_State(), XrdOlbServer::do_Try(), XrdOlbServer::Login(), XrdOlbManager::Login(), XrdOlbServer::Receive(), and XrdOdcManager::Receive().

char * XrdNetLink::GetToken

(

void

)

References Bucket, XrdOucTokenizer::GetToken(), XrdOucStream::GetToken(), and Stream.

int XrdNetLink::isConnected

(

void

)

[inline]

References FD, and Stream.

int XrdNetLink::LastError

(

)

References XrdOucStream::LastError(), and Stream.

Referenced by XrdOlbServer::Process_Director(), XrdOlbServer::Process_Requests(), XrdOlbServer::Process_Responses(), and XrdOdcManager::Start().

const char* XrdNetLink::Moniker

(

)

[inline]

References Sname.

const char* XrdNetLink::Name

(

)

[inline]

References Lname.

Referenced by XrdOlbServer::do_Disc(), XrdOlbServer::isServer(), XrdOlbServer::Login(), XrdOlbServer::Process_Director(), XrdOlbServer::Process_Requests(), XrdOlbServer::Process_Responses(), XrdOdcManager::Receive(), and XrdOlbServer::setName().

const char* XrdNetLink::Nick

(

)

[inline]

References Sname.

Referenced by XrdOlbManager::Add_Manager(), XrdOlbManager::AddServer(), XrdOlbManager::Login(), XrdOlbManager::Login_Failed(), XrdOlbManager::MonPing(), XrdOlbServer::setName(), and XrdOlbStartSupervising().

int XrdNetLink::OK2Recv

(

int

mills

)

References FD, poll(), POLLIN, POLLRDNORM, and pollfd::revents.

Referenced by XrdOlbServer::Login().

int XrdNetLink::OK2Send	(	int	timeout = 0,
		const char *	dest = 0
	)			[private]

References eDest, XrdSysError::Emsg(), FD, Lname, poll(), POLLOUT, POLLWRNORM, and pollfd::revents.

Referenced by Send().

int XrdNetLink::Recv	(	char *	buff,
		int	blen
	)

References eDest, XrdSysError::Emsg(), FD, Lname, XrdSysMutex::Lock(), rdMutex, read(), ssize_t, and XrdSysMutex::UnLock().

void XrdNetLink::Recycle

(

void

)

References Close(), LinkLink, LinkList, LinkStack, XrdSysMutex::Lock(), maxlink, numlink, XrdOucStack< T >::Push(), and XrdSysMutex::UnLock().

Referenced by XrdOlbManager::AddServer(), Alloc(), XrdOdcManager::Hookup(), XrdOlbManager::Login_Failed(), XrdOdcManager::Start(), XrdOdcManager::~XrdOdcManager(), and XrdOlbServer::~XrdOlbServer().

int XrdNetLink::retErr	(	int	ecode,
		const char *	dest = 0
	)			[private]

References eDest, XrdSysError::Emsg(), EWOULDBLOCK, Lname, XrdSysMutex::UnLock(), and wrMutex.

Referenced by Send().

void XrdNetLink::RetToken

(

void

)

References Bucket, XrdOucTokenizer::RetToken(), XrdOucStream::RetToken(), and Stream.

Referenced by XrdOlbServer::do_PrepAdd().

int XrdNetLink::Send	(	const struct iovec	iov[],
		int	iovcnt,
		int	tmo = -1
	)

References XrdNetBufferQ::Alloc(), BuffQ, XrdNetBuffer::BuffSize(), XrdNetBuffer::data, EMSGSIZE, FD, InetAddr, iovec::iov_base, iovec::iov_len, XrdSysMutex::Lock(), OK2Send(), retErr(), sendbuff, Sokdata_t, Stream, XrdSysMutex::UnLock(), writev, and wrMutex.

int XrdNetLink::Send	(	const char *	dest,
		const struct iovec	iov[],
		int	iovcnt,
		int	tmo = -1
	)

References XrdNetBufferQ::Alloc(), BuffQ, XrdNetBuffer::BuffSize(), XrdNetBuffer::data, eDest, XrdSysError::Emsg(), EMSGSIZE, FD, XrdNetDNS::Host2Dest(), iovec::iov_len, XrdSysMutex::Lock(), OK2Send(), retErr(), sendbuff, Sokdata_t, Stream, XrdSysMutex::UnLock(), and wrMutex.

int XrdNetLink::Send	(	const char *	buff,
		int	blen = 0,
		int	tmo = -1
	)

References FD, InetAddr, IOV_INIT, XrdSysMutex::Lock(), OK2Send(), retErr(), Sokdata_t, Stream, XrdSysMutex::UnLock(), write(), and wrMutex.

Referenced by XrdOlbServer::do_Delay(), XrdOlbServer::do_Disc(), XrdOlbServer::do_Locate(), XrdOlbServer::do_Ping(), XrdOlbServer::do_Select(), XrdOlbServer::do_Space(), XrdOlbServer::do_State(), XrdOlbServer::do_Stats(), XrdOlbServer::do_Usage(), XrdOdcManager::Hookup(), XrdOlbServer::Inform(), XrdOlbServer::Login(), XrdOlbManager::Login(), XrdOlbManager::SelServer(), XrdOlbServer::Send(), XrdOdcManager::Send(), Send(), and XrdOlbManager::sendAList().

int XrdNetLink::Send	(	const void *	buff,
		int	blen = 0,
		int	tmo = -1
	)

References FD, InetAddr, XrdSysMutex::Lock(), OK2Send(), retErr(), Sokdata_t, Stream, XrdSysMutex::UnLock(), write(), and wrMutex.

int XrdNetLink::Send	(	const char *	dest,
		const char *	buff,
		int	blen = 0,
		int	tmo = -1
	)

References eDest, XrdSysError::Emsg(), FD, XrdNetDNS::Host2Dest(), IOV_INIT, XrdSysMutex::Lock(), OK2Send(), retErr(), Send(), Sokdata_t, Stream, XrdSysMutex::UnLock(), and wrMutex.

void XrdNetLink::Set

(

int

maxl

)

References LinkList, XrdSysMutex::Lock(), maxlink, and XrdSysMutex::UnLock().

void XrdNetLink::SetOpts

(

int

opts

)

References F_SETFL, fcntl(), FD, O_NONBLOCK, and XRDNETLINK_NOBLOCK.

---

Member Data Documentation

XrdOucTokenizer* XrdNetLink::Bucket [private]

Referenced by Alloc(), Close(), GetLine(), GetToken(), RetToken(), and XrdNetLink().

XrdNetBufferQ* XrdNetLink::BuffQ [private]

Referenced by Alloc(), Send(), and XrdNetLink().

int XrdNetLink::devNull = open("/dev/null", O_RDONLY) [static, private]

Referenced by Close().

XrdSysError* XrdNetLink::eDest [private]

Referenced by OK2Send(), Recv(), retErr(), Send(), and XrdNetLink().

int XrdNetLink::FD [private]

Referenced by Alloc(), Close(), FDnum(), isConnected(), OK2Recv(), OK2Send(), Recv(), Send(), SetOpts(), and XrdNetLink().

struct sockaddr XrdNetLink::InetAddr [private]

Referenced by Addr(), Alloc(), and Send().

int XrdNetLink::isReset [private]

Referenced by Alloc(), and Close().

XrdOucQSItem<XrdNetLink> XrdNetLink::LinkLink

Referenced by Recycle().

XrdSysMutex XrdNetLink::LinkList [static, private]

Referenced by Alloc(), Recycle(), and Set().

XrdOucStack< XrdNetLink > XrdNetLink::LinkStack [static, private]

Referenced by Alloc(), and Recycle().

char* XrdNetLink::Lname [private]

Referenced by Alloc(), Close(), Name(), OK2Send(), Recv(), retErr(), and XrdNetLink().

int XrdNetLink::maxlink = 16 [static, private]

Referenced by Recycle(), and Set().

int XrdNetLink::noclose [private]

Referenced by Alloc(), and Close().

int XrdNetLink::numlink = 0 [static, private]

Referenced by Alloc(), and Recycle().

XrdSysMutex XrdNetLink::rdMutex [private]

Referenced by Close(), and Recv().

XrdNetBuffer* XrdNetLink::recvbuff [private]

Referenced by Alloc(), Close(), GetLine(), and XrdNetLink().

XrdNetBuffer* XrdNetLink::sendbuff [private]

Referenced by Alloc(), Close(), Send(), and XrdNetLink().

int XrdNetLink::size [static, private]

char* XrdNetLink::Sname [private]

Referenced by Alloc(), Moniker(), Nick(), and XrdNetLink().

XrdOucStream* XrdNetLink::Stream [private]

Referenced by Alloc(), Close(), GetLine(), GetToken(), isConnected(), LastError(), RetToken(), Send(), and XrdNetLink().

XrdSysMutex XrdNetLink::wrMutex [private]

Referenced by Close(), retErr(), and Send().

---

The documentation for this class was generated from the following files:

• XrdNetLink.hh
• XrdNetLink.cc