XrdPfc::DataFsState Struct Reference

#include <XrdPfcDirState.hh>

Inheritance diagram for XrdPfc::DataFsState:

Collaboration diagram for XrdPfc::DataFsState:

Public Member Functions
	DataFsState ()
void	dump_recursively (int max_depth) const
DirState *	find_dirstate_for_lfn (const std::string &lfn, DirState **last_existing_dir=nullptr)
DirState *	get_root ()
void	init_stat_reset_times (time_t t)
long long	reap_empty_leaf_dirs (unlink_func unlink_foo)
void	reset_sshot_stats (time_t last_update)
void	update_stats_and_usages (time_t last_update, bool collect_reap_candidates)

Public Attributes
std::vector< DirState * >	m_reap_candidates
DirState	m_root
time_t	m_sshot_stats_reset_time = 0
long long	m_st_blocks_fuzz = 0
time_t	m_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 145 of file XrdPfcDirState.hh.

Constructor & Destructor Documentation

DataFsState()

XrdPfc::DataFsState::DataFsState ( )

inline

Definition at line 155 of file XrdPfcDirState.hh.

: m_root() {}

References m_root.

Member Function Documentation

dump_recursively()

void DataFsState::dump_recursively

(

int

max_depth

)

const

Definition at line 314 of file XrdPfcDirState.cc.

{
   if (max_depth < 0)
      max_depth = 4096;
 
   printf("DataFsState::dump_recursively delta_t = %lld, max_dump_depth = %d\n",
          (long long)(m_usage_update_time - m_sshot_stats_reset_time), max_depth);
 
   m_root.dump_recursively("root", max_depth);
}

References m_root, m_sshot_stats_reset_time, and XrdPfc::DataFsStateBase::m_usage_update_time.

find_dirstate_for_lfn()

DirState * XrdPfc::DataFsState::find_dirstate_for_lfn ( const std::string & lfn, DirState ** last_existing_dir = nullptr )

inline

Definition at line 161 of file XrdPfcDirState.hh.

   {
      return m_root.find_path(lfn, -1, true, true, last_existing_dir);
   }

References m_root.

get_root()

DirState * XrdPfc::DataFsState::get_root ( )

inline

Definition at line 159 of file XrdPfcDirState.hh.

{ return & m_root; }

References m_root.

init_stat_reset_times()

void XrdPfc::DataFsState::init_stat_reset_times ( time_t t )

inline

Definition at line 157 of file XrdPfcDirState.hh.

{ m_stats_reset_time = m_sshot_stats_reset_time = t; }

References m_sshot_stats_reset_time, and m_stats_reset_time.

reap_empty_leaf_dirs()

long long DataFsState::reap_empty_leaf_dirs

(

unlink_func

unlink_foo

)

Remove the empty leaves collected at the last snapshot, which reported them once more, empty. The root is never a candidate, and a parent waits for the next snapshot. Returns the leftover st_blocks taken out of the tree.

Definition at line 276 of file XrdPfcDirState.cc.

{
   long long total_residue = 0;
   for (DirState *ds : m_reap_candidates)
   {
      // A pending close points at a DirState while m_NFilesOpen > 0.
      if ( ! ds->is_empty_leaf())
         continue;
 
      std::string dir_path;
      dir_path.reserve(1024);
      ds->generate_dir_path(dir_path);
      if (unlink_foo(dir_path) != 0)
         continue;
 
      // Return a leftover st_blocks through the recursive stats, where the ancestors
      // counted it, rather than lose it with the node. Keep the correction, and the
      // node's own fuzz, as the parent's.
      DirState *parent  = ds->m_parent;
      long long residue = ds->m_here_usage.m_StBlocks + ds->m_recursive_subdir_usage.m_StBlocks;
      parent->m_recursive_subdir_stats.m_StBlocksRemoved += residue;
      parent->m_StBlocksFuzz += std::llabs(residue) + ds->m_StBlocksFuzz;
      m_st_blocks_fuzz       += std::llabs(residue);
      total_residue          += residue;
 
      ++parent->m_here_stats.m_NDirectoriesRemoved;
      parent->m_subdirs.erase(parent->m_subdirs.find(ds->m_dir_name));
   }
   m_reap_candidates.clear();
   return total_residue;
}

References m_reap_candidates, m_st_blocks_fuzz, and parent().

Here is the call graph for this function:

reset_sshot_stats()

void DataFsState::reset_sshot_stats

(

time_t

last_update

)

Definition at line 308 of file XrdPfcDirState.cc.

{
   m_root.reset_sshot_stats();
   m_sshot_stats_reset_time = last_update;
}

References m_root, and m_sshot_stats_reset_time.

update_stats_and_usages()

void DataFsState::update_stats_and_usages	(	time_t	last_update,
		bool	collect_reap_candidates )

Definition at line 260 of file XrdPfcDirState.cc.

{
   if (collect_reap_candidates)
      m_reap_candidates.clear();
   m_root.update_stats_and_usages(collect_reap_candidates ? &m_reap_candidates : nullptr);
   m_root.m_here_stats.Reset();
   m_root.m_recursive_subdir_stats.Reset();
   m_usage_update_time = last_update;
   m_stats_reset_time  = last_update;
}

References m_reap_candidates, m_root, m_stats_reset_time, and XrdPfc::DataFsStateBase::m_usage_update_time.

Member Data Documentation

m_reap_candidates

std::vector<DirState*> XrdPfc::DataFsState::m_reap_candidates

Definition at line 152 of file XrdPfcDirState.hh.

Referenced by reap_empty_leaf_dirs(), and update_stats_and_usages().

m_root

DirState XrdPfc::DataFsState::m_root

Definition at line 147 of file XrdPfcDirState.hh.

Referenced by DataFsState(), dump_recursively(), find_dirstate_for_lfn(), get_root(), reset_sshot_stats(), and update_stats_and_usages().

m_sshot_stats_reset_time

time_t XrdPfc::DataFsState::m_sshot_stats_reset_time = 0

Definition at line 149 of file XrdPfcDirState.hh.

Referenced by dump_recursively(), init_stat_reset_times(), and reset_sshot_stats().

m_st_blocks_fuzz

long long XrdPfc::DataFsState::m_st_blocks_fuzz = 0

Definition at line 151 of file XrdPfcDirState.hh.

Referenced by reap_empty_leaf_dirs().

m_stats_reset_time

time_t XrdPfc::DataFsState::m_stats_reset_time = 0

Definition at line 148 of file XrdPfcDirState.hh.

Referenced by init_stat_reset_times(), and update_stats_and_usages().

---

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

• XrdPfcDirState.hh
• XrdPfcDirState.cc