Go to the documentation of this file. 1 #ifndef __XRDSYSIOEVENTS_HH__
2 #define __XRDSYSIOEVENTS_HH__
35 #include <sys/types.h>
131 virtual void Fatal(
Channel *chP,
void *cbArg,
int eNum,
const char *eTxt)
133 (void)chP; (void)cbArg; (void)eNum; (void)eTxt;
146 virtual void Stop(
Channel *chP,
void *cbArg) { (void)chP; (void)cbArg;}
212 bool Disable(
int events,
const char **eText=0);
248 bool Enable(
int events,
int timeout=0,
const char **eText=0);
440 bool Init(
Channel *cP,
int &eNum,
const char **eTxt,
bool &isLockd);
time_t rdDL
Definition: XrdSysIOEvents.hh:344
EventType
Events that may cause a callback object to be activated.
Definition: XrdSysIOEvents.hh:87
EventCode
Event bits used to feed Enable() and Disable(); can be or'd.
Definition: XrdSysIOEvents.hh:192
dlQ attList
Definition: XrdSysIOEvents.hh:333
int GetPollEnt(Channel *cP)
Definition: XrdSysIOEvents.hh:438
@ ReadTimeOut
Read timeout.
Definition: XrdSysIOEvents.hh:89
virtual void Fatal(Channel *chP, void *cbArg, int eNum, const char *eTxt)
Definition: XrdSysIOEvents.hh:131
virtual bool Event(Channel *chP, void *cbArg, int evFlags)=0
time_t deadLine
Definition: XrdSysIOEvents.hh:346
Channel * prev
Definition: XrdSysIOEvents.hh:329
Definition: XrdSysPthread.hh:166
@ RmFD
Definition: XrdSysIOEvents.hh:499
bool Init(Channel *cP, int &eNum, const char **eTxt, bool &isLockd)
Poller * chPoller
Definition: XrdSysIOEvents.hh:336
char dlType
Definition: XrdSysIOEvents.hh:347
bool chDead
Definition: XrdSysIOEvents.hh:511
virtual void Stop(Channel *chP, void *cbArg)
Definition: XrdSysIOEvents.hh:146
short chFault
Definition: XrdSysIOEvents.hh:354
void Detach(Channel *cP, bool &isLocked, bool keep=true)
char chEvents
Definition: XrdSysIOEvents.hh:348
@ readEvents
Read and Read Timeouts.
Definition: XrdSysIOEvents.hh:192
virtual void Begin(XrdSysSemaphore *syncp, int &rc, const char **eTxt)=0
@ isCBMode
Definition: XrdSysIOEvents.hh:350
Definition: XrdSysIOEvents.hh:496
Definition: XrdClPollerBuiltIn.hh:28
int GetFD()
Definition: XrdSysIOEvents.hh:276
@ ReadyToWrite
Writing won't block.
Definition: XrdSysIOEvents.hh:90
@ Post
Definition: XrdSysIOEvents.hh:498
friend class BootStrap
Definition: XrdSysIOEvents.hh:373
XrdSysMutex toMutex
Definition: XrdSysIOEvents.hh:527
char reMod
Definition: XrdSysIOEvents.hh:353
static time_t maxTime
Definition: XrdSysIOEvents.hh:513
char inPSet
Definition: XrdSysIOEvents.hh:352
@ allEvents
All of the above.
Definition: XrdSysIOEvents.hh:197
CallBack()
Constructor.
Definition: XrdSysIOEvents.hh:152
@ writeEvents
Write and Write Timeouts.
Definition: XrdSysIOEvents.hh:193
XrdSysMutex adMutex
Definition: XrdSysIOEvents.hh:526
int chFD
Definition: XrdSysIOEvents.hh:340
short ent
Definition: XrdSysIOEvents.hh:496
@ stopEvent
Poller stop event.
Definition: XrdSysIOEvents.hh:196
XrdSysSemaphore * theSem
Definition: XrdSysIOEvents.hh:497
void Reset(Poller *thePoller, int fd, int eNum=0)
XrdSysRecMutex chMutex
Definition: XrdSysIOEvents.hh:331
Channel * attBase
Definition: XrdSysIOEvents.hh:488
void GetCallBack(CallBack **cbP, void **cbArg)
char chStat
Definition: XrdSysIOEvents.hh:349
Definition: XrdSysPthread.hh:404
int chRTO
Definition: XrdSysIOEvents.hh:342
char inTOQ
Definition: XrdSysIOEvents.hh:351
bool CbkXeq(Channel *cP, int events, int eNum, const char *eTxt)
int GetFault(Channel *cP)
Definition: XrdSysIOEvents.hh:437
Definition: XrdSysPthread.hh:240
CreateOpts
Definition: XrdSysIOEvents.hh:398
virtual void Exclude(Channel *cP, bool &isLocked, bool dover=1)=0
@ Stop
Definition: XrdSysIOEvents.hh:499
struct pollfd pipePoll
Definition: XrdSysIOEvents.hh:493
void LockChannel(Channel *cP)
Definition: XrdSysIOEvents.hh:441
@ MiFD
Definition: XrdSysIOEvents.hh:499
void SetCallBack(CallBack *cbP, void *cbArg=0)
@ errorEvents
Error event non-r/w specific.
Definition: XrdSysIOEvents.hh:195
Channel(Poller *pollP, int fd, CallBack *cbP=0, void *cbArg=0)
PipeData reqBuff
Definition: XrdSysIOEvents.hh:506
int pipeBlen
Definition: XrdSysIOEvents.hh:508
int cmdFD
Definition: XrdSysIOEvents.hh:494
int SendCmd(PipeData &cmd)
bool Enable(int events, int timeout=0, const char **eText=0)
static Poller * Create(int &eNum, const char **eTxt=0, int crOpts=0)
@ isClear
Definition: XrdSysIOEvents.hh:350
char evt
Definition: XrdSysIOEvents.hh:496
Poller * chPollXQ
Definition: XrdSysIOEvents.hh:337
int fd
Definition: XrdSysIOEvents.hh:496
Definition: XrdSysIOEvents.hh:372
static Poller * newPoller(int pFD[2], int &eNum, const char **eTxt)
int Poll2Enum(short events)
CPP_ATOMIC_TYPE(bool) wakePend
int pollEnt
Definition: XrdSysIOEvents.hh:341
Definition: XrdSysIOEvents.hh:174
int reqFD
Definition: XrdSysIOEvents.hh:495
virtual bool Modify(Channel *cP, int &eNum, const char **eTxt, bool &isLocked)=0
@ isDead
Definition: XrdSysIOEvents.hh:350
dlQ tmoList
Definition: XrdSysIOEvents.hh:334
void UnLock()
Definition: XrdSysPthread.hh:222
~PipeData()
Definition: XrdSysIOEvents.hh:504
@ rwEvents
Both of the above.
Definition: XrdSysIOEvents.hh:194
PipeData(char reQ=0, char evT=0, short enT=0, int fD=0, XrdSysSemaphore *sP=0)
Definition: XrdSysIOEvents.hh:500
virtual ~Poller()
Destructor. Stop() is effecively called when this object is deleted.
Definition: XrdSysIOEvents.hh:430
void Lock()
Definition: XrdSysPthread.hh:220
char req
Definition: XrdSysIOEvents.hh:496
@ ReadyToRead
New data has arrived.
Definition: XrdSysIOEvents.hh:88
int chWTO
Definition: XrdSysIOEvents.hh:343
~Channel()
Destuctor is private, use Delete() to delete this object.
Definition: XrdSysIOEvents.hh:327
virtual bool Include(Channel *cP, int &eNum, const char **eTxt, bool &isLocked)=0
@ optTOM
Definition: XrdSysIOEvents.hh:398
char * pipeBuff
Definition: XrdSysIOEvents.hh:507
@ ValidEvents
Mask to test for valid events.
Definition: XrdSysIOEvents.hh:92
Definition: XrdSysIOEvents.hh:329
unsigned char tmoMask
Definition: XrdSysIOEvents.hh:509
int GetEvents()
Definition: XrdSysIOEvents.hh:267
void UnLockChannel(Channel *cP)
Definition: XrdSysIOEvents.hh:448
virtual void Shutdown()=0
@ WriteTimeOut
Write timeout.
Definition: XrdSysIOEvents.hh:91
pthread_t pollTid
Definition: XrdSysIOEvents.hh:491
bool TmoAdd(Channel *cP, int tmoSet)
Channel * next
Definition: XrdSysIOEvents.hh:329
cmd
Definition: XrdSysIOEvents.hh:498
Channel * tmoBase
Definition: XrdSysIOEvents.hh:489
time_t wrDL
Definition: XrdSysIOEvents.hh:345
void SetPollEnt(Channel *cP, int ptEnt)
CallBack * chCB
Definition: XrdSysIOEvents.hh:338
virtual ~CallBack()
Destructor.
Definition: XrdSysIOEvents.hh:158
Status
Definition: XrdSysIOEvents.hh:350
bool Disable(int events, const char **eText=0)
@ NoOp
Definition: XrdSysIOEvents.hh:498
Definition: XrdSysIOEvents.hh:79
void * chCBA
Definition: XrdSysIOEvents.hh:339
@ MdFD
Definition: XrdSysIOEvents.hh:498