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