#include <XrdSsiTaskReal.hh>
|
void | Detach (bool force=false) |
|
void | Finished (XrdSsiRequest &rqstR, const XrdSsiRespInfo &rInfo, bool cancel=false) |
|
void * | Implementation () |
|
bool | Kill () |
|
int | ID () |
|
void | Init (XrdSsiRequest *rP, unsigned short tmo=0) |
|
void | PostError () |
|
const char * | RequestID () |
|
void | SchedError (XrdSsiErrInfo *eInfo=0) |
|
void | SendError () |
|
bool | SendRequest (const char *node) |
|
int | SetBuff (XrdSsiErrInfo &eRef, char *buff, int blen, bool &last) |
|
bool | SetBuff (XrdSsiErrInfo &eRef, char *buff, int blen) |
|
void | SetTaskID (uint32_t tid, uint32_t sid) |
|
int | XeqEvent (XrdCl::XRootDStatus *status, XrdCl::AnyObject **respP) |
|
void | XeqEvFin () |
|
| XrdSsiTaskReal (XrdSsiSessReal *sP) |
|
| ~XrdSsiTaskReal () |
|
void | AddEvent (XrdCl::XRootDStatus *st, XrdCl::AnyObject *resp) |
|
void | ClrEvent () |
|
virtual void | DoIt () |
|
virtual void | HandleResponse (XrdCl::XRootDStatus *status, XrdCl::AnyObject *response) |
|
| XrdSsiEvent () |
|
| ~XrdSsiEvent () |
|
| XrdJob (const char *desc="") |
|
virtual | ~XrdJob () |
|
Public Member Functions inherited from XrdCl::ResponseHandler |
virtual | ~ResponseHandler () |
|
virtual void | HandleResponseWithHosts (XRootDStatus *status, AnyObject *response, HostList *hostList) |
|
void | BindRequest (XrdSsiRequest &rqstR) |
|
bool | UnBindRequest () |
|
virtual Buffer * | GetBuff (XrdSsiErrInfo &eRef, int &dlen, bool &last) |
|
StreamType | Type () |
|
| XrdSsiStream (StreamType stype) |
|
virtual | ~XrdSsiStream () |
|
◆ respType
Enumerator |
---|
isBad | |
isAlert | |
isData | |
isStream | |
◆ TaskStat
Enumerator |
---|
isPend | |
isWrite | |
isSync | |
isReady | |
isDone | |
isDead | |
◆ XrdSsiTaskReal()
◆ ~XrdSsiTaskReal()
XrdSsiTaskReal::~XrdSsiTaskReal |
( |
| ) |
|
|
inline |
◆ Ask4Resp()
bool XrdSsiTaskReal::Ask4Resp |
( |
| ) |
|
|
private |
◆ Detach()
void XrdSsiTaskReal::Detach |
( |
bool |
force = false | ) |
|
◆ Finished()
Notify the responder that a request either completed or was canceled. This allows the responder to release any resources given to the request object (e.g. data response buffer or a stream). This method is invoked when XrdSsiRequest::Finished() is called by the client.
- Parameters
-
rqstR | reference to the object describing the request. |
rInfo | reference to the object describing the response. |
cancel | False -> the request/response interaction completed. True -> the request/response interaction aborted because of an error or the client requested that the request be canceled. |
Implements XrdSsiResponder.
◆ GetResp()
◆ ID()
int XrdSsiTaskReal::ID |
( |
| ) |
|
|
inline |
◆ Implementation()
void * XrdSsiTaskReal::Implementation |
( |
| ) |
|
|
inline |
◆ Init()
void XrdSsiTaskReal::Init |
( |
XrdSsiRequest * |
rP, |
|
|
unsigned short |
tmo = 0 |
|
) |
| |
|
inline |
References attList, defer, isPend, mdResp, mhPend, XrdSsiTaskReal::dlQ::next, XrdSsiTaskReal::dlQ::prev, rqstP, tmOut, tStat, and wPost.
◆ Kill()
bool XrdSsiTaskReal::Kill |
( |
| ) |
|
◆ PostError()
void XrdSsiTaskReal::PostError |
( |
| ) |
|
◆ RequestID()
const char * XrdSsiTaskReal::RequestID |
( |
| ) |
|
|
inline |
◆ RespErr()
◆ SchedError()
◆ SendError()
void XrdSsiTaskReal::SendError |
( |
| ) |
|
◆ SendRequest()
bool XrdSsiTaskReal::SendRequest |
( |
const char * |
node | ) |
|
◆ SetBuff() [1/2]
bool XrdSsiTaskReal::SetBuff |
( |
XrdSsiErrInfo & |
eRef, |
|
|
char * |
buff, |
|
|
int |
blen |
|
) |
| |
|
virtual |
Asynchronously obtain data from a passive stream (client-side only).
- Parameters
-
eRef | reference to where error information is to be placed for encountered before during the stream initiation. When data is ready for processing, the ProcessResponseData() callback is called on the request associated with this stream. Also see XrdSsiRequest::GetResponseData() helper method. |
buff | pointer to the buffer to receive the data. The buffer must remain valid until ProcessResponse() is called. |
blen | the length of the buffer (i.e. maximum that can be returned). |
- Returns
- true The stream has been successfully scheduled to return the data.
-
false The stream could not be scheduled; eRef holds the reason.
Reimplemented from XrdSsiStream.
◆ SetBuff() [2/2]
int XrdSsiTaskReal::SetBuff |
( |
XrdSsiErrInfo & |
eRef, |
|
|
char * |
buff, |
|
|
int |
blen, |
|
|
bool & |
last |
|
) |
| |
|
virtual |
Synchronously obtain data from a passive stream (client- or server-side).
- Parameters
-
eRef | The object to receive any error description. |
buff | pointer to the buffer to receive the data. request object is notified that the operation completed. |
blen | the length of the buffer (i.e. maximum that can be returned). |
last | input: should be set to false. output: if true it indicates that no more data remains to be returned either for this call or on the next call. |
- Returns
- >0 The number of bytes placed in buff.
-
=0 No more data remains and the stream becomes invalid.
-
<0 Fatal error occurred; eRef holds the reason.
Reimplemented from XrdSsiStream.
◆ SetTaskID()
void XrdSsiTaskReal::SetTaskID |
( |
uint32_t |
tid, |
|
|
uint32_t |
sid |
|
) |
| |
|
inline |
◆ XeqEvent()
◆ XeqEvFin()
void XrdSsiTaskReal::XeqEvFin |
( |
| ) |
|
|
virtual |
◆ attList
dlQ XrdSsiTaskReal::attList |
◆ dataBuff
char* XrdSsiTaskReal::dataBuff |
|
private |
◆ dataRlen
int XrdSsiTaskReal::dataRlen |
|
private |
◆ defer
int XrdSsiTaskReal::defer |
|
private |
◆ errInfo
◆ mdResp
◆ mhPend
bool XrdSsiTaskReal::mhPend |
|
private |
◆ rqstP
◆ sessP
◆ tmOut
unsigned short XrdSsiTaskReal::tmOut |
|
private |
◆ tskID
uint32_t XrdSsiTaskReal::tskID |
|
private |
◆ tStat
◆ wPost
The documentation for this class was generated from the following file: