1 #ifndef __XRDSYSIOEVENTS_HH__
2 #define __XRDSYSIOEVENTS_HH__
35 #include <sys/types.h>
115 virtual bool Event(
Channel *chP,
void *cbArg,
int evFlags) = 0;
130 virtual void Fatal(
Channel *chP,
void *cbArg,
int eNum,
const char *eTxt)
132 (void)chP; (void)cbArg; (void)eNum; (void)eTxt;
145 virtual void Stop(
Channel *chP,
void *cbArg) { (void)chP; (void)cbArg;}
211 bool Disable(
int events,
const char **eText=0);
247 bool Enable(
int events,
int timeout=0,
const char **eText=0);
399 static Poller *
Create(
int &eNum,
const char **eTxt=0,
int crOpts=0);
435 bool CbkXeq(
Channel *cP,
int events,
int eNum,
const char *eTxt);
439 bool Init(
Channel *cP,
int &eNum,
const char **eTxt,
bool &isLockd);
458 virtual void Exclude(
Channel *cP,
bool &isLocked,
bool dover=1) = 0;
Channel * prev
Definition: XrdSysIOEvents.hh:328
time_t wrDL
Definition: XrdSysIOEvents.hh:344
static Poller * newPoller(int pFD[2], int &eNum, const char **eTxt)
Definition: XrdSysIOEvents.hh:497
Definition: XrdSysPthread.hh:168
int GetEvents()
Definition: XrdSysIOEvents.hh:266
char chEvents
Definition: XrdSysIOEvents.hh:347
virtual void Exclude(Channel *cP, bool &isLocked, bool dover=1)=0
char dlType
Definition: XrdSysIOEvents.hh:346
int reqFD
Definition: XrdSysIOEvents.hh:494
Channel * attBase
Definition: XrdSysIOEvents.hh:487
virtual void Stop(Channel *chP, void *cbArg)
Definition: XrdSysIOEvents.hh:145
Status
Definition: XrdSysIOEvents.hh:349
Definition: XrdSysIOEvents.hh:498
virtual void Fatal(Channel *chP, void *cbArg, int eNum, const char *eTxt)
Definition: XrdSysIOEvents.hh:130
int GetFD()
Definition: XrdSysIOEvents.hh:275
int cmdFD
Definition: XrdSysIOEvents.hh:493
int SendCmd(PipeData &cmd)
Write and Write Timeouts.
Definition: XrdSysIOEvents.hh:192
dlQ attList
Definition: XrdSysIOEvents.hh:332
time_t deadLine
Definition: XrdSysIOEvents.hh:345
virtual bool Include(Channel *cP, int &eNum, const char **eTxt, bool &isLocked)=0
Channel * next
Definition: XrdSysIOEvents.hh:328
virtual ~CallBack()
Destructor.
Definition: XrdSysIOEvents.hh:157
int Poll2Enum(short events)
virtual ~Poller()
Destructor. Stop() is effecively called when this object is deleted.
Definition: XrdSysIOEvents.hh:429
Definition: XrdSysIOEvents.hh:349
static Poller * Create(int &eNum, const char **eTxt=0, int crOpts=0)
virtual void Shutdown()=0
bool TmoAdd(Channel *cP, int tmoSet)
All of the above.
Definition: XrdSysIOEvents.hh:196
char reMod
Definition: XrdSysIOEvents.hh:352
virtual bool Modify(Channel *cP, int &eNum, const char **eTxt, bool &isLocked)=0
Poller * chPoller
Definition: XrdSysIOEvents.hh:335
char inPSet
Definition: XrdSysIOEvents.hh:351
Channel * tmoBase
Definition: XrdSysIOEvents.hh:488
short chFault
Definition: XrdSysIOEvents.hh:353
Error event non-r/w specific.
Definition: XrdSysIOEvents.hh:194
Poller stop event.
Definition: XrdSysIOEvents.hh:195
char tmoMask
Definition: XrdSysIOEvents.hh:508
Read and Read Timeouts.
Definition: XrdSysIOEvents.hh:191
Definition: XrdSysIOEvents.hh:349
XrdSysRecMutex chMutex
Definition: XrdSysIOEvents.hh:330
char * pipeBuff
Definition: XrdSysIOEvents.hh:506
Definition: XrdSysIOEvents.hh:349
Definition: XrdSysPthread.hh:140
bool wakePend
Definition: XrdSysIOEvents.hh:509
short ent
Definition: XrdSysIOEvents.hh:495
Mask to test for valid events.
Definition: XrdSysIOEvents.hh:91
Channel(Poller *pollP, int fd, CallBack *cbP=0, void *cbArg=0)
Definition: XrdSysIOEvents.hh:77
char chStat
Definition: XrdSysIOEvents.hh:348
Definition: XrdSysIOEvents.hh:495
void UnLockChannel(Channel *cP)
Definition: XrdSysIOEvents.hh:447
pthread_t pollTid
Definition: XrdSysIOEvents.hh:490
int GetPollEnt(Channel *cP)
Definition: XrdSysIOEvents.hh:437
void Reset(Poller *thePoller, int fd, int eNum=0)
void SetCallBack(CallBack *cbP, void *cbArg=0)
void SetPollEnt(Channel *cP, int ptEnt)
void GetCallBack(CallBack **cbP, void **cbArg)
Read timeout.
Definition: XrdSysIOEvents.hh:88
~PipeData()
Definition: XrdSysIOEvents.hh:503
Definition: XrdSysPthread.hh:329
Definition: XrdSysIOEvents.hh:370
int chFD
Definition: XrdSysIOEvents.hh:339
EventType
Events that may cause a callback object to be activated.
Definition: XrdSysIOEvents.hh:85
Definition: XrdSysIOEvents.hh:328
Definition: XrdSysIOEvents.hh:497
char req
Definition: XrdSysIOEvents.hh:495
Writing won't block.
Definition: XrdSysIOEvents.hh:89
Definition: XrdSysIOEvents.hh:497
int chRTO
Definition: XrdSysIOEvents.hh:341
char inTOQ
Definition: XrdSysIOEvents.hh:350
Write timeout.
Definition: XrdSysIOEvents.hh:90
XrdSysSemaphore * theSem
Definition: XrdSysIOEvents.hh:496
void Detach(Channel *cP, bool &isLocked, bool keep=true)
bool Init(Channel *cP, int &eNum, const char **eTxt, bool &isLockd)
bool Enable(int events, int timeout=0, const char **eText=0)
virtual void Begin(XrdSysSemaphore *syncp, int &rc, const char **eTxt)=0
char evt
Definition: XrdSysIOEvents.hh:495
Poller * chPollXQ
Definition: XrdSysIOEvents.hh:336
void Lock()
Definition: XrdSysPthread.hh:149
bool chDead
Definition: XrdSysIOEvents.hh:510
Definition: XrdSysIOEvents.hh:498
Both of the above.
Definition: XrdSysIOEvents.hh:193
PipeData(char reQ=0, char evT=0, short enT=0, int fD=0, XrdSysSemaphore *sP=0)
Definition: XrdSysIOEvents.hh:499
int fd
Definition: XrdSysIOEvents.hh:495
XrdSysMutex toMutex
Definition: XrdSysIOEvents.hh:526
Definition: XrdSysIOEvents.hh:498
int chWTO
Definition: XrdSysIOEvents.hh:342
virtual bool Event(Channel *chP, void *cbArg, int evFlags)=0
static time_t maxTime
Definition: XrdSysIOEvents.hh:512
Definition: XrdSysIOEvents.hh:172
int pollEnt
Definition: XrdSysIOEvents.hh:340
XrdSysMutex adMutex
Definition: XrdSysIOEvents.hh:525
CallBack()
Constructor.
Definition: XrdSysIOEvents.hh:151
friend class BootStrap
Definition: XrdSysIOEvents.hh:372
EventCode
Event bits used to feed Enable() and Disable(); can be or'd.
Definition: XrdSysIOEvents.hh:191
void UnLock()
Definition: XrdSysPthread.hh:151
struct pollfd pipePoll
Definition: XrdSysIOEvents.hh:492
void LockChannel(Channel *cP)
Definition: XrdSysIOEvents.hh:440
Definition: XrdSysIOEvents.hh:397
dlQ tmoList
Definition: XrdSysIOEvents.hh:333
CallBack * chCB
Definition: XrdSysIOEvents.hh:337
bool Disable(int events, const char **eText=0)
cmd
Definition: XrdSysIOEvents.hh:497
bool CbkXeq(Channel *cP, int events, int eNum, const char *eTxt)
void * chCBA
Definition: XrdSysIOEvents.hh:338
PipeData reqBuff
Definition: XrdSysIOEvents.hh:505
int GetFault(Channel *cP)
Definition: XrdSysIOEvents.hh:436
int pipeBlen
Definition: XrdSysIOEvents.hh:507
time_t rdDL
Definition: XrdSysIOEvents.hh:343
CreateOpts
Definition: XrdSysIOEvents.hh:397
New data has arrived.
Definition: XrdSysIOEvents.hh:87
~Channel()
Destuctor is private, use Delete() to delete this object.
Definition: XrdSysIOEvents.hh:326