#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().