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);
122 void Init(
const char *cID=0);
long long fileSz
Definition: XrdSsiFileReq.hh:154
Definition: XrdSsiAtomics.hh:109
Definition: XrdSsiStream.hh:63
Definition: XrdSsiRespInfo.hh:43
bool strmEOF
Definition: XrdSsiFileReq.hh:166
static int freeMax
Definition: XrdSsiFileReq.hh:135
XrdSsiFileReq * nextReq
Definition: XrdSsiFileReq.hh:138
void Alert(XrdSsiRespInfoMsg &aMsg)
Send or receive a server generated alert.
XrdSsiFileReq(const char *cID=0)
Definition: XrdSsiFileReq.hh:106
char * tident
Definition: XrdSsiFileReq.hh:147
bool WantResponse(XrdOucErrInfo &eInfo)
int respLen
Definition: XrdSsiFileReq.hh:155
Definition: XrdSsiFileReq.hh:113
Definition: XrdSsiFileReq.hh:113
char rID[8]
Definition: XrdSsiFileReq.hh:169
virtual ~XrdSsiFileReq()
Definition: XrdSsiFileReq.hh:110
XrdSsiAlert * alrtSent
Definition: XrdSsiFileReq.hh:143
unsigned long long respCBarg
Definition: XrdSsiFileReq.hh:141
rspState
Definition: XrdSsiFileReq.hh:113
bool isEnding
Definition: XrdSsiFileReq.hh:168
Definition: XrdSsiRespInfo.hh:86
XrdSsiFileSess * fileP
Definition: XrdSsiFileReq.hh:151
Definition: XrdSsiFileSess.hh:46
int XrdSfsXferSize
Definition: XrdSfsInterface.hh:129
static XrdSsiFileReq * freeReq
Definition: XrdSsiFileReq.hh:133
Definition: XrdSsiFileReq.hh:112
bool respWait
Definition: XrdSsiFileReq.hh:165
static XrdSsiFileReq * Alloc(XrdOucErrInfo *eP, XrdSsiFileResource *rP, XrdSsiFileSess *fP, const char *sn, const char *id, unsigned int rnum)
char * GetRequest(int &rLen)
XrdSsiAlert * alrtPend
Definition: XrdSsiFileReq.hh:144
char * respBuf
Definition: XrdSsiFileReq.hh:152
Definition: XrdSsiFileReq.hh:113
Definition: XrdSsiRRInfo.hh:37
Definition: XrdSsiFileReq.hh:113
int Same(unsigned long long arg1, unsigned long long arg2)
Definition: XrdSsiFileReq.hh:98
reqState myState
Definition: XrdSsiFileReq.hh:160
XrdOucEICB * respCB
Definition: XrdSsiFileReq.hh:140
void Init(const char *cID=0)
Definition: XrdSsiService.hh:54
Definition: XrdSsiFileReq.hh:112
bool Finished(bool cancel=false)
void Done(int &Result, XrdOucErrInfo *cbInfo, const char *path=0)
void WakeUp(XrdSsiAlert *aP=0)
Definition: XrdSysPthread.hh:164
int Emsg(const char *pfx, int ecode, const char *op)
Definition: XrdSsiFileReq.hh:112
unsigned int reqID
Definition: XrdSsiFileReq.hh:163
bool ProcessResponse(const XrdSsiErrInfo &eInfo, const XrdSsiRespInfo &resp)
XrdSfsXioHandle sfsBref
Definition: XrdSsiFileReq.hh:157
XrdSfsXferSize readStrmP(XrdSsiStream *strmP, char *buff, XrdSfsXferSize blen)
Definition: XrdOucErrInfo.hh:100
int reqSize
Definition: XrdSsiFileReq.hh:162
rspState urState
Definition: XrdSsiFileReq.hh:161
Definition: XrdSysPthread.hh:493
long long respOff
Definition: XrdSsiFileReq.hh:153
bool schedDone
Definition: XrdSsiFileReq.hh:167
XrdSsiStream::Buffer * strBuff
Definition: XrdSsiFileReq.hh:159
Definition: XrdSsiFileReq.hh:112
Definition: XrdSsiFileReq.hh:113
Definition: XrdSsiFileReq.hh:112
reqState
Definition: XrdSsiFileReq.hh:112
XrdSsiFileResource * fileR
Definition: XrdSsiFileReq.hh:150
Definition: XrdSsiFileReq.hh:53
const char * sessN
Definition: XrdSsiFileReq.hh:148
int Send(XrdSfsDio *sfDio, XrdSfsXferSize size)
Definition: XrdSsiStream.hh:53
Definition: XrdSsiErrInfo.hh:40
Definition: XrdSsiFileReq.hh:112
bool haveResp
Definition: XrdSsiFileReq.hh:164
Definition: XrdSsiRequest.hh:70
Definition: XrdOucBuffer.hh:140
XrdSsiMutex frqMutex
Definition: XrdSsiFileReq.hh:137
Definition: XrdSsiFileReq.hh:112
static XrdSysMutex aqMutex
Definition: XrdSsiFileReq.hh:132
int sendStrmA(XrdSsiStream *strmP, XrdSfsDio *sfDio, XrdSfsXferSize blen)
static void SetMax(int mVal)
Definition: XrdSsiFileReq.hh:89
XrdSysSemaphore * finWait
Definition: XrdSsiFileReq.hh:139
Definition: XrdSfsDio.hh:46
void Activate(XrdOucBuffer *oP, XrdSfsXioHandle bR, int rSz)
Definition: XrdSsiFileResource.hh:41
static int freeCnt
Definition: XrdSsiFileReq.hh:134
Definition: XrdOucErrInfo.hh:484
Definition: XrdSsiFileReq.hh:113
XrdSfsXferSize Read(bool &done, char *buffer, XrdSfsXferSize blen)
XrdSsiAlert * alrtLast
Definition: XrdSsiFileReq.hh:145
Definition: XrdSsiAlert.hh:37
void Finished(XrdSsiRequest &rqstR, const XrdSsiRespInfo &rInfo, bool cancel=false)
Definition: XrdSsiFileReq.hh:72
XrdSfsXferSize readStrmA(XrdSsiStream *strmP, char *buff, XrdSfsXferSize blen)
XrdOucErrInfo * cbInfo
Definition: XrdSsiFileReq.hh:149
class XrdBuffer * XrdSfsXioHandle
Definition: XrdSfsXio.hh:46
XrdOucBuffer * oucBuff
Definition: XrdSsiFileReq.hh:158