XrdPfcPurgeQuota Class Reference

Inheritance diagram for XrdPfcPurgeQuota:

Collaboration diagram for XrdPfcPurgeQuota:

Public Member Functions
	XrdPfcPurgeQuota (XrdSysError &log)
bool	ConfigPurgePin (const char *parms) override
	Provide bytes to erase from dir quota listed in a text file. More...
long long	GetBytesToRecover (const XrdPfc::DataFsPurgeshot &purge_shot) override
	Provide bytes to erase from dir quota listed in a text file. More...
void	InitDirStatesForLocalPaths (const XrdPfc::DataFsPurgeshot &purge_shot)
	Set directory statistics. More...
Public Member Functions inherited from XrdPfc::PurgePin
virtual	~PurgePin ()
virtual bool	CallPeriodically ()
list_t &	refDirInfos ()

Additional Inherited Members
Public Types inherited from XrdPfc::PurgePin
typedef list_t::iterator	list_i
typedef std::vector< DirInfo >	list_t
Protected Attributes inherited from XrdPfc::PurgePin
list_t	m_list

Detailed Description

Definition at line 11 of file XrdPfcPurgeQuota.cc.

Constructor & Destructor Documentation

XrdPfcPurgeQuota()

XrdPfcPurgeQuota::XrdPfcPurgeQuota ( XrdSysError &  log )

inline

Definition at line 16 of file XrdPfcPurgeQuota.cc.

: m_log(log) {}

Member Function Documentation

ConfigPurgePin()

bool XrdPfcPurgeQuota::ConfigPurgePin ( const char *  parms )

inlineoverridevirtual

Provide bytes to erase from dir quota listed in a text file.

Reimplemented from XrdPfc::PurgePin.

Definition at line 61 of file XrdPfcPurgeQuota.cc.

   {
      // retrive configuration file name
      if (!parms || !parms[0] || (strlen(parms) == 0))
      {
         m_log.Emsg("ConfigPurgePin", "Quota file not specified.");
         return false;
      }
      m_log.Emsg("ConfigPurgePin", "Using directory list", parms);
 
      //  parse the file to get directory quotas
      const char *config_filename = parms;
      const char *theINS = getenv("XRDINSTANCE");
      XrdOucEnv myEnv;
      XrdOucStream Config(&m_log, theINS, &myEnv, "=====> PurgeQuota ");
 
      int fd;
      if ((fd = open(config_filename, O_RDONLY, 0)) < 0)
      {
         m_log.Emsg("ConfigPurgePin() can't open configuration file ", config_filename);
      }
 
      Config.Attach(fd);
      static const char *cvec[] = {"*** pfc purge plugin :", 0};
      Config.Capture(cvec);
 
      char *var;
      while ((var = Config.GetMyFirstWord()))
      {
         std::string dirpath = var;
         const char *val;
 
         if (!(val = Config.GetWord()))
         {
            m_log.Emsg("PurgeQuota plugin", "quota not specified");
            continue;
         }
 
         std::string tmpc = val;
         long long quota = 0;
         if (::isalpha(*(tmpc.rbegin())))
         {
            if (XrdOuca2x::a2sz(m_log, "Error getting quota", tmpc.c_str(), &quota))
            {
               continue;
            }
         }
         else
         {
            if (XrdOuca2x::a2ll(m_log, "Error getting quota", tmpc.c_str(), &quota))
            {
               continue;
            }
         }
 
         DirInfo d;
         d.path = dirpath;
         d.nBytesQuota = quota;
         m_list.push_back(d);
      }
 
      return true;
   }

References XrdOuca2x::a2ll(), XrdOuca2x::a2sz(), XrdCms::Config, XrdSysError::Emsg(), XrdPfc::PurgePin::m_list, XrdPfc::PurgePin::DirInfo::nBytesQuota, open, and XrdPfc::PurgePin::DirInfo::path.

Here is the call graph for this function:

GetBytesToRecover()

long long XrdPfcPurgeQuota::GetBytesToRecover ( const XrdPfc::DataFsPurgeshot &  purge_shot )

inlineoverridevirtual

Provide bytes to erase from dir quota listed in a text file.

Implements XrdPfc::PurgePin.

Definition at line 32 of file XrdPfcPurgeQuota.cc.

   {
      // setup diskusage for each dir path
      InitDirStatesForLocalPaths(purge_shot);
 
      long long totalToRemove = 0;
      // get bytes to remove
      for (list_i it = m_list.begin(); it != m_list.end(); ++it)
      {
         if (it->dirUsage == nullptr)
         {
            m_log.Emsg("PurgeQuotaPin--GetBytesToRecover", "directory not found:", it->path.c_str());
            continue;
         }
         long long cv = 512ll * it->dirUsage->m_StBlocks - it->nBytesQuota;
         if (cv > 0)
            it->nBytesToRecover = cv;
         else
            it->nBytesToRecover = 0;
 
         totalToRemove += it->nBytesToRecover;
      }
 
      return totalToRemove;
   }

References XrdSysError::Emsg(), InitDirStatesForLocalPaths(), and XrdPfc::PurgePin::m_list.

Here is the call graph for this function:

InitDirStatesForLocalPaths()

void XrdPfcPurgeQuota::InitDirStatesForLocalPaths ( const XrdPfc::DataFsPurgeshot &  purge_shot )

inline

Set directory statistics.

Definition at line 21 of file XrdPfcPurgeQuota.cc.

   {
      for (list_i it = m_list.begin(); it != m_list.end(); ++it)
      {
         it->dirUsage = purge_shot.find_dir_usage_for_dir_path(it->path);
      }
   }

References XrdPfc::DataFsPurgeshot::find_dir_usage_for_dir_path(), and XrdPfc::PurgePin::m_list.

Referenced by GetBytesToRecover().

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 file:

• XrdPfcPurgeQuota.cc