XrdPfc::DataFsSnapshot Struct Reference

#include <XrdPfcDirStateSnapshot.hh>

Inheritance diagram for XrdPfc::DataFsSnapshot:

Collaboration diagram for XrdPfc::DataFsSnapshot:

Public Member Functions
	DataFsSnapshot ()
	DataFsSnapshot (const DataFsStateBase &b, time_t sshot_stats_reset_time)
void	dump ()
void	write_json_file (const std::string &fname, XrdOss &oss, bool include_preamble)

Public Attributes
std::vector< DirStateElement >	m_dir_states
time_t	m_sshot_stats_reset_time = 0
Public Attributes inherited from XrdPfc::DataFsStateBase
long long	m_disk_total = 0
long long	m_disk_used = 0
long long	m_file_usage = 0
long long	m_meta_total = 0
long long	m_meta_used = 0
time_t	m_usage_update_time = 0

Detailed Description

Definition at line 35 of file XrdPfcDirStateSnapshot.hh.

Constructor & Destructor Documentation

DataFsSnapshot() [1/2]

XrdPfc::DataFsSnapshot::DataFsSnapshot ( )

inline

Definition at line 40 of file XrdPfcDirStateSnapshot.hh.

{}

DataFsSnapshot() [2/2]

XrdPfc::DataFsSnapshot::DataFsSnapshot ( const DataFsStateBase & b, time_t sshot_stats_reset_time )

inline

Definition at line 41 of file XrdPfcDirStateSnapshot.hh.

                                                                           :
     DataFsStateBase(b),
     m_sshot_stats_reset_time(sshot_stats_reset_time)
   {}

References m_sshot_stats_reset_time.

Member Function Documentation

dump()

void DataFsSnapshot::dump

(

)

Definition at line 153 of file XrdPfcDirStateSnapshot.cc.

{
   nlohmann::ordered_json j;
   to_json(j, *this);
   std::cout << j.dump(3) << "\n";
}

write_json_file()

void DataFsSnapshot::write_json_file	(	const std::string &	fname,
		XrdOss &	oss,
		bool	include_preamble )

Definition at line 70 of file XrdPfcDirStateSnapshot.cc.

{
  // Create the data file.const
   const Configuration &conf    =  Cache::Conf();
   const char          *myUser = conf.m_username.c_str();
   XrdOucEnv            myEnv;
 
   const char* size_str = "524288";
   myEnv.Put("oss.asize",  size_str); // advisory size
   myEnv.Put("oss.cgroup", conf.m_data_space.c_str()); // AMT: data or metadata space
 
   mode_t mode = 0644;
 
   int cret;
   if ((cret = oss.Create(myUser, file_path.c_str(), mode, myEnv, XRDOSS_mkpath)) != XrdOssOK)
   {
      TRACE(Error, "Create failed for data file " << file_path << ERRNO_AND_ERRSTR(-cret));
      return;
   }
 
   XrdOssDF *myFile = oss.newFile(myUser);
   if ((cret = myFile->Open(file_path.c_str(), O_RDWR, mode, myEnv)) != XrdOssOK)
   {
      TRACE(Error, "Open failed for data file " << file_path << ERRNO_AND_ERRSTR(-cret));
      delete myFile;
      return;
   }
 
   // Fill the data file.
   std::ostringstream os;
 
   if (include_preamble)
   {
      os << "{ \"dirstate_snapshot\": ";
   }
 
   nlohmann::ordered_json j;
   to_json(j, *this);
 
   os << std::setw(1);
   os << j;
 
   if (include_preamble)
   {
      os << " }";
   }
 
   os << "\n";
   myFile->Ftruncate(0);
   myFile->Write(os.str().c_str(), 0, os.str().size());
   myFile->Close();     delete myFile;
 
   // Create the info file.
 
   std::string cinfo_path(file_path + Info::s_infoExtension);
 
   if ((cret = oss.Create(myUser, cinfo_path.c_str(), mode, myEnv, XRDOSS_mkpath)) != XrdOssOK)
   {
      TRACE(Error, "Create failed for info file " << cinfo_path << ERRNO_AND_ERRSTR(-cret));
      myFile->Close(); delete myFile;
      return;
   }
 
   XrdOssDF *myInfoFile = oss.newFile(myUser);
   if ((cret = myInfoFile->Open(cinfo_path.c_str(), O_RDWR, mode, myEnv)) != XrdOssOK)
   {
      TRACE(Error, "Open failed for info file " << cinfo_path << ERRNO_AND_ERRSTR(-cret));
      delete myInfoFile;
      myFile->Close(); delete myFile;
      return;
   }
 
   // Fill up cinfo.
 
   Info myInfo(GetTrace(), false);
   myInfo.SetBufferSizeFileSizeAndCreationTime(512*1024, os.str().size());
   myInfo.SetAllBitsSynced();
 
   myInfo.Write(myInfoFile, cinfo_path.c_str());
   myInfoFile->Close();
   delete myInfoFile;
}

References XrdOssDF::Close(), XrdPfc::Cache::Conf(), XrdOss::Create(), ERRNO_AND_ERRSTR, Error, XrdOssDF::Ftruncate(), XrdPfc::Configuration::m_data_space, XrdPfc::Configuration::m_username, XrdOss::newFile(), XrdOssDF::Open(), XrdOucEnv::Put(), XrdPfc::Info::s_infoExtension, XrdPfc::Info::SetAllBitsSynced(), XrdPfc::Info::SetBufferSizeFileSizeAndCreationTime(), TRACE, XrdOssDF::Write(), XrdPfc::Info::Write(), XRDOSS_mkpath, and XrdOssOK.

Referenced by XrdPfc::ResourceMonitor::heart_beat().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

m_dir_states

std::vector<DirStateElement> XrdPfc::DataFsSnapshot::m_dir_states

Definition at line 37 of file XrdPfcDirStateSnapshot.hh.

Referenced by XrdPfc::ResourceMonitor::heart_beat().

m_sshot_stats_reset_time

time_t XrdPfc::DataFsSnapshot::m_sshot_stats_reset_time = 0

Definition at line 38 of file XrdPfcDirStateSnapshot.hh.

Referenced by DataFsSnapshot().

---

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

• XrdPfcDirStateSnapshot.hh
• XrdPfcDirStateSnapshot.cc