XRootD
XrdCpFile.cc
Go to the documentation of this file.
1 /******************************************************************************/
2 /* */
3 /* X r d C p F i l e . c c */
4 /* */
5 /* (c) 2012 by the Board of Trustees of the Leland Stanford, Jr., University */
6 /* All Rights Reserved */
7 /* Produced by Andrew Hanushevsky for Stanford University under contract */
8 /* DE-AC02-76-SFO0515 with the Department of Energy */
9 /* */
10 /* This file is part of the XRootD software suite. */
11 /* */
12 /* XRootD is free software: you can redistribute it and/or modify it under */
13 /* the terms of the GNU Lesser General Public License as published by the */
14 /* Free Software Foundation, either version 3 of the License, or (at your */
15 /* option) any later version. */
16 /* */
17 /* XRootD is distributed in the hope that it will be useful, but WITHOUT */
18 /* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or */
19 /* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public */
20 /* License for more details. */
21 /* */
22 /* You should have received a copy of the GNU Lesser General Public License */
23 /* along with XRootD in a file called COPYING.LESSER (LGPL license) and file */
24 /* COPYING (GPL license). If not, see <http://www.gnu.org/licenses/>. */
25 /* */
26 /* The copyright holder's institutional names and contributor's names may not */
27 /* be used to endorse or promote products derived from this software without */
28 /* specific prior written permission of the institution or contributor. */
29 /******************************************************************************/
30 
31 #include <cerrno>
32 #include <fcntl.h>
33 #include <cstring>
34 #include <strings.h>
35 #include <sys/types.h>
36 #include <sys/stat.h>
37 
38 #include "XrdApps/XrdCpFile.hh"
39 #include "XrdOuc/XrdOucNSWalk.hh"
40 
41 /******************************************************************************/
42 /* S t a t i c M e m b e r s */
43 /******************************************************************************/
44 
45 const char *XrdCpFile::mPfx = 0;
46 
47 /******************************************************************************/
48 /* C o n s t r u c t o r */
49 /******************************************************************************/
50 
51 XrdCpFile::XrdCpFile(const char *FSpec, int &badURL)
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  {"pelican://", 10, isPelican},
60  {"https://", 8, isHttps}
61  };
62  static int pTnum = sizeof(pTab)/sizeof(struct proto);
63  const char *Slash;
64  int i;
65 
66 // Do some common initialization
67 //
68  Doff = 0;
69  Dlen = 0;
70  Next = 0;
71  fSize = 0;
72  badURL= 0;
73  memset(ProtName, 0, sizeof(ProtName));
74 
75 // Copy out the path and remove trailing slashes (except the last one)
76 //
77  Path = strdup(FSpec);
78  i = strlen(Path);
79  while(i) if (Path[i-1] != '/' || (i > 1 && Path[i-2] != '/')) break;
80  else Path[--i] = 0;
81 
82 // Check for stdin stdout spec
83 //
84  if (!strcmp(Path, "-"))
85  {Protocol = isStdIO;
86  return;
87  }
88 
89 // Dtermine protocol of the incoming spec
90 //
91  for (i = 0; i < pTnum; i++)
92  {if (!strncmp(FSpec, pTab[i].pHdr, pTab[i].pHsz))
93  {Protocol = pTab[i].pVal;
94  memcpy(ProtName, pTab[i].pHdr, pTab[i].pHsz-3);
95  return;
96  }
97  }
98 
99 // See if this is a file
100 //
101  Protocol = isFile;
102  if (!strncmp(Path, "file://", 7))
103  {char *pP = Path + 7;
104  if (!strncmp(pP, "localhost", 9)) memmove( Path, pP + 9, strlen( pP + 9 ) + 1 );
105  else if (*pP == '/') memmove( Path, pP, strlen( pP ) + 1 );
106  else {Protocol = isOther;
107  strcpy(ProtName, "remote");
108  return;
109  }
110  }
111 
112 // Set the default Doff and Dlen assuming non-recursive copy
113 //
114  if ((Slash = rindex(Path, '/'))) Dlen = Doff = Slash - Path + 1;
115 }
116 
117 /******************************************************************************/
118 
119 XrdCpFile::XrdCpFile(char *FSpec, struct stat &Stat, short doff, short dlen)
120  : Next(0), Path(FSpec), Doff(doff), Dlen(dlen),
121  Protocol(isFile), fSize(Stat.st_size)
122  {strcpy(ProtName, "file");}
123 
124 /******************************************************************************/
125 /* E x t e n d */
126 /******************************************************************************/
127 
128 int XrdCpFile::Extend(XrdCpFile **pLast, int &nFile, long long &nBytes)
129 {
131  XrdOucNSWalk::NSEnt *nP, *nnP;
132  XrdCpFile *fP, *pP = this;
133  int rc;
134  short dlen, doff = strlen(Path);
135 
136  nsObj.setMsgOn(mPfx);
137 
138  while((nP = nsObj.Index(rc)) && rc == 0)
139  {do {dlen = nP->Plen - doff;
140  fP = new XrdCpFile(nP->Path, nP->Stat, doff, dlen);
141  nFile++; nBytes += nP->Stat.st_size; nP->Path = 0;
142  pP->Next = fP; pP = fP;
143  nnP = nP->Next; delete nP;
144  } while((nP = nnP));
145  }
146 
147  if (pLast) *pLast = pP;
148  return rc;
149 }
150 
151 /******************************************************************************/
152 /* R e s o l v e */
153 /******************************************************************************/
154 
156 {
157  struct stat Stat;
158 
159 // Ignore this call if this is not a file
160 //
161  if (Protocol != isFile) return 0;
162 
163 // This should exist but it might not, the caller will determine what to do
164 //
165  char *cgibeg = strchr( Path, '?' );
166  if( cgibeg ) *cgibeg = '\0';
167  if (stat(Path, &Stat)) return errno;
168  if( cgibeg ) *cgibeg = '?';
169 
170 // Find out what this really is
171 //
172  if (S_ISREG(Stat.st_mode)) fSize = Stat.st_size;
173  else if (S_ISDIR(Stat.st_mode)) Protocol = isDir;
174  else if (!strcmp(Path, "/dev/null")) Protocol = isDevNull;
175  else if (!strcmp(Path, "/dev/zero")) Protocol = isDevZero;
176  else return ENOTSUP;
177 
178 // All is well
179 //
180  return 0;
181 }
struct stat Stat
Definition: XrdCks.cc:49
int stat(const char *path, struct stat *buf)
XrdOucString Path
short Doff
Definition: XrdCpFile.hh:46
PType Protocol
Definition: XrdCpFile.hh:49
int Resolve()
Definition: XrdCpFile.cc:155
int Extend(XrdCpFile **pLast, int &nFile, long long &nBytes)
Definition: XrdCpFile.cc:128
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
static const int retFile
void setMsgOn(const char *pfx)
NSEnt * Index(int &rc, const char **dPath=0)
Definition: XrdOucNSWalk.cc:93
static const int Recurse
ProtocolImpl< false > Protocol
struct NSEnt * Next
Definition: XrdOucNSWalk.hh:48