xrootd
XrdFrmConfig.hh
Go to the documentation of this file.
1 #ifndef _XRD_FRMCONFIG_H
2 #define _XRD_FRMCONFIG_H
3 /******************************************************************************/
4 /* */
5 /* X r d F r m C o n f i g . h h */
6 /* */
7 /* (C) 2009 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 Deprtment 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 <unistd.h>
34 
35 #include "XrdOss/XrdOssSpace.hh"
36 
37 class XrdCks;
38 class XrdNetCmsNotify;
39 class XrdOfsConfigPI;
40 class XrdOss;
41 class XrdOucMsubs;
42 class XrdOucName2Name;
43 class XrdOucProg;
44 class XrdOucStream;
45 class XrdOucTList;
46 class XrdSysLogger;
47 
48 class XrdFrmConfigSE;
49 
50 struct XrdVersionInfo;
51 struct stat;
52 
54 {
55 public:
56 
57 const char *myProg;
58 const char *myName;
59 const char *myInst;
60 const char *mySite;
61 const char *myFrmid;
62 const char *myFrmID;
63 const char *lockFN;
64 char *AdminPath;
65 char *QPath;
66 char *PidPath;
67 char *myInstance;
68 char *StopPurge;
69 char *MSSCmd;
71 
72 struct Cmd
73  {const char *Desc;
74  char *theCmd;
76  int TLimit;
77  int Opts;
78  } xfrCmd[4];
79 static const int cmdAlloc = 0x0001;
80 static const int cmdMDP = 0x0002;
81 static const int cmdStats = 0x0004;
82 static const int cmdXPD = 0x0008;
83 static const int cmdRME = 0x0010;
84 
85 int xfrIN;
86 int xfrOUT;
87 
88 XrdOfsConfigPI *OfsCfg; // -> Plugin Configurator
89 XrdCks *CksMan; // -> Checksum Manager
90 XrdOucName2Name *the_N2N; // -> File mapper object
93 uid_t myUid;
94 gid_t myGid;
95 long long cmdFree;
96 int cmdHold;
98 int isAgent;
99 int xfrMax;
108 int isOTO;
109 int Fix;
110 int Test;
113 int runOld; // Backward compatability
114 int runNew; // Forward compatability
115 int nonXA; // Backward compatability for noXA spaces
116 int hasCache; // Backward compatability for noXA spaces
117 char **vectArg;
120 
121 struct VPInfo
123  char *Name;
125  int Val;
126  VPInfo(char *n, int m=0, struct VPInfo *p=0)
127  : Next(p), Name(strdup(n)), Dir(0), Val(m) {}
128  ~VPInfo() {} // Deletes are not important
129  } *VPList;
130 VPInfo *pathList; // Migr/Purg list of paths
131 XrdOucTList *spacList; // Migr/Purg list of spaces
132 
133 struct Policy
134  {long long minFree;
135  long long maxFree;
136  int Hold;
137  int Ext;
140  Policy(const char *snv, long long minV, long long maxV,
141  int hV, int xV) : minFree(minV), maxFree(maxV),
142  Hold(hV), Ext(xV), Next(0) {strcpy(Sname, snv);}
143  ~Policy() {}
144  };
146 
148 int pVecNum; // Number of policy variables
149 static const int pVecMax=8;
150 char pVec[pVecMax];
151 char *pProg;
152 char *xfrFdir;
154 
157 
158 int Configure(int argc, char **argv, int (*ppf)());
159 
160 int LocalPath (const char *oldp, char *newp, int newpsz);
161 
162 int LogicalPath(const char *oldp, char *newp, int newpsz);
163 
164 int NeedsCTA(const char *Lfn);
165 
166 unsigned
167 long long PathOpts(const char *Lfn);
168 
169 int RemotePath (const char *oldp, char *newp, int newpsz);
170 
171 XrdOucTList *Space(const char *Name, const char *Path=0);
172 
173 int Stat(const char *xLfn, const char *xPfn, struct stat *buff);
174 
176 
177  XrdFrmConfig(SubSys ss, const char *vopts, const char *uinfo);
179 
180 private:
181 XrdOucMsubs *ConfigCmd(const char *cname, char *cdata);
182 int ConfigMum(XrdFrmConfigSE &theSE);
183 int ConfigN2N();
184 int ConfigMon(int isxfr);
185 int ConfigMP(const char *);
186 int ConfigMss();
187 int ConfigOTO(char *Parms);
189 void ConfigPF(const char *pFN);
191 int ConfigXeq(char *var, int mbok);
192 int ConfigXfr();
193 int getTime(const char *, const char *, int *, int mnv=-1, int mxv=-1);
194 int Grab(const char *var, char **Dest, int nosubs);
195 XrdOucTList *InsertPL(XrdOucTList *pP, const char *Path, int Plen, int isRW);
196 void InsertXD(const char *Path);
197 void Usage(int rc);
198 int xapath();
199 int xcks();
200 int xcnsd();
201 int xcopy();
202 int xcopy(int &TLim);
203 int xcmax();
204 int xdpol();
205 int xitm(const char *What, int &tDest);
206 int xnml();
207 int xmon();
208 int xpol();
209 int xpolprog();
210 int xqchk();
211 int xsit();
212 int xspace(int isPrg=0, int isXA=1);
213 void xspaceBuild(char *grp, char *fn, int isxa);
214 int xxfr();
215 
216 char *ConfigFN;
217 char *LocalRoot;
220 XrdVersionInfo *myVersion;
221 
222 bool doStatPF;
223 int plnDTS;
224 const char *pfxDTS;
225 const char *vOpts;
226 const char *uInfo;
227 char *N2N_Lib; // -> Name2Name Library Path
228 char *N2N_Parms; // -> Name2Name Object Parameters
229 XrdOucName2Name *lcl_N2N; // -> File mapper for local files
230 XrdOucName2Name *rmt_N2N; // -> File mapper for remote files
232 };
233 namespace XrdFrm
234 {
235 extern XrdFrmConfig Config;
236 }
237 #endif
XrdOss
Definition: XrdOss.hh:499
XrdFrmConfig::VPInfo::Dir
XrdOucTList * Dir
Definition: XrdFrmConfig.hh:124
XrdFrmConfig::PP_ctime
@ PP_ctime
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::NeedsCTA
int NeedsCTA(const char *Lfn)
XrdFrmConfig::cmdStats
static const int cmdStats
Definition: XrdFrmConfig.hh:81
XrdFrmConfig::ssXfr
@ ssXfr
Definition: XrdFrmConfig.hh:175
XrdFrm
Definition: XrdFrmAdmin.hh:229
XrdFrmConfig::InsertPL
XrdOucTList * InsertPL(XrdOucTList *pP, const char *Path, int Plen, int isRW)
XrdFrmConfig::VPInfo::~VPInfo
~VPInfo()
Definition: XrdFrmConfig.hh:128
XrdFrmConfig::PPVar
PPVar
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::CksMan
XrdCks * CksMan
Definition: XrdFrmConfig.hh:89
XrdFrmConfig::cmdXPD
static const int cmdXPD
Definition: XrdFrmConfig.hh:82
XrdFrmConfig::myProg
const char * myProg
Definition: XrdFrmConfig.hh:57
XrdFrmConfig::FailHold
int FailHold
Definition: XrdFrmConfig.hh:102
XrdFrmConfig::PP_pfn
@ PP_pfn
Definition: XrdFrmConfig.hh:156
XrdFrmConfig::PP_fsize
@ PP_fsize
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::cFile
XrdOucStream * cFile
Definition: XrdFrmConfig.hh:219
XrdOucProg
Definition: XrdOucProg.hh:38
XrdFrmConfig::LocalPath
int LocalPath(const char *oldp, char *newp, int newpsz)
XrdFrmConfig::Cmd::theCmd
char * theCmd
Definition: XrdFrmConfig.hh:74
XrdFrmConfig::ssMigr
@ ssMigr
Definition: XrdFrmConfig.hh:175
XrdOfsConfigPI
Definition: XrdOfsConfigPI.hh:61
XrdOssSpace.hh
XrdNetCmsNotify
Definition: XrdNetCmsNotify.hh:37
XrdFrmConfig::ConfigFN
char * ConfigFN
Definition: XrdFrmConfig.hh:216
XrdFrmConfig::lcl_N2N
XrdOucName2Name * lcl_N2N
Definition: XrdFrmConfig.hh:229
XrdFrmConfig::myGid
gid_t myGid
Definition: XrdFrmConfig.hh:94
XrdFrmConfig::ConfigPF
void ConfigPF(const char *pFN)
XrdFrmConfig::xapath
int xapath()
XrdFrmConfig::Usage
void Usage(int rc)
XrdFrmConfig::ConfigMon
int ConfigMon(int isxfr)
XrdFrmConfig::InsertXD
void InsertXD(const char *Path)
XrdFrmConfig::N2N_Lib
char * N2N_Lib
Definition: XrdFrmConfig.hh:227
XrdFrmConfig::isOTO
int isOTO
Definition: XrdFrmConfig.hh:108
XrdFrmConfig::hasCache
int hasCache
Definition: XrdFrmConfig.hh:116
XrdFrmConfig::Test
int Test
Definition: XrdFrmConfig.hh:110
XrdFrmConfig::ssAdmin
@ ssAdmin
Definition: XrdFrmConfig.hh:175
XrdFrm::Config
XrdFrmConfig Config
XrdFrmConfig::VPInfo::VPInfo
VPInfo(char *n, int m=0, struct VPInfo *p=0)
Definition: XrdFrmConfig.hh:126
XrdFrmConfig::RemoteRoot
char * RemoteRoot
Definition: XrdFrmConfig.hh:218
XrdFrmConfig::xcopy
int xcopy()
XrdFrmConfig::ConfigMss
int ConfigMss()
XrdFrmConfig::nonXA
int nonXA
Definition: XrdFrmConfig.hh:115
XrdFrmConfig::xitm
int xitm(const char *What, int &tDest)
XrdFrmConfig::ConfigN2N
int ConfigN2N()
XrdFrmConfig::myInst
const char * myInst
Definition: XrdFrmConfig.hh:59
XrdFrmConfig::RemotePath
int RemotePath(const char *oldp, char *newp, int newpsz)
XrdFrmConfig::ConfigMum
int ConfigMum(XrdFrmConfigSE &theSE)
XrdOucMsubs
Definition: XrdOucMsubs.hh:91
XrdFrmConfig::ossFS
XrdOss * ossFS
Definition: XrdFrmConfig.hh:91
XrdFrmConfig::pathList
VPInfo * pathList
Definition: XrdFrmConfig.hh:130
XrdFrmConfig::plnDTS
int plnDTS
Definition: XrdFrmConfig.hh:223
XrdFrmConfig::myFrmid
const char * myFrmid
Definition: XrdFrmConfig.hh:61
XrdFrmConfig::PP_sname
@ PP_sname
Definition: XrdFrmConfig.hh:156
XrdFrmConfig::Space
XrdOucTList * Space(const char *Name, const char *Path=0)
XrdFrmConfig::pProg
char * pProg
Definition: XrdFrmConfig.hh:151
XrdFrmConfig::xfrMax
int xfrMax
Definition: XrdFrmConfig.hh:99
XrdFrmConfig::Policy::Ext
int Ext
Definition: XrdFrmConfig.hh:137
XrdFrmConfig::LogicalPath
int LogicalPath(const char *oldp, char *newp, int newpsz)
XrdFrmConfig::numcArg
int numcArg
Definition: XrdFrmConfig.hh:119
XrdFrmConfig::Policy::Sname
char Sname[XrdOssSpace::minSNbsz]
Definition: XrdFrmConfig.hh:139
XrdFrmConfig::cmdMDP
static const int cmdMDP
Definition: XrdFrmConfig.hh:80
XrdFrmConfig::runNew
int runNew
Definition: XrdFrmConfig.hh:114
XrdFrmConfig::Cmd::theVec
XrdOucMsubs * theVec
Definition: XrdFrmConfig.hh:75
XrdFrmConfig::rmt_N2N
XrdOucName2Name * rmt_N2N
Definition: XrdFrmConfig.hh:230
XrdOucStream
Definition: XrdOucStream.hh:47
XrdFrmConfig::Policy::Policy
Policy(const char *snv, long long minV, long long maxV, int hV, int xV)
Definition: XrdFrmConfig.hh:140
XrdFrmConfig::SubSys
SubSys
Definition: XrdFrmConfig.hh:175
XrdFrmConfig::xcopy
int xcopy(int &TLim)
XrdFrmConfig::ConfigXeq
int ConfigXeq(char *var, int mbok)
XrdFrmConfig::xspaceBuild
void xspaceBuild(char *grp, char *fn, int isxa)
XrdFrmConfig::myFrmID
const char * myFrmID
Definition: XrdFrmConfig.hh:62
XrdCks
Definition: XrdCks.hh:92
XrdFrmConfig::xdpol
int xdpol()
XrdFrmConfig::StopPurge
char * StopPurge
Definition: XrdFrmConfig.hh:68
XrdFrmConfig::xfrMaxOt
int xfrMaxOt
Definition: XrdFrmConfig.hh:101
XrdFrmConfig::pfxDTS
const char * pfxDTS
Definition: XrdFrmConfig.hh:224
XrdFrmConfig::PP_fname
@ PP_fname
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::VPInfo::Name
char * Name
Definition: XrdFrmConfig.hh:123
XrdFrmConfig::PidPath
char * PidPath
Definition: XrdFrmConfig.hh:66
XrdFrmConfig::Policy::Next
Policy * Next
Definition: XrdFrmConfig.hh:138
XrdFrmConfig::Cmd
Definition: XrdFrmConfig.hh:73
XrdOssSpace::minSNbsz
static const int minSNbsz
Definition: XrdOssSpace.hh:45
XrdFrmConfig::WaitMigr
int WaitMigr
Definition: XrdFrmConfig.hh:106
XrdFrmConfig::Fix
int Fix
Definition: XrdFrmConfig.hh:109
XrdFrmConfig::AdminPath
char * AdminPath
Definition: XrdFrmConfig.hh:64
XrdFrmConfig::xqchk
int xqchk()
XrdFrmConfig::xpol
int xpol()
XrdFrmConfig::xfrFdir
char * xfrFdir
Definition: XrdFrmConfig.hh:152
XrdFrmConfig::PP_usage
@ PP_usage
Definition: XrdFrmConfig.hh:156
XrdFrmConfig::ssPurg
@ ssPurg
Definition: XrdFrmConfig.hh:175
XrdFrmConfig::PP_fspace
@ PP_fspace
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::cmdRME
static const int cmdRME
Definition: XrdFrmConfig.hh:83
XrdFrmConfig::xcmax
int xcmax()
XrdFrmConfig::ConfigCmd
XrdOucMsubs * ConfigCmd(const char *cname, char *cdata)
XrdFrmConfig::MSSCmd
char * MSSCmd
Definition: XrdFrmConfig.hh:69
XrdFrmConfig::Policy
Definition: XrdFrmConfig.hh:134
XrdFrmConfig::cmsPath
XrdNetCmsNotify * cmsPath
Definition: XrdFrmConfig.hh:92
XrdFrmConfig
Definition: XrdFrmConfig.hh:54
XrdFrmConfig::Verbose
int Verbose
Definition: XrdFrmConfig.hh:112
XrdFrmConfig::dfltPolicy
Policy dfltPolicy
Definition: XrdFrmConfig.hh:145
XrdSysLogger
Definition: XrdSysLogger.hh:53
XrdFrmConfig::VPInfo
Definition: XrdFrmConfig.hh:122
XrdFrmConfig::Cmd::TLimit
int TLimit
Definition: XrdFrmConfig.hh:76
XrdFrmConfig::PP_tspace
@ PP_tspace
Definition: XrdFrmConfig.hh:156
XrdFrmConfig::spacList
XrdOucTList * spacList
Definition: XrdFrmConfig.hh:131
XrdFrmConfig::ssPstg
@ ssPstg
Definition: XrdFrmConfig.hh:175
XrdFrmConfig::ConfigMP
int ConfigMP(const char *)
XrdFrmConfig::pVecNum
int pVecNum
Definition: XrdFrmConfig.hh:148
XrdFrmConfig::WaitPurge
int WaitPurge
Definition: XrdFrmConfig.hh:105
XrdFrmConfig::haveCMS
int haveCMS
Definition: XrdFrmConfig.hh:107
XrdFrmConfig::lockFN
const char * lockFN
Definition: XrdFrmConfig.hh:63
XrdFrmConfig::getTime
int getTime(const char *, const char *, int *, int mnv=-1, int mxv=-1)
XrdFrmConfig::cmdFree
long long cmdFree
Definition: XrdFrmConfig.hh:95
XrdFrmConfig::Grab
int Grab(const char *var, char **Dest, int nosubs)
XrdFrmConfig::xfrOUT
int xfrOUT
Definition: XrdFrmConfig.hh:86
XrdFrmConfig::myVersion
XrdVersionInfo * myVersion
Definition: XrdFrmConfig.hh:220
XrdFrmConfig::xspace
int xspace(int isPrg=0, int isXA=1)
XrdFrmConfig::cmdAlloc
static const int cmdAlloc
Definition: XrdFrmConfig.hh:79
XrdFrmConfig::ssID
SubSys ssID
Definition: XrdFrmConfig.hh:231
XrdFrmConfig::xfrIN
int xfrIN
Definition: XrdFrmConfig.hh:85
XrdFrmConfig::vOpts
const char * vOpts
Definition: XrdFrmConfig.hh:225
XrdFrmConfig::pVec
char pVec[pVecMax]
Definition: XrdFrmConfig.hh:150
XrdFrmConfig::N2N_Parms
char * N2N_Parms
Definition: XrdFrmConfig.hh:228
XrdOucName2Name
Definition: XrdOucName2Name.hh:49
XrdFrmConfig::LocalRoot
char * LocalRoot
Definition: XrdFrmConfig.hh:217
XrdFrmConfig::XrdFrmConfig
XrdFrmConfig(SubSys ss, const char *vopts, const char *uinfo)
XrdFrmConfig::xsit
int xsit()
XrdFrmConfig::Cmd::Desc
const char * Desc
Definition: XrdFrmConfig.hh:73
XrdFrmConfig::xfrFdln
int xfrFdln
Definition: XrdFrmConfig.hh:153
XrdFrmConfig::ConfigProc
int ConfigProc()
XrdFrmConfig::myName
const char * myName
Definition: XrdFrmConfig.hh:58
XrdFrmConfig::myUid
uid_t myUid
Definition: XrdFrmConfig.hh:93
XrdFrmConfig::xxfr
int xxfr()
XrdFrmConfig::cmdHold
int cmdHold
Definition: XrdFrmConfig.hh:96
XrdFrmConfig::Policy::maxFree
long long maxFree
Definition: XrdFrmConfig.hh:135
XrdFrmConfig::VPList
struct XrdFrmConfig::VPInfo * VPList
XrdFrmConfig::TrackDC
int TrackDC
Definition: XrdFrmConfig.hh:111
XrdFrmConfig::WaitQChk
int WaitQChk
Definition: XrdFrmConfig.hh:104
XrdFrmConfig::xfrMaxIn
int xfrMaxIn
Definition: XrdFrmConfig.hh:100
XrdFrmConfig::ConfigXfr
int ConfigXfr()
stat
#define stat(a, b)
Definition: XrdPosix.hh:96
XrdFrmConfig::Policy::Hold
int Hold
Definition: XrdFrmConfig.hh:136
XrdFrmConfig::uInfo
const char * uInfo
Definition: XrdFrmConfig.hh:226
XrdFrmConfig::xnml
int xnml()
XrdFrmConfig::AdminMode
int AdminMode
Definition: XrdFrmConfig.hh:97
XrdFrmConfig::Stat
int Stat(const char *xLfn, const char *xPfn, struct stat *buff)
XrdFrmConfig::isAgent
int isAgent
Definition: XrdFrmConfig.hh:98
XrdFrmConfig::ConfigOTO
int ConfigOTO(char *Parms)
XrdFrmConfig::xmon
int xmon()
XrdFrmConfig::the_N2N
XrdOucName2Name * the_N2N
Definition: XrdFrmConfig.hh:90
XrdFrmConfig::MSSProg
XrdOucProg * MSSProg
Definition: XrdFrmConfig.hh:70
XrdFrmConfig::Policy::~Policy
~Policy()
Definition: XrdFrmConfig.hh:143
XrdFrmConfig::ConfigPaths
int ConfigPaths()
XrdFrmConfig::VPInfo::Next
VPInfo * Next
Definition: XrdFrmConfig.hh:122
XrdFrmConfig::QPath
char * QPath
Definition: XrdFrmConfig.hh:65
XrdFrmConfig::Configure
int Configure(int argc, char **argv, int(*ppf)())
XrdFrmConfig::xpolprog
int xpolprog()
XrdFrmConfig::Policy::minFree
long long minFree
Definition: XrdFrmConfig.hh:134
XrdFrmConfig::nextArg
int nextArg
Definition: XrdFrmConfig.hh:118
XrdFrmConfig::PathOpts
unsigned long long PathOpts(const char *Lfn)
XrdFrmConfig::dirHold
int dirHold
Definition: XrdFrmConfig.hh:147
XrdFrmConfig::PP_atime
@ PP_atime
Definition: XrdFrmConfig.hh:155
XrdFrmConfig::runOld
int runOld
Definition: XrdFrmConfig.hh:113
XrdFrmConfig::doStatPF
bool doStatPF
Definition: XrdFrmConfig.hh:222
XrdFrmConfig::pVecMax
static const int pVecMax
Definition: XrdFrmConfig.hh:149
XrdFrmConfig::PP_mtime
@ PP_mtime
Definition: XrdFrmConfig.hh:156
XrdFrmConfig::mySite
const char * mySite
Definition: XrdFrmConfig.hh:60
XrdFrmConfig::xfrCmd
struct XrdFrmConfig::Cmd xfrCmd[4]
XrdFrmConfig::VPInfo::Val
int Val
Definition: XrdFrmConfig.hh:125
XrdFrmConfig::myInstance
char * myInstance
Definition: XrdFrmConfig.hh:67
XrdFrmConfig::xcnsd
int xcnsd()
XrdOucTList
Definition: XrdOucTList.hh:42
XrdFrmConfig::~XrdFrmConfig
~XrdFrmConfig()
Definition: XrdFrmConfig.hh:178
XrdFrmConfig::vectArg
char ** vectArg
Definition: XrdFrmConfig.hh:117
XrdFrmConfig::IdleHold
int IdleHold
Definition: XrdFrmConfig.hh:103
XrdFrmConfig::Cmd::Opts
int Opts
Definition: XrdFrmConfig.hh:77
XrdFrmConfig::OfsCfg
XrdOfsConfigPI * OfsCfg
Definition: XrdFrmConfig.hh:88
XrdFrmConfig::xcks
int xcks()