Classes | |
struct | Config |
Public Types | |
using | Parameters = ServiceTable< Config > |
using | Callback_t = TFileDirectory::Callback_t |
Public Member Functions | |
TFileService (ServiceTable< Config > const &config, art::ActivityRegistry &r) | |
~TFileService () | |
void | registerFileSwitchCallback (Callback_t c) |
template<typename T > | |
void | registerFileSwitchCallback (T *provider, void(T::*)()) |
TFile & | file () const |
template<typename T , typename... ARGS> | |
T * | make (ARGS...args) const |
template<typename T , typename... ARGS> | |
T * | makeAndRegister (char const *name, char const *title, ARGS...args) const |
template<typename T , typename... ARGS> | |
T * | makeAndRegister (std::string const &name, std::string const &title, ARGS...args) const |
TFileDirectory | mkdir (std::string const &dir, std::string const &descr="") |
Static Public Attributes | |
static constexpr const char * | default_tmpDir = "<parent-path-of-filename>" |
Protected Member Functions | |
void | invokeCallbacks () |
void | registerCallback (Callback_t) |
std::string | fullPath () const |
Protected Attributes | |
TFile * | file_ |
std::string | dir_ |
std::string | descr_ |
bool | requireCallback_ {false} |
Private Member Functions | |
TFileService (TFileService const &)=delete | |
TFileService | operator= (TFileService const &)=delete |
void | setDirectoryName_ (art::ModuleDescription const &desc) |
void | openFile_ () |
void | closeFile_ () |
void | maybeSwitchFiles_ () |
bool | requestsToCloseFile_ () |
std::string | fileNameAtOpen_ () |
std::string | fileNameAtClose_ (std::string const &) |
Private Attributes | |
bool const | closeFileFast_ |
FileStatsCollector | fstats_ |
PostCloseFileRenamer | fRenamer_ {fstats_} |
std::string | filePattern_ |
std::string | uniqueFilename_ |
std::string | tmpDir_ |
std::string | lastClosedFile_ {} |
Granularity | currentGranularity_ {Granularity::Unset} |
std::chrono::steady_clock::time_point | beginTime_ {} |
ClosingCriteria | fileSwitchCriteria_ {ClosingCriteria::Config{}} |
OutputFileStatus | status_ {OutputFileStatus::Closed} |
FileProperties | fp_ {} |
Definition at line 31 of file TFileService.h.
Definition at line 54 of file TFileService.h.
Definition at line 48 of file TFileService.h.
|
privatedelete |
TFileService::TFileService | ( | ServiceTable< Config > const & | config, |
art::ActivityRegistry & | r | ||
) |
Definition at line 37 of file TFileService_service.cc.
References closeFileFast_, gen_hdf5record::config, currentGranularity_, e, art::Granularity::Event, plotROC::fileName, filePattern_, fileSwitchCriteria_, fp_, fstats_, art::Run::id(), art::SubRun::id(), art::Event::id(), art::Granularity::InputFile, maybeSwitchFiles_(), openFile_(), r(), art::FileStatsCollector::recordEvent(), art::FileStatsCollector::recordInputFile(), art::FileStatsCollector::recordRun(), art::FileStatsCollector::recordSubRun(), requestsToCloseFile_(), art::TFileDirectory::requireCallback_, art::Granularity::Run, setDirectoryName_(), sr, status_, string, art::Granularity::SubRun, tmpDir_, art::FileProperties::update(), and art::detail::validateFileNamePattern().
TFileService::~TFileService | ( | ) |
|
private |
Definition at line 165 of file TFileService_service.cc.
References art::Closed, closeFileFast_, art::TFileDirectory::file_, fileNameAtClose_(), fstats_, lastClosedFile_, art::FileStatsCollector::recordFileClose(), status_, and uniqueFilename_.
Referenced by maybeSwitchFiles_(), and ~TFileService().
|
inline |
Definition at line 63 of file TFileService.h.
Referenced by calib::BetheBlochFit::endJob(), and chaninfo::BadChanValidate::endSubRun().
|
private |
Definition at line 146 of file TFileService_service.cc.
References filePattern_, fRenamer_, and art::PostCloseFileRenamer::maybeRenameFile().
Referenced by closeFile_().
|
private |
Definition at line 136 of file TFileService_service.cc.
References default_tmpDir, filePattern_, art::parent_path(), string, tmpDir_, and art::unique_filename().
Referenced by openFile_().
|
protectedinherited |
Return the full pathname of the current directory, formed from appending 'dir' to the end of 'path'.
|
protectedinherited |
Referenced by maybeSwitchFiles_().
|
inherited |
make new ROOT object of type T, using constructor parameters args. It will be made in the 'current directory', as established with a call to 'cd'.
Definition at line 82 of file TFileDirectory.h.
References make_syst_table_plots::args, art::TFileDirectory::cd(), and T.
Referenced by calib::ADCShapeFitAna::analyze(), slicer::S4DParamCalc::analyze(), beamlinereco::EventWaveformDump::analyze(), tbana::DSToFAna::AnalyzeDSToF2Signals(), comi::ChanOcc::beginJob(), highe::HighEnergyAna::beginJob(), qeef::QeFinderVal::beginJob(), rsim::RecordNoiseSpectrumFile::beginJob(), tut::TutAnalyzer::beginJob(), cheat::TestTrackIds::beginJob(), novaddt::SingletonRejectionAna::beginJob(), util::RemoveBeamSpills::beginJob(), ve::VertexEva::beginJob(), util::RemoveTBSpills::beginJob(), calhit::CalHitAna::beginJob(), calib::FindOutliers::beginJob(), remid::ReMIdValidate::beginJob(), calib::AbsCalib::beginJob(), util::RemoveBeamSpillsPrecise::beginJob(), calib::ParticleCorrections::beginJob(), novaddt::TriCellTriggerAna::beginJob(), rsim::MakeNoiseSpectrumFile::beginJob(), air::AirShower::beginJob(), validation::ValidateDAQ2RawDigit::beginJob(), jmshower::RecoJMShowerAna::beginJob(), ddt::SMMADC::beginJob(), lem::AlignLibToVtx::beginJob(), cheat::RecoCheckAna::beginJob(), air::AirTree::beginJob(), calib::ResizeDetector::beginJob(), calib::TestParticleCorrections::beginJob(), febstat::FEBShutoff::beginJob(), novaddt::ClusterAna::beginJob(), comi::CosmicMetrics::beginJob(), DataCheck::HardwareStatusCheck::beginJob(), calib::BetheBlochFit::beginJob(), mmc::Validation::beginJob(), demo::DemoModule::beginJob(), jmshower::JMTrackMerge::beginJob(), dq::DAQHeaderSummaryAna::beginJob(), remid::ReMIdTrain::beginJob(), calib::AssessCalib::beginJob(), beamlinereco::ToFSingleCounterAnalysis::beginJob(), BeamlineAna::beginJob(), supernova::SimAna::beginJob(), zcl::SMMTriggerAna::beginJob(), supernova::SnovaAna::beginJob(), tut::yn2020::FancyScience::beginJob(), febstat::EventFEBStatus::beginJob(), calib::FiberCalibration::beginJob(), novaddt::ActivityTriggerAna::beginJob(), comi::Cana::beginJob(), mcchk::MonopoleAna::beginJob(), mcchk::ShowerAnaCheck::beginJob(), earms::ElasticArmsHS::beginJob(), air::CosmicTrackRate::beginJob(), beamlinereco::ToFRecoAnalysis::beginJob(), pa::HitEva::beginJob(), comi::DataCheck::beginJob(), mcchk::RockAna::beginJob(), tut::RecoValidationTutorial::beginJob(), tut::yn2017::AnalysisModule::beginJob(), slicer::S4DParamCalc::beginJob(), pa::ClusterEva::beginJob(), mcchk::NeutrinoAna::beginJob(), murem::MuonRemoveAna::beginJob(), airshower::AirSlicer::beginJob(), tut::yn2017::DebugThis::beginJob(), zcl::MMCheater::beginJob(), align::SplitTracks::beginJob(), numue::NumuEAna::beginJob(), beamlinereco::WCTrackReco::beginJob(), novatb::TOFTimingResolution::beginJob(), cmf::CovarianceMatrixMaker::beginJob(), sn::SNSlicerAna::beginJob(), vf::TrackEva::beginJob(), vdt::VertexDT::beginJob(), zcl::SMMCluster::beginJob(), bpfit::BPFdEdxHistoMaker::beginJob(), mono::DataCheckMonopole::beginJob(), calib::TimingCalibration::beginJob(), testbeam::TestBeamCommissioning::beginJob(), lem::MakeLibrary::beginJob(), bpfit::BPFEnergyAna::beginJob(), calib::HitEfficiency::beginJob(), jmshower::JMClusterMerge::beginJob(), validation::NoiseClusterAnalysis::beginJob(), comi::Leana::beginJob(), dt::DiscreteTracker::beginJob(), sn::SupernovaMCCluster::beginJob(), zcl::FmmTriggerAna::beginJob(), nnbar::SigVsBkgSimCompare::beginJob(), bsf::BremShowerFilter::beginJob(), remid::ReMIdDedx::beginJob(), calib::EnergyStandardCandles::beginJob(), novaddt::HorizontalMuonAna::beginJob(), calib::MuondEdx::beginJob(), chaninfo::FindSwappedChannels::beginJob(), comi::NumiFilteringAna::beginJob(), trk::KalmanTrackAna::beginJob(), ddt::DataSliceEva::beginJob(), beamlinereco::EventWaveformDump::beginJob(), zcl::FmmTrackerValidation::beginJob(), ddt::SlicerEva::beginJob(), cmf::RandomUniverses::beginJob(), novaddt::Calibration::beginJob(), calib::DetRespDrift::beginJob(), zcl::FmmTrackerAna::beginJob(), hough::HoughValidate::beginJob(), tbem::TBRecoAna::beginJob(), calib::PEResponse::beginJob(), cvn::CVNEventDump::beginJob(), trigmon::LongReadoutAnalyzer::beginJob(), cvn::CVNCosmicEventDump::beginJob(), showere::ShowerEnergyAna::beginJob(), jmshower::NueSel::beginJob(), bpfit::BreakPointAna::beginJob(), earms::ElasticArmsValidate::beginJob(), showere::ShowerEnergyFilterMC::beginJob(), mcchk::DetSimAna::beginJob(), rockmuon::NDRockMuon::beginJob(), mono::SlowMonopoleAna::beginJob(), cvn::CVNEventProngDump::beginJob(), cmf::FitFeldmanCousinsPoint::beginJob(), novaddt::UpMuAna::beginJob(), slicer::SlicerAna::beginJob(), calib::MuonTrackHits::beginJob(), mono::Monopole::beginJob(), comi::NearlineAna::beginJob(), ncid::NCNNKeras::beginJob(), ncid::NCNNKerasVal::beginJob(), zcl::FastMMStudy::beginJob(), cheat::MCCheater::beginJob(), remid::ReMIdDedxRock::beginJob(), beamlinereco::ToFAnalysisMini::beginJob(), fuzz::FuzzyKValidate::beginJob(), remid::ReMIdDedxFD::beginJob(), remid::ReMIdDedxStudies::beginJob(), ncpi0::TwoProngBDTAna::beginJob(), tbana::DetectorRateShutOff::beginJob(), bpfit::BPFTmvaTrainer::beginJob(), nnbar::ShowerMuonCoincidence::beginJob(), bpfit::BreakPointProtonAna::beginJob(), bpfit::DimuonFitter::beginJob(), bpf::BPFCVNAna::beginJob(), air::AirKalmanAna::beginJob(), ncs::Xbeam::beginJob(), skim::SkimmerAna::beginJob(), ncs::GenieTruth::beginJob(), ncs::Xeff::beginJob(), skim::CellHitSkimmer::beginJob(), ncs::ROCKMRE::beginJob(), skim::CosmicBeamComparison::beginJob(), moonshadowana::MoonShadowAna::beginJob(), ddt::SuperDDTEva::beginJob(), calib::CalibAna::beginJob(), slid::LIDTraining::beginJob(), moonshadowana::MoonShadowAnaHough::beginJob(), ncs::NCAna::beginJob(), upmuana::UpMuRecoAna::beginJob(), upmuana::UpMuAnalysis::beginJob(), calib::MuondEdxAna::beginJob(), trident::DimuonSliceAna::beginJob(), nnbar::RecoAnalysis::beginJob(), beamlinereco::ToFPositionRecoAnalysis::beginJob(), sn::SNMichelAnalyzer::beginJob(), htk::HoughTrack::beginJob(), comi::FEBFlash::beginJob(), trk::CosmicTrackAna::beginJob(), red::EWCosmics::beginJob(), calib::ThresholdAna::beginRun(), chaninfo::CosmicEff::beginRun(), mcchk::CloseInTime::beginRun(), dprf::ChannelPlots::beginRun(), dprf::TrackPlots::beginRun(), calib::CosmicCalib::beginRun(), mcchk::DetAna::beginRun(), mcchk::CosmicAna::beginRun(), mcchk::NeutrinoAna::beginRun(), calib::MakeAttenuationProfiles::beginRun(), evgen::IsoGen::beginRun(), mcchk::LeptonAna::beginRun(), calib::PEResponse::beginRun(), calib::StopperThreshold::beginRun(), photrans::ImprovedTransport::beginRun(), rsim::ReadoutSim::beginRun(), calib::CosmicTrends::beginRun(), comi::DataCheck::beginSubRun(), chaninfo::BadChanValidate::beginSubRun(), ifdb::MIN::beginSubRun(), cmf::CMFDecorrelator::CMFDecorrelator(), g4n::FLSHitListAction::ComputeCerenkovPhotons(), LightLevels::CreateHistos(), CerenkovResponse::CreateHistos(), bpfit::BreakPoint::DebugFitList(), bpfit::BreakPoint::DebugHitList(), bpfit::BreakPoint::DebugScatSurf(), rsim::ReadoutSim::DrawASICOutput(), red::MatterProbe::ECalc(), calib::SystematicUncertaintyScaleAna::endJob(), mcchk::POTAna::endJob(), novaddt::RateMonitor::endJob(), chaninfo::CosmicEff::endJob(), calib::CosmicCalib::endJob(), dprf::TrackPlots::endJob(), calib::MakeAttenuationProfiles::endJob(), lem::MakeLibrary::endJob(), rockmuon::NDRockMuon::endJob(), calib::DCMTimingOffset::endJob(), ncs::Xeff::endJob(), calib::CalibAna::endJob(), ncs::ROCKMRE::endJob(), ncs::NCAna::endJob(), beamlinereco::ToFPositionRecoAnalysis::endJob(), calib::DriftResponseCalc::endRun(), calib::MuondEdx::endRun(), calib::MuonTrackHits::endRun(), calib::MuondEdxAna::endRun(), skim::EvaluatorNumuCCpi::EvaluatorNumuCCpi(), rsim::IFPGAAlgorithm::FetchThresholds(), bpfit::BreakPoint::FillExceptNt(), bpfit::BreakPoint::FillTrackNt(), G4MismatchAna::G4MismatchAna(), align::Alignment::GetChannelHists(), moonshadowana::MoonShadowAna::GetHisto(), moonshadowana::MoonShadowAnaHough::GetHisto(), novaddt::HitsAna::HitsAna(), testbeam::BeamlineRecoValidation::initializeHists(), novaddt::HorizontalMuonAna::IsHorzMuonTrack(), bpfit::BreakPoint::LogResiduals(), cmf::PlotUtilities::Make1DPlot(), trk::CosmicTrackAna::Make1DRecoHistograms(), cmf::CovarianceFitHelper::Make1DSpectra(), trk::CosmicTrackAna::Make1DTruthHistograms(), cmf::PlotUtilities::Make2DContours(), trk::CosmicTrackAna::Make2DRecoHistograms(), trk::CosmicTrackAna::Make2DTruthHistograms(), highe::HighEnergyAna::make_histo(), novaddt::SNAna::make_histo(), mono::SlowMonopoleAna::make_histo(), cmf::FitFeldmanCousinsPoint::MakeCanvases(), cmf::PlotUtilities::MakeCLHeatMaps(), cmf::CovarianceFitHelper::MakeCovarianceMatrixHistogram(), cmf::CovarianceFitHelper::MakeDataMCCanv(), cmf::PlotUtilities::MakeEnergySpectraFromBins(), cmf::PlotUtilities::MakeGeneric2DHist(), cmf::SpectrumPredictionMaker::MakeHiddenParameterHistograms(), MakeHist(), cmf::CovarianceFitHelper::MakeIterationGraphs(), novaddt::Calibration::MakeNoiseHisto(), cmf::PlotUtilities::MakeSpectrumHistogram(), airshower::AirSlicer::MakeTrackSlices(), cmf::RandomUniverseUtility::MakeUniverseHistograms(), mix::MixSimEvents::MixSimEvents(), calib::EnergyStandardCandles::PrepareMichelENtuple(), rwgt::MakeGENIEReweightTable::produce(), dprf::RawFebPlots::RawFebPlots(), calib::DriftCorrection::respondToCloseOutputFiles(), rwgt::RwgtTest::RwgtTest(), cmf::CMFCappedEventList::Serialize(), supernova::sliceAna::sliceAna(), sn::SupernovaAna::SupernovaAna(), geo::GeometryTest::testCellPos(), beamlinerecoana::WCTrackRecoAnalysis::WCTrackRecoAnalysis(), hough::HoughT::WriteHoughHistos(), hough::MultiHoughT::WriteHoughHistos(), cvn::CVNEventDump::WriteMapTH2(), cvn::CVNCosmicEventDump::WriteMapTH2(), and cvn::CVNEventProngDump::WriteMapTH2().
|
inherited |
make and register a new ROOT object of type T, giving it the specified name and title, using constructor parameters 'args'. The type must be registerable, and must support naming and titling.
Definition at line 91 of file TFileDirectory.h.
References make_syst_table_plots::args, art::TFileDirectory::cd(), and T.
Referenced by tbana::DetectorRateShutOff::beginJob(), tbana::DSToFAna::DSToFAna(), cmf::PlotUtilities::Make1DPlot(), cmf::PlotUtilities::Make2DContours(), art::TFileDirectory::makeAndRegister(), and cmf::ContourFromLibrary::MakeAndStorePlots().
|
inherited |
Definition at line 106 of file TFileDirectory.h.
References make_syst_table_plots::args, and art::TFileDirectory::makeAndRegister().
|
private |
Definition at line 180 of file TFileService_service.cc.
References closeFile_(), currentGranularity_, filePattern_, fileSwitchCriteria_, fp_, art::ClosingCriteria::granularity(), art::TFileDirectory::invokeCallbacks(), lastClosedFile_, art::detail::logFileAction(), openFile_(), status_, and art::Switching.
Referenced by TFileService().
|
inherited |
Create a new TFileDirectory, sharing the same TFile as this one, but with an additional 'dir', and with 'path' being the fullPath() of this one.
Referenced by beamlinereco::EventWaveformDump::analyze(), beamlinereco::ToFSingleCounterAnalysis::beginJob(), beamlinereco::EventWaveformDump::beginJob(), beamlinereco::ToFAnalysisMini::beginJob(), beamlinereco::ToFPositionRecoAnalysis::beginJob(), cmf::CMFCappedEventList::endJob(), cmf::CMFSpectraMaker::endJob(), calib::CosmicCalib::endJob(), calib::MakeAttenuationProfiles::endJob(), beamlinereco::ToFPositionRecoAnalysis::endJob(), cmf::ContourFromLibrary::MakeAndStorePlots(), cmf::FitFeldmanCousinsPoint::MakeCanvases(), cmf::SpectrumPredictionMaker::MakeHiddenParameterHistograms(), cmf::CovarianceFitHelper::MakeResultPlots(), cmf::RandomUniverseUtility::MakeUniverseHistograms(), and cmf::SerializeEventListColl().
|
private |
Definition at line 154 of file TFileService_service.cc.
References ana::assert(), beginTime_, art::TFileDirectory::file_, fileNameAtOpen_(), fstats_, recentWatchdog::now, art::Open, art::FileStatsCollector::recordFileOpen(), status_, and uniqueFilename_.
Referenced by maybeSwitchFiles_(), and TFileService().
|
privatedelete |
|
protectedinherited |
Referenced by registerFileSwitchCallback().
void TFileService::registerFileSwitchCallback | ( | Callback_t | c | ) |
Definition at line 119 of file TFileService_service.cc.
References art::TFileDirectory::registerCallback().
void art::TFileService::registerFileSwitchCallback | ( | T * | provider, |
void(T::*)() | f | ||
) |
Definition at line 102 of file TFileService.h.
References DECLARE_ART_SERVICE, MakeMiniprodValidationCuts::f, and art::LEGACY.
|
private |
Definition at line 198 of file TFileService_service.cc.
References beginTime_, DEFINE_ART_SERVICE, art::TFileDirectory::file_, fileSwitchCriteria_, fp_, recentWatchdog::now, art::ClosingCriteria::should_close(), submit_hadd::u, art::FileProperties::updateAge(), and art::FileProperties::updateSize().
Referenced by TFileService().
|
private |
Definition at line 125 of file TFileService_service.cc.
References CET_ASSERT_ONLY_ONE_THREAD, art::TFileDirectory::descr_, art::TFileDirectory::dir_, art::ModuleDescription::moduleLabel(), art::ModuleDescription::moduleName(), and string.
Referenced by TFileService().
|
private |
Definition at line 79 of file TFileService.h.
Referenced by openFile_(), and requestsToCloseFile_().
|
private |
Definition at line 69 of file TFileService.h.
Referenced by closeFile_(), and TFileService().
|
private |
Definition at line 78 of file TFileService.h.
Referenced by maybeSwitchFiles_(), and TFileService().
|
static |
Definition at line 37 of file TFileService.h.
Referenced by fileNameAtOpen_().
|
protectedinherited |
Definition at line 69 of file TFileDirectory.h.
Referenced by setDirectoryName_().
|
protectedinherited |
Definition at line 68 of file TFileDirectory.h.
Referenced by setDirectoryName_().
|
protectedinherited |
Definition at line 67 of file TFileDirectory.h.
Referenced by closeFile_(), openFile_(), and requestsToCloseFile_().
|
private |
Definition at line 72 of file TFileService.h.
Referenced by fileNameAtClose_(), fileNameAtOpen_(), maybeSwitchFiles_(), and TFileService().
|
private |
Definition at line 83 of file TFileService.h.
Referenced by maybeSwitchFiles_(), requestsToCloseFile_(), and TFileService().
|
private |
Definition at line 85 of file TFileService.h.
Referenced by maybeSwitchFiles_(), requestsToCloseFile_(), and TFileService().
|
private |
Definition at line 71 of file TFileService.h.
Referenced by fileNameAtClose_().
|
private |
Definition at line 70 of file TFileService.h.
Referenced by closeFile_(), openFile_(), and TFileService().
|
private |
Definition at line 77 of file TFileService.h.
Referenced by closeFile_(), and maybeSwitchFiles_().
|
protectedinherited |
Definition at line 70 of file TFileDirectory.h.
Referenced by TFileService().
|
private |
Definition at line 84 of file TFileService.h.
Referenced by closeFile_(), maybeSwitchFiles_(), openFile_(), and TFileService().
|
private |
Definition at line 74 of file TFileService.h.
Referenced by fileNameAtOpen_(), and TFileService().
|
private |
Definition at line 73 of file TFileService.h.
Referenced by closeFile_(), and openFile_().