#include <FileStatsCollector.h>

Public Member Functions
	FileStatsCollector (std::string const &moduleLabel, std::string const &processName)

void	recordFileOpen ()

void	recordInputFile (std::string const &inputFileName)

void	recordEvent (EventID const &id)

void	recordRun (RunID const &id)

void	recordSubRun (SubRunID const &id)

void	recordFileClose ()

std::string const &	moduleLabel () const

std::string const &	processName () const

boost::posix_time::ptime	outputFileOpenTime () const

boost::posix_time::ptime	outputFileCloseTime () const

boost::posix_time::ptime	lowestRunStartTime () const

boost::posix_time::ptime	highestRunStartTime () const

boost::posix_time::ptime	lowestSubRunStartTime () const

boost::posix_time::ptime	highestSubRunStartTime () const

RunID	lowestRunID () const

RunID	highestRunID () const

SubRunID const &	lowestSubRunID () const

SubRunID const &	highestSubRunID () const

EventID const &	lowestEventID () const

EventID const &	highestEventID () const

std::string const &	lastOpenedInputFile () const

std::vector< std::string >	parents (bool want_basename=true) const

bool	fileCloseRecorded () const

std::size_t	eventsThisFile () const

std::set< SubRunID > const &	seenSubRuns () const

Private Member Functions
void	resetStatistics_ ()

Private Attributes
std::string const	moduleLabel_

std::string const	processName_

RunID	lowestRun_ {}

RunID	highestRun_ {}

SubRunID	lowestSubRun_ {}

SubRunID	highestSubRun_ {}

EventID	lowestEventIDSeen_ {}

EventID	highestEventIDSeen_ {}

boost::posix_time::ptime	fo_ {}

boost::posix_time::ptime	fc_ {}

boost::posix_time::ptime	lowestRunStartTime_ {}

boost::posix_time::ptime	highestRunStartTime_ {}

boost::posix_time::ptime	lowestSubRunStartTime_ {}

boost::posix_time::ptime	highestSubRunStartTime_ {}

bool	fileCloseRecorded_ {false}

std::string	lastOpenedInputFile_ {}

std::vector< std::string >	inputFilesSeen_ {}

std::size_t	nEvents_ {}

std::set< SubRunID >	subRunsSeen_ {}

Detailed Description

Definition at line 24 of file FileStatsCollector.h.

Constructor & Destructor Documentation

art::FileStatsCollector::FileStatsCollector	(	std::string const &	moduleLabel,
		std::string const &	processName
	)

Definition at line 12 of file FileStatsCollector.cc.

14 : moduleLabel_{moduleLabel}, processName_{processName}

15 {}

art::FileStatsCollector::processName

std::string const & processName() const

Definition: FileStatsCollector.h:87

art::FileStatsCollector::moduleLabel

std::string const & moduleLabel() const

Definition: FileStatsCollector.h:81

art::FileStatsCollector::moduleLabel_

std::string const moduleLabel_

Definition: FileStatsCollector.h:59

art::FileStatsCollector::processName_

std::string const processName_

Definition: FileStatsCollector.h:60

Member Function Documentation

std::size_t art::FileStatsCollector::eventsThisFile ( ) const

inline

Definition at line 177 of file FileStatsCollector.h.

 {
   return nEvents_;
 }

bool art::FileStatsCollector::fileCloseRecorded ( ) const

inline

Definition at line 171 of file FileStatsCollector.h.

 {
   return fileCloseRecorded_;
 }

art::EventID const & art::FileStatsCollector::highestEventID ( ) const

inline

Definition at line 159 of file FileStatsCollector.h.

 {
   return highestEventIDSeen_;
 }

art::RunID art::FileStatsCollector::highestRunID ( ) const

inline

Definition at line 135 of file FileStatsCollector.h.

 {
   return highestRun_;
 }

boost::posix_time::ptime art::FileStatsCollector::highestRunStartTime ( ) const

inline

Definition at line 111 of file FileStatsCollector.h.

 {
   return highestRunStartTime_;
 }

art::SubRunID const & art::FileStatsCollector::highestSubRunID ( ) const

inline

Definition at line 147 of file FileStatsCollector.h.

 {
   return highestSubRun_;
 }

boost::posix_time::ptime art::FileStatsCollector::highestSubRunStartTime ( ) const

inline

Definition at line 123 of file FileStatsCollector.h.

 {
   return highestSubRunStartTime_;
 }

