XrdFrmReqBoss Class Reference
#include <XrdFrmReqBoss.hh>
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, XrdFrmRequest::Prty, rQueue, and Wakeup().
Referenced by Process().
| void XrdFrmReqBoss::Del | ( | XrdFrmRequest & | Request | ) |
References XrdFrmRequest::maxPrty, and rQueue.
| void XrdFrmReqBoss::Process | ( | ) |
References Add(), DEBUG, EPNAME, XrdFrmRequest::maxPrty, XrdFrmRequest::Options, Persona, Register(), XrdFrmRequest::Register, rQueue, theQ, and Wakeup().
Referenced by mainServerXeq().
| void XrdFrmReqBoss::Register | ( | XrdFrmRequest & | Req, | |
| int | qNum | |||
| ) | [private] |
References XrdFrmCID::Add(), XrdFrmRequest::addTOD, XrdFrm::CID, DEBUG, XrdFrmReqFile::Del(), EPNAME, XrdFrmRequest::ID, XrdFrmRequest::iName, XrdFrmRequest::LFN, and rQueue.
Referenced by Process().
| int XrdFrmReqBoss::Server | ( | ) |
| int XrdFrmReqBoss::Start | ( | char * | aPath, | |
| int | aMode | |||
| ) |
References mainServerXeq(), XrdFrmUtils::makeQDir(), XrdFrmRequest::maxPrty, Persona, rQueue, XrdSysThread::Run(), Say, and XRDSYSTHREAD_BIND.
Referenced by XrdFrmXfrDaemon::Init().
| void XrdFrmReqBoss::Wakeup | ( | int | PushIt = 1 |
) |
References isPosted, XrdSysMutex::Lock(), XrdSysSemaphore::Post(), rqReady, XrdSysMutex::UnLock(), and XrdSysSemaphore::Wait().
Referenced by Add(), XrdFrmXfrDaemon::Pong(), Process(), and XrdFrmXfrDaemon::Start().
Member Data Documentation
int XrdFrmReqBoss::isPosted [private] |
Referenced by Wakeup().
const char* XrdFrmReqBoss::Persona [private] |
XrdSysSemaphore XrdFrmReqBoss::rqReady [private] |
Referenced by Wakeup().
XrdFrmReqFile* XrdFrmReqBoss::rQueue[XrdFrmRequest::maxPQE] [private] |
Referenced by Add(), Del(), Process(), Register(), and Start().
int XrdFrmReqBoss::theQ [private] |
Referenced by Process().
The documentation for this class was generated from the following files:
