XRootD
XrdSsiFileSess.hh
Go to the documentation of this file.
1 #ifndef __SSI_FILESESS_H__
2 #define __SSI_FILESESS_H__
3 /******************************************************************************/
4 /* */
5 /* X r d S s i F i l e S e s s . h h */
6 /* */
7 /* (c) 2016 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 <cstring>
33 #include <sys/types.h>
34 
36 #include "XrdSfs/XrdSfsXio.hh"
37 #include "XrdSsi/XrdSsiBVec.hh"
38 #include "XrdSsi/XrdSsiFileReq.hh"
40 #include "XrdSsi/XrdSsiRRTable.hh"
41 #include "XrdSys/XrdSysPthread.hh"
42 
43 class XrdOucEnv;
44 struct XrdSsiRespInfo;
45 
47 {
48 public:
49 
50 static XrdSsiFileSess *Alloc(XrdOucErrInfo &einfo, const char *user);
51 
52  bool AttnInfo( XrdOucErrInfo &eInfo,
53  const XrdSsiRespInfo *respP,
54  unsigned int reqID);
55 
56  XrdOucErrInfo *errInfo() {return eInfo;}
57 
58  int close(bool viaDel=false);
59 
60  int fctl(const int cmd,
61  int alen,
62  const char *args,
63  const XrdSecEntity *client);
64 
65  const char *FName() {return gigID;}
66 
67  int open(const char *fileName,
69  XrdSfsFileOpenMode openMode);
70 
72  char *buffer,
73  XrdSfsXferSize buffer_size);
74 
75  void Recycle();
76 
77 XrdSsiFileResource &Resource() {return fileResource;}
78 
79  int SendData(XrdSfsDio *sfDio,
80  XrdSfsFileOffset offset,
81  XrdSfsXferSize size);
82 
83 static void SetAuthDNS() {authDNS = true;}
84 
85  void setXio(XrdSfsXio *xP) {xioP = xP;}
86 
87  int truncate(XrdSfsFileOffset fileOffset);
88 
90  const char *buffer,
91  XrdSfsXferSize buffer_size);
92 
93 private:
94 
95 // Constructor (via Alloc()) and destructor (via Recycle())
96 //
97  XrdSsiFileSess(XrdOucErrInfo &einfo, const char *user)
98  {Init(einfo, user, false);}
99  ~XrdSsiFileSess() {} // Recycle() calls Reset()
100 
101 void Init(XrdOucErrInfo &einfo, const char *user, bool forReuse);
102 bool NewRequest(unsigned int reqid, XrdOucBuffer *oP,
103  XrdSfsXioHandle bR, int rSz);
104 void Reset();
105 XrdSfsXferSize writeAdd(const char *buff, XrdSfsXferSize blen,
106  unsigned int rid);
107 
108 static XrdSysMutex arMutex; // Alloc and Recycle protector
109 static XrdSsiFileSess *freeList;
110 static int freeNum;
111 static int freeNew;
112 static int freeMax;
113 static int freeAbs;
114 static bool authDNS;
115 
116 XrdSsiFileResource fileResource;
117 char *tident;
118 XrdOucErrInfo *eInfo;
119 char *gigID;
120 char *fsUser;
121 XrdSysMutex myMutex;
122 XrdSfsXio *xioP;
123 XrdOucBuffer *oucBuff;
124 XrdSsiFileSess *nextFree;
125 int reqSize;
126 int reqLeft;
127 bool isOpen;
128 bool inProg;
129 
130 XrdSsiBVec eofVec;
132 };
133 #endif
int XrdSfsFileOpenMode
long long XrdSfsFileOffset
int XrdSfsXferSize
class XrdBuffer * XrdSfsXioHandle
Definition: XrdSfsXio.hh:46
void setXio(XrdSfsXio *xP)
int fctl(const int cmd, int alen, const char *args, const XrdSecEntity *client)
int open(const char *fileName, XrdOucEnv &theEnv, XrdSfsFileOpenMode openMode)
XrdOucErrInfo * errInfo()
XrdSsiFileResource & Resource()
int close(bool viaDel=false)
XrdSfsXferSize write(XrdSfsFileOffset fileOffset, const char *buffer, XrdSfsXferSize buffer_size)
bool AttnInfo(XrdOucErrInfo &eInfo, const XrdSsiRespInfo *respP, unsigned int reqID)
static void SetAuthDNS()
XrdSfsXferSize read(XrdSfsFileOffset fileOffset, char *buffer, XrdSfsXferSize buffer_size)
const char * FName()
int truncate(XrdSfsFileOffset fileOffset)
int SendData(XrdSfsDio *sfDio, XrdSfsFileOffset offset, XrdSfsXferSize size)
static XrdSsiFileSess * Alloc(XrdOucErrInfo &einfo, const char *user)
XrdOucEnv theEnv