#include <XrdFrmReqAgent.hh>
Public Member Functions | |
void | Add (XrdFrmRequest &Request) |
void | Del (XrdFrmRequest &Request) |
int | List (XrdFrmRequest::Item *Items, int Num) |
int | List (XrdFrmRequest::Item *Items, int Num, int Prty) |
int | NextLFN (char *Buff, int Bsz, int Prty, int &Offs) |
void | Ping (const char *Msg=0) |
int | Start (char *aPath, int aMode) |
XrdFrmReqAgent (const char *Me, int qVal) | |
~XrdFrmReqAgent () | |
Private Attributes | |
XrdFrmReqFile * | rQueue [XrdFrmRequest::maxPQE] |
const char * | Persona |
const char * | pingMsg |
const char * | myName |
int | theQ |
Static Private Attributes | |
static char * | c2sFN |
Definition at line 18 of file XrdFrmReqAgent.hh.
XrdFrmReqAgent::XrdFrmReqAgent | ( | const char * | Me, | |
int | qVal | |||
) |
Definition at line 44 of file XrdFrmReqAgent.cc.
References XrdFrmRequest::getQ, XrdFrmRequest::migQ, pingMsg, XrdFrmRequest::putQ, and XrdFrmRequest::stgQ.
XrdFrmReqAgent::~XrdFrmReqAgent | ( | ) | [inline] |
Definition at line 36 of file XrdFrmReqAgent.hh.
void XrdFrmReqAgent::Add | ( | XrdFrmRequest & | Request | ) |
Definition at line 62 of file XrdFrmReqAgent.cc.
References XrdFrmRequest::addTOD, XrdFrmRequest::iName, XrdFrmRequest::maxPrty, myName, Ping(), XrdFrmRequest::Prty, rQueue, and strlcpy().
Referenced by XrdFrmProxy::Add(), and XrdFrmXfrAgent::Add().
void XrdFrmReqAgent::Del | ( | XrdFrmRequest & | Request | ) |
Definition at line 89 of file XrdFrmReqAgent.cc.
References i, XrdFrmRequest::maxPrty, and rQueue.
Referenced by XrdFrmXfrAgent::Del(), and XrdFrmProxy::Del().
int XrdFrmReqAgent::List | ( | XrdFrmRequest::Item * | Items, | |
int | Num | |||
) |
Definition at line 102 of file XrdFrmReqAgent.cc.
References i, XrdFrmRequest::maxPrty, n, and rQueue.
Referenced by List(), XrdFrmProxy::List(), and XrdFrmXfrAgent::List().
int XrdFrmReqAgent::List | ( | XrdFrmRequest::Item * | Items, | |
int | Num, | |||
int | Prty | |||
) |
Definition at line 121 of file XrdFrmReqAgent.cc.
References List(), XrdFrmRequest::maxPrty, n, and rQueue.
int XrdFrmReqAgent::NextLFN | ( | char * | Buff, | |
int | Bsz, | |||
int | Prty, | |||
int & | Offs | |||
) |
Definition at line 143 of file XrdFrmReqAgent.cc.
References XrdFrmRequest::getLFN, XrdFrmReqFile::List(), and rQueue.
Referenced by XrdFrmProxy::List().
void XrdFrmReqAgent::Ping | ( | const char * | Msg = 0 |
) |
Definition at line 156 of file XrdFrmReqAgent.cc.
References c2sFN, pingMsg, XrdFrm::Say(), XrdNetMsg::Send(), and stat.
Referenced by Add(), XrdFrmXfrAgent::Process(), and Start().
int XrdFrmReqAgent::Start | ( | char * | aPath, | |
int | aMode | |||
) |
Definition at line 172 of file XrdFrmReqAgent.cc.
References XrdFrmReqFile::Add(), c2sFN, getenv(), i, Init(), XrdOucUtils::InstName(), XrdFrmUtils::makeQDir(), XrdFrmRequest::maxPrty, myName, Persona, Ping(), XrdFrmRequest::Register, rQueue, sprintf(), and strlcpy().
Referenced by XrdFrmXfrAgent::Start().
char * XrdFrmReqAgent::c2sFN [static, private] |
XrdFrmReqFile* XrdFrmReqAgent::rQueue[XrdFrmRequest::maxPQE] [private] |
const char* XrdFrmReqAgent::Persona [private] |
const char* XrdFrmReqAgent::pingMsg [private] |
const char* XrdFrmReqAgent::myName [private] |
int XrdFrmReqAgent::theQ [private] |
Definition at line 46 of file XrdFrmReqAgent.hh.