std::string const & art::FileStatsCollector::lastOpenedInputFile ( ) const

inline

Definition at line 165 of file FileStatsCollector.h.

 {
   return lastOpenedInputFile_;
 }

art::EventID const & art::FileStatsCollector::lowestEventID ( ) const

inline

Definition at line 153 of file FileStatsCollector.h.

 {
   return lowestEventIDSeen_;
 }

art::RunID art::FileStatsCollector::lowestRunID ( ) const

inline

Definition at line 129 of file FileStatsCollector.h.

 {
   return lowestRun_;
 }

boost::posix_time::ptime art::FileStatsCollector::lowestRunStartTime ( ) const

inline

Definition at line 105 of file FileStatsCollector.h.

 {
   return lowestRunStartTime_;
 }

art::SubRunID const & art::FileStatsCollector::lowestSubRunID ( ) const

inline

Definition at line 141 of file FileStatsCollector.h.

 {
   return lowestSubRun_;
 }

boost::posix_time::ptime art::FileStatsCollector::lowestSubRunStartTime ( ) const

inline

Definition at line 117 of file FileStatsCollector.h.

 {
   return lowestSubRunStartTime_;
 }

std::string const & art::FileStatsCollector::moduleLabel ( ) const

inline

Definition at line 81 of file FileStatsCollector.h.

 {
   return moduleLabel_;
 }

boost::posix_time::ptime art::FileStatsCollector::outputFileCloseTime ( ) const

inline

Definition at line 99 of file FileStatsCollector.h.

 {
   return fc_;
 }

boost::posix_time::ptime art::FileStatsCollector::outputFileOpenTime ( ) const

inline

Definition at line 93 of file FileStatsCollector.h.

 {
   return fo_;
 }

std::vector< std::string > art::FileStatsCollector::parents ( bool want_basename = true ) const

Definition at line 100 of file FileStatsCollector.cc.

 {
   std::vector<std::string> result;
   if (want_basename) {
     result.reserve(inputFilesSeen_.size());
     for (auto const& ifile : inputFilesSeen_) {
       boost::filesystem::path const ifp{ifile};
       result.emplace_back(ifp.filename().native());
     }
   } else {
     result = inputFilesSeen_;
   }
   return result;
 }

std::string const & art::FileStatsCollector::processName ( ) const

inline

Definition at line 87 of file FileStatsCollector.h.

 {
   return processName_;
 }

void art::FileStatsCollector::recordEvent ( EventID const & id )

Definition at line 38 of file FileStatsCollector.cc.

 {
   ++nEvents_;
   if (!lowestEventIDSeen_.isValid()) {
     lowestEventIDSeen_ = highestEventIDSeen_ = id;
   } else if (id < lowestEventIDSeen_) {
     lowestEventIDSeen_ = id;
   } else if (id > highestEventIDSeen_) {
     highestEventIDSeen_ = id;
   }
 }

void art::FileStatsCollector::recordFileClose ( )

Definition at line 93 of file FileStatsCollector.cc.

 {
   fc_ = now();
   fileCloseRecorded_ = true;
 }

void art::FileStatsCollector::recordFileOpen ( )

Definition at line 18 of file FileStatsCollector.cc.

 {
   resetStatistics_();
   if (!inputFilesSeen_.empty()) {
     inputFilesSeen_.emplace_back(lastOpenedInputFile_);
   }
   fo_ = now();
   fileCloseRecorded_ = false;
 }

void art::FileStatsCollector::recordInputFile ( std::string const & inputFileName )

Definition at line 29 of file FileStatsCollector.cc.

 {
   if (!inputFileName.empty()) {
     inputFilesSeen_.emplace_back(inputFileName);
   }
   lastOpenedInputFile_ = inputFileName;
 }

void art::FileStatsCollector::recordRun ( RunID const & id )

Definition at line 51 of file FileStatsCollector.cc.

 {
   if (!lowestRun_.isValid()) {
     lowestRun_ = highestRun_ = id;
     lowestRunStartTime_ = highestRunStartTime_ = now();
     return;
   }
 
   if (id < lowestRun_) {
     lowestRun_ = id;
     lowestRunStartTime_ = now();
     if (lowestSubRun_.runID() != lowestRun_) {
       lowestSubRun_ = SubRunID{};
       lowestSubRunStartTime_ = ptime{};
     }
   } else if (id > highestRun_) {
     highestRun_ = id;
     highestRunStartTime_ = now();
     if (highestSubRun_.runID() != highestRun_) {
       highestSubRun_ = SubRunID{};
       highestSubRunStartTime_ = ptime{};
     }
   }
 }

