XrdFrmReqBoss Class Reference

#include <XrdFrmReqBoss.hh>

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

---

Detailed Description

Definition at line 19 of file XrdFrmReqBoss.hh.

---

Constructor & Destructor Documentation

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

Definition at line 35 of file XrdFrmReqBoss.hh.

XrdFrmReqBoss::~XrdFrmReqBoss

(

)

[inline]

Definition at line 37 of file XrdFrmReqBoss.hh.

---

Member Function Documentation

void XrdFrmReqBoss::Add

(

XrdFrmRequest &

Request

)

Definition at line 50 of file XrdFrmReqBoss.cc.

References XrdFrmRequest::addTOD, XrdFrmRequest::maxPrty, XrdFrmRequest::Prty, rQueue, and Wakeup().

void XrdFrmReqBoss::Del

(

XrdFrmRequest &

Request

)

Definition at line 73 of file XrdFrmReqBoss.cc.

References i, XrdFrmRequest::maxPrty, and rQueue.

void XrdFrmReqBoss::Process

(

)

Definition at line 86 of file XrdFrmReqBoss.cc.

References XrdFrmXfrQueue::Add(), DEBUG, EPNAME, Reflex::Dummy::Get(), i, XrdFrmRequest::maxPrty, XrdFrmRequest::Options, Persona, XrdFrmRequest::Register, Register(), rQueue, theQ, and Wakeup().

Referenced by mainServerXeq().

int XrdFrmReqBoss::Server

(

)

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

Definition at line 138 of file XrdFrmReqBoss.cc.

References XrdSysError::Emsg(), i, Init(), mainServerXeq(), XrdFrmUtils::makeQDir(), XrdFrmRequest::maxPrty, Persona, rQueue, XrdSysThread::Run(), XrdFrm::Say(), sprintf(), and XRDSYSTHREAD_BIND.

Referenced by XrdFrmXfrDaemon::Init().

void XrdFrmReqBoss::Wakeup

(

int

PushIt = 1

)

Definition at line 174 of file XrdFrmReqBoss.cc.

References isPosted, XrdSysMutex::Lock(), XrdSysSemaphore::Post(), rqReady, XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().

Referenced by Add(), XrdFrmXfrDaemon::Pong(), Process(), and XrdFrmXfrDaemon::Start().

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

Definition at line 115 of file XrdFrmReqBoss.cc.

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

Referenced by Process().

---

Member Data Documentation

XrdSysSemaphore XrdFrmReqBoss::rqReady [private]

Definition at line 42 of file XrdFrmReqBoss.hh.

Referenced by Wakeup().

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

Definition at line 43 of file XrdFrmReqBoss.hh.

Referenced by Add(), Del(), Process(), Register(), and Start().

const char* XrdFrmReqBoss::Persona [private]

Definition at line 44 of file XrdFrmReqBoss.hh.

Referenced by Process(), and Start().

int XrdFrmReqBoss::theQ [private]

Definition at line 45 of file XrdFrmReqBoss.hh.

Referenced by Process().

int XrdFrmReqBoss::isPosted [private]

Definition at line 46 of file XrdFrmReqBoss.hh.

Referenced by Wakeup().

---

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

• net/xrootd/src/xrootd/src/XrdFrm/XrdFrmReqBoss.hh
• net/xrootd/src/xrootd/src/XrdFrm/XrdFrmReqBoss.cc

---