xrootd
XrdSsiFileReq.hh
Go to the documentation of this file.
1 #ifndef __SSI_FILEREQ_H__
2 #define __SSI_FILEREQ_H__
3 /******************************************************************************/
4 /* */
5 /* X r d S s i F i l e R e q . h h */
6 /* */
7 /* (c) 2013 by the Board of Trustees of the Leland Stanford, Jr., University */
8 /* Produced by Andrew Hanushevsky for Stanford University under contract */
9 /* DE-AC02-76-SFO0515 with the Department of Energy */
10 /* */
11 /* This file is part of the XRootD software suite. */
12 /* */
13 /* XRootD is free software: you can redistribute it and/or modify it under */
14 /* the terms of the GNU Lesser General Public License as published by the */
15 /* Free Software Foundation, either version 3 of the License, or (at your */
16 /* option) any later version. */
17 /* */
18 /* XRootD is distributed in the hope that it will be useful, but WITHOUT */
19 /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
20 /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
21 /* License for more details. */
22 /* */
23 /* You should have received a copy of the GNU Lesser General Public License */
24 /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
25 /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
26 /* */
27 /* The copyright holder's institutional names and contributor's names may not */
28 /* be used to endorse or promote products derived from this software without */
29 /* specific prior written permission of the institution or contributor. */
30 /******************************************************************************/
31 
32 #include <string.h>
33 #include <sys/types.h>
34 
35 #include "Xrd/XrdJob.hh"
36 #include "Xrd/XrdScheduler.hh"
38 #include "XrdSfs/XrdSfsXio.hh"
39 #include "XrdSsi/XrdSsiRequest.hh"
41 #include "XrdSsi/XrdSsiStream.hh"
42 #include "XrdSys/XrdSysPthread.hh"
43 
44 class XrdOucErrInfo;
45 class XrdSsiAlert;
46 class XrdSsiFileResource;
47 class XrdSsiFileSess;
48 class XrdSsiRespInfoMsg;
49 class XrdSsiRRInfo;
50 class XrdSsiService;
51 class XrdSsiStream;
52 
53 class XrdSsiFileReq : public XrdSsiRequest, public XrdOucEICB, public XrdJob
54 {
55 public:
56 
57 
58 // SsiRequest methods
59 //
60  void Activate(XrdOucBuffer *oP, XrdSfsXioHandle bR, int rSz);
61 
62  void Alert(XrdSsiRespInfoMsg &aMsg);
63 
65  XrdSsiFileSess *fP, const char *sn,
66  const char *id, unsigned int rnum);
67 
68  void Finalize();
69 
71 
72  void Finished( XrdSsiRequest &rqstR,
73  const XrdSsiRespInfo &rInfo,
74  bool cancel=false) {}
75 
76  char *GetRequest(int &rLen);
77 
78  bool ProcessResponse(const XrdSsiErrInfo &eInfo,
79  const XrdSsiRespInfo &resp);
80 
81  XrdSfsXferSize Read(bool &done,
82  char *buffer,
83  XrdSfsXferSize blen);
84 
85  void RelRequestBuffer();
86 
87  int Send(XrdSfsDio *sfDio, XrdSfsXferSize size);
88 
89 static void SetMax(int mVal) {freeMax = mVal;}
90 
91  bool WantResponse(XrdOucErrInfo &eInfo);
92 
93 // OucEICB methods
94 //
95  void Done(int &Result, XrdOucErrInfo *cbInfo,
96  const char *path=0);
97 
98  int Same(unsigned long long arg1, unsigned long long arg2)
99  {return 0;}
100 // Job methods
101 //
102  void DoIt();
103 
104 // Constructor and destructor
105 //
106  XrdSsiFileReq(const char *cID=0)
107  : frqMutex(XrdSsiMutex::Recursive)
108  {Init(cID);}
109 
110 virtual ~XrdSsiFileReq() {if (tident) free(tident);}
111 
114 
115 private:
116 
117 void BindDone(); // Override
118 void Dispose(); // Override
119 int Emsg(const char *pfx, int ecode, const char *op);
120 int Emsg(const char *pfx, XrdSsiErrInfo &eObj,
121  const char *op);
122 void Init(const char *cID=0);
123 XrdSfsXferSize readStrmA(XrdSsiStream *strmP, char *buff,
124  XrdSfsXferSize blen);
125 XrdSfsXferSize readStrmP(XrdSsiStream *strmP, char *buff,
126  XrdSfsXferSize blen);
127 int sendStrmA(XrdSsiStream *strmP, XrdSfsDio *sfDio,
128  XrdSfsXferSize blen);
129 void Recycle();
130 void WakeUp(XrdSsiAlert *aP=0);
131 
134 static int freeCnt;
135 static int freeMax;
136 
141 unsigned long long respCBarg;
142 
146 
147 char *tident;
148 const char *sessN;
152 char *respBuf;
153 long long respOff;
154 union {long long fileSz;
155  int respLen;
156  };
163 unsigned int reqID;
164 bool haveResp;
165 bool respWait;
166 bool strmEOF;
168 bool isEnding;
169 char rID[8];
170 };
171 #endif
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)
void RelRequestBuffer()
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:165
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:405
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
Definition: XrdJob.hh:42
XrdOucBuffer * oucBuff
Definition: XrdSsiFileReq.hh:158