Go to the documentation of this file. 1 #ifndef __SSI_FILEREQ_H__
2 #define __SSI_FILEREQ_H__
33 #include <sys/types.h>
66 const char *
id,
unsigned int rnum);
98 int Same(
unsigned long long arg1,
unsigned long long arg2)
119 int Emsg(
const char *pfx,
int ecode,
const char *op);
const char * sessN
Definition: XrdSsiFileReq.hh:148
bool strmEOF
Definition: XrdSsiFileReq.hh:166
XrdSsiMutex frqMutex
Definition: XrdSsiFileReq.hh:137
bool Finished(bool cancel=false)
static XrdSysMutex aqMutex
Definition: XrdSsiFileReq.hh:132
XrdSfsXferSize Read(bool &done, char *buffer, XrdSfsXferSize blen)
@ erRsp
Definition: XrdSsiFileReq.hh:112
bool WantResponse(XrdOucErrInfo &eInfo)
Definition: XrdSysPthread.hh:166
XrdOucEICB * respCB
Definition: XrdSsiFileReq.hh:140
char rID[8]
Definition: XrdSsiFileReq.hh:169
bool respWait
Definition: XrdSsiFileReq.hh:165
Definition: XrdSsiFileResource.hh:42
XrdOucBuffer * oucBuff
Definition: XrdSsiFileReq.hh:158
@ isDone
Definition: XrdSsiFileReq.hh:113
static void SetMax(int mVal)
Definition: XrdSsiFileReq.hh:89
int sendStrmA(XrdSsiStream *strmP, XrdSfsDio *sfDio, XrdSfsXferSize blen)
char * GetRequest(int &rLen)
Definition: XrdSsiFileReq.hh:54
void WakeUp(XrdSsiAlert *aP=0)
rspState urState
Definition: XrdSsiFileReq.hh:161
int reqSize
Definition: XrdSsiFileReq.hh:162
int respLen
Definition: XrdSsiFileReq.hh:155
class XrdBuffer * XrdSfsXioHandle
Definition: XrdSfsXio.hh:46
XrdSsiFileReq * nextReq
Definition: XrdSsiFileReq.hh:138
long long respOff
Definition: XrdSsiFileReq.hh:153
int XrdSfsXferSize
Definition: XrdSfsInterface.hh:129
bool schedDone
Definition: XrdSsiFileReq.hh:167
XrdSysSemaphore * finWait
Definition: XrdSsiFileReq.hh:139
void Alert(XrdSsiRespInfoMsg &aMsg)
Send or receive a server generated alert.
virtual ~XrdSsiFileReq()
Definition: XrdSsiFileReq.hh:110
Definition: XrdSsiRespInfo.hh:87
void Activate(XrdOucBuffer *oP, XrdSfsXioHandle bR, int rSz)
void Done(int &Result, XrdOucErrInfo *cbInfo, const char *path=0)
@ isMax
Definition: XrdSsiFileReq.hh:113
Definition: XrdSsiRRInfo.hh:38
unsigned long long respCBarg
Definition: XrdSsiFileReq.hh:141
rspState
Definition: XrdSsiFileReq.hh:113
bool isEnding
Definition: XrdSsiFileReq.hh:168
int Send(XrdSfsDio *sfDio, XrdSfsXferSize size)
static int freeCnt
Definition: XrdSsiFileReq.hh:134
Definition: XrdSsiAtomics.hh:110
@ odRsp
Definition: XrdSsiFileReq.hh:112
int Emsg(const char *pfx, XrdSsiErrInfo &eObj, const char *op)
reqState
Definition: XrdSsiFileReq.hh:112
bool ProcessResponse(const XrdSsiErrInfo &eInfo, const XrdSsiRespInfo &resp)
Definition: XrdSsiRequest.hh:71
Definition: XrdOucErrInfo.hh:483
XrdSsiStream::Buffer * strBuff
Definition: XrdSsiFileReq.hh:159
XrdSfsXioHandle sfsBref
Definition: XrdSsiFileReq.hh:157
Definition: XrdSsiErrInfo.hh:41
@ rsEnd
Definition: XrdSsiFileReq.hh:112
void Finished(XrdSsiRequest &rqstR, const XrdSsiRespInfo &rInfo, bool cancel=false)
Definition: XrdSsiFileReq.hh:72
XrdSsiAlert * alrtLast
Definition: XrdSsiFileReq.hh:145
int Emsg(const char *pfx, int ecode, const char *op)
bool haveResp
Definition: XrdSsiFileReq.hh:164
char * tident
Definition: XrdSsiFileReq.hh:147
XrdOucErrInfo * cbInfo
Definition: XrdSsiFileReq.hh:149
void Init(const char *cID=0)
Definition: XrdSysPthread.hh:404
@ isBegun
Definition: XrdSsiFileReq.hh:113
@ isNew
Definition: XrdSsiFileReq.hh:113
XrdSsiAlert * alrtSent
Definition: XrdSsiFileReq.hh:143
Definition: XrdSsiStream.hh:64
unsigned int reqID
Definition: XrdSsiFileReq.hh:163
static int freeMax
Definition: XrdSsiFileReq.hh:135
XrdSsiAlert * alrtPend
Definition: XrdSsiFileReq.hh:144
XrdSfsXferSize readStrmP(XrdSsiStream *strmP, char *buff, XrdSfsXferSize blen)
Definition: XrdSsiAlert.hh:38
Definition: XrdSsiFileSess.hh:47
Definition: XrdSsiStream.hh:54
@ isBound
Definition: XrdSsiFileReq.hh:113
int Same(unsigned long long arg1, unsigned long long arg2)
Definition: XrdSsiFileReq.hh:98
@ isAbort
Definition: XrdSsiFileReq.hh:113
XrdSfsXferSize readStrmA(XrdSsiStream *strmP, char *buff, XrdSfsXferSize blen)
XrdSsiFileReq(const char *cID=0)
Definition: XrdSsiFileReq.hh:106
Definition: XrdSfsDio.hh:47
XrdSsiFileResource * fileR
Definition: XrdSsiFileReq.hh:150
Definition: XrdOucErrInfo.hh:99
static XrdSsiFileReq * Alloc(XrdOucErrInfo *eP, XrdSsiFileResource *rP, XrdSsiFileSess *fP, const char *sn, const char *id, unsigned int rnum)
@ wtRsp
Definition: XrdSsiFileReq.hh:112
reqState myState
Definition: XrdSsiFileReq.hh:160
Definition: XrdSsiService.hh:55
XrdSsiFileSess * fileP
Definition: XrdSsiFileReq.hh:151
static XrdSsiFileReq * freeReq
Definition: XrdSsiFileReq.hh:133
long long fileSz
Definition: XrdSsiFileReq.hh:154
Definition: XrdSsiRespInfo.hh:44
Definition: XrdOucBuffer.hh:141
@ doRsp
Definition: XrdSsiFileReq.hh:112
@ xqReq
Definition: XrdSsiFileReq.hh:112
char * respBuf
Definition: XrdSsiFileReq.hh:152
@ wtReq
Definition: XrdSsiFileReq.hh:112