XRootD
Loading...
Searching...
No Matches
XrdCpFile Class Reference

#include <XrdCpFile.hh>

Collaboration diagram for XrdCpFile:

Public Types

enum  PType {
  isOther = 0 ,
  isDir ,
  isFile ,
  isStdIO ,
  isXroot ,
  isXroots ,
  isHttp ,
  isHttps ,
  isPelican ,
  isS3 ,
  isDevNull ,
  isDevZero
}

Public Member Functions

 XrdCpFile ()
 XrdCpFile (char *FSpec, struct stat &Stat, short doff, short dlen)
 XrdCpFile (const char *FSpec, int &badURL)
 ~XrdCpFile ()
int Extend (XrdCpFile **pLast, int &nFile, long long &nBytes)
int Resolve ()

Static Public Member Functions

static void SetMsgPfx (const char *pfx)

Public Attributes

short Dlen
short Doff
long long fSize
XrdCpFileNext
char * Path
char ProtName [8]
PType Protocol

Detailed Description

Definition at line 36 of file XrdCpFile.hh.

Member Enumeration Documentation

◆ PType

Enumerator
isOther 
isDir 
isFile 
isStdIO 
isXroot 
isXroots 
isHttp 
isHttps 
isPelican 
isS3 
isDevNull 
isDevZero 

Definition at line 40 of file XrdCpFile.hh.

Constructor & Destructor Documentation

◆ XrdCpFile() [1/3]

XrdCpFile::XrdCpFile ( )
inline

Definition at line 59 of file XrdCpFile.hh.

59 : Next(0), Path(0), Doff(0), Dlen(0),
60 Protocol(isOther), fSize(0) {*ProtName = 0;}
short Doff
Definition XrdCpFile.hh:46
PType Protocol
Definition XrdCpFile.hh:49
long long fSize
Definition XrdCpFile.hh:51
char * Path
Definition XrdCpFile.hh:45
char ProtName[8]
Definition XrdCpFile.hh:50
XrdCpFile * Next
Definition XrdCpFile.hh:44
short Dlen
Definition XrdCpFile.hh:47

References Dlen, Doff, fSize, isOther, Next, Path, ProtName, and Protocol.

Referenced by Extend().

Here is the caller graph for this function:

◆ XrdCpFile() [2/3]

XrdCpFile::XrdCpFile ( const char * FSpec,
int & badURL )

Definition at line 51 of file XrdCpFile.cc.

52{
53 static struct proto {const char *pHdr; int pHsz; PType pVal;}
54 pTab[] = {{"xroot://", 8, isXroot},
55 {"xroots://", 9, isXroots},
56 {"root://", 7, isXroot},
57 {"roots://", 8, isXroots},
58 {"http://", 7, isHttp},
59 {"https://", 8, isHttps},
60 {"dav://", 6, isHttp},
61 {"davs://", 7, isHttps},
62 {"pelican://", 10, isPelican},
63 {"s3://", 5, isS3}
64 };
65 static int pTnum = sizeof(pTab)/sizeof(struct proto);
66 const char *Slash;
67 int i;
68
69// Do some common initialization
70//
71 Doff = 0;
72 Dlen = 0;
73 Next = 0;
74 fSize = 0;
75 badURL= 0;
76 memset(ProtName, 0, sizeof(ProtName));
77
78// Copy out the path and remove trailing slashes (except the last one)
79//
80 Path = strdup(FSpec);
81 i = strlen(Path);
82 while(i) if (Path[i-1] != '/' || (i > 1 && Path[i-2] != '/')) break;
83 else Path[--i] = 0;
84
85// Check for stdin stdout spec
86//
87 if (!strcmp(Path, "-"))
89 return;
90 }
91
92// Dtermine protocol of the incoming spec
93//
94 for (i = 0; i < pTnum; i++)
95 {if (!strncmp(FSpec, pTab[i].pHdr, pTab[i].pHsz))
96 {Protocol = pTab[i].pVal;
97 memcpy(ProtName, pTab[i].pHdr, pTab[i].pHsz-3);
98 return;
99 }
100 }
101
102// See if this is a file
103//
105 if (!strncmp(Path, "file://", 7))
106 {char *pP = Path + 7;
107 if (!strncmp(pP, "localhost", 9)) memmove( Path, pP + 9, strlen( pP + 9 ) + 1 );
108 else if (*pP == '/') memmove( Path, pP, strlen( pP ) + 1 );
109 else {Protocol = isOther;
110 strcpy(ProtName, "remote");
111 return;
112 }
113 }
114
115// Set the default Doff and Dlen assuming non-recursive copy
116//
117 if ((Slash = rindex(Path, '/'))) Dlen = Doff = Slash - Path + 1;
118}

