#include <XrdSsiEvent.hh>
Definition at line 36 of file XrdSsiEvent.hh.
◆ XrdSsiEvent()
XrdSsiEvent::XrdSsiEvent |
( |
| ) |
|
|
inline |
Definition at line 54 of file XrdSsiEvent.hh.
55 running(
false), isClear(
true)
XrdJob(const char *desc="")
References tident.
◆ ~XrdSsiEvent()
XrdSsiEvent::~XrdSsiEvent |
( |
| ) |
|
|
inline |
◆ AddEvent()
Definition at line 56 of file XrdSsiEvent.cc.
63 DEBUG(
"New event: isClear=" <<isClear <<
" running=" <<running);
69 if (!thisEvent.status)
70 {thisEvent.status = st;
71 thisEvent.response = resp;
83 EventData *edP = freeEvent;
84 if (!edP) edP =
new EventData(st, resp);
85 else {freeEvent = edP->next;
94 if (lastEvent) lastEvent->next = edP;
95 else thisEvent .next = edP;
void Schedule(XrdJob *jp)
References DEBUG, EPNAME, XrdSsi::schedP, and XrdScheduler::Schedule().
Referenced by HandleResponse().
◆ ClrEvent()
void XrdSsiEvent::ClrEvent |
( |
| ) |
|
|
inline |
◆ DoIt()
void XrdSsiEvent::DoIt |
( |
| ) |
|
|
virtual |
Implements XrdJob.
Definition at line 148 of file XrdSsiEvent.cc.
151 EventData *edP, myEvent;
162 do{thisEvent.Move2(myEvent);
168 do {
if ((rc =
XeqEvent(edP->status, &edP->response)) != 0)
break;
175 {
DEBUG(
"XeqEvent requested " <<(rc < 0 ?
"halt" :
"flush"));
182 }
while(thisEvent.status);
virtual void XeqEvFin()=0
virtual int XeqEvent(XrdCl::XRootDStatus *st, XrdCl::AnyObject **resp)=0
References DEBUG, and EPNAME.
◆ HandleResponse()
Called when a response to associated request arrives or an error occurs
- Parameters
-
status | status of the request |
response | an object associated with the response (request dependent) |
Reimplemented from XrdCl::ResponseHandler.
Definition at line 46 of file XrdSsiEvent.hh.
void AddEvent(XrdCl::XRootDStatus *st, XrdCl::AnyObject *resp)
References AddEvent().
◆ XeqEvent()
◆ XeqEvFin()
virtual void XrdSsiEvent::XeqEvFin |
( |
| ) |
|
|
pure virtual |
◆ tident
char XrdSsiEvent::tident[24] |
|
protected |
The documentation for this class was generated from the following files: