XrdOssArcBackup Class Reference

#include <XrdOssArcBackup.hh>

Inheritance diagram for XrdOssArcBackup:

Collaboration diagram for XrdOssArcBackup:

Public Member Functions
	XrdOssArcBackup (const char *scp, bool &isOK)
	~XrdOssArcBackup ()
bool	Archive (const char *dsName, const char *dsDir)
const char *	Arena ()
void	DoIt () override
const char *	theScope ()
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static void	StartWorkers (int maxw)

Friends
class	XrdOssArcBackupTask

Additional Inherited Members
Public Attributes inherited from XrdJob
const char *	Comment
XrdJob *	NextJob

Detailed Description

Definition at line 69 of file XrdOssArcBackup.hh.

Constructor & Destructor Documentation

XrdOssArcBackup()

XrdOssArcBackup::XrdOssArcBackup	(	const char *	scp,
		bool &	isOK )

Definition at line 342 of file XrdOssArcBackup.cc.

                : XrdJob("Backup"), Scope(scp)
{
   char abuff[1024];
   int rc;
 
// Construct the arena where our backups will be staged
//
   snprintf(abuff, sizeof(abuff), "%s%s/",Config.dsetRepoPFN,scp);
   rc = XrdOucUtils::makePath(abuff, S_IRWXU|S_IRGRP|S_IXGRP);
   if (rc)
      {Elog.Emsg("Backup", rc, "create arena", abuff);
       isOK = false;
      } else {
       myArena = strdup(abuff);
       isOK = true;
      }
}

References XrdJob::XrdJob(), XrdOssArcGlobals::Config, XrdOssArcGlobals::Elog, and XrdOucUtils::makePath().

Here is the call graph for this function:

~XrdOssArcBackup()

XrdOssArcBackup::~XrdOssArcBackup ( )

inline

Definition at line 88 of file XrdOssArcBackup.hh.

{}

Member Function Documentation

Archive()

bool XrdOssArcBackup::Archive	(	const char *	dsName,
		const char *	dsDir )

Definition at line 389 of file XrdOssArcBackup.cc.

{
   TraceInfo("Archive",0);
   XrdOucStream cmdOut;
   char tapPath[MAXPATHLEN];
   int n, rc;
 
// All we need to do is launch the archive program to complete the steps:
// 1. Create the zip file of all files in the dataset.
// 2. Move the zip file to the <tape_dir>.
// 3. Do a recursvive delete starting at and including <src_dir>.
// 4. Delete file <trg_dir>/<zipfn>.
 
// The calling parameters are:
// <src_dir> <tape_dir> <arcfn> [{<arcpy> | ""} [<arcdsp> <manifest>]]
//
// <src_dir>:  The directory containing all of the files in the dataset.
//             This is apssed as a PFN via dsDir parameter.
// <tape_dir>: The directory to hold the zip archive destined to tape.
//             We need to build this using the dsName parameter.
// <arcfn>:    The actual filename to be used for the archive. By convention
//             the archive is created as '<src_dir>/../<arcfn>'.
//[<arcpy>]    Optional parameter to drive remote mode backups.
//                       0      1        2               3
   const char* argV[] = {dsDir, tapPath, Config.arFName, Config.ArchiverSave};
//                                       4                   5
   if (Config.bkpLocal)
      {n = snprintf(tapPath, sizeof(tapPath), "%s/%s/%s",
                             Config.tapePath, Scope, dsName);
       argV[3] = "";
      } else {
       n = snprintf(tapPath, sizeof(tapPath), "%s/%s", Scope, dsName);
       argV[3] =  Config.ArchiverSave;
      }
 
 
 
// Verify we didn't truncate the path
//
   if (n >= (int)sizeof(tapPath))
      {rc = -ENAMETOOLONG;
       snprintf(tapPath, sizeof(tapPath), "%s:%s", Scope, dsName);
       Elog.Emsg("Archive", rc, "generate tape path for dataset", tapPath);
       Elog.Emsg("Archive","Dataset",dsName,"needs manual intervention!!!");
       return false;
      }
 
// Do some tracing
//
   DEBUG("Running "<<Config.ArchiverName<<' '<<argV[0]<<' '
                   <<argV[1]<<' '<<argV[2]<<' '<<argV[3]);
 
// Run the archive script.
//
   n = sizeof(argV)/sizeof(char*);
   if (!(rc = Config.ArchiverProg->Run(&cmdOut, argV, n)))
      {char* lp;
       while((lp = cmdOut.GetLine())) {} // Throw away stdout
       rc = Config.ArchiverProg->RunDone(cmdOut);
      }
 
// Check for any failures
//
   if (rc)
      {char rcVal[32];
       snprintf(rcVal, sizeof(rcVal),"%d",rc);
       Elog.Emsg("Archive", "Archive script failed with rc=", rcVal);
       Elog.Emsg("Archive", "Dataset", dsName, "needs manual intervention!!!");
       return false;
      }
 
   return true;   
}

References XrdOssArcGlobals::Config, DEBUG, XrdOssArcGlobals::Elog, XrdOucStream::GetLine(), and TraceInfo.

Here is the call graph for this function:

Arena()

const char * XrdOssArcBackup::Arena ( )

inline

Definition at line 77 of file XrdOssArcBackup.hh.

{return myArena;}

DoIt()

void XrdOssArcBackup::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 467 of file XrdOssArcBackup.cc.

{
  // Do a backup round and then reschedule for the next one
  //
  GetManifest();
 
  schedP->Schedule(this, time(0)+Config.bkpPoll);
}

References XrdOssArcGlobals::Config, and XrdOssArcGlobals::schedP.

StartWorkers()

void XrdOssArcBackup::StartWorkers ( int maxw )

static

Definition at line 558 of file XrdOssArcBackup.cc.

{
   TraceInfo("StartWorkers",0);
   numRunning = maxRunning = maxw;
 
// Start all of the workers, they will immediately go idle.
// This is a one time call from config.
//
   for (int i = 0; i < maxw; i++)
       {XrdJob* bJob = new BkpWorker();
        schedP->Schedule(bJob);
       }
 
// Do some tracing
//
   DEBUG("Started "<<maxw<<" backup workers.");
}

References XrdJob::XrdJob(), DEBUG, XrdOssArcGlobals::schedP, and TraceInfo.

Referenced by XrdOssArcConfig::Configure().

Here is the call graph for this function:

Here is the caller graph for this function:

theScope()

const char * XrdOssArcBackup::theScope ( )

inline

Definition at line 85 of file XrdOssArcBackup.hh.

{return Scope;}

Friends And Related Symbol Documentation

XrdOssArcBackupTask

friend class XrdOssArcBackupTask

friend

Definition at line 71 of file XrdOssArcBackup.hh.

References XrdOssArcBackupTask.

Referenced by XrdOssArcBackupTask.

---

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

• XrdOssArcBackup.hh
• XrdOssArcBackup.cc