XrdOssArcStage Class Reference

#include <XrdOssArcStage.hh>

Inheritance diagram for XrdOssArcStage:

Collaboration diagram for XrdOssArcStage:

Public Types
enum	MssRC {   isBad = -1 ,   isFalse = 0 ,   isTrue = 1 }

Public Member Functions
	XrdOssArcStage (const char *aPath)
virtual	~XrdOssArcStage ()
virtual void	DoIt () override
Public Member Functions inherited from XrdJob
	XrdJob (const char *desc="")
virtual	~XrdJob ()

Static Public Member Functions
static MssRC	isOnline (const char *path)
static int	Stage (const char *path, const char *mssPath)

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

Detailed Description

Definition at line 40 of file XrdOssArcStage.hh.

Member Enumeration Documentation

MssRC

enum XrdOssArcStage::MssRC

Enumerator
isBad
isFalse
isTrue

Definition at line 46 of file XrdOssArcStage.hh.

{isBad = -1, isFalse = 0, isTrue = 1};

Constructor & Destructor Documentation

XrdOssArcStage()

XrdOssArcStage::XrdOssArcStage ( const char *  aPath )

inline

Definition at line 52 of file XrdOssArcStage.hh.

                                           : XrdJob("Arc Staging"),
                        arcvPath(aPath) {}

~XrdOssArcStage()

virtual XrdOssArcStage::~XrdOssArcStage ( )

inlinevirtual

Definition at line 55 of file XrdOssArcStage.hh.

{}

Member Function Documentation

DoIt()

void XrdOssArcStage::DoIt ( )

overridevirtual

Implements XrdJob.

Definition at line 90 of file XrdOssArcStage.cc.

{
   TraceInfo("Bring_Online",0);
   const char* nxtPath;
   time_t seTime;
   int   fd;
 
// The arcvPath is the path of the file in the locally mounted tape buffer.
// Simply open it to force it to be staged online.
//
do{DEBUG("Staging "<<arcvPath);
   seTime = time(0);
   if ((fd = XrdSysFD_Open(arcvPath, O_RDONLY)) < 0)
      StageError(errno, "open/stage file", arcvPath);
      else {close(fd);
            seTime = time(0) - seTime;
            DEBUG(arcvPath<<" staged in "<<seTime<<" second(s)");
           }
 
// Check if there is something pending that we can do now
//
   schedMtx.Lock();
   if (Pending.empty()) break;
   nxtPath = Pending.front();
   Pending.pop();
   schedMtx.UnLock();
 
// Reset this object to handle the path
//
   Reset(nxtPath);
 
  } while(true);
 
// Do final reset as we finished processing
//
   Reset(0);
 
// We are done, so delete this object and return 
//
   int n = Config.maxStage++;  // schedMtx is still held
   schedMtx.UnLock();
   DEBUG("Staging queue empty; MaxStage="<<n+1);
   delete this;
}

References close, XrdOssArcGlobals::Config, DEBUG, XrdSysMutex::Lock(), XrdOssArcConfig::maxStage, XrdOssArcGlobals::Pending, XrdOssArcGlobals::schedMtx, TraceInfo, and XrdSysMutex::UnLock().

Here is the call graph for this function:

isOnline()

XrdOssArcStage::MssRC XrdOssArcStage::isOnline ( const char *  path )

static

Definition at line 139 of file XrdOssArcStage.cc.

{
   TraceInfo("isOnline",0);
   int rc, finrc;
 
   DEBUG("Running "<<Config.MssComName<<" online "<<path);
   rc = Config.MssComProg->Run("online", path);
 
// Adjust return code. Note that XrdOucProg return -status!
//
   if (rc < -1 || rc > 1) finrc = -1;
      else finrc = -rc;
   DEBUG("MssComCmd returned "<<rc<<" -> "<<finrc);
          
   return static_cast<MssRC>(finrc);
}

References XrdOssArcGlobals::Config, DEBUG, XrdOssArcConfig::MssComName, XrdOssArcConfig::MssComProg, XrdOucProg::Run(), and TraceInfo.

Here is the call graph for this function:

Stage()

int XrdOssArcStage::Stage ( const char *  path, const char *  mssPath  )

static

Definition at line 186 of file XrdOssArcStage.cc.

{
   TraceInfo("Stage",0);
   ActInfo aInfo(path);
 
// Check if this is being staged
//
   stageMtx.Lock();
   auto it = Active.find(&aInfo);
   if (it != Active.end())
      {int rc;
       if ((*it)->rc == 0) rc = EINPROGRESS;
          else {rc = (*it)->rc;
                ActInfo* aiP = *it;
                Active.erase(it);
                delete aiP;
               }
       stageMtx.UnLock();
       return rc;
      } else stageMtx.UnLock();
 
// Make sure the path exists and is actually online
//
   MssRC mssRC = isOnline(mssPath);
   switch(mssRC)
         {case isFalse: break;
          case isTrue:  return 0;      break;
          default:      return EINVAL; break;
         }
 
// Create a an action information object. This will copy the path and we
// can use the copy in other places as the pointer i
//
   ActInfo* stageInfo = new ActInfo(path, true);
 
// Add the path to the staging set. Another thread may have beat us to it.
//
   stageMtx.Lock();
   auto iResult = Active.insert(stageInfo);
   stageMtx.UnLock();
   if (!iResult.second)
      {delete stageInfo;
       return EINPROGRESS;
      }
 
// Schedule this staging request if we are allowed to do so
//
   int smx;
   schedMtx.Lock();
   if (Config.maxStage)
      {smx = Config.maxStage--; 
       schedMtx.UnLock();
       XrdOssArcStage *asP = new XrdOssArcStage(stageInfo->path);
       schedP->Schedule((XrdJob*)asP);
       return EINPROGRESS;
      } else smx = 0;
 
// Too many things being staged, so queue this request
//
   Pending.push(stageInfo->path);
   schedMtx.UnLock();
 
// Do some debugging
//
   DEBUG("MaxStage="<<smx<<" staging '"<<path<<(smx?"' scheduled":"' queued"));
 
// All done
//
   return EINPROGRESS;
}

References XrdOssArcGlobals::Config, DEBUG, XrdSysMutex::Lock(), XrdOssArcConfig::maxStage, XrdOssArcGlobals::ActInfo::path, XrdOssArcGlobals::Pending, XrdOssArcGlobals::schedMtx, XrdOssArcGlobals::schedP, XrdScheduler::Schedule(), XrdOssArcGlobals::stageMtx, TraceInfo, and XrdSysMutex::UnLock().

Referenced by XrdOssArcFile::Open().

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• XrdOssArcStage.hh
• XrdOssArcStage.cc