void art::FileStatsCollector::recordSubRun ( SubRunID const & id )

Definition at line 77 of file FileStatsCollector.cc.

 {
   if (!lowestSubRun_.isValid()) {
     lowestSubRun_ = highestSubRun_ = id;
     lowestSubRunStartTime_ = highestSubRunStartTime_ = now();
   } else if (id < lowestSubRun_) {
     lowestSubRun_ = id;
     lowestSubRunStartTime_ = now();
   } else if (id > highestSubRun_) {
     highestSubRun_ = id;
     highestSubRunStartTime_ = now();
   }
   subRunsSeen_.emplace(id);
 }

void art::FileStatsCollector::resetStatistics_ ( )

private

Definition at line 116 of file FileStatsCollector.cc.

 {
   fo_ = fc_ = ptime{};
   lowestRun_ = highestRun_ = RunID{};
   lowestSubRun_ = highestSubRun_ = SubRunID{};
   lowestRunStartTime_ = highestRunStartTime_ = ptime{};
   lowestSubRunStartTime_ = highestSubRunStartTime_ = ptime{};
   inputFilesSeen_.clear();
   nEvents_ = 0ul;
   subRunsSeen_.clear();
 }

std::set< art::SubRunID > const & art::FileStatsCollector::seenSubRuns ( ) const

inline

Definition at line 183 of file FileStatsCollector.h.

 {
   return subRunsSeen_;
 }

Member Data Documentation

boost::posix_time::ptime art::FileStatsCollector::fc_ {}

private

Definition at line 68 of file FileStatsCollector.h.

bool art::FileStatsCollector::fileCloseRecorded_ {false}

private

Definition at line 73 of file FileStatsCollector.h.

boost::posix_time::ptime art::FileStatsCollector::fo_ {}

private

Definition at line 67 of file FileStatsCollector.h.

EventID art::FileStatsCollector::highestEventIDSeen_ {}

private

Definition at line 66 of file FileStatsCollector.h.

RunID art::FileStatsCollector::highestRun_ {}

private

Definition at line 62 of file FileStatsCollector.h.

boost::posix_time::ptime art::FileStatsCollector::highestRunStartTime_ {}

private

Definition at line 70 of file FileStatsCollector.h.

SubRunID art::FileStatsCollector::highestSubRun_ {}

private

Definition at line 64 of file FileStatsCollector.h.

boost::posix_time::ptime art::FileStatsCollector::highestSubRunStartTime_ {}

private

Definition at line 72 of file FileStatsCollector.h.

std::vector<std::string> art::FileStatsCollector::inputFilesSeen_ {}

private

Definition at line 75 of file FileStatsCollector.h.

std::string art::FileStatsCollector::lastOpenedInputFile_ {}

private

Definition at line 74 of file FileStatsCollector.h.

EventID art::FileStatsCollector::lowestEventIDSeen_ {}

private

Definition at line 65 of file FileStatsCollector.h.

RunID art::FileStatsCollector::lowestRun_ {}

private

Definition at line 61 of file FileStatsCollector.h.

boost::posix_time::ptime art::FileStatsCollector::lowestRunStartTime_ {}

private

Definition at line 69 of file FileStatsCollector.h.

SubRunID art::FileStatsCollector::lowestSubRun_ {}

private

Definition at line 63 of file FileStatsCollector.h.

boost::posix_time::ptime art::FileStatsCollector::lowestSubRunStartTime_ {}

private

Definition at line 71 of file FileStatsCollector.h.

std::string const art::FileStatsCollector::moduleLabel_

private

Definition at line 59 of file FileStatsCollector.h.

std::size_t art::FileStatsCollector::nEvents_ {}

private

Definition at line 76 of file FileStatsCollector.h.

std::string const art::FileStatsCollector::processName_

private

Definition at line 60 of file FileStatsCollector.h.

std::set<SubRunID> art::FileStatsCollector::subRunsSeen_ {}

private

Definition at line 77 of file FileStatsCollector.h.

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

art/art/Framework/IO/FileStatsCollector.h
art/art/Framework/IO/FileStatsCollector.cc

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation