![]() |
XRootD
|
#include <XrdOfsEvr.hh>
Classes | |
class | theClient |
struct | theEvent |
Public Member Functions | |
XrdOfsEvr () | |
~XrdOfsEvr () | |
void | flushEvents () |
int | Init (XrdCmsClient *trg=0) |
int | Init (XrdSysError *eObj) |
void | recvEvents () |
void | Wait4Event (const char *path, XrdOucErrInfo *einfo) |
void | Work4Event (theClient *Client) |
Definition at line 42 of file XrdOfsEvr.hh.
|
inline |
Definition at line 59 of file XrdOfsEvr.hh.
XrdOfsEvr::~XrdOfsEvr | ( | ) |
Definition at line 75 of file XrdOfsEvr.cc.
References XrdOucStream::Close(), XrdSysMutex::Lock(), and XrdSysMutex::UnLock().
void XrdOfsEvr::flushEvents | ( | ) |
Definition at line 89 of file XrdOfsEvr.cc.
References XrdSysMutex::Lock(), XrdOfsEvr::theClient::Next, XrdOfsEvr::theClient::Path, XrdSysMutex::UnLock(), XrdSysSemaphore::Wait(), XrdSysTimer::Wait(), and XrdOfsScrubScan().
Referenced by XrdOfsEvFlush().
int XrdOfsEvr::Init | ( | XrdCmsClient * | trg = 0 | ) |
Definition at line 167 of file XrdOfsEvr.cc.
References XrdSysError::Emsg(), XrdSysThread::Run(), XrdOfsEvFlush(), and XrdOfsEvRecv().
int XrdOfsEvr::Init | ( | XrdSysError * | eObj | ) |
Definition at line 132 of file XrdOfsEvr.cc.
References XrdNetSocket::Create(), XrdNetSocket::Detach(), XrdSysError::Emsg(), XrdOucEnv::Export(), and XRDNET_FIFO.
Referenced by XrdOfs::Configure().
void XrdOfsEvr::recvEvents | ( | ) |
Definition at line 201 of file XrdOfsEvr.cc.
References XrdOucStream::Attach(), DEBUG, XrdSysError::Emsg(), EPNAME, XrdOucStream::GetLine(), XrdOucStream::GetToken(), and tident.
Referenced by XrdOfsEvRecv().
void XrdOfsEvr::Wait4Event | ( | const char * | path, |
XrdOucErrInfo * | einfo | ||
) |
Definition at line 226 of file XrdOfsEvr.cc.
References XrdOucErrInfo::setErrCB().
Referenced by XrdOfsFile::open().
void XrdOfsEvr::Work4Event | ( | theClient * | Client | ) |
Definition at line 240 of file XrdOfsEvr.cc.
References XrdOfsEvr::theEvent::aClient, XrdOfsEvr::theClient::evtCB, XrdOfsEvr::theClient::evtCBarg, XrdOfsEvr::theEvent::Happened, XrdSysMutex::Lock(), XrdOfsEvr::theClient::Next, XrdOfsEvr::theClient::Path, XrdOucEICB::Same(), and XrdSysMutex::UnLock().
Referenced by XrdOfsEvr::theClient::Done().