11 config_require(
bool const cond,
string const& msg)
20 FileProperties::~FileProperties() =
default;
23 FileProperties::FileProperties()
33 ,
age_{chrono::seconds::zero()}
39 unsigned const subRuns,
41 unsigned const inputFiles,
42 unsigned const the_size,
68 ,
age_{rhs.age_.load()}
69 ,
size_{rhs.size_.load()}
83 ,
age_{rhs.age_.load()}
84 ,
size_{rhs.size_.load()}
119 age_ = rhs.age_.load();
120 size_ = rhs.size_.load();
226 <<
", size: " << fp.
size() <<
", age: " << fp.
age().count() <<
"]";
252 config_require(cc.nEvents() > 0,
"maxEvents must be greater than 0.");
253 config_require(cc.nSubRuns() > 0,
"maxSubRuns must be greater than 0.");
254 config_require(cc.nRuns() > 0,
"maxRuns must be greater than 0.");
255 config_require(cc.nInputFiles() > 0,
256 "maxInputFiles must be greater than 0.");
257 config_require(cc.size() > 0,
"maxSize must be greater than 0 KiB.");
258 config_require(cc.age() > decltype(cc.age())::zero(),
259 "maxAge must be greater than 0 seconds.");
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_subRun_
std::atomic< unsigned > counts_inputFile_
FileIndex::EntryNumber_t runEntryNumber() const
Granularity granularity() const
std::atomic< std::chrono::seconds > age_
unsigned nSubRuns() const
art::FileIndex::EntryNumber_t EntryNumber_t
Atom< unsigned > maxSubRuns
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_run_
std::atomic< unsigned > size_
unsigned nInputFiles() const
std::atomic< unsigned > counts_run_
FileIndex::EntryNumber_t eventEntryNumber() const
FileProperties const & fileProperties() const
static BT value(std::string const &spec)
std::ostream & operator<<(std::ostream &os, const GroupSelector &gs)
std::chrono::seconds age() const
bool should_close(FileProperties const &) const
void updateAge(std::chrono::seconds const age)
second seconds
Alias for common language habits.
Atom< unsigned > maxInputFiles
void update_subRun(OutputFileStatus const status)
FileProperties & operator=(FileProperties const &)
std::atomic< unsigned > counts_event_
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_inputFile_
FileProperties closingCriteria_
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
std::atomic< unsigned > counts_job_
static constexpr char const * granularity_default()
Atom< std::string > granularity
std::atomic< unsigned > counts_subRun_
void update_run(OutputFileStatus const status)
FileIndex::EntryNumber_t subRunEntryNumber() const
void updateSize(unsigned const size)
std::atomic< FileIndex::EntryNumber_t > treeEntryNumbers_event_
Atom< unsigned > maxEvents