82 Name(
"enableLargeFileCatalogMetadata"),
85 Name(
"fileProperties")};
101 std::set<std::string>
104 std::set<std::string>
keys{
106 keys.insert(
"results");
224 config.get_PSet().has_key(
config().fileProperties.name()),
226 config().fileProperties())}
244 <<
" has parameter writeParameterSets set to false.\n" 245 <<
"Parameter set provenance will not be available in subsequent jobs.\n" 246 <<
"Check your experiment's policy on this issue to avoid future " 248 <<
"with analysis reproducibility.\n";
282 (rfb->tree() !=
nullptr) &&
287 <<
"Fast cloning deactivated for this input file due to " 288 <<
"empty event tree and/or event limits.";
290 if (fastCloneThisOne && !rfb->fastClonable()) {
292 <<
"Fast cloning deactivated for this input file due to " 293 <<
"information in FileBlock.";
294 fastCloneThisOne =
false;
365 auto resp = std::make_unique<ResultsPrincipal>(
370 resp->addToProcessHistory();
460 auto const& params = w.
params();
516 <<
"Attempt to open output file before input file. " 517 <<
"Please report this to the core framework developers.\n";
520 std::make_unique<RootOutputFile>(
this,
558 <<
"called before meaningful.\n";
void writeParentageRegistry() override
void respondToCloseInputFile(FileBlock const &) override
Atom< bool > enableLargeFileCatalogMetadata
void startEndFile() override
static constexpr ModuleDescriptionID invalidID()
bool parentageEnabled() const
std::string const filePattern_
bool shouldDropEvents(bool dropAllEventsSet, bool dropAllEvents, bool dropAllSubRuns)
void writeProductDescriptionRegistry() override
bool rangesEnabled() const
void endSubRun(SubRunPrincipal const &) override
void doEvent(EventPrincipal const &)
auto const & get_PSet() const
bool dropMetaDataForDroppedData_
void doBeginSubRun(SubRunPrincipal const &)
Atom< bool > dropMetaDataForDroppedData
static cet::exempt_ptr< Consumer > non_module_context()
void recordRun(RunID const &id)
ClosingCriteria fileProperties_
std::string fileNameAtOpen() const
void doWriteFileCatalogMetadata(FileCatalogMetadata::collection_type const &md, FileCatalogMetadata::collection_type const &ssmd) override
void doWriteResults(ResultsPrincipal &)
ModuleDescription const & moduleDescription() const
std::string const & fileName() const
FileStatsCollector fstats_
void writeFileIndex() override
void registerProducts(MasterProductRegistry &mpr, ProductDescriptions &producedProducts, ModuleDescription const &md)
PostCloseFileRenamer fRenamer_
std::string const moduleLabel_
void doReadResults(ResultsPrincipal const &)
void validateFileNamePattern(bool do_check, std::string const &pattern)
void logFileAction(const char *msg, std::string const &file)
void writeFileFormatVersion() override
void setFileStatus(OutputFileStatus) override
void recordEvent(EventID const &id)
static constexpr char const * default_tmpDir
void addToProcessHistory()
std::vector< BranchDescription > ProductDescriptions
bool isFileOpen() const override
void openFile(FileBlock const &) override
void writeProcessConfigurationRegistry() override
void doEndRun(RunPrincipal const &)
DEFINE_ART_MODULE(TestTMapFile)
void incrementInputFileNumber() override
void for_each_RPWorker(on_rpworker_t wfunc)
int64_t const treeMaxVirtualSize_
std::string lastClosedFileName_
OptionalAtom< bool > fastCloning
std::string unique_filename(std::string stem, std::string extension=".root")
void doBeginRun(RunPrincipal const &)
void doRegisterProducts(MasterProductRegistry &mpr, ProductDescriptions &producedProducts, ModuleDescription const &md) override
void writeParameterSetRegistry() override
Atom< int64_t > saveMemoryObjectThreshold
DropMetaData dropMetaData_
void doEndSubRun(SubRunPrincipal const &)
bool requestsToCloseFile() const override
ProductTable producedResultsProducts_
void write(EventPrincipal &) override
std::unique_ptr< RootOutputFile > rootOutputFile_
std::string const & lastClosedFileName() const override
void setModuleDescription(ModuleDescription const &)
void recordSubRun(SubRunID const &id)
RootOutput(Parameters const &)
int const compressionLevel_
fhicl::TableFragment< art::OutputModule::Config > omConfig
Atom< std::string > tmpDir
void recordInputFile(std::string const &inputFileName)
Atom< bool > writeParameterSets
void writeProductDependencies() override
std::array< bool, NumBranchTypes > const & hasNewlyDroppedBranch() const
void writeSubRun(SubRunPrincipal &) override
ModuleDescription const & description() const
void beginRun(RunPrincipal const &) override
Atom< std::string > catalog
int64_t const saveMemoryObjectThreshold_
void invoke(invoke_function_t< void, ARGS... > mfunc, ARGS &&...args)
std::string const & moduleLabel() const
int remainingEvents() const
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
void setRunAuxiliaryRangeSetID(RangeSet const &) override
void respondToOpenInputFile(FileBlock const &) override
std::set< std::string > operator()() const
std::string parent_path(std::string const &path)
void readResults(ResultsPrincipal const &resp) override
MaybeLogger_< ELseverityLevel::ELsev_warning, false > LogWarning
void setSubRunAuxiliaryRangeSetID(RangeSet const &) override
std::string fileNameAtClose(std::string const ¤tFileName)
void endRun(RunPrincipal const &) override
void showMissingConsumes() const
std::string maybeRenameFile(std::string const &inPath, std::string const &toPattern)
Service to store calibration data products (CDP) in the SQLite3 metadatabase of a file...
EventID const & id() const
Granularity fileGranularity() const override
Atom< int64_t > treeMaxVirtualSize
Atom< bool > dropAllSubRuns
void beginSubRun(SubRunPrincipal const &) override
void writeProcessHistoryRegistry() override
void postSelectProducts() override
void writeRun(RunPrincipal &) override
fhicl::Table< ClosingCriteria::Config > fileProperties
void writeEventHistory() override
bool shouldFastClone(bool fastCloningSet, bool fastCloning, bool wantAllEvents, ClosingCriteria const &fileProperties)
std::string const catalog_
std::string const & processName() const
RPParams const & params() const
void set_par_style(par_style const vt)
OptionalAtom< bool > dropAllEvents
void event(EventPrincipal const &) override
ProcessConfiguration const & processConfiguration() const
Atom< std::string > dropMetaData
bool enableLargeFileCatalogMetadata_
bool wantAllEvents() const
void finishEndFile() override
Atom< int > compressionLevel