XrdPollPoll Class Reference

#include <XrdPollPoll.hh>

Inheritance diagram for XrdPollPoll:

Collaboration diagram for XrdPollPoll:

Public Member Functions
void	Detach (XrdLink *lp)
void	Disable (XrdLink *lp, const char *etxt=0)
int	Enable (XrdLink *lp)
void	Start (XrdSysSemaphore *syncp, int &rc)
	XrdPollPoll (struct pollfd *pp, int numfd)
	~XrdPollPoll ()

Protected Member Functions
void	doDetach (int pti)
void	Exclude (XrdLink *lp)
int	Include (XrdLink *lp)

Private Member Functions
void	doRequests (int maxreq)
void	dqLink (XrdLink *lp)
void	LogEvent (int req, int pollfd, int cmdfd)
void	Recover (int numleft)
void	Restart (int ecode)
Private Member Functions inherited from XrdPoll
	XrdPoll ()
virtual	~XrdPoll ()
int	getRequest ()

Private Attributes
struct pollfd *	PollTab
int	PollTNum
XrdLink *	PollQ
XrdSysMutex	PollMutex
int	maxent
Private Attributes inherited from XrdPoll
int	PID
pthread_t	TID
XrdSysMutex	PollPipe
struct pollfd	PipePoll
int	CmdFD
int	ReqFD
PipeData	ReqBuff
char *	PipeBuff
int	PipeBlen
int	numEnabled
int	numEvents
int	numInterrupts

Additional Inherited Members
Static Private Member Functions inherited from XrdPoll
static int	Attach (XrdLink *lp)
static void	Detach (XrdLink *lp)
static int	Finish (XrdLink *lp, const char *etxt=0)
static void	Init (XrdSysError *eP, XrdOucTrace *tP, XrdScheduler *sP)
static char *	Poll2Text (short events)
static int	Setup (int numfd)
static int	Stats (char *buff, int blen, int do_sync=0)
static XrdPoll *	newPoller (int pollid, int numfd)
Static Private Attributes inherited from XrdPoll
static XrdPoll *	Pollers [XRD_NUMPOLLERS] = {0, 0, 0}
static const char *	TraceID = "Poll"
static XrdOucTrace *	XrdTrace = 0
static XrdSysError *	XrdLog = 0
static XrdScheduler *	XrdSched = 0

Constructor & Destructor Documentation

XrdPollPoll::XrdPollPoll	(	struct pollfd *	pp,
		int	numfd
	)

References maxent, PollQ, PollTab, and PollTNum.

XrdPollPoll::~XrdPollPoll

(

)

References PollTab.

Member Function Documentation

void XrdPollPoll::Detach

(

XrdLink *

lp

)

void XrdPollPoll::Disable ( XrdLink *  lp, const char *  etxt = 0  )

virtual

Implements XrdPoll.

References XrdPoll::PipeData::Arg, XrdPoll::CmdFD, XrdPoll::PipeData::DiFD, dqLink(), XrdSysError::Emsg(), XrdLink::FD, XrdPoll::Finish(), XrdLink::ID, XrdLink::inQ, XrdLink::isEnabled, XrdSysMutex::Lock(), XrdPoll::PipeData::Parms, XrdPoll::PID, XrdLink::PollEnt, XrdPoll::PollPipe, PollTab, XrdPoll::PipeData::Post, XrdPoll::PipeData::req, XrdScheduler::Schedule(), XrdPoll::PipeData::theSem, TRACEI, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), write(), XrdPoll::XrdLog, and XrdPoll::XrdSched.

Referenced by Exclude().

void XrdPollPoll::doDetach ( int  pti )

protected

References XrdSysError::Emsg(), XrdSysMutex::Lock(), PollMutex, PollTab, PollTNum, XrdSysMutex::UnLock(), and XrdPoll::XrdLog.

Referenced by doRequests().

void XrdPollPoll::doRequests ( int  maxreq )

private

References XrdPoll::PipeData::Arg, XrdPoll::PipeData::DiFD, doDetach(), XrdSysError::Emsg(), XrdPoll::PipeData::EnFD, XrdLink::fd2link(), XrdPoll::getRequest(), XrdLink::isEnabled, LogEvent(), XrdPoll::numEnabled, XrdPoll::PipeData::Parms, XrdPoll::PID, PollTab, PollTNum, XrdPoll::PipeData::Post, XrdSysSemaphore::Post(), XrdPoll::PipeData::req, XrdPoll::ReqBuff, XrdPoll::PipeData::RmFD, XrdPoll::PipeData::theSem, TRACE, and XrdPoll::XrdLog.

Referenced by Start().

void XrdPollPoll::dqLink ( XrdLink *  lp )

private

References XrdSysError::Emsg(), XrdLink::ID, XrdLink::inQ, XrdSysMutex::Lock(), XrdLink::Next, PollMutex, PollQ, XrdSysMutex::UnLock(), and XrdPoll::XrdLog.

