xrootd
|
#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 | ( | ) |
|
private |
void XrdOfsEvr::flushEvents | ( | ) |
int XrdOfsEvr::Init | ( | XrdSysError * | eObj | ) |
int XrdOfsEvr::Init | ( | XrdCmsClient * | trg = 0 | ) |
void XrdOfsEvr::recvEvents | ( | ) |
|
private |
void XrdOfsEvr::Wait4Event | ( | const char * | path, |
XrdOucErrInfo * | einfo | ||
) |
void XrdOfsEvr::Work4Event | ( | theClient * | Client | ) |
Referenced by XrdOfsEvr::theClient::Done().
|
private |
|
private |
Referenced by XrdOfsEvr().
|
private |
|
private |
|
private |
|
staticprivate |
|
private |
|
private |
|
private |
|
private |
Referenced by XrdOfsEvr().