XRootD
Loading...
Searching...
No Matches
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"
40
41/******************************************************************************/
42/* S t a t i c M e m b e r s */
43/******************************************************************************/
44
45const char *XrdCpFile::mPfx = 0;
46
47/******************************************************************************/
48/* C o n s t r u c t o r */
49/******************************************************************************/
50
51XrdCpFile::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, "-"))
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//
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
119XrdCpFile::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
128int 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
#define stat(a, b)
Definition XrdPosix.hh:96
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)
static const int Recurse
struct NSEnt * Next