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
XrdCpFile *	Next
char *	Path
char	ProtName [8]
PType	Protocol

Detailed Description

Definition at line 36 of file XrdCpFile.hh.

Member Enumeration Documentation

PType

enum XrdCpFile::PType

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

Definition at line 40 of file XrdCpFile.hh.

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

Constructor & Destructor Documentation

XrdCpFile() [1/3]

XrdCpFile::XrdCpFile ( )

inline

Definition at line 59 of file XrdCpFile.hh.

                              : Next(0), Path(0), Doff(0), Dlen(0),
                                Protocol(isOther), fSize(0) {*ProtName = 0;}

References ProtName.

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.

{
   static struct proto {const char *pHdr; int pHsz; PType pVal;}
                 pTab[] = {{"xroot://",  8, isXroot},
                           {"xroots://", 9, isXroots},
                           {"root://",   7, isXroot},
                           {"roots://",  8, isXroots},
                           {"http://",   7, isHttp},
                           {"https://",  8, isHttps},
                           {"dav://",    6, isHttp},
                           {"davs://",   7, isHttps},
                           {"pelican://", 10,  isPelican},
                           {"s3://",     5, isS3}
                          };
   static int pTnum = sizeof(pTab)/sizeof(struct proto);
   const char *Slash;
   int i;
 
// Do some common initialization
//
   Doff  = 0;
   Dlen  = 0;
   Next  = 0;
   fSize = 0;
   badURL= 0;
   memset(ProtName, 0, sizeof(ProtName));
 
// Copy out the path and remove trailing slashes (except the last one)
//
   Path = strdup(FSpec);
   i = strlen(Path);
   while(i) if (Path[i-1] != '/' || (i > 1 && Path[i-2] != '/')) break;
               else Path[--i] = 0;
 
// Check for stdin stdout spec
//
   if (!strcmp(Path, "-"))
      {Protocol = isStdIO;
       return;
      }
 
// Dtermine protocol of the incoming spec
//
   for (i = 0; i < pTnum; i++)
       {if (!strncmp(FSpec, pTab[i].pHdr, pTab[i].pHsz))
           {Protocol = pTab[i].pVal;
            memcpy(ProtName, pTab[i].pHdr, pTab[i].pHsz-3);
            return;
           }
       }
 
// See if this is a file
//
   Protocol = isFile;
   if (!strncmp(Path, "file://", 7))
      {char *pP = Path + 7;
               if (!strncmp(pP, "localhost", 9)) memmove( Path, pP + 9, strlen( pP + 9 ) + 1 );
          else if (*pP == '/') memmove( Path, pP, strlen( pP ) + 1 );
          else {Protocol = isOther;
                strcpy(ProtName, "remote");
                return;
               }
      }
 
// Set the default Doff and Dlen assuming non-recursive copy
//
   if ((Slash = rindex(Path, '/'))) Dlen = Doff = Slash - Path + 1;
}

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.

                    : Next(0), Path(FSpec), Doff(doff), Dlen(dlen),
                      Protocol(isFile), fSize(Stat.st_size)
                    {strcpy(ProtName, "file");}

References ProtName.

~XrdCpFile()

XrdCpFile::~XrdCpFile ( )

inline

Definition at line 67 of file XrdCpFile.hh.

{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.

{
   XrdOucNSWalk nsObj(0, Path, 0, XrdOucNSWalk::retFile|XrdOucNSWalk::Recurse);
   XrdOucNSWalk::NSEnt *nP, *nnP;
   XrdCpFile *fP, *pP = this;
   int rc;
   short dlen, doff = strlen(Path);
 
   nsObj.setMsgOn(mPfx);
 
   while((nP = nsObj.Index(rc)) && rc == 0)
        {do {dlen = nP->Plen - doff;
             fP = new XrdCpFile(nP->Path, nP->Stat, doff, dlen);
             nFile++; nBytes += nP->Stat.st_size; nP->Path = 0;
             pP->Next = fP; pP = fP;
             nnP = nP->Next; delete nP;
            } while((nP = nnP));
        }
 
   if (pLast) *pLast = pP;
   return rc;
}

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.

Referenced by XrdCpConfig::Config().

Here is the call graph for this function:

Here is the caller graph for this function:

Resolve()

int XrdCpFile::Resolve

(

)

Definition at line 158 of file XrdCpFile.cc.

{
   struct stat Stat;
 
// Ignore this call if this is not a file
//
   if (Protocol != isFile) return 0;
 
// This should exist but it might not, the caller will determine what to do
//
   char *cgibeg = strchr( Path, '?' );
   if( cgibeg ) *cgibeg = '\0';
   if (stat(Path, &Stat)) return errno;
   if( cgibeg ) *cgibeg = '?';
 
// Find out what this really is
//
        if (S_ISREG(Stat.st_mode)) fSize = Stat.st_size;
   else if (S_ISDIR(Stat.st_mode))      Protocol = isDir;
   else if (!strcmp(Path, "/dev/null")) Protocol = isDevNull;
   else if (!strcmp(Path, "/dev/zero")) Protocol = isDevZero;
   else return ENOTSUP;
 
// All is well
//
   return 0;
}

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

Referenced by XrdCpConfig::Config().

Here is the caller graph for this function:

SetMsgPfx()

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

inlinestatic

Definition at line 57 of file XrdCpFile.hh.

{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(), and main().

Doff

short XrdCpFile::Doff

Definition at line 46 of file XrdCpFile.hh.

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

fSize

long long XrdCpFile::fSize

Definition at line 51 of file XrdCpFile.hh.

Referenced by XrdCpFile(), and Resolve().

Next

XrdCpFile* XrdCpFile::Next

Definition at line 44 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpConfig::~XrdCpConfig(), XrdCpConfig::Config(), CountSources(), Extend(), IndexRemote(), and main().

Path

char* XrdCpFile::Path

Definition at line 45 of file XrdCpFile.hh.

Referenced by XrdCpFile(), ~XrdCpFile(), AdjustFileInfo(), XrdCpConfig::Config(), Extend(), IndexRemote(), main(), and Resolve().

ProtName

char XrdCpFile::ProtName[8]

Definition at line 50 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpConfig::Config(), and main().

Protocol

PType XrdCpFile::Protocol

Definition at line 49 of file XrdCpFile.hh.

Referenced by XrdCpFile(), XrdCpConfig::Config(), main(), and Resolve().

---

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

• XrdCpFile.hh
• XrdCpFile.cc