1 #ifndef art_Framework_IO_ClosingCriteria_h 2 #define art_Framework_IO_ClosingCriteria_h 39 unsigned nRuns()
const;
41 unsigned size()
const;
63 std::atomic<std::chrono::seconds>
age_;
72 static constexpr
unsigned 75 return std::numeric_limits<unsigned>::max();
77 static constexpr
unsigned 82 static constexpr
unsigned 85 return std::chrono::duration_values<unsigned>::max();
87 static constexpr
char const*
105 Defaults::unsigned_max()};
107 Comment(
"Maximum size of file (in KiB)"),
108 Defaults::size_max()};
110 Comment(
"Maximum age of output file (in seconds)"),
111 Defaults::seconds_max()};
116 "The 'granularity' parameter specifies the level at which\n" 117 "a file may be closed, and thereby the granularity of the file.\n" 118 "The following values are possible:\n\n" 120 " =======================================================\n" 121 " \"Event\" Allow file switch at next Event\n" 122 " \"SubRun\" Allow file switch at next SubRun\n" 123 " \"Run\" Allow file switch at next Run\n" 124 " \"InputFile\" Allow file switch at next InputFile\n" 125 " \"Job\" File closes at the end of Job\n\n" 126 "For example, if a granularity of \"SubRun\" is specified, but the\n" 127 "file has reached the maximum events written to disk (as specified\n" 128 "by the 'maxEvents' parameter), switching to a new file will NOT\n" 129 "happen until a new SubRun has been reached (or there are no more\n" 130 "Events/SubRuns/Runs to process)."),
131 Defaults::granularity_default()};
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_subRun_
std::atomic< unsigned > counts_inputFile_
FileIndex::EntryNumber_t runEntryNumber() const
std::atomic< std::chrono::seconds > age_
unsigned nSubRuns() const
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_run_
std::atomic< unsigned > size_
unsigned nInputFiles() const
std::atomic< unsigned > counts_run_
FileIndex::EntryNumber_t eventEntryNumber() const
static BT value(std::string const &spec)
std::ostream & operator<<(std::ostream &os, const GroupSelector &gs)
std::chrono::seconds age() const
void updateAge(std::chrono::seconds const age)
second seconds
Alias for common language habits.
void update_subRun(OutputFileStatus const status)
FileProperties & operator=(FileProperties const &)
std::atomic< unsigned > counts_event_
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_inputFile_
FileProperties closingCriteria_
std::atomic< unsigned > counts_job_
static constexpr char const * granularity_default()
std::atomic< unsigned > counts_subRun_
static constexpr unsigned unsigned_max()
void update_run(OutputFileStatus const status)
static constexpr unsigned size_max()
FileIndex::EntryNumber_t subRunEntryNumber() const
void updateSize(unsigned const size)
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_event_
static constexpr unsigned seconds_max()