References Dlen, Doff, fSize, isFile, isHttp, isHttps, isOther, isPelican, isS3, isStdIO, isXroot, isXroots, Next, Path, ProtName, and Protocol.

◆ XrdCpFile() [3/3]

XrdCpFile::XrdCpFile ( char * FSpec,
struct stat & Stat,
short doff,
short dlen )

Definition at line 122 of file XrdCpFile.cc.

123 : Next(0), Path(FSpec), Doff(doff), Dlen(dlen),
124 Protocol(isFile), fSize(Stat.st_size)
125 {strcpy(ProtName, "file");}
struct stat Stat
Definition XrdCks.cc:49

References Dlen, Doff, fSize, isFile, Next, Path, ProtName, Protocol, Stat, and stat.

◆ ~XrdCpFile()

XrdCpFile::~XrdCpFile ( )
inline

Definition at line 67 of file XrdCpFile.hh.

67{if (Path) free(Path);}

References Path.

Member Function Documentation

◆ Extend()

int XrdCpFile::Extend ( XrdCpFile ** pLast,
int & nFile,
long long & nBytes )

Definition at line 131 of file XrdCpFile.cc.

132{
133 XrdOucNSWalk nsObj(0, Path, 0, XrdOucNSWalk::retFile|XrdOucNSWalk::Recurse);
134 XrdOucNSWalk::NSEnt *nP, *nnP;
135 XrdCpFile *fP, *pP = this;
136 int rc;
137 short dlen, doff = strlen(Path);
138
139 nsObj.setMsgOn(mPfx);
140
141 while((nP = nsObj.Index(rc)) && rc == 0)
142 {do {dlen = nP->Plen - doff;
143 fP = new XrdCpFile(nP->Path, nP->Stat, doff, dlen);
144 nFile++; nBytes += nP->Stat.st_size; nP->Path = 0;
145 pP->Next = fP; pP = fP;
146 nnP = nP->Next; delete nP;
147 } while((nP = nnP));
148 }
149
150 if (pLast) *pLast = pP;
151 return rc;
152}
static const int retFile
static const int Recurse
struct NSEnt * Next

References XrdCpFile(), XrdOucNSWalk::Index(), Next, XrdOucNSWalk::NSEnt::Next, Path, XrdOucNSWalk::NSEnt::Path, XrdOucNSWalk::NSEnt::Plen, XrdOucNSWalk::Recurse, XrdOucNSWalk::retFile, XrdOucNSWalk::setMsgOn(), and XrdOucNSWalk::NSEnt::Stat.

Here is the call graph for this function:

◆ Resolve()

int XrdCpFile::Resolve ( )

Definition at line 158 of file XrdCpFile.cc.

159{
160 struct stat Stat;
161
162// Ignore this call if this is not a file
163//
164 if (Protocol != isFile) return 0;
165
166// This should exist but it might not, the caller will determine what to do
167//
168 char *cgibeg = strchr( Path, '?' );
169 if( cgibeg ) *cgibeg = '\0';
170 if (stat(Path, &Stat)) return errno;
171 if( cgibeg ) *cgibeg = '?';
172
173// Find out what this really is
174//
175 if (S_ISREG(Stat.st_mode)) fSize = Stat.st_size;
176 else if (S_ISDIR(Stat.st_mode)) Protocol = isDir;
177 else if (!strcmp(Path, "/dev/null")) Protocol = isDevNull;
178 else if (!strcmp(Path, "/dev/zero")) Protocol = isDevZero;
179 else return ENOTSUP;
180
181// All is well
182//
183 return 0;
184}
#define stat(a, b)
Definition XrdPosix.hh:101

References fSize, isDevNull, isDevZero, isDir, isFile, Path, Protocol, Stat, and stat.

◆ SetMsgPfx()

void XrdCpFile::SetMsgPfx ( const char * pfx)
inlinestatic

Definition at line 57 of file XrdCpFile.hh.

57{mPfx = pfx;}

Referenced by XrdCpConfig::XrdCpConfig().

Here is the caller graph for this function:

Member Data Documentation

◆ Dlen

short XrdCpFile::Dlen

Definition at line 47 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpFile(), XrdCpFile(), and main().

◆ Doff

short XrdCpFile::Doff

Definition at line 46 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpFile(), XrdCpFile(), AdjustFileInfo(), IndexRemote(), and main().

◆ fSize

long long XrdCpFile::fSize

Definition at line 51 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpFile(), XrdCpFile(), and Resolve().

◆ Next

XrdCpFile* XrdCpFile::Next

◆ Path

char* XrdCpFile::Path

◆ ProtName

char XrdCpFile::ProtName[8]

Definition at line 50 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpFile(), XrdCpFile(), and main().

◆ Protocol

PType XrdCpFile::Protocol

Definition at line 49 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpFile(), XrdCpFile(), main(), and Resolve().


The documentation for this class was generated from the following files: