#include <XrdOfsEvr.hh>

Classes | |
| class | theClient |
| struct | theEvent |
Public Member Functions | |
| void | flushEvents () |
| int | Init (XrdSysError *eObj) |
| int | Init (XrdCmsClient *trg=0) |
| void | recvEvents () |
| void | Wait4Event (const char *path, XrdOucErrInfo *einfo) |
| void | Work4Event (theClient *Client) |
| XrdOfsEvr () | |
| ~XrdOfsEvr () | |
Private Member Functions | |
| void | eventStage () |
| void | sendEvent (theEvent *ep) |
Private Attributes | |
| XrdSysMutex | myMutex |
| XrdSysSemaphore | mySem |
| XrdOucStream | eventFIFO |
| XrdSysError * | eDest |
| XrdCmsClient * | Balancer |
| theClient * | deferQ |
| int | runQ |
| int | msgFD |
| XrdOucHash< theEvent > | Events |
Static Private Attributes | |
| static const int | maxLife = (8*60*60) |
| XrdOfsEvr::~XrdOfsEvr | ( | ) |
| void XrdOfsEvr::eventStage | ( | ) | [private] |
| void XrdOfsEvr::flushEvents | ( | ) |
| int XrdOfsEvr::Init | ( | XrdCmsClient * | trg = 0 |
) |
| int XrdOfsEvr::Init | ( | XrdSysError * | eObj | ) |
| void XrdOfsEvr::recvEvents | ( | ) |
| void XrdOfsEvr::sendEvent | ( | theEvent * | ep | ) | [private] |
| void XrdOfsEvr::Wait4Event | ( | const char * | path, | |
| XrdOucErrInfo * | einfo | |||
| ) |
| void XrdOfsEvr::Work4Event | ( | theClient * | Client | ) |
Referenced by XrdOfsEvr::theClient::Done().
XrdCmsClient* XrdOfsEvr::Balancer [private] |
theClient* XrdOfsEvr::deferQ [private] |
Referenced by XrdOfsEvr().
XrdSysError* XrdOfsEvr::eDest [private] |
XrdOucStream XrdOfsEvr::eventFIFO [private] |
XrdOucHash<theEvent> XrdOfsEvr::Events [private] |
const int XrdOfsEvr::maxLife = (8*60*60) [static, private] |
int XrdOfsEvr::msgFD [private] |
XrdSysMutex XrdOfsEvr::myMutex [private] |
XrdSysSemaphore XrdOfsEvr::mySem [private] |
int XrdOfsEvr::runQ [private] |
Referenced by XrdOfsEvr().
1.6.1