Referenced by Disable(), and Exclude().

int XrdPollPoll::Enable ( XrdLink *  lp )

virtual

Implements XrdPoll.

References XrdPoll::PipeData::Arg, XrdPoll::CmdFD, XrdSysError::Emsg(), XrdPoll::PipeData::EnFD, XrdLink::FD, XrdLink::ID, XrdLink::inQ, XrdLink::isEnabled, XrdSysMutex::Lock(), XrdLink::Next, XrdPoll::PipeData::Parms, XrdPoll::PID, XrdLink::PollEnt, PollMutex, XrdPoll::PollPipe, PollQ, PollTab, XrdPoll::PipeData::req, TRACEI, XrdSysMutex::UnLock(), write(), and XrdPoll::XrdLog.

void XrdPollPoll::Exclude ( XrdLink *  lp )

protectedvirtual

Implements XrdPoll.

References XrdPoll::PipeData::Arg, XrdPoll::CmdFD, Disable(), dqLink(), XrdSysError::Emsg(), XrdLink::FD, XrdLink::ID, XrdLink::inQ, XrdLink::isEnabled, XrdSysMutex::Lock(), XrdPoll::PipeData::Parms, XrdPoll::PID, XrdLink::PollEnt, XrdPoll::PollPipe, PollTab, XrdPoll::PipeData::Post, XrdPoll::PipeData::req, XrdPoll::PipeData::RmFD, XrdPoll::PipeData::theSem, TRACEI, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), write(), and XrdPoll::XrdLog.

int XrdPollPoll::Include ( XrdLink *  lp )

protectedvirtual

Implements XrdPoll.

References XrdSysError::Emsg(), XrdLink::FD, XrdLink::ID, XrdSysMutex::Lock(), maxent, XrdLink::PollEnt, PollMutex, PollTab, PollTNum, XrdSysMutex::UnLock(), and XrdPoll::XrdLog.

void XrdPollPoll::LogEvent ( int  req, int  pollfd, int  cmdfd  )

private

References XrdPoll::PipeData::DiFD, XrdSysError::Emsg(), XrdPoll::PipeData::EnFD, XrdLink::fd2link(), XrdLink::ID, XrdPoll::PID, XrdPoll::PipeData::req, XrdPoll::ReqBuff, XrdPoll::PipeData::RmFD, and XrdPoll::XrdLog.

Referenced by doRequests().

void XrdPollPoll::Recover ( int  numleft )

private

References XrdSysError::Emsg(), XrdLink::fd2link(), XrdLink::ID, XrdLink::isEnabled, PollTab, PollTNum, and XrdPoll::XrdLog.

Referenced by Start().

void XrdPollPoll::Restart ( int  ecode )

private

References XrdSysError::Emsg(), XrdPoll::Finish(), XrdSysMutex::Lock(), XrdLink::Next, XrdPoll::PID, XrdLink::PollEnt, PollMutex, PollQ, XrdScheduler::Schedule(), XrdPoll::TID, TRACE, XrdSysMutex::UnLock(), XrdPoll::XrdLog, and XrdPoll::XrdSched.

Referenced by Start().

void XrdPollPoll::Start ( XrdSysSemaphore *  syncp, int &  rc  )

virtual

Implements XrdPoll.

References doRequests(), XrdSysError::Emsg(), XrdPoll::Finish(), XrdLink::ID, XrdLink::inQ, XrdLink::isEnabled, XrdSysMutex::Lock(), XrdLink::Next, XrdJob::NextJob, XrdPoll::numEvents, XrdPoll::numInterrupts, XrdPoll::Poll2Text(), XrdLink::PollEnt, PollMutex, PollQ, PollTab, PollTNum, XrdSysSemaphore::Post(), Recover(), XrdPoll::ReqFD, Restart(), XrdScheduler::Schedule(), XrdSysMutex::UnLock(), XrdPoll::XrdLog, and XrdPoll::XrdSched.

Member Data Documentation

int XrdPollPoll::maxent

private

Referenced by Include(), and XrdPollPoll().

XrdSysMutex XrdPollPoll::PollMutex

private

Referenced by doDetach(), dqLink(), Enable(), Include(), Restart(), and Start().

XrdLink* XrdPollPoll::PollQ

private

Referenced by dqLink(), Enable(), Restart(), Start(), and XrdPollPoll().

struct pollfd* XrdPollPoll::PollTab

private

Referenced by Disable(), doDetach(), doRequests(), Enable(), Exclude(), Include(), Recover(), Start(), XrdPollPoll(), and ~XrdPollPoll().

int XrdPollPoll::PollTNum

private

Referenced by doDetach(), doRequests(), Include(), Recover(), Start(), and XrdPollPoll().

---

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

• XrdPollPoll.hh
• XrdPollPoll.icc