XRootD
XrdSys::IOEvents::PollerErr1 Class Reference
+ Inheritance diagram for XrdSys::IOEvents::PollerErr1:
+ Collaboration diagram for XrdSys::IOEvents::PollerErr1:

Public Member Functions

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

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)
 
 CPP_ATOMIC_TYPE (bool) wakePend
 
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, int tmoSet)
 
void TmoDel (Channel *cP)
 
int TmoGet ()
 
void UnLockChannel (Channel *cP)
 

Additional Inherited Members

- Public Types inherited from XrdSys::IOEvents::Poller
enum  CreateOpts { optTOM }
 
- Static Public Member Functions inherited from XrdSys::IOEvents::Poller
static PollerCreate (int &eNum, const char **eTxt=0, int crOpts=0)
 
- Protected Attributes inherited from XrdSys::IOEvents::Poller
ChannelattBase
 
bool chDead
 
int cmdFD
 
int pipeBlen
 
char * pipeBuff
 
struct pollfd pipePoll
 
pthread_t pollTid
 
PipeData reqBuff
 
int reqFD
 
ChanneltmoBase
 
unsigned char tmoMask
 
- Static Protected Attributes inherited from XrdSys::IOEvents::Poller
static time_t maxTime = (sizeof(time_t) == 8 ? 0x7fffffffffffffffLL : 0x7fffffff)
 
static pid_t parentPID = getpid()
 

Detailed Description

Definition at line 166 of file XrdSysIOEvents.cc.

Constructor & Destructor Documentation

◆ PollerErr1()

XrdSys::IOEvents::PollerErr1::PollerErr1 ( )
inline

Definition at line 170 of file XrdSysIOEvents.cc.

170 : Poller(-1, -1) {}
Poller(int cFD, int rFD)

◆ ~PollerErr1()

XrdSys::IOEvents::PollerErr1::~PollerErr1 ( )
inline

Definition at line 171 of file XrdSysIOEvents.cc.

171 {}

Member Function Documentation

◆ Begin()

void XrdSys::IOEvents::PollerErr1::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.

Definition at line 174 of file XrdSysIOEvents.cc.

175  {(void)syncp; (void)rc; (void)eTxt;}

◆ Exclude()

void XrdSys::IOEvents::PollerErr1::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.

Definition at line 177 of file XrdSysIOEvents.cc.

178  {(void)cP; (void)isLocked; (void)dover;}

◆ Include()

bool XrdSys::IOEvents::PollerErr1::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.

Definition at line 180 of file XrdSysIOEvents.cc.

181  {(void)isLocked;
182  if (!(eNum = GetFault(cP))) eNum = EPROTO;
183  if (eTxt) *eTxt = "initializing channel";
184  return false;
185  }
int GetFault(Channel *cP)

References XrdSys::IOEvents::Poller::GetFault().

+ Here is the call graph for this function:

◆ Modify()

bool XrdSys::IOEvents::PollerErr1::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.

Definition at line 187 of file XrdSysIOEvents.cc.

188  {(void)isLocked;
189  if (!(eNum = GetFault(cP))) eNum = EPROTO;
190  if (eTxt) *eTxt = "modifying channel";
191  return false;
192  }

References XrdSys::IOEvents::Poller::GetFault().

+ Here is the call graph for this function:

◆ Shutdown()

void XrdSys::IOEvents::PollerErr1::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.

Definition at line 194 of file XrdSysIOEvents.cc.

194 {}

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