xrootd
Public Member Functions | Protected Member Functions | List of all members
XrdSys::IOEvents::PollerWait Class Reference
Inheritance diagram for XrdSys::IOEvents::PollerWait:
Inheritance graph
[legend]
Collaboration diagram for XrdSys::IOEvents::PollerWait:
Collaboration graph
[legend]

Public Member Functions

 PollerWait ()
 
 ~PollerWait ()
 
- Public Member Functions inherited from XrdSys::IOEvents::Poller
void Stop ()
 
 Poller (int cFD, int rFD)
 
virtual ~Poller ()
 Destructor. Stop() is effecively called when this object is deleted. More...
 

Protected Member Functions

void Begin (XrdSysSemaphore *syncp, int &rc, const char **eTxt)
 
void Exclude (Channel *cP, bool &isLocked, bool dover=1)
 
bool Include (Channel *cP, int &eNum, const char **eTxt, bool &isLocked)
 
bool Modify (Channel *cP, int &eNum, const char **eTxt, bool &isLocked)
 
void Shutdown ()
 
- Protected Member Functions inherited from XrdSys::IOEvents::Poller
void CbkTMO ()
 
bool CbkXeq (Channel *cP, int events, int eNum, const char *eTxt)
 
int GetFault (Channel *cP)
 
int GetPollEnt (Channel *cP)
 
int GetRequest ()
 
bool Init (Channel *cP, int &eNum, const char **eTxt, bool &isLockd)
 
void LockChannel (Channel *cP)
 
int Poll2Enum (short events)
 
int SendCmd (PipeData &cmd)
 
void SetPollEnt (Channel *cP, int ptEnt)
 
bool TmoAdd (Channel *cP)
 
void TmoDel (Channel *cP)
 
int TmoGet ()
 
void UnLockChannel (Channel *cP)
 

Additional Inherited Members

- Static Public Member Functions inherited from XrdSys::IOEvents::Poller
static PollerCreate (int &eNum, const char **eTxt=0)
 
- Protected Attributes inherited from XrdSys::IOEvents::Poller
ChannelattBase
 
ChanneltmoBase
 
pthread_t pollTid
 
struct pollfd pipePoll
 
int cmdFD
 
int reqFD
 
PipeData reqBuff
 
char * pipeBuff
 
int pipeBlen
 
bool wakePend
 
bool chDead
 
- Static Protected Attributes inherited from XrdSys::IOEvents::Poller
static time_t maxTime = (sizeof(time_t) == 8 ? 0x7fffffffffffffffLL : 0x7fffffff)
 

Constructor & Destructor Documentation

XrdSys::IOEvents::PollerWait::PollerWait ( )
inline
XrdSys::IOEvents::PollerWait::~PollerWait ( )
inline

Member Function Documentation

void XrdSys::IOEvents::PollerWait::Begin ( XrdSysSemaphore syncp,
int &  rc,
const char **  eTxt 
)
inlineprotectedvirtual

Start the polling event loop. An implementation must be supplied. Begin() is called via the internal BootStrap class from a new thread.

Implements XrdSys::IOEvents::Poller.

void XrdSys::IOEvents::PollerWait::Exclude ( Channel cP,
bool &  isLocked,
bool  dover = 1 
)
inlineprotectedvirtual

Remove a channel to the poll set. An implementation must be supplied. The channel is locked when this method is called but must be unlocked by the method if a command is sent to the poller thread and isLocked set to false.

Implements XrdSys::IOEvents::Poller.

bool XrdSys::IOEvents::PollerWait::Include ( Channel cP,
int &  eNum,
const char **  eTxt,
bool &  isLocked 
)
inlineprotectedvirtual

Add a channel to the poll set. An implementation must be supplied. The channel is locked when this method is called but must be unlocked by the method if a command is sent to the poller thread and isLocked set to false.

Implements XrdSys::IOEvents::Poller.

bool XrdSys::IOEvents::PollerWait::Modify ( Channel cP,
int &  eNum,
const char **  eTxt,
bool &  isLocked 
)
inlineprotectedvirtual

Modify the event status of a channel. An implementation must be supplied. The channel is locked when this method is called but must be unlocked by the method if a command is sent to the poller thread and isLocked set to false.

Implements XrdSys::IOEvents::Poller.

void XrdSys::IOEvents::PollerWait::Shutdown ( )
inlineprotectedvirtual

Shutdown the poller. An implementation must be supplied. The shutdown method must release any allocated storage and close private file descriptors. The polling thread will have already been terminated and x-thread pipe closed. Warning: the derived destructor must call Stop() and do nothing else!

Implements XrdSys::IOEvents::Poller.


The documentation for this class was generated from the following file: