XrdFrmFileset Class Reference

#include <XrdFrmFiles.hh>

Collaboration diagram for XrdFrmFileset:

Public Member Functions
	XrdFrmFileset (XrdFrmFileset *sP=0, XrdOucTList *diP=0)
	~XrdFrmFileset ()
XrdOucNSWalk::NSEnt *	baseFile ()
const char *	basePath ()
int	dirPath (char *dBuff, int dBlen)
XrdOucNSWalk::NSEnt *	failFile ()
const char *	failPath ()
XrdOucNSWalk::NSEnt *	lockFile ()
const char *	lockPath ()
XrdOucNSWalk::NSEnt *	pfnFile ()
const char *	pfnPath ()
XrdOucNSWalk::NSEnt *	pinFile ()
const char *	pinPath ()
int	Refresh (int isMig=0, int doLock=1)
int	Screen (int needLF=1)
int	setCpyTime (int Refresh=0)
XrdOucNSWalk::NSEnt *	xyzFile (XrdOssPath::theSfx sfx)
const char *	xyzPath (XrdOssPath::theSfx sfx)

Static Public Member Functions
static void	Purge ()

Public Attributes
int	Age
XrdOucXAttr< XrdFrcXAttrCpy >	cpyInfo
XrdFrmFileset *	Next
XrdOucXAttr< XrdFrcXAttrPin >	pinInfo

Friends
class	XrdFrmFiles

Detailed Description

Definition at line 48 of file XrdFrmFiles.hh.

Constructor & Destructor Documentation

XrdFrmFileset()

XrdFrmFileset::XrdFrmFileset	(	XrdFrmFileset *	sP = 0,
		XrdOucTList *	diP = 0
	)

Definition at line 62 of file XrdFrmFiles.cc.

              : Next(sP), dInfo(diP)
{  memset(File, 0, sizeof(File));
   if (diP) diP->ival[dRef]++;
}

~XrdFrmFileset()

XrdFrmFileset::~XrdFrmFileset

(

)

Definition at line 72 of file XrdFrmFiles.cc.

{
   int i;
 
// Delete all the table entries
//
   for (i = 0; i < XrdOssPath::sfxNum; i++) if(File[i]) delete File[i];
 
// If there is a shared directory buffer, decrease reference count, delete if 0
//
   if (dInfo && ((dInfo->ival[dRef] -= 1) <= 0)) delete dInfo;
}

References XrdOssPath::sfxNum.

Member Function Documentation

baseFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::baseFile ( )

inline

Definition at line 60 of file XrdFrmFiles.hh.

{return File[XrdOssPath::isBase];}

References File, and XrdOssPath::isBase.

Referenced by XrdFrmTSort::Add(), basePath(), Refresh(), and Screen().

Here is the caller graph for this function:

basePath()

const char* XrdFrmFileset::basePath ( )

inline

Definition at line 61 of file XrdFrmFiles.hh.

{return Mkfn(baseFile());}

References baseFile().

Referenced by XrdFrmMigrate::Queue(), Screen(), and setCpyTime().

Here is the call graph for this function:

Here is the caller graph for this function:

dirPath()

int XrdFrmFileset::dirPath	(	char *	dBuff,
		int	dBlen
	)

Definition at line 89 of file XrdFrmFiles.cc.

{
   char *dP = 0;
   int   dN = 0, i;
 
// If we have a shared directory pointer, use that as directory information
// Otherwise, get it from one of the files in the fileset.
//
   if (dInfo) {dP = dInfo->text; dN = dInfo->ival[dLen];}
      else {for (i = 0; i < XrdOssPath::sfxNum; i++)
                if (File[i])
                   {dP = File[i]->Path;
                    dN = File[i]->File - File[i]->Path;
                    break;
                   }
           }
 
// Copy out the directory path
//
   if (dBlen > dN && dP) strncpy(dBuff, dP, dN);
      else dN = 0;
   *(dBuff+dN) = '\0';
   return dN;
}

References XrdOucNSWalk::NSEnt::File, XrdOucNSWalk::NSEnt::Path, XrdOssPath::sfxNum, and XrdOucTList::text.

Referenced by Refresh().

Here is the caller graph for this function:

failFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::failFile ( )

inline

Definition at line 62 of file XrdFrmFiles.hh.

{return File[XrdOssPath::isFail];}

References File, and XrdOssPath::isFail.

Referenced by failPath().

Here is the caller graph for this function:

failPath()

const char* XrdFrmFileset::failPath ( )

inline

Definition at line 63 of file XrdFrmFiles.hh.

{return Mkfn(failFile());}

References failFile().

Here is the call graph for this function:

lockFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::lockFile ( )

inline

Definition at line 64 of file XrdFrmFiles.hh.

{return File[XrdOssPath::isLock];}

References File, and XrdOssPath::isLock.

Referenced by lockPath(), Refresh(), Screen(), and setCpyTime().

Here is the caller graph for this function:

lockPath()

const char* XrdFrmFileset::lockPath ( )

inline

Definition at line 65 of file XrdFrmFiles.hh.

{return Mkfn(lockFile());}

References lockFile().

Referenced by Screen(), and setCpyTime().

Here is the call graph for this function:

Here is the caller graph for this function:

pfnFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::pfnFile ( )

inline

Definition at line 66 of file XrdFrmFiles.hh.

{return File[XrdOssPath::isPfn ];}

References File, and XrdOssPath::isPfn.

Referenced by pfnPath().

Here is the caller graph for this function:

pfnPath()

const char* XrdFrmFileset::pfnPath ( )

inline

Definition at line 67 of file XrdFrmFiles.hh.

{return Mkfn(pfnFile());}

References pfnFile().

Here is the call graph for this function:

pinFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::pinFile ( )

inline

Definition at line 68 of file XrdFrmFiles.hh.

{return File[XrdOssPath::isPin ];}

References File, and XrdOssPath::isPin.

Referenced by pinPath(), and Screen().

Here is the caller graph for this function:

pinPath()

const char* XrdFrmFileset::pinPath ( )

inline

Definition at line 69 of file XrdFrmFiles.hh.

{return Mkfn(pinFile());}

References pinFile().

Referenced by Screen().

Here is the call graph for this function:

Here is the caller graph for this function:

Purge()

static void XrdFrmFileset::Purge ( )

inlinestatic

Definition at line 77 of file XrdFrmFiles.hh.

{BadFiles.Purge();}

References XrdOucHash< T >::Purge().

Here is the call graph for this function:

Refresh()

int XrdFrmFileset::Refresh	(	int	isMig = 0,
		int	doLock = 1
	)

Definition at line 118 of file XrdFrmFiles.cc.

{
   class fdClose
        {public:
         int Num;
             fdClose() : Num(-1) {}
            ~fdClose() {if (Num >= 0) close(Num);}
        } fnFD;
   XrdOucNSWalk::NSEnt *lP, *bP = baseFile();
   char pBuff[MAXPATHLEN+1], *fnP, *pnP = pBuff;
   int n, lkFD = -1;
 
// Get the directory path for this entry
//
   if (!(n = dirPath(pBuff, sizeof(pBuff)-1))) return 0;
   fnP = pBuff+n;
 
// If we need to lock the entry, do so. We also check if file is in use
//
   if (doLock && bP)
      {strcpy(fnP, baseFile()->File);
       if (!(lkFD = chkLock(pBuff))) return 0;
       fnFD.Num = lkFD;
      }
 
// Do a new stat call on each relevant file (pin file excluded for isMig)
//
   if (bP)
      {if (bP->Link) pnP = bP->Link;
         else strcpy(fnP, bP->File);
       if (stat(pnP, &(bP->Stat)))
          {Say.Emsg("Refresh", errno, "stat", pnP); return 0;}
      }
 
   if (!isMig) pinInfo.Get(pnP, lkFD);
 
   if ((lP = lockFile()))
      {strcpy(fnP, lP->File);
       if (stat(pBuff, &(lP->Stat)))
          {Say.Emsg("Refresh", errno, "stat", pBuff); return 0;}
       cpyInfo.Attr.cpyTime = static_cast<long long>(lP->Stat.st_mtime);
      } else if (cpyInfo.Get(pnP, lkFD) <= 0) cpyInfo.Attr.cpyTime = 0;
 
// All done
//
   return 1;
}

References XrdOucXAttr< T >::Attr, baseFile(), close, cpyInfo, XrdFrcXAttrCpy::cpyTime, dirPath(), XrdSysError::Emsg(), XrdOucNSWalk::NSEnt::File, XrdOucXAttr< T >::Get(), XrdOucNSWalk::NSEnt::Link, lockFile(), pinInfo, XrdCms::Say, XrdOucNSWalk::NSEnt::Stat, and stat.

Referenced by setCpyTime().

