#include <XrdFrmReqBoss.hh>
Collaboration diagram for XrdFrmReqBoss:
Public Member Functions | |
| void | Add (XrdFrcRequest &Request) |
| void | Del (XrdFrcRequest &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 (XrdFrcRequest &Req, int qNum) |
Private Attributes | |
| XrdSysSemaphore | rqReady |
| XrdFrcReqFile * | rQueue [XrdFrcRequest::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 | ( | XrdFrcRequest & | Request | ) |
References XrdFrcRequest::Prty, XrdFrcRequest::maxPrty, and XrdFrcRequest::addTOD.
| void XrdFrmReqBoss::Del | ( | XrdFrcRequest & | Request | ) |
| void XrdFrmReqBoss::Process | ( | ) |
References EPNAME, XrdFrcRequest::maxPrty, XrdFrcRequest::Options, XrdFrcRequest::Register, XrdFrmXfrQueue::Add(), and DEBUG.
Referenced by mainServerXeq().
| void XrdFrmReqBoss::Register | ( | XrdFrcRequest & | Req, |
| int | qNum | ||
| ) | [private] |
References EPNAME, XrdFrcRequest::LFN, XrdFrcRequest::ID, XrdFrc::CID, XrdFrcCID::Add(), XrdFrcRequest::iName, XrdFrcRequest::addTOD, and DEBUG.
| int XrdFrmReqBoss::Server | ( | ) |
| int XrdFrmReqBoss::Start | ( | char * | aPath, |
| int | aMode | ||
| ) |
References XrdFrcUtils::makeQDir(), XrdSysThread::Run(), mainServerXeq(), XRDSYSTHREAD_BIND, XrdFrc::Say, and XrdSysError::Emsg().
| 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] |
XrdFrcReqFile* XrdFrmReqBoss::rQueue[XrdFrcRequest::maxPQE] [private] |
int XrdFrmReqBoss::theQ [private] |
The documentation for this class was generated from the following files:
