xrootd
|
#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 |
XrdFrmReqBoss::XrdFrmReqBoss | ( | const char * | Me, |
int | qVal | ||
) | [inline] |
XrdFrmReqBoss::~XrdFrmReqBoss | ( | ) | [inline] |
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 | ||
) |
void XrdFrmReqBoss::Wakeup | ( | int | PushIt = 1 | ) |
References XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
Referenced by XrdFrmXfrDaemon::Pong().
int XrdFrmReqBoss::isPosted [private] |
const char* XrdFrmReqBoss::Persona [private] |
XrdSysSemaphore XrdFrmReqBoss::rqReady [private] |
XrdFrmReqFile* XrdFrmReqBoss::rQueue[XrdFrmRequest::maxPQE] [private] |
int XrdFrmReqBoss::theQ [private] |