xrootd: XrdFrmReqBoss Class Reference

xrootd

#include <XrdFrmReqBoss.hh>

Collaboration diagram for XrdFrmReqBoss:

Collaboration graph

List of all members.

Public Member Functions
void	Add (XrdFrmRequest &Request)
void	Del (XrdFrmRequest &Request)
void	Process ()
int	Server ()
int	Start (char *aPath, int aMode)
void	Wakeup (int PushIt=1)
	XrdFrmReqBoss (const char *Me, int qVal)
	~XrdFrmReqBoss ()
Private Member Functions
void	Register (XrdFrmRequest &Req, int qNum)
Private Attributes
XrdSysSemaphore	rqReady
XrdFrmReqFile *	rQueue [XrdFrmRequest::maxPQE]
const char *	Persona
int	theQ
int	isPosted

Constructor & Destructor Documentation

XrdFrmReqBoss::XrdFrmReqBoss	(	const char *	Me,
		int	qVal
	)		`[inline]`

XrdFrmReqBoss::~XrdFrmReqBoss ( ) [inline]

Member Function Documentation

void XrdFrmReqBoss::Add ( XrdFrmRequest & Request )

References XrdFrmRequest::addTOD, XrdFrmRequest::maxPrty, and XrdFrmRequest::Prty.

void XrdFrmReqBoss::Del ( XrdFrmRequest & Request )

References XrdFrmRequest::maxPrty.

void XrdFrmReqBoss::Process ( )

References XrdFrmXfrQueue::Add(), DEBUG, EPNAME, XrdFrmRequest::maxPrty, XrdFrmRequest::Options, and XrdFrmRequest::Register.

Referenced by mainServerXeq().

void XrdFrmReqBoss::Register	(	XrdFrmRequest &	Req,
		int	qNum
	)		`[private]`

References XrdFrmCID::Add(), XrdFrmRequest::addTOD, XrdFrm::CID, DEBUG, EPNAME, XrdFrmRequest::ID, XrdFrmRequest::iName, and XrdFrmRequest::LFN.

int XrdFrmReqBoss::Server ( )

int XrdFrmReqBoss::Start	(	char *	aPath,
		int	aMode
	)

References XrdSysError::Emsg(), mainServerXeq(), XrdFrmUtils::makeQDir(), XrdFrmRequest::maxPrty, XrdSysThread::Run(), XrdFrm::Say, and XRDSYSTHREAD_BIND.

void XrdFrmReqBoss::Wakeup ( int PushIt = 1 )

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

Referenced by XrdFrmXfrDaemon::Pong().

Member Data Documentation

int XrdFrmReqBoss::isPosted [private]

const char* XrdFrmReqBoss::Persona [private]

XrdSysSemaphore XrdFrmReqBoss::rqReady [private]

XrdFrmReqFile* XrdFrmReqBoss::rQueue[XrdFrmRequest::maxPQE] [private]

int XrdFrmReqBoss::theQ [private]

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