Here is the call graph for this function:

Here is the caller graph for this function:

Screen()

int XrdFrmFileset::Screen

(

int

needLF = 1

)

Definition at line 170 of file XrdFrmFiles.cc.

{
   const char *What = 0, *badFN = 0;
 
// Verify that we have all the relevant files (old mode only)
//
   if (!Config.runNew && !baseFile())
      {if (Config.Fix)
          {if (lockFile()) Remfix("Lock", lockPath());
           if ( pinFile()) Remfix("Pin",  pinPath());
           return 0;
          }
            if (lockFile()) badFN = lockPath();
       else if ( pinFile()) badFN = pinPath();
       else return 0;
       What = "No base file for";
      }
 
// If no errors from above, try to get the copy time for this file
//
   if (!What)
      {if (!needLF || setCpyTime()) return 1;
       What = Config.runNew ? "no copy time xattr for" : "no lock file for";
       badFN = basePath();
      }
 
// Issue message if we haven't issued one before
//
   if (!BadFiles.Add(badFN, 0, 0, Hash_data_is_key))
      Say.Emsg("Screen", What, badFN);
   return 0;
}

References XrdOucHash< T >::Add(), baseFile(), basePath(), XrdCms::Config, XrdSysError::Emsg(), Hash_data_is_key, lockFile(), lockPath(), pinFile(), pinPath(), XrdCms::Say, and setCpyTime().

Here is the call graph for this function:

setCpyTime()

int XrdFrmFileset::setCpyTime

(

int

Refresh = 0

)

Definition at line 207 of file XrdFrmFiles.cc.

{
   XrdOucNSWalk::NSEnt *lP;
 
// In new run mode the copy time comes from the extended attributes
//
   if (Config.runNew) return cpyInfo.Get(basePath()) > 0;
 
// If there is no lock file, indicate so
//
   if (!(lP = lockFile())) return 0;
 
// Use the lock file as the source of information
//
   if (Refresh && stat(lockPath(), &(lP->Stat)))
      {Say.Emsg("setCpyTime", errno, "stat", lockPath()); return 0;}
   cpyInfo.Attr.cpyTime = static_cast<long long>(lP->Stat.st_mtime);
   return 1;
}

References XrdOucXAttr< T >::Attr, basePath(), XrdCms::Config, cpyInfo, XrdFrcXAttrCpy::cpyTime, XrdSysError::Emsg(), XrdOucXAttr< T >::Get(), lockFile(), lockPath(), Refresh(), XrdCms::Say, XrdOucNSWalk::NSEnt::Stat, and stat.

Referenced by XrdFrmFiles::Get(), and Screen().

Here is the call graph for this function:

Here is the caller graph for this function:

xyzFile()

XrdOucNSWalk::NSEnt* XrdFrmFileset::xyzFile ( XrdOssPath::theSfx  sfx )

inline

Definition at line 71 of file XrdFrmFiles.hh.

{return File[sfx];}

References File.

xyzPath()

const char* XrdFrmFileset::xyzPath ( XrdOssPath::theSfx  sfx )

inline

Definition at line 72 of file XrdFrmFiles.hh.

                                    {return Mkfn(File[sfx]);}

References File.

Friends And Related Function Documentation

XrdFrmFiles

friend class XrdFrmFiles

friend

Definition at line 51 of file XrdFrmFiles.hh.

Member Data Documentation

Age

int XrdFrmFileset::Age

Definition at line 91 of file XrdFrmFiles.hh.

Referenced by XrdFrmTSort::Add().

cpyInfo

XrdOucXAttr<XrdFrcXAttrCpy> XrdFrmFileset::cpyInfo

Definition at line 55 of file XrdFrmFiles.hh.

Referenced by Refresh(), and setCpyTime().

Next

XrdFrmFileset* XrdFrmFileset::Next

Definition at line 90 of file XrdFrmFiles.hh.

Referenced by XrdFrmFiles::~XrdFrmFiles(), XrdFrmTSort::Add(), XrdFrmFiles::Get(), XrdFrmMigrate::Migrate(), XrdFrmTSort::Oldest(), and XrdFrmTSort::Purge().

pinInfo

XrdOucXAttr<XrdFrcXAttrPin> XrdFrmFileset::pinInfo

Definition at line 56 of file XrdFrmFiles.hh.

Referenced by Refresh().

---

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

• XrdFrmFiles.hh
• XrdFrmFiles.cc