Classes | Public Member Functions | Private Member Functions | Private Attributes | Friends | List of all members
art::DataViewImpl Class Reference

#include "/cvmfs/nova.opensciencegrid.org/externals/art/v3_05_01/source/art/Framework/Principal/DataViewImpl.h"

Inheritance diagram for art::DataViewImpl:
art::Event art::Results art::Run art::SubRun

Classes

struct  PMValue
 

Public Member Functions

 ~DataViewImpl ()
 
 DataViewImpl (BranchType bt, Principal const &p, ModuleContext const &mc, bool recordParents, RangeSet const &rs=RangeSet::invalid())
 
 DataViewImpl (DataViewImpl const &)=delete
 
 DataViewImpl (DataViewImpl &&)=delete
 
DataViewImploperator= (DataViewImpl const &)=delete
 
DataViewImploperator= (DataViewImpl &)=delete
 
RunID runID () const
 
SubRunID subRunID () const
 
EventID eventID () const
 
RunNumber_t run () const
 
SubRunNumber_t subRun () const
 
EventNumber_t event () const
 
Timestamp const & beginTime () const
 
Timestamp const & endTime () const
 
Timestamp time () const
 
bool isRealData () const
 
EventAuxiliary::ExperimentType experimentType () const
 
History const & history () const
 
ProcessHistoryID const & processHistoryID () const
 
ProcessHistory const & processHistory () const
 
template<typename PROD >
bool removeCachedProduct (Handle< PROD > &) const
 
EDProductGetter const * productGetter (ProductID const pid) const
 
bool getProcessParameterSet (std::string const &process, fhicl::ParameterSet &) const
 
template<typename PROD >
bool get (SelectorBase const &, Handle< PROD > &result) const
 
template<typename PROD >
bool get (ProductID const pid, Handle< PROD > &result) const
 
template<typename PROD >
bool getByLabel (std::string const &label, std::string const &instance, Handle< PROD > &result) const
 
template<typename PROD >
bool getByLabel (std::string const &label, std::string const &instance, std::string const &process, Handle< PROD > &result) const
 
template<typename PROD >
PROD const & getByLabel (InputTag const &tag) const
 
template<typename PROD >
bool getByLabel (InputTag const &tag, Handle< PROD > &result) const
 
template<typename PROD >
PROD const * getPointerByLabel (InputTag const &tag) const
 
template<typename PROD >
ValidHandle< PROD > getValidHandle (InputTag const &tag) const
 
template<typename PROD >
bool getByToken (ProductToken< PROD > const &, Handle< PROD > &result) const
 
template<typename PROD >
ValidHandle< PROD > getValidHandle (ProductToken< PROD > const &) const
 
template<typename PROD >
std::vector< InputTaggetInputTags (SelectorBase const &selector=MatchAllSelector{}) const
 
template<typename PROD >
std::vector< ProductToken< PROD > > getProductTokens (SelectorBase const &selector=MatchAllSelector{}) const
 
template<typename PROD >
std::vector< Handle< PROD > > getMany (SelectorBase const &selector=MatchAllSelector{}) const
 
template<typename PROD >
void getMany (SelectorBase const &, std::vector< Handle< PROD >> &results) const
 
template<typename PROD >
void getManyByType (std::vector< Handle< PROD >> &results) const
 
template<typename ELEMENT >
std::size_t getView (std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
 
template<typename ELEMENT >
std::size_t getView (std::string const &moduleLabel, std::string const &productInstanceName, std::vector< ELEMENT const * > &result) const
 
template<typename ELEMENT >
std::size_t getView (InputTag const &, std::vector< ELEMENT const * > &result) const
 
template<typename ELEMENT >
std::size_t getView (ViewToken< ELEMENT > const &, std::vector< ELEMENT const * > &result) const
 
template<typename ELEMENT >
bool getView (std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, View< ELEMENT > &result) const
 
template<typename ELEMENT >
bool getView (std::string const &moduleLabel, std::string const &productInstanceName, View< ELEMENT > &result) const
 
template<typename ELEMENT >
bool getView (InputTag const &, View< ELEMENT > &result) const
 
template<typename ELEMENT >
bool getView (ViewToken< ELEMENT > const &, View< ELEMENT > &result) const
 
template<typename ELEMENT >
void getPtrVector (std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, PtrVector< ELEMENT > &result) const
 
template<typename ELEMENT >
void getPtrVector (std::string const &moduleLabel, std::string const &productInstanceName, PtrVector< ELEMENT > &result) const
 
template<typename ELEMENT >
void getPtrVector (InputTag const &, PtrVector< ELEMENT > &result) const
 
template<typename ELEMENT >
void getPtrVector (ViewToken< ELEMENT > const &, PtrVector< ELEMENT > &result) const
 
template<typename T >
ProductID getProductID (std::string const &instance_name="") const
 
cet::exempt_ptr< BranchDescription const > getProductDescription (ProductID) const
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, FragmentSemantic< Level::Run > const semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, RangedFragmentSemantic< Level::Run > semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, FullSemantic< Level::Run >)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, FragmentSemantic< Level::Run >)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, RangedFragmentSemantic< Level::Run > semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, FullSemantic< Level::SubRun > const semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, FragmentSemantic< Level::SubRun > const semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, RangedFragmentSemantic< Level::SubRun > semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, FullSemantic< Level::SubRun >)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, FragmentSemantic< Level::SubRun >)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, RangedFragmentSemantic< Level::SubRun > semantic)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance)
 
template<typename PROD >
ProductID put (std::unique_ptr< PROD > &&edp, std::string const &instance, RangeSet const &rs)
 
void movePutProductsToPrincipal (Principal &principal)
 
void movePutProductsToPrincipal (Principal &principal, bool const checkProducts, std::map< TypeLabel, BranchDescription > const *expectedProducts)
 

Private Member Functions

std::string const & getProcessName_ (std::string const &) const
 
BranchDescription const & getProductDescription_ (TypeID const &type, std::string const &instance, bool const alwaysEnableLookupOfProducedProducts=false) const
 
void recordAsParent_ (cet::exempt_ptr< Group const > grp) const
 
cet::exempt_ptr< Group const > getContainerForView_ (TypeID const &, std::string const &moduleLabel, std::string const &productInstanceName, ProcessTag const &processTag) const
 

Private Attributes

std::recursive_mutex mutex_ {}
 
BranchType const branchType_
 
Principal const & principal_
 
ModuleContext const & mc_
 
ModuleDescription const & md_
 
bool const recordParents_
 
RangeSet rangeSet_ {RangeSet::invalid()}
 
std::set< ProductIDretrievedProducts_ {}
 
std::map< TypeLabel, PMValueputProducts_ {}
 

Friends

class detail::Analyzer
 
class detail::Filter
 
class detail::Producer
 
class ResultsProducer
 
class ProducingService
 

Detailed Description

Definition at line 74 of file DataViewImpl.h.

Constructor & Destructor Documentation

art::DataViewImpl::~DataViewImpl ( )
art::DataViewImpl::DataViewImpl ( BranchType  bt,
Principal const &  p,
ModuleContext const &  mc,
bool  recordParents,
RangeSet const &  rs = RangeSet::invalid() 
)
explicit
art::DataViewImpl::DataViewImpl ( DataViewImpl const &  )
delete
art::DataViewImpl::DataViewImpl ( DataViewImpl &&  )
delete

Member Function Documentation

Timestamp const& art::DataViewImpl::beginTime ( ) const
Timestamp const& art::DataViewImpl::endTime ( ) const
EventNumber_t art::DataViewImpl::event ( ) const

Referenced by cheat::TestTrackIds::analyze(), tbana::RawFileDumper::analyze(), mcdatadaq::MockDataDAQAna::analyze(), novaddt::DAQHeaderAna::analyze(), tut::yn2017::AnalysisModule::analyze(), BeamlineAna::analyze(), beamlinereco::BeamlineRecoDump::analyze(), tut::yn2017::DebugThis::analyze(), neut::RegenAna::analyze(), tbana::DSToFAna::analyze(), numue::NumuEAna::analyze(), febstat::EventFEBStatus::analyze(), testbeam::BeamlineRecoValidation::analyze(), beamlinerecoana::WCTrackRecoAnalysis::analyze(), testbeam::TestBeamCommissioning::analyze(), novaddt::HorizontalMuonAna::analyze(), tbem::TBRecoAna::analyze(), calib::PEResponse::analyze(), beamlinereco::EventWaveformDump::analyze(), Mono::Mono::analyze(), mono::SlowMonopoleAna::analyze(), zcl::FastMMStudy::analyze(), mono::Monopole::analyze(), testbeam::BeamlineEventDisplay::analyze(), air::AirKalmanAna::analyze(), moonshadowana::MoonShadowAna::analyze(), beamlinesim::CombinedBeamlineDetectorAna::analyze(), htk::HoughTrack::analyze(), skim::CellHitSkimmer::EvaluateSlices(), nnbar::RecoAnalysis::evd(), mono::SlowMonopoleAna::fill_track_tree(), highe::HighEnergyFilt::filter(), calib::RockMuonStopperSelection::filter(), air::AirFilter::filter(), util::RemoveTBSpills::filter(), novaddt::DropoutDCMFilter::filter(), util::EventFilterNoSlice::filter(), mono::SlowMonopoleFilt::filter(), util::RunEventFilter::filter(), chaninfo::FindSwappedChannels::filter(), calib::MuonTrackHits::filter(), skim::CellHitSkimmer::filter(), runh::BadDataFilter::filter(), novaddt::SupernovaTrigger::GetTime(), skim::EvaluatorNue::Initialize(), daq2raw::DAQHit2Raw::PopulateRawTrig(), rsim::ReadoutSim::PopulateRawTrig(), evd::SliceNavigator::postProcessEvent(), evdb::EventDisplay::postProcessEvent(), mmc::Validation::print_truth_info(), mono::SlowMonopoleAna::print_truth_info(), noe::noe::produce(), lem::UnTranspose::produce(), lem::AlignLibToVtx::produce(), tut::yn2020::FancyScience::produce(), lem::FindMatchesTranspose::produce(), airshower::AirSlicer::produce(), dt::ViewMerger::produce(), lem::MakeLibrary::produce(), evgen::SupernovaGen::produce(), dt::DiscreteTracker::produce(), lem::FindLEMMatches::produce(), lem::LEM::produce(), dif::DiFShowerFinder::produce(), photrans::ImprovedTransport::produce(), beamlinesim::BeamlineSimInput::produce(), cvn::CVNEventDump::WriteMapTH2(), cvn::CVNCosmicEventDump::WriteMapTH2(), and cvn::CVNEventProngDump::WriteMapTH2().

EventID art::DataViewImpl::eventID ( ) const
EventAuxiliary::ExperimentType art::DataViewImpl::experimentType ( ) const
template<typename PROD >
bool art::DataViewImpl::get ( SelectorBase const &  sel,
Handle< PROD > &  result 
) const

Definition at line 386 of file DataViewImpl.h.

References art::Handle< T >::clear().

387  {
388  std::lock_guard lock{mutex_};
389  result.clear();
390  // We do *not* track whether consumes was called for a SelectorBase.
391  ProcessTag const processTag{"", md_.processName()};
392  auto qr = principal_.getBySelector(
393  mc_, WrappedTypeID::make<PROD>(), sel, processTag);
394  result = Handle<PROD>{qr};
395  bool const ok = qr.succeeded() && !qr.failed();
396  if (recordParents_ && ok) {
397  recordAsParent_(qr.result());
398  }
399  return ok;
400  }
Principal const & principal_
Definition: DataViewImpl.h:327
GroupQueryResult getBySelector(ModuleContext const &mc, WrappedTypeID const &wrapped, SelectorBase const &, ProcessTag const &) const
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
ModuleContext const & mc_
Definition: DataViewImpl.h:330
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename PROD >
bool art::DataViewImpl::get ( ProductID const  pid,
Handle< PROD > &  result 
) const

Definition at line 404 of file DataViewImpl.h.

References art::Handle< T >::clear().

405  {
406  std::lock_guard lock{mutex_};
407  result.clear();
408  auto qr = principal_.getByProductID(pid);
409  result = Handle<PROD>{qr};
410  bool const ok = qr.succeeded() && !qr.failed();
411  if (recordParents_ && ok) {
412  recordAsParent_(qr.result());
413  }
414  return ok;
415  }
Principal const & principal_
Definition: DataViewImpl.h:327
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
GroupQueryResult getByProductID(ProductID const pid) const
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename PROD >
bool art::DataViewImpl::getByLabel ( std::string const &  label,
std::string const &  instance,
Handle< PROD > &  result 
) const

Definition at line 446 of file DataViewImpl.h.

References fillBadChanDBTables::result.

Referenced by om::TestTMapFile::analyze(), novaddt::NovaDDTTrigger::analyze(), highe::HighEnergyAna::analyze(), tut::TutAnalyzer::analyze(), calib::ADCShapeFitAna::analyze(), spilltime::analyze(), novaddt::MilliBlockChecking::analyze(), comi::ChanOcc::analyze(), qeef::QeFinderVal::analyze(), tbana::RawFileDumper::analyze(), novaddt::Evaluation::analyze(), validation::ValidateChannelInfo::analyze(), cheat::TestTrackIds::analyze(), ddt::DDTEva::analyze(), rsim::RecordNoiseSpectrumFile::analyze(), novaddt::SingletonRejectionAna::analyze(), calhit::CalHitAna::analyze(), validation::ValidateDAQ2RawDigit::analyze(), ve::VertexEva::analyze(), novaddt::TriCellTriggerAna::analyze(), calib::ThresholdAna::analyze(), cheat::CheckBackTracking::analyze(), chaninfo::CosmicEff::analyze(), remid::ReMIdValidate::analyze(), cheat::RecoCheckAna::analyze(), air::AirTree::analyze(), jmshower::RecoJMShowerAna::analyze(), mcdatadaq::MockDataDAQAna::analyze(), novaddt::ClusterAna::analyze(), calib::ParticleCorrections::analyze(), comi::CosmicMetrics::analyze(), air::AirShower::analyze(), febstat::FEBShutoff::analyze(), ddt::SMMADC::analyze(), align::AlignInspect::analyze(), dq::DAQHeaderSummaryAna::analyze(), mcchk::CloseInTime::analyze(), mmc::Validation::analyze(), valid::CellHitValidation::analyze(), tut::RecoValidationTutorial::analyze(), dprf::ChannelPlots::analyze(), novaddt::DAQHeaderAna::analyze(), calib::TestParticleCorrections::analyze(), valid::FluxValidation::analyze(), mcchk::DetAna::analyze(), G4MismatchAna::analyze(), remid::ReMIdTrain::analyze(), valid::RecoHitValidation::analyze(), zcl::SMMTriggerAna::analyze(), tut::reco2016::RecoObjectsTutorial::analyze(), tut::yn2017::AnalysisModule::analyze(), mcchk::ShowerAnaCheck::analyze(), tut::yn2017::DebugThis::analyze(), dprf::TrackPlots::analyze(), beamlinereco::BeamlineRecoDump::analyze(), slicer::S4DParamCalc::analyze(), beamlinereco::ToFSingleCounterAnalysis::analyze(), BeamlineAna::analyze(), air::CosmicTrackRate::analyze(), mcchk::MonopoleAna::analyze(), numue::NumuEAna::analyze(), align::Alignment::analyze(), testbeam::BeamlineRecoValidation::analyze(), febstat::EventFEBStatus::analyze(), tbana::DSToFAna::analyze(), mcchk::RockAna::analyze(), murem::MuonRemoveAna::analyze(), novaddt::SNAna::analyze(), align::SplitTracks::analyze(), sn::SNSlicerAna::analyze(), sn::SupernovaAna::analyze(), beamlinereco::ToFRecoAnalysis::analyze(), novatb::TOFTimingResolution::analyze(), mcchk::NeutrinoAna::analyze(), mono::DataCheckMonopole::analyze(), pa::ClusterEva::analyze(), pa::HitEva::analyze(), calib::AssessCalib::analyze(), slicer::IdenticalSlicerAna::analyze(), testbeam::TestBeamCommissioning::analyze(), beamlinerecoana::WCTrackRecoAnalysis::analyze(), vf::TrackEva::analyze(), comi::DataCheck::analyze(), calib::EnergyStandardCandles::analyze(), meta::Metadata::analyze(), calib::HitEfficiency::analyze(), tbana::BeamStructureAna::analyze(), CerenkovSelection::analyze(), zcl::MMCheater::analyze(), novaddt::HorizontalMuonAna::analyze(), remid::ReMIdDedx::analyze(), nnbar::SigVsBkgSimCompare::analyze(), chaninfo::BadChanValidate::analyze(), comi::NumiFilteringAna::analyze(), zcl::FmmTriggerAna::analyze(), mcchk::LeptonAna::analyze(), novaddt::Calibration::analyze(), comi::Leana::analyze(), tbana::BeamlineTriggerAna::analyze(), ddt::DataSliceEva::analyze(), tbem::TBRecoAna::analyze(), ddt::SlicerEva::analyze(), calib::PEResponse::analyze(), novatb::TOFTriggerAna::analyze(), novatb::TriggerRateAna::analyze(), zcl::FmmTrackerValidation::analyze(), zcl::FmmTrackerAna::analyze(), trk::KalmanTrackAna::analyze(), showere::ShowerEnergyAna::analyze(), beamlinereco::EventWaveformDump::analyze(), trigmon::LongReadoutAnalyzer::analyze(), novaddt::SendTriggerSignal::analyze(), cvn::CVNEventDump::analyze(), hough::HoughValidate::analyze(), cvn::CVNCosmicEventDump::analyze(), earms::ElasticArmsValidate::analyze(), bpfit::BreakPointAna::analyze(), cvn::CVNEventProngDump::analyze(), calib::StopperThreshold::analyze(), Mono::Mono::analyze(), novaddt::UpMuAna::analyze(), mono::SlowMonopoleAna::analyze(), mcchk::DetSimAna::analyze(), slicer::SlicerAna::analyze(), rockmuon::NDRockMuon::analyze(), ncid::NCNNKerasVal::analyze(), remid::ReMIdDedxRock::analyze(), comi::NearlineAna::analyze(), tbana::SpillStreamAna::analyze(), ncpi0::TwoProngBDTAna::analyze(), mono::Monopole::analyze(), fuzz::FuzzyKValidate::analyze(), remid::ReMIdDedxFD::analyze(), remid::ReMIdDedxStudies::analyze(), zcl::FastMMStudy::analyze(), nnbar::ShowerMuonCoincidence::analyze(), testbeam::BeamlineEventDisplay::analyze(), tbana::DetectorRateShutOff::analyze(), beamlinereco::ToFAnalysisMini::analyze(), LightLevels::analyze(), calib::CosmicTrends::analyze(), CerenkovResponse::analyze(), air::AirKalmanAna::analyze(), ncs::Xbeam::analyze(), ncs::GenieTruth::analyze(), ncs::Xeff::analyze(), calib::CalibAna::analyze(), ncs::ROCKMRE::analyze(), moonshadowana::MoonShadowAna::analyze(), ddt::SuperDDTEva::analyze(), slid::LIDTraining::analyze(), beamlinesim::CombinedBeamlineDetectorAna::analyze(), moonshadowana::MoonShadowAnaHough::analyze(), ncs::NCAna::analyze(), upmuana::UpMuRecoAna::analyze(), upmuana::UpMuAnalysis::analyze(), nnbar::RecoAnalysis::analyze(), beamlinereco::ToFPositionRecoAnalysis::analyze(), sn::SNMichelAnalyzer::analyze(), htk::HoughTrack::analyze(), novatb::BeamTuning::analyze(), trk::CosmicTrackAna::analyze(), red::EWCosmics::analyze(), comi::FEBFlash::analyze(), murem::MRCCAna::analyze(), lem::UnTranspose::beginRun(), lem::MakeMatches::beginRun(), lem::MakePID::beginRun(), calib::DriftCorrection::beginRun(), caf::CAFMaker::beginRun(), mcchk::POTAna::beginSubRun(), jmshower::RecoJMShowerAna::beginSubRun(), skim::RandomEventFilter::beginSubRun(), comi::NumiFilteringAna::beginSubRun(), air::AirKalmanAna::beginSubRun(), caf::CAFMaker::beginSubRun(), trk::CosmicTrackAna::beginSubRun(), sn::SNMichelAnalyzer::ClusterAroundTrackEnds(), evd::PlotView::Draw(), calib::SumRunsCalib::endRun(), calib::AbsCalib::endRun(), calib::BetheBlochFit::endRun(), calib::AttenFit::endRun(), calib::SumSubrunsCalib::endSubRun(), rsim::RecordNoiseSpectrumFile::endSubRun(), MergeGenCollections::MergeGenCollections::endSubRun(), comi::Cana::endSubRun(), lem::MakeLibrary::endSubRun(), ifdb::IFDBSpillInfo::endSubRun(), calib::PEResponse::endSubRun(), calib::AttenFit::endSubRun(), slicer::SlicerAna::endSubRun(), calib::DCMTimingOffset::endSubRun(), ifdb::MIN::endSubRun(), bpfit::BreakPointProtonAna::endSubRun(), ncs::Xbeam::endSubRun(), ncs::Xeff::endSubRun(), ncs::ROCKMRE::endSubRun(), ncs::NCAna::endSubRun(), caf::CAFMaker::endSubRun(), filter::Filter::FillDigitVariables(), LSTME::FillLSTME::fillEnergies(), filter::Filter::FillG4GenVariables(), caf::FillMRCCParentInfo(), skim::CosmicBeamComparison::FillNueHistograms(), SliceLID::FillSliceLID::fillSliceLIDPreds(), filter::Filter::FillSliceVariables(), filter::Filter::FillTrackVariables(), murem::MuonRemove::FillTruthInfo(), filter::Filter::FillTruthVariables(), evgen::CRVFilter::filter(), lem::ApplyFilter::filter(), lem::BackgroundEnricher::filter(), novaddt::SortByPlane::filter(), novaddt::SortByDCM::filter(), novaddt::HighSortByTDC::filter(), novaddt::SortByTDC::filter(), comi::CanaFilter::filter(), novaddt::Clusterer::filter(), novaddt::TDSlice::filter(), novaddt::RemoveNoise::filter(), highe::HighEnergyFilt::filter(), novaddt::SpaceSlice::filter(), calib::ThroughgoingSelection::filter(), evgen::OccupiedSpillFilter::filter(), novaddt::DCMSlice::filter(), novaddt::HighADCFilter::filter(), novaddt::TimeDCMSlice::filter(), calib::RockMuonStopperSelection::filter(), calib::StopperSelection::filter(), air::AirFilter::filter(), novaddt::TimeSlice::filter(), novaddt::HighETrigger::filter(), util::RemoveTBSpills::filter(), novaddt::DDTStreamer::filter(), beamlinereco::GoodBeamlineEventFilter::filter(), util::RemoveBeamSpills::filter(), novaddt::TriCellTrigger::filter(), novaddt::DBSlicer::filter(), novaddt::DDTDemo::filter(), mono::HighEnergySliceRemoval::filter(), novaddt::ActivityTrigger::filter(), util::RemoveBeamSpillsPrecise::filter(), novaddt::NuESelect::filter(), jmshower::RecoJMShowerFilter::filter(), filter::FLSFilter::filter(), snutil::DDSNEWSfilter::filter(), beamlinereco::DigitizerSaturationFilter::filter(), novaddt::FEBOverflowTrigger::filter(), beamlinereco::ToFFilter::filter(), DataCheck::HardwareStatusCheck::filter(), novaddt::MoonShadow::filter(), calib::StopperFilter::filter(), novaddt::ActivityTriggerAna::filter(), novaddt::SlowMonopoleTrigger::filter(), mono::EventSelector::filter(), EliminateBeamSpills::filter(), comi::NumiFiltering::filter(), novaddt::FastMMTrigger::filter(), mono::MonopoleCluster::filter(), novaddt::NNFastMMTrigger::filter(), calib::TimingCalFilter::filter(), novaddt::HoughTracker::filter(), filter::TruthContain::filter(), novaddt::SlowMMTrigger::filter(), mono::SlowMonopoleFilt::filter(), novaddt::HorizontalMuonTrigger::filter(), chaninfo::FindSwappedChannels::filter(), util::RunEventFilter::filter(), calib::MuondEdx::filter(), calib::DetRespDrift::filter(), showere::ShowerEnergyFilterMC::filter(), util::TimeFilter::filter(), mono::MonopoleTrack::filter(), novaddt::UpMuTrigger::filter(), calib::MuonTrackHits::filter(), novaddt::MichelETrigger::filter(), calib::MuondEdxAna::filter(), calib::EnergyStandardCandles::FindStoppingMuons(), evd::SliceNavigator::GetBounds(), evd::SliceNavigator::GetBox(), caf::CAFMaker::GetByLabelIfExists(), caf::CAFMaker::GetByLabelStrict(), evd::SimulationDrawer::GetFLSHits(), SliceLID::FillSliceLID::getIsRHC(), LSTME::FillLSTME::getIsRHC(), evd::SliceNavigator::GetProducts(), evd::SliceNavigator::GetProductsImplFull(), evd::SliceNavigator::GetProductsImplPart(), evd::RawDataDrawer::GetRawDigits(), getrawtrigger(), novaddt::SupernovaTrigger::GetTime(), novaddt::MoonShadow::GetTime(), neut::RegenAna::GetTruthInfo(), remid::RecoMuon::Init(), skim::EvaluatorNue::Initialize(), skim::EvaluatorNumu::Initialize(), rb::IsFiltered(), nuonecvntf::NuonECVNTF::IsRHC(), regcvntf::RegCVNTF::IsRHC(), cvneventtf::CVNEventTF::IsRHC(), cvnprongtf::CVNProngTF::IsRHC(), cosrej::MakeNueCosRej::IsRHC(), comi::Cana::LoadMCInfo(), evtsum::EventSummary::MakeOutput(), evg::MCTruthToDk2NuHackItr::MCTruthToDk2NuHackItr(), earms::ElasticArmsHS::MCVertex(), novaddt::UpMuAna::populateFLSmap(), evd::SliceNavigator::postProcessEvent(), photrans::FiberBrightness::preBeginRun(), nova::dbi::RunHistoryService::preBeginRun(), nova::dbi::RunHistoryService::preBeginSubrun(), jmshower::RecoJMShower::PreSel(), novaddt::SortByView::produce(), cvntf::CVNTF::produce(), util::RewriteSpillData::produce(), presel::LEMPresel::produce(), lem::LEMAssociator::produce(), slicer::MMSlicer::produce(), trk::TrkAssn::produce(), vf::VertexFinder::produce(), util::TruthExpand::produce(), slicer::Slicer::produce(), photrans::PhotonSystRewriter::produce(), qeef::QeFinder::produce(), hough::HoughT::produce(), tf::TimingFit::produce(), cheat::ClusterCheater::produce(), recodemo::RecoDemo::produce(), noe::noe::produce(), MergeCalCollections::MergeCalCollections::produce(), filter::TruthFilter::produce(), hv::HoughVertex::produce(), cheat::ProngCheater::produce(), cheat::ShowerCheater::produce(), cheat::TrueEnergy::produce(), tut::TutProducer::produce(), slicer::Slicer4D::produce(), MergeTBDaqCollections::MergeTBDaqCollections::produce(), trk::KalmanTrack::produce(), cheat::TrackCheater::produce(), NovaDDTHitProducer::produce(), lem::UnTranspose::produce(), nuesand::FillNueSandbox::produce(), demo::DemoModule::produce(), nnbar::ShowerProducer::produce(), slicer::TruthSlicer::produce(), numue::TrackOverlapECalc::produce(), wsnumu::WSNumu::produce(), beamlinereco::TimeOfFlightReco::produce(), calib::ResizeDetector::produce(), presel::RockPresel::produce(), lem::LEMSummarizer::produce(), trk::KalmanTrackMerge::produce(), MergeG4Collections::MergeG4Collections::produce(), regcvntf::RegCVNTF::produce(), MergeCollections::MergeCollections::produce(), MergeDaqCollections::MergeDaqCollections::produce(), trackinfo::TrackInfo::produce(), nussand::FillNusSandbox::produce(), presel::CosmicVeto::produce(), slid::Recluster::produce(), novaddt::TrackFit::produce(), numusand::FillSandbox::produce(), presel::CosmicCVNVeto::produce(), presel::NuePresel::produce(), hough::MultiHoughT::produce(), jmshower::JMTrackMerge::produce(), nuonecvntf::NuonECVNTF::produce(), lem::Preselection::produce(), calib::FiberCalibration::produce(), tut::yn2020::FancyScience::produce(), slid::SliceLIDBuilder::produce(), lem::AlignLibToVtx::produce(), calib::PCHitTransposer::produce(), g4n::TruthSlim::produce(), zcl::SPCluster::produce(), MergeGenCollections::MergeGenCollections::produce(), daq2raw::DAQHit2Raw::produce(), trk::CosmicTrack::produce(), lem::MakeMatches::produce(), cosrej::CosRej::produce(), cvnprongtf::CVNProngTF::produce(), beamlinereco::CkovCounterReco::produce(), cvnneutronprongtf::CVNNeutronProngTF::produce(), cvneventtf::CVNEventTF::produce(), numue::NumuEnergy::produce(), beamlinereco::ToFCalibration::produce(), lem::FindMatchesTranspose::produce(), dq::DAQHeaderSummary::produce(), muonid::MuonIDProd::produce(), airshower::AirSlicer::produce(), dt::ViewMerger::produce(), calib::TimingCalibration::produce(), lem::MakeLibrary::produce(), dt::DiscreteTracker::produce(), beamlinereco::LEHitReco::produce(), comi::Cana::produce(), wcvtx::WCVertex::produce(), calib::PCHitsList::produce(), photrans::PhotonTransport::produce(), beamlinereco::WCTrackReco::produce(), beamlinereco::CFDHitReco::produce(), zcl::SMMCluster::produce(), lem::FindLEMMatches::produce(), jmshower::JMClusterMerge::produce(), sn::SupernovaMCCluster::produce(), ifdb::IFDBSpillInfo::produce(), sn::SNSlicer::produce(), zcl::FMMTracker::produce(), neut::NEUTRegen::produce(), vdt::VertexDT::produce(), zcl::FmmTriggerEvd::produce(), ifdb::TBSpillInfo::produce(), ncpi0::MakeNCPi0BkgRej::produce(), cvn::CVNMapper::produce(), calib::DriftResponseCalc::produce(), lem::MakePID::produce(), murem::MRE::produce(), slid::LIDBuilder::produce(), lem::LEM::produce(), jmshower::NueSel::produce(), dif::DiFShowerFinder::produce(), rvp::RecVarPID::produce(), lem::LEMWorkerOutput::produce(), dqsf::DQSpillFlags::produce(), slid::SPIDBuilder::produce(), xnue::XnuePID::produce(), cheat::MCCheater::produce(), g4n::G4Gen::produce(), jmshower::NueSelLID::produce(), crvtx::CosmicRayVertex::produce(), ncid::MakeNCCosRej::produce(), remid::RecoMuon::produce(), xsrec::MakeXSecCCPi0Inc::produce(), sn::SNBackgroundRejection::produce(), g4rwgt::MakeG4WeightTable::produce(), lem::LEMClient::produce(), cvn::CVNAddTrainingData::produce(), murem::MergeDigits::produce(), upmuana::UpMuProb::produce(), ifdb::MIN::produce(), ncid::NCNNKeras::produce(), rsim::ReadoutSim::produce(), photrans::ImprovedTransport::produce(), murem::MuonRemove::produce(), murem::FindMREParent::produce(), beamlinesim::BeamlineSimInput::produce(), jmshower::RecoJMShower::produce(), murem::FindParent::produce(), murem::MergeTruth::produce(), slicemergeviews::SliceMergeViews::produce(), gibuu::GiBUURegen::produce(), tdslicer::TDSlicer::produce(), me::MEFinder::produce(), cmf::CombineResults::ReadOscParamPoints(), calib::SumAttenuationProfiles::readResults(), CMFUniverseReader::readResults(), cmf::CovarianceMatrixFitter::readResults(), cmf::ContourFromGrid::readResults(), cmf::SpectraFromPredictions::readResults(), cmf::ContourFromLibrary::readResults(), cmf::GridPointsBestFit::readResults(), calib::AttenuationFit::readResults(), cheat::BackTracker::Rebuild(), jmshower::RecoJMShower::RecoShowers(), skim::NumuCCpiSkimmer::Skim(), skim::NumuSkimmer::Skim(), skim::NueSkimmer::Skim(), evd::SliceNavigator::SlicesToNavigate(), dq::DAQHeaderSummary::UnpackRawDaqData(), and om::OnMonProd::UnpackRawDaqData().

449  {
450  return getByLabel<PROD>(moduleLabel, instance, {}, result);
451  }
template<typename PROD >
bool art::DataViewImpl::getByLabel ( std::string const &  label,
std::string const &  instance,
std::string const &  process,
Handle< PROD > &  result 
) const

Definition at line 419 of file DataViewImpl.h.

References art::Handle< T >::clear(), art::GroupQueryResult::failed(), art::ConsumesInfo::instance(), art::ProductInfo::Product, art::GroupQueryResult::result(), art::GroupQueryResult::succeeded(), and art::ConsumesInfo::validateConsumedProduct().

423  {
424  std::lock_guard lock{mutex_};
425  result.clear();
426  auto const wrapped = WrappedTypeID::make<PROD>();
427  ProcessTag const processTag{processName, md_.processName()};
428  ProductInfo const pinfo{ProductInfo::ConsumableType::Product,
429  wrapped.product_type,
430  moduleLabel,
431  productInstanceName,
432  processTag};
434  GroupQueryResult qr = principal_.getByLabel(
435  mc_, wrapped, moduleLabel, productInstanceName, processTag);
436  result = Handle<PROD>{qr};
437  bool const ok = qr.succeeded() && !qr.failed();
438  if (recordParents_ && ok) {
439  recordAsParent_(qr.result());
440  }
441  return ok;
442  }
Principal const & principal_
Definition: DataViewImpl.h:327
BranchType const branchType_
Definition: DataViewImpl.h:324
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
void validateConsumedProduct(BranchType const, ModuleDescription const &, ProductInfo const &productInfo)
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
GroupQueryResult getByLabel(ModuleContext const &mc, WrappedTypeID const &wrapped, std::string const &label, std::string const &productInstanceName, ProcessTag const &processTag) const
ModuleContext const & mc_
Definition: DataViewImpl.h:330
static ConsumesInfo * instance()
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename PROD >
PROD const & art::DataViewImpl::getByLabel ( InputTag const &  tag) const

Definition at line 473 of file DataViewImpl.h.

References make_syst_table_plots::h.

474  {
475  Handle<PROD> h;
476  getByLabel(tag, h);
477  return *h;
478  }
bool getByLabel(std::string const &label, std::string const &instance, Handle< PROD > &result) const
Definition: DataViewImpl.h:446
template<typename PROD >
bool art::DataViewImpl::getByLabel ( InputTag const &  tag,
Handle< PROD > &  result 
) const

Definition at line 455 of file DataViewImpl.h.

References art::InputTag::instance(), art::InputTag::label(), art::InputTag::process(), and fillBadChanDBTables::result.

456  {
457  return getByLabel<PROD>(tag.label(), tag.instance(), tag.process(), result);
458  }
template<typename PROD >
bool art::DataViewImpl::getByToken ( ProductToken< PROD > const &  token,
Handle< PROD > &  result 
) const

Definition at line 462 of file DataViewImpl.h.

References art::ProductToken< T >::inputTag_, and fillBadChanDBTables::result.

Referenced by bpfit::BPFdEdxHistoMaker::analyze(), bpfit::BPFEnergyAna::analyze(), bpfit::BPFTmvaTrainer::analyze(), bpf::BPFCVNAna::analyze(), bpfit::BreakPointProtonAna::analyze(), bpfit::BPFTmvaTrainer::endSubRun(), gibuu::GiBUURegen::endSubRun(), util::NonEmptyCluster::filter(), util::CopyCellHits::filter(), evgen::OccupiedSpillFilter::filter(), evgen::GENIEFilter::filter(), util::HasStandardRecord::filter(), calhit::HasCellHits::filter(), bsf::BremShowerFilter::filter(), bpfit::DimuonFitter::FindSlices(), trident::DimuonSliceFilter::FindSlices(), bpfit::BreakPoint::FindSlices(), cosmic::CosmicExposureInfo::produce(), cvntf::CVNCosmicTFFilt::produce(), cvntf::CVNCosmicTF::produce(), cvn::CVNCosmicMapper::produce(), cosrej::CosRej::produce(), earms::ElasticArmsHS::produce(), ndreco::NDReco::produce(), cvn::CVNMapper::produce(), rwgt::MakeGENIEReweightTable::produce(), calhit::RemoveBadChannels::produce(), cvntf::CVNProngEvaluatorTF::produce(), cvn::RegCVNMapper::produce(), bpfit::BPFEnergyEstimator::produce(), calhit::CalHit::produce(), bpfit::BPFPIdMaker::produce(), bpfit::BPFEnergyEstimatorOnly::produce(), cosrej::MakeNueCosRej::produce(), fuzz::FuzzyKVertex::produce(), nerd::NERDProng::produce(), and gibuu::GiBUURegen::produce().

464  {
465  return getByLabel<PROD>(token.inputTag_.label(),
466  token.inputTag_.instance(),
467  token.inputTag_.process(),
468  result);
469  }
::xsd::cxx::tree::token< char, normalized_string > token
Definition: Database.h:156
cet::exempt_ptr<Group const> art::DataViewImpl::getContainerForView_ ( TypeID const &  ,
std::string const &  moduleLabel,
std::string const &  productInstanceName,
ProcessTag const &  processTag 
) const
private
template<typename PROD >
std::vector< InputTag > art::DataViewImpl::getInputTags ( SelectorBase const &  selector = MatchAllSelector{}) const

Definition at line 507 of file DataViewImpl.h.

508  {
509  auto const wrapped = WrappedTypeID::make<PROD>();
510  ProcessTag const processTag{"", md_.processName()};
511  return principal_.getInputTags(mc_, wrapped, selector, processTag);
512  }
Principal const & principal_
Definition: DataViewImpl.h:327
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::vector< InputTag > getInputTags(ModuleContext const &mc, WrappedTypeID const &wrapped, SelectorBase const &, ProcessTag const &) const
ModuleContext const & mc_
Definition: DataViewImpl.h:330
template<typename PROD >
std::vector< Handle< PROD > > art::DataViewImpl::getMany ( SelectorBase const &  selector = MatchAllSelector{}) const

Definition at line 529 of file DataViewImpl.h.

References art::ConsumesInfo::instance(), art::ProductInfo::Many, datagram_client::products, and art::ConsumesInfo::validateConsumedProduct().

530  {
531  std::lock_guard lock{mutex_};
532  auto const wrapped = WrappedTypeID::make<PROD>();
534  branchType_,
535  md_,
536  ProductInfo{ProductInfo::ConsumableType::Many, wrapped.product_type});
537  ProcessTag const processTag{"", md_.processName()};
538  std::vector<Handle<PROD>> products;
539  for (auto const& qr : principal_.getMany(mc_, wrapped, sel, processTag)) {
540  products.emplace_back(qr);
541  if (recordParents_) {
542  recordAsParent_(qr.result());
543  }
544  }
545  return products;
546  }
Principal const & principal_
Definition: DataViewImpl.h:327
BranchType const branchType_
Definition: DataViewImpl.h:324
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
void validateConsumedProduct(BranchType const, ModuleDescription const &, ProductInfo const &productInfo)
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
ModuleContext const & mc_
Definition: DataViewImpl.h:330
static ConsumesInfo * instance()
std::vector< GroupQueryResult > getMany(ModuleContext const &mc, WrappedTypeID const &wrapped, SelectorBase const &, ProcessTag const &) const
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename PROD >
void art::DataViewImpl::getMany ( SelectorBase const &  sel,
std::vector< Handle< PROD >> &  results 
) const

Definition at line 550 of file DataViewImpl.h.

References makeDatasetsPage::results.

552  {
553  results = getMany<PROD>(sel);
554  }
template<typename PROD >
void art::DataViewImpl::getManyByType ( std::vector< Handle< PROD >> &  results) const
template<typename PROD >
PROD const * art::DataViewImpl::getPointerByLabel ( InputTag const &  tag) const

Definition at line 482 of file DataViewImpl.h.

References make_syst_table_plots::h, and art::Handle< T >::product().

483  {
484  Handle<PROD> h;
485  getByLabel(tag, h);
486  return h.product();
487  }
bool getByLabel(std::string const &label, std::string const &instance, Handle< PROD > &result) const
Definition: DataViewImpl.h:446
std::string const& art::DataViewImpl::getProcessName_ ( std::string const &  ) const
private
bool art::DataViewImpl::getProcessParameterSet ( std::string const &  process,
fhicl::ParameterSet  
) const
cet::exempt_ptr<BranchDescription const> art::DataViewImpl::getProductDescription ( ProductID  ) const
BranchDescription const& art::DataViewImpl::getProductDescription_ ( TypeID const &  type,
std::string const &  instance,
bool const  alwaysEnableLookupOfProducedProducts = false 
) const
private
template<typename PROD >
ProductID art::DataViewImpl::getProductID ( std::string const &  instance_name = "") const

Definition at line 358 of file DataViewImpl.h.

References art::canonicalProductName(), and art::errors::ProductRegistrationFailure.

359  {
360  std::lock_guard lock{mutex_};
361  TypeID const type{typeid(PROD)};
362  auto const& product_name = canonicalProductName(
363  type.friendlyClassName(), md_.moduleLabel(), instance, md_.processName());
364  ProductID const pid{product_name};
365  auto desc = principal_.getProductDescription(pid);
366  if (!desc) {
368  "DataViewImpl::getProductID: error while trying to "
369  "retrieve product description:\n")
370  << "No product is registered for\n"
371  << " process name: '" << md_.processName() << "'\n"
372  << " module label: '" << md_.moduleLabel() << "'\n"
373  << " product friendly class name: '" << type.friendlyClassName()
374  << "'\n"
375  << " product instance name: '" << instance << "'\n"
376  << " branch type: '" << branchType_ << "'\n";
377  }
378  // The description object is owned by either the source or the
379  // event processor, whose lifetimes exceed that of the
380  // DataViewImpl object. It is therefore safe to dereference.
381  return desc->productID();
382  }
Principal const & principal_
Definition: DataViewImpl.h:327
BranchType const branchType_
Definition: DataViewImpl.h:324
cet::exempt_ptr< BranchDescription const > getProductDescription(ProductID const pid, bool const alwaysEnableLookupOfProducedProducts=false) const
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::string canonicalProductName(std::string const &friendlyClassName, std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName)
std::string const & moduleLabel() const
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
template<typename PROD >
std::vector< ProductToken< PROD > > art::DataViewImpl::getProductTokens ( SelectorBase const &  selector = MatchAllSelector{}) const

Definition at line 516 of file DataViewImpl.h.

References getGoodRuns4SAM::tag, msf_helper::tags, parsePQSLOutput::tokens, and cet::transform_all().

517  {
518  auto const tags = getInputTags<PROD>(selector);
519  std::vector<ProductToken<PROD>> tokens;
520  tokens.reserve(tags.size());
521  cet::transform_all(tags, back_inserter(tokens), [](auto const& tag) {
522  return ProductToken<PROD>{tag};
523  });
524  return tokens;
525  }
auto transform_all(Container &, OutputIt, UnaryOp)
template<typename ELEMENT >
void art::DataViewImpl::getPtrVector ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
std::string const &  processName,
PtrVector< ELEMENT > &  result 
) const

Definition at line 671 of file DataViewImpl.h.

References submit_syst::const, art::PtrVector< T >::emplace_back(), MECModelEnuComparisons::i, and POTSpillRate::view.

675  {
676  std::lock_guard lock{mutex_};
677  auto grp = getContainerForView_(TypeID{typeid(ELEMENT)},
678  moduleLabel,
679  productInstanceName,
680  ProcessTag{processName, md_.processName()});
681  if (recordParents_) {
682  recordAsParent_(grp);
683  }
684  std::vector<void const*> view;
685  grp->uniqueProduct()->fillView(view);
686  std::size_t i{0};
687  for (auto p : view) {
688  result.emplace_back(
689  grp->productID(), static_cast<ELEMENT const*>(p), i++);
690  }
691  }
cet::exempt_ptr< Group const > getContainerForView_(TypeID const &, std::string const &moduleLabel, std::string const &productInstanceName, ProcessTag const &processTag) const
const char * p
Definition: xmltok.h:285
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename ELEMENT >
void art::DataViewImpl::getPtrVector ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
PtrVector< ELEMENT > &  result 
) const

Definition at line 695 of file DataViewImpl.h.

References fillBadChanDBTables::result.

698  {
699  getPtrVector(moduleLabel, productInstanceName, {}, result);
700  }
void getPtrVector(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, PtrVector< ELEMENT > &result) const
Definition: DataViewImpl.h:671
template<typename ELEMENT >
void art::DataViewImpl::getPtrVector ( InputTag const &  tag,
PtrVector< ELEMENT > &  result 
) const

Definition at line 704 of file DataViewImpl.h.

References art::InputTag::instance(), art::InputTag::label(), art::InputTag::process(), and fillBadChanDBTables::result.

706  {
707  getPtrVector(tag.label(), tag.instance(), tag.process(), result);
708  }
void getPtrVector(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, PtrVector< ELEMENT > &result) const
Definition: DataViewImpl.h:671
template<typename ELEMENT >
void art::DataViewImpl::getPtrVector ( ViewToken< ELEMENT > const &  token,
PtrVector< ELEMENT > &  result 
) const

Definition at line 712 of file DataViewImpl.h.

References art::ViewToken< Element >::inputTag_, and fillBadChanDBTables::result.

714  {
715  getPtrVector(token.inputTag_.label(),
716  token.inputTag_.instance(),
717  token.inputTag_.process(),
718  result);
719  }
void getPtrVector(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, PtrVector< ELEMENT > &result) const
Definition: DataViewImpl.h:671
::xsd::cxx::tree::token< char, normalized_string > token
Definition: Database.h:156
template<typename PROD >
ValidHandle< PROD > art::DataViewImpl::getValidHandle ( InputTag const &  tag) const

Definition at line 491 of file DataViewImpl.h.

References make_syst_table_plots::h, art::Handle< T >::product(), and art::Handle< T >::provenance().

Referenced by daq2raw::SpillWrapper::add(), novaddt::HitsAna::addHit(), rwgt::RwgtTest::analyze(), novaddt::EvTimeAna::analyze(), novaddt::ChannelMapMaker::analyze(), supernova::SimAna::analyze(), supernova::SnovaAna::analyze(), novaddt::HotMapMaker::analyze(), supernova::sliceAna::analyze(), skim::CellHitSkimmer::CheckEvent(), novaddt::DropoutDCMFilter::CountDCMOccupancy(), skim::POTSummary::event(), calib::MakeAttenuationProfiles::event(), Expression::fetchAll(), Expression::fetchOne(), skim::SkimmerAna::FillNueHistograms(), skim::SkimmerAna::FillNumuHistograms(), skim::CosmicBeamComparison::FillNumuHistograms(), EvTimeFilter::filter(), calib::CosmicCalib::filter(), novaddt::ActiveDCMFilter::filter(), supernova::HighEFinder::filter(), novaddt::MichelETrigger::filter(), novaddt::SupernovaTrigger::GetCandidates(), skim::EvaluatorNumuCCpi::Initialize(), novaddt::MichelEfinder::produce(), ifdb::IFDBSpillInfo::produce(), ifdb::MIN::produce(), and skim::NumuCCpiSkimmer::Skim().

492  {
493  Handle<PROD> h;
494  getByLabel(tag, h);
495  return ValidHandle{h.product(), *h.provenance()};
496  }
bool getByLabel(std::string const &label, std::string const &instance, Handle< PROD > &result) const
Definition: DataViewImpl.h:446
template<typename PROD >
ValidHandle< PROD > art::DataViewImpl::getValidHandle ( ProductToken< PROD > const &  token) const

Definition at line 500 of file DataViewImpl.h.

References art::ProductToken< T >::inputTag_.

501  {
502  return getValidHandle<PROD>(token.inputTag_);
503  }
::xsd::cxx::tree::token< char, normalized_string > token
Definition: Database.h:156
template<typename ELEMENT >
std::size_t art::DataViewImpl::getView ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
std::string const &  processName,
std::vector< ELEMENT const * > &  result 
) const

Definition at line 565 of file DataViewImpl.h.

References POTSpillRate::view.

Referenced by evd::SliceNavigator::GetProductsImplFull().

569  {
570  std::lock_guard lock{mutex_};
571  std::size_t const orig_size = result.size();
572  auto grp = getContainerForView_(TypeID{typeid(ELEMENT)},
573  moduleLabel,
574  productInstanceName,
575  ProcessTag{processName, md_.processName()});
576  if (recordParents_) {
577  recordAsParent_(grp);
578  }
579  std::vector<void const*> view;
580  grp->uniqueProduct()->fillView(view);
581  std::vector<ELEMENT const*> castedView;
582  for (auto p : view) {
583  castedView.push_back(static_cast<ELEMENT const*>(p));
584  }
585  result = std::move(castedView);
586  return result.size() - orig_size;
587  }
cet::exempt_ptr< Group const > getContainerForView_(TypeID const &, std::string const &moduleLabel, std::string const &productInstanceName, ProcessTag const &processTag) const
const char * p
Definition: xmltok.h:285
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename ELEMENT >
std::size_t art::DataViewImpl::getView ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
std::vector< ELEMENT const * > &  result 
) const

Definition at line 591 of file DataViewImpl.h.

References fillBadChanDBTables::result.

594  {
595  return getView(moduleLabel, productInstanceName, {}, result);
596  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
template<typename ELEMENT >
std::size_t art::DataViewImpl::getView ( InputTag const &  tag,
std::vector< ELEMENT const * > &  result 
) const

Definition at line 600 of file DataViewImpl.h.

References art::InputTag::instance(), art::InputTag::label(), art::InputTag::process(), and fillBadChanDBTables::result.

602  {
603  return getView(tag.label(), tag.instance(), tag.process(), result);
604  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
template<typename ELEMENT >
std::size_t art::DataViewImpl::getView ( ViewToken< ELEMENT > const &  token,
std::vector< ELEMENT const * > &  result 
) const

Definition at line 608 of file DataViewImpl.h.

References art::ViewToken< Element >::inputTag_, and fillBadChanDBTables::result.

610  {
611  return getView(token.inputTag_.label(),
612  token.inputTag_.instance(),
613  token.inputTag_.process(),
614  result);
615  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
::xsd::cxx::tree::token< char, normalized_string > token
Definition: Database.h:156
template<typename ELEMENT >
bool art::DataViewImpl::getView ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
std::string const &  processName,
View< ELEMENT > &  result 
) const

Definition at line 619 of file DataViewImpl.h.

References POTSpillRate::view.

623  {
624  std::lock_guard lock{mutex_};
625  auto grp = getContainerForView_(TypeID{typeid(ELEMENT)},
626  moduleLabel,
627  productInstanceName,
628  ProcessTag{processName, md_.processName()});
629  if (recordParents_) {
630  recordAsParent_(grp);
631  }
632  std::vector<void const*> view;
633  grp->uniqueProduct()->fillView(view);
634  std::vector<ELEMENT const*> castedView;
635  for (auto p : view) {
636  castedView.push_back(static_cast<ELEMENT const*>(p));
637  }
638  result = View{castedView, grp->productID(), grp->uniqueProduct()};
639  return true;
640  }
cet::exempt_ptr< Group const > getContainerForView_(TypeID const &, std::string const &moduleLabel, std::string const &productInstanceName, ProcessTag const &processTag) const
const char * p
Definition: xmltok.h:285
ModuleDescription const & md_
Definition: DataViewImpl.h:333
std::string const & processName() const
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
void recordAsParent_(cet::exempt_ptr< Group const > grp) const
bool const recordParents_
Definition: DataViewImpl.h:340
template<typename ELEMENT >
bool art::DataViewImpl::getView ( std::string const &  moduleLabel,
std::string const &  productInstanceName,
View< ELEMENT > &  result 
) const

Definition at line 644 of file DataViewImpl.h.

References fillBadChanDBTables::result.

647  {
648  return getView(moduleLabel, productInstanceName, {}, result);
649  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
template<typename ELEMENT >
bool art::DataViewImpl::getView ( InputTag const &  tag,
View< ELEMENT > &  result 
) const

Definition at line 653 of file DataViewImpl.h.

References art::InputTag::instance(), art::InputTag::label(), art::InputTag::process(), and fillBadChanDBTables::result.

654  {
655  return getView(tag.label(), tag.instance(), tag.process(), result);
656  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
template<typename ELEMENT >
bool art::DataViewImpl::getView ( ViewToken< ELEMENT > const &  token,
View< ELEMENT > &  result 
) const

Definition at line 660 of file DataViewImpl.h.

References art::ViewToken< Element >::inputTag_, and fillBadChanDBTables::result.

662  {
663  return getView(token.inputTag_.label(),
664  token.inputTag_.instance(),
665  token.inputTag_.process(),
666  result);
667  }
std::size_t getView(std::string const &moduleLabel, std::string const &productInstanceName, std::string const &processName, std::vector< ELEMENT const * > &result) const
Definition: DataViewImpl.h:565
::xsd::cxx::tree::token< char, normalized_string > token
Definition: Database.h:156
History const& art::DataViewImpl::history ( ) const
bool art::DataViewImpl::isRealData ( ) const

Referenced by calib::ADCShapeFitAna::analyze(), cheat::TestTrackIds::analyze(), cheat::RecoCheckAna::analyze(), meta::Metadata::analyze(), trigmon::LongReadoutAnalyzer::analyze(), calib::AttenFit::analyze(), calib::CosmicTrends::analyze(), calib::CalibAna::analyze(), slid::LIDTraining::analyze(), skim::CellHitSkimmer::CheckEvent(), calib::MakeAttenuationProfiles::event(), skim::SkimmerAna::FillNumuHistograms(), skim::CosmicBeamComparison::FillNumuHistograms(), calib::ThroughgoingSelection::filter(), calib::RockMuonStopperSelection::filter(), calib::StopperSelection::filter(), util::RemoveTBSpills::filter(), util::RemoveBeamSpills::filter(), jmshower::RecoJMShowerFilter::filter(), util::RemoveBeamSpillsPrecise::filter(), calib::CosmicCalib::filter(), SliceLID::FillSliceLID::getIsRHC(), LSTME::FillLSTME::getIsRHC(), calib::MuondEdx::getPECorr(), calib::DetRespDrift::getPECorr(), calib::MuonTrackHits::getPECorr(), calib::MuondEdxAna::getPECorr(), calib::MuonTrackHits::getPECorrToGeV(), calib::MuondEdxAna::getPECorrToGeV(), remid::RecoMuon::Init(), skim::EvaluatorNumuCCpi::Initialize(), skim::EvaluatorNumu::Initialize(), skim::EvaluatorNue::Initialize(), regcvntf::RegCVNTF::IsRHC(), nuonecvntf::NuonECVNTF::IsRHC(), cvnprongtf::CVNProngTF::IsRHC(), cvneventtf::CVNEventTF::IsRHC(), cosrej::MakeNueCosRej::IsRHC(), util::RewriteSpillData::produce(), cheat::TrueEnergy::produce(), lem::LEMSummarizer::produce(), cosrej::CosRej::produce(), numue::NumuEnergy::produce(), dq::DAQHeaderSummary::produce(), ifdb::IFDBSpillInfo::produce(), ifdb::TBSpillInfo::produce(), murem::MergeDigits::produce(), ifdb::MIN::produce(), jmshower::RecoJMShower::produce(), cheat::BackTracker::Rebuild(), jmshower::RecoJMShower::RecoShowers(), skim::NumuCCpiSkimmer::Skim(), skim::NumuSkimmer::Skim(), and skim::NueSkimmer::Skim().

void art::DataViewImpl::movePutProductsToPrincipal ( Principal principal)
void art::DataViewImpl::movePutProductsToPrincipal ( Principal principal,
bool const  checkProducts,
std::map< TypeLabel, BranchDescription > const *  expectedProducts 
)
DataViewImpl& art::DataViewImpl::operator= ( DataViewImpl const &  )
delete
DataViewImpl& art::DataViewImpl::operator= ( DataViewImpl )
delete
ProcessHistory const& art::DataViewImpl::processHistory ( ) const
ProcessHistoryID const& art::DataViewImpl::processHistoryID ( ) const
EDProductGetter const* art::DataViewImpl::productGetter ( ProductID const  pid) const
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
FullSemantic< Level::Run > const  semantic 
)

Definition at line 730 of file DataViewImpl.h.

Referenced by util::StoreGDML::beginRun(), lem::UnTranspose::beginRun(), lem::MergeMatches::beginRun(), daq2raw::DAQHit2Raw::beginRun(), evgen::CosmicsGen::beginRun(), evgen::CosmicPionGen::beginRun(), evgen::IsoGen::beginRun(), supernova::SnovaGen::beginRun(), lem::FindLEMMatches::beginRun(), evgen::SupernovaGen::beginRun(), evgen::GENIERockGen::beginRun(), evgen::SingleGen::beginRun(), lem::LEM::beginRun(), calhit::RemoveBadChannels::beginRun(), evgen::CORSIKAGen::beginRun(), evgen::GENIEGen::beginRun(), calhit::CalHit::beginRun(), photrans::ImprovedTransport::beginRun(), evgen::GENIENeutronOscGen::beginRun(), evgen::TextFileGen::beginRun(), calhit::RemoveBadChannels::beginSubRun(), calhit::CalHit::beginSubRun(), calib::SumSubrunsCalib::endRun(), calib::SumRunsCalib::endRun(), calib::PCHitAggregator::endRun(), lem::FindMatchesTranspose::endRun(), calib::DriftResponseCalc::endRun(), calib::MuondEdx::endRun(), calib::MuonTrackHits::endRun(), calib::DCMTimingOffset::endRun(), calib::MuondEdxAna::endRun(), cosmic::CosmicExposureInfo::endSubRun(), MergeGenCollections::MergeGenCollections::endSubRun(), calib::CosmicCalib::endSubRun(), calib::TimingCalFilter::endSubRun(), evgen::CosmicsGen::endSubRun(), evgen::CosmicPionGen::endSubRun(), evgen::SupernovaGen::endSubRun(), evgen::GENIERockGen::endSubRun(), evgen::SingleGen::endSubRun(), ifdb::IFDBSpillInfo::endSubRun(), evgen::GENIEGen::endSubRun(), evgen::CORSIKAGen::endSubRun(), ifdb::MIN::endSubRun(), evgen::GENIENeutronOscGen::endSubRun(), skim::CellHitSkimmer::endSubRun(), gibuu::GiBUURegen::endSubRun(), evgen::TextFileGen::endSubRun(), skim::CellHitSkimmer::EvaluateSlices(), util::CopyCellHits::filter(), novaddt::HighSortByTDC::filter(), novaddt::SortByDCM::filter(), novaddt::SortByTDC::filter(), novaddt::SortByPlane::filter(), novaddt::TDSlice::filter(), novaddt::Clusterer::filter(), novaddt::RemoveNoise::filter(), novaddt::SpaceSlice::filter(), highe::HighEnergyFilt::filter(), novaddt::DCMSlice::filter(), novaddt::HighADCFilter::filter(), calib::ThroughgoingSelection::filter(), novaddt::TimeDCMSlice::filter(), calib::RockMuonStopperSelection::filter(), novaddt::TimeSlice::filter(), calib::StopperSelection::filter(), novaddt::HighETrigger::filter(), novaddt::DDTStreamer::filter(), novaddt::DBSlicer::filter(), novaddt::DDTDemo::filter(), novaddt::TriCellTrigger::filter(), mono::HighEnergySliceRemoval::filter(), novaddt::ActivityTrigger::filter(), novaddt::NuESelect::filter(), novaddt::FEBOverflowTrigger::filter(), novaddt::MoonShadow::filter(), calib::StopperFilter::filter(), novaddt::ActivityTriggerAna::filter(), novaddt::SlowMonopoleTrigger::filter(), supernova::HighEFinder::filter(), comi::NumiFiltering::filter(), novaddt::FastMMTrigger::filter(), mono::MonopoleCluster::filter(), novaddt::NNFastMMTrigger::filter(), novaddt::HoughTracker::filter(), novaddt::SlowMMTrigger::filter(), mono::SlowMonopoleFilt::filter(), bsf::BremShowerFilter::filter(), novaddt::HorizontalMuonTrigger::filter(), util::RunEventFilter::filter(), showere::ShowerEnergyFilterMC::filter(), mono::MonopoleTrack::filter(), novaddt::UpMuTrigger::filter(), novaddt::MichelETrigger::filter(), trident::DimuonSliceFilter::filter(), art::MixOp< Prod, OProd >::mixAndPut(), novaddt::HoughTrackMaker::move_collections_into_event(), util::FakeSpillData::produce(), util::WriteHornCurrentCosmic::produce(), novaddt::SortByView::produce(), util::RewriteSpillData::produce(), lem::LEMAssociator::produce(), presel::LEMPresel::produce(), trk::TrkAssn::produce(), slicer::MMSlicer::produce(), art::RandomNumberSaver::produce(), util::TruthExpand::produce(), vf::VertexFinder::produce(), slicer::Slicer::produce(), cvntf::CVNCosmicTFFilt::produce(), photrans::PhotonSystRewriter::produce(), qeef::QeFinder::produce(), tf::TimingFit::produce(), hough::HoughT::produce(), cheat::ClusterCheater::produce(), hv::HoughVertex::produce(), tut::TutProducer::produce(), recodemo::RecoDemo::produce(), cheat::ProngCheater::produce(), cheat::ShowerCheater::produce(), cheat::TrueEnergy::produce(), MergeCalCollections::MergeCalCollections::produce(), filter::TruthFilter::produce(), trk::KalmanTrack::produce(), cheat::TrackCheater::produce(), cvntf::CVNCosmicTF::produce(), MergeTBDaqCollections::MergeTBDaqCollections::produce(), slicer::Slicer4D::produce(), demo::DemoModule::produce(), lem::MergeMatches::produce(), NovaDDTHitProducer::produce(), lem::UnTranspose::produce(), nuesand::FillNueSandbox::produce(), wsnumu::WSNumu::produce(), calib::ResizeDetector::produce(), nnbar::ShowerProducer::produce(), numue::TrackOverlapECalc::produce(), beamlinereco::TimeOfFlightReco::produce(), slicer::TruthSlicer::produce(), regcvntf::RegCVNTF::produce(), trk::KalmanTrackMerge::produce(), lem::LEMSummarizer::produce(), MergeCollections::MergeCollections::produce(), MergeDaqCollections::MergeDaqCollections::produce(), presel::RockPresel::produce(), MergeG4Collections::MergeG4Collections::produce(), trackinfo::TrackInfo::produce(), novaddt::TrackFit::produce(), nussand::FillNusSandbox::produce(), presel::CosmicVeto::produce(), slid::Recluster::produce(), hough::MultiHoughT::produce(), lem::Preselection::produce(), numusand::FillSandbox::produce(), presel::CosmicCVNVeto::produce(), presel::NuePresel::produce(), jmshower::JMTrackMerge::produce(), nuonecvntf::NuonECVNTF::produce(), lem::AlignLibToVtx::produce(), cvn::CVNCosmicMapper::produce(), tut::yn2020::FancyScience::produce(), calib::FiberCalibration::produce(), slid::SliceLIDBuilder::produce(), g4n::TruthSlim::produce(), SliceLID::FillSliceLID::produce(), trk::CosmicTrack::produce(), daq2raw::DAQHit2Raw::produce(), calib::PCHitTransposer::produce(), lem::MakeMatches::produce(), zcl::SPCluster::produce(), cvnprongtf::CVNProngTF::produce(), beamlinereco::CkovCounterReco::produce(), cvnneutronprongtf::CVNNeutronProngTF::produce(), MergeGenCollections::MergeGenCollections::produce(), cosrej::CosRej::produce(), cvneventtf::CVNEventTF::produce(), LSTME::FillLSTME::produce(), numue::NumuEnergy::produce(), beamlinereco::ToFCalibration::produce(), lem::FindMatchesTranspose::produce(), dq::DAQHeaderSummary::produce(), neut::NEUTxsec::produce(), muonid::MuonIDProd::produce(), airshower::AirSlicer::produce(), evgen::CosmicsGen::produce(), evgen::IsoGen::produce(), dt::ViewMerger::produce(), earms::ElasticArmsHS::produce(), evgen::CosmicPionGen::produce(), calib::TimingCalibration::produce(), wcvtx::WCVertex::produce(), evgen::SupernovaGen::produce(), beamlinereco::LEHitReco::produce(), dt::DiscreteTracker::produce(), comi::Cana::produce(), calib::PCHitsList::produce(), zcl::SMMCluster::produce(), beamlinereco::CFDHitReco::produce(), beamlinereco::WCTrackReco::produce(), novaddt::MichelEfinder::produce(), evgen::GENIERockGen::produce(), photrans::PhotonTransport::produce(), sn::SupernovaMCCluster::produce(), ifdb::IFDBSpillInfo::produce(), lem::FindLEMMatches::produce(), evgen::SingleGen::produce(), jmshower::JMClusterMerge::produce(), sn::SNSlicer::produce(), zcl::FMMTracker::produce(), neut::NEUTRegen::produce(), vdt::VertexDT::produce(), cvn::CVNMapper::produce(), ifdb::TBSpillInfo::produce(), ncpi0::MakeNCPi0BkgRej::produce(), zcl::FmmTriggerEvd::produce(), lem::MakePID::produce(), rwgt::MakeGENIEReweightTable::produce(), slid::LIDBuilder::produce(), lem::LEM::produce(), murem::MRE::produce(), lem::LEMWorker::produce(), evgen::GENIEGen::produce(), jmshower::NueSel::produce(), dif::DiFShowerFinder::produce(), cvntf::CVNProngEvaluatorTF::produce(), evgen::CORSIKAGen::produce(), calhit::RemoveBadChannels::produce(), dqsf::DQSpillFlags::produce(), rvp::RecVarPID::produce(), cvn::RegCVNMapper::produce(), xnue::XnuePID::produce(), slid::SPIDBuilder::produce(), crvtx::CosmicRayVertex::produce(), jmshower::NueSelLID::produce(), cheat::MCCheater::produce(), g4n::G4Gen::produce(), calhit::CalHit::produce(), bpfit::BPFEnergyEstimator::produce(), fxwgt::FluxWeightCalculator::produce(), ncid::MakeNCCosRej::produce(), xsrec::MakeXSecCCPi0Inc::produce(), bpfit::BPFEnergyEstimatorOnly::produce(), remid::RecoMuon::produce(), bpfit::BPFPIdMaker::produce(), sn::SNBackgroundRejection::produce(), g4rwgt::MakeG4WeightTable::produce(), lem::LEMClient::produce(), cvn::CVNAddTrainingData::produce(), murem::MergeDigits::produce(), upmuana::UpMuProb::produce(), cosrej::MakeNueCosRej::produce(), ifdb::MIN::produce(), rsim::ReadoutSim::produce(), ncid::NCNNKeras::produce(), evgen::GENIENeutronOscGen::produce(), photrans::ImprovedTransport::produce(), murem::MuonRemove::produce(), murem::FindMREParent::produce(), skim::DataProductSkimmer::produce(), beamlinesim::BeamlineSimInput::produce(), murem::FindParent::produce(), murem::MergeTruth::produce(), jmshower::RecoJMShower::produce(), novaddt::HitSubtract::produce(), slicemergeviews::SliceMergeViews::produce(), fuzz::FuzzyKVertex::produce(), nerd::NERDProng::produce(), evgen::TextFileGen::produce(), gibuu::GiBUURegen::produce(), tdslicer::TDSlicer::produce(), me::MEFinder::produce(), bpfit::DimuonFitter::produce(), bpfit::BreakPoint::produce(), supernova::SnovaGen::SaveEvent(), skim::NumuCCpiSkimmer::Skim(), skim::NumuSkimmer::Skim(), skim::NueSkimmer::Skim(), cmf::CombineResults::writeResults(), skim::POTSummary::writeResults(), calib::SumAttenuationProfiles::writeResults(), calib::MakeAttenuationProfiles::writeResults(), cmf::CovarianceMatrixFitter::writeResults(), cmf::PredictionLibraryMaker::writeResults(), cmf::GridPointsBestFit::writeResults(), cmf::RandomUniverses::writeResults(), and cmf::FitFeldmanCousinsPoint::writeResults().

732  {
733  return put(move(edp), "", semantic);
734  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
FragmentSemantic< Level::Run > const  semantic 
)

Definition at line 738 of file DataViewImpl.h.

740  {
741  return put(move(edp), "", semantic);
742  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
RangedFragmentSemantic< Level::Run semantic 
)

Definition at line 746 of file DataViewImpl.h.

748  {
749  return put(move(edp), "", std::move(semantic));
750  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
FullSemantic< Level::Run  
)

Definition at line 754 of file DataViewImpl.h.

References art::RangeSet::forRun().

757  {
758  return put(move(edp), instance, RangeSet::forRun(runID()));
759  }
static RangeSet forRun(RunID)
RunID runID() const
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
FragmentSemantic< Level::Run  
)

Definition at line 763 of file DataViewImpl.h.

References art::errors::ProductPutFailure.

766  {
767  std::lock_guard lock{mutex_};
768  static_assert(
770  "\n\n"
771  "art error: A Run product put with the semantic 'RunFragment'\n"
772  " must be able to be aggregated. Please add the appropriate\n"
773  " void aggregate(T const&)\n"
774  " function to your class, or contact artists@fnal.gov.\n");
775  if (rangeSet_.collapse().is_full_run()) {
776  throw art::Exception{errors::ProductPutFailure, "Run::put"}
777  << "\nCannot put a product corresponding to a full Run using\n"
778  << "art::runFragment(). This can happen if you attempted to\n"
779  << "put a product at beginRun using art::runFragment().\n"
780  << "Please use either:\n"
781  << " art::fullRun(), or\n"
782  << " art::runFragment(art::RangeSet const&)\n"
783  << "or contact artists@fnal.gov for assistance.\n";
784  }
785  return put(move(edp), instance, rangeSet_);
786  }
bool is_full_run() const
const XML_Char int const XML_Char * value
Definition: expat.h:331
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
RangeSet & collapse()
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
RangedFragmentSemantic< Level::Run semantic 
)

Definition at line 790 of file DataViewImpl.h.

References art::errors::ProductPutFailure, and art::RangedFragmentSemantic< Level >::rs.

793  {
794  std::lock_guard lock{mutex_};
795  static_assert(
797  "\n\n"
798  "art error: A Run product put with the semantic 'RunFragment'\n"
799  " must be able to be aggregated. Please add the appropriate\n"
800  " void aggregate(T const&)\n"
801  " function to your class, or contact artists@fnal.gov.\n");
802  if (semantic.rs.collapse().is_full_run()) {
803  throw art::Exception{errors::ProductPutFailure, "Run::put"}
804  << "\nCannot put a product corresponding to a full Run using\n"
805  << "art::runFragment(art::RangeSet&). Please use:\n"
806  << " art::fullRun()\n"
807  << "or contact artists@fnal.gov for assistance.\n";
808  }
809  return put(move(edp), instance, semantic.rs);
810  }
const XML_Char int const XML_Char * value
Definition: expat.h:331
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
FullSemantic< Level::SubRun > const  semantic 
)

Definition at line 814 of file DataViewImpl.h.

816  {
817  return put(move(edp), "", semantic);
818  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
FragmentSemantic< Level::SubRun > const  semantic 
)

Definition at line 822 of file DataViewImpl.h.

824  {
825  return put(move(edp), "", semantic);
826  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
RangedFragmentSemantic< Level::SubRun semantic 
)

Definition at line 830 of file DataViewImpl.h.

832  {
833  return put(move(edp), "", std::move(semantic));
834  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
FullSemantic< Level::SubRun  
)

Definition at line 838 of file DataViewImpl.h.

References art::RangeSet::forSubRun().

841  {
842  return put(move(edp), instance, RangeSet::forSubRun(subRunID()));
843  }
SubRunID subRunID() const
static RangeSet forSubRun(SubRunID)
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
FragmentSemantic< Level::SubRun  
)

Definition at line 847 of file DataViewImpl.h.

References art::errors::ProductPutFailure.

850  {
851  std::lock_guard lock{mutex_};
852  static_assert(
854  "\n\n"
855  "art error: A SubRun product put with the semantic 'SubRunFragment'\n"
856  " must be able to be aggregated. Please add the appropriate\n"
857  " void aggregate(T const&)\n"
858  " function to your class, or contact artists@fnal.gov.\n");
860  throw art::Exception(errors::ProductPutFailure, "SubRun::put")
861  << "\nCannot put a product corresponding to a full SubRun using\n"
862  << "art::subRunFragment(). This can happen if you attempted to\n"
863  << "put a product at beginSubRun using art::subRunFragment().\n"
864  << "Please use either:\n"
865  << " art::fullSubRun(), or\n"
866  << " art::subRunFragment(art::RangeSet const&)\n"
867  << "or contact artists@fnal.gov for assistance.\n";
868  }
869  return put(move(edp), instance, rangeSet_);
870  }
const XML_Char int const XML_Char * value
Definition: expat.h:331
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
bool is_full_subRun() const
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
RangeSet & collapse()
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
RangedFragmentSemantic< Level::SubRun semantic 
)

Definition at line 874 of file DataViewImpl.h.

References art::errors::ProductPutFailure, and art::RangedFragmentSemantic< Level >::rs.

877  {
878  std::lock_guard lock{mutex_};
879  static_assert(
881  "\n\n"
882  "art error: A SubRun product put with the semantic 'SubRunFragment'\n"
883  " must be able to be aggregated. Please add the appropriate\n"
884  " void aggregate(T const&)\n"
885  " function to your class, or contact artists@fnal.gov.\n");
886  if (semantic.rs.collapse().is_full_subRun()) {
887  throw art::Exception{errors::ProductPutFailure, "Run::put"}
888  << "\nCannot put a product corresponding to a full SubRun using\n"
889  << "art::subRunFragment(art::RangeSet&). Please use:\n"
890  << " art::fullSubRun()\n"
891  << "or contact artists@fnal.gov for assistance.\n";
892  }
893  return put(move(edp), instance, semantic.rs);
894  }
const XML_Char int const XML_Char * value
Definition: expat.h:331
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp)

Definition at line 723 of file DataViewImpl.h.

724  {
725  return put(move(edp), "");
726  }
ProductID put(std::unique_ptr< PROD > &&edp, FullSemantic< Level::Run > const semantic)
Definition: DataViewImpl.h:730
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance 
)

Definition at line 898 of file DataViewImpl.h.

References ana::assert(), art::ProductID::invalid(), art::RangeSet::invalid(), art::errors::NullPointerError, art::errors::ProductPutFailure, art::detail::range_sets_supported(), fillBadChanDBTables::result, moon_position_table_new3::second, and art::detail::type_label_for().

899  {
900  std::lock_guard lock{mutex_};
901  TypeID const tid{typeid(PROD)};
902  if (edp.get() == nullptr) {
904  << "Event::put: A null unique_ptr was passed to 'put'.\n"
905  << "The pointer is of type " << tid << ".\n"
906  << "The specified productInstanceName was '" << instance << "'.\n";
907  }
908  auto const& bd = getProductDescription_(tid, instance, true);
909  assert(bd.productID() != ProductID::invalid());
910  auto const typeLabel =
912  auto wp = std::make_unique<Wrapper<PROD>>(move(edp));
913  auto const& rs = detail::range_sets_supported(branchType_) ?
914  rangeSet_.collapse() :
916  bool const result =
917  putProducts_.try_emplace(typeLabel, PMValue{std::move(wp), bd, rs})
918  .second;
919  if (!result) {
920  cet::HorizontalRule rule{30};
922  << "Event::put: Attempt to put multiple products with the\n"
923  << " following description onto the Event.\n"
924  << " Products must be unique per Event.\n"
925  << rule('=') << '\n'
926  << bd << rule('=') << '\n';
927  }
928  return bd.productID();
929  }
TypeLabel type_label_for(TypeID const typeID, std::string const &instance, bool const supportsView, ModuleDescription const &md)
BranchType const branchType_
Definition: DataViewImpl.h:324
static RangeSet invalid()
const XML_Char int const XML_Char * value
Definition: expat.h:331
ModuleDescription const & md_
Definition: DataViewImpl.h:333
BranchDescription const & getProductDescription_(TypeID const &type, std::string const &instance, bool const alwaysEnableLookupOfProducedProducts=false) const
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
std::map< TypeLabel, PMValue > putProducts_
Definition: DataViewImpl.h:353
static constexpr ProductID invalid() noexcept
Definition: ProductID.h:27
assert(nhit_max >=nhit_nbins)
constexpr bool range_sets_supported(BranchType const bt)
RangeSet & collapse()
template<typename PROD >
ProductID art::DataViewImpl::put ( std::unique_ptr< PROD > &&  edp,
std::string const &  instance,
RangeSet const &  rs 
)

Definition at line 933 of file DataViewImpl.h.

References ana::assert(), art::ProductID::invalid(), art::RangeSet::is_valid(), art::errors::NullPointerError, art::errors::ProductPutFailure, fillBadChanDBTables::result, moon_position_table_new3::second, and art::detail::type_label_for().

936  {
937  std::lock_guard lock{mutex_};
938  TypeID const tid{typeid(PROD)};
939  if (edp.get() == nullptr) {
941  << "Event::put: A null unique_ptr was passed to 'put'.\n"
942  << "The pointer is of type " << tid << ".\n"
943  << "The specified productInstanceName was '" << instance << "'.\n";
944  }
945  if (!rs.is_valid()) {
946  throw art::Exception{errors::ProductPutFailure, "SubRun::put"}
947  << "\nCannot put a product with an invalid RangeSet.\n"
948  << "Please contact artists@fnal.gov.\n";
949  }
950  auto const& bd = getProductDescription_(tid, instance, true);
951  assert(bd.productID() != ProductID::invalid());
952  auto const typeLabel =
954  auto wp = std::make_unique<Wrapper<PROD>>(move(edp));
955  auto result =
956  putProducts_.try_emplace(typeLabel, PMValue{move(wp), bd, rs}).second;
957  if (!result) {
958  constexpr cet::HorizontalRule rule{30};
960  << "Event::put: Attempt to put multiple products with the\n"
961  << " following description onto the Event.\n"
962  << " Products must be unique per Event.\n"
963  << rule('=') << '\n'
964  << bd << rule('=') << '\n';
965  }
966  return bd.productID();
967  }
TypeLabel type_label_for(TypeID const typeID, std::string const &instance, bool const supportsView, ModuleDescription const &md)
const XML_Char int const XML_Char * value
Definition: expat.h:331
ModuleDescription const & md_
Definition: DataViewImpl.h:333
BranchDescription const & getProductDescription_(TypeID const &type, std::string const &instance, bool const alwaysEnableLookupOfProducedProducts=false) const
cet::coded_exception< errors::ErrorCodes, ExceptionDetail::translate > Exception
Definition: Exception.h:66
std::recursive_mutex mutex_
Definition: DataViewImpl.h:321
std::map< TypeLabel, PMValue > putProducts_
Definition: DataViewImpl.h:353
static constexpr ProductID invalid() noexcept
Definition: ProductID.h:27
assert(nhit_max >=nhit_nbins)
void art::DataViewImpl::recordAsParent_ ( cet::exempt_ptr< Group const >  grp) const
private
template<typename PROD >
bool art::DataViewImpl::removeCachedProduct ( Handle< PROD > &  h) const
RunNumber_t art::DataViewImpl::run ( ) const

Referenced by caf::CAFMaker::AddMCTruthToVec(), tbana::RawFileDumper::analyze(), jmshower::RecoJMShowerAna::analyze(), comi::CosmicMetrics::analyze(), novaddt::DAQHeaderAna::analyze(), zcl::SMMTriggerAna::analyze(), tut::yn2017::AnalysisModule::analyze(), neut::RegenAna::analyze(), BeamlineAna::analyze(), tut::yn2017::DebugThis::analyze(), mcchk::CosmicAna::analyze(), numue::NumuEAna::analyze(), febstat::EventFEBStatus::analyze(), comi::DataCheck::analyze(), calib::EnergyStandardCandles::analyze(), novaddt::HorizontalMuonAna::analyze(), zcl::FmmTriggerAna::analyze(), comi::NumiFilteringAna::analyze(), comi::Leana::analyze(), tbem::TBRecoAna::analyze(), zcl::FmmTrackerAna::analyze(), calib::PEResponse::analyze(), beamlinereco::EventWaveformDump::analyze(), trigmon::LongReadoutAnalyzer::analyze(), hough::HoughValidate::analyze(), Mono::Mono::analyze(), mono::SlowMonopoleAna::analyze(), slicer::SlicerAna::analyze(), comi::NearlineAna::analyze(), zcl::FastMMStudy::analyze(), mono::Monopole::analyze(), fuzz::FuzzyKValidate::analyze(), testbeam::BeamlineEventDisplay::analyze(), beamlinereco::ToFAnalysisMini::analyze(), skim::SkimmerAna::analyze(), bpf::BPFCVNAna::analyze(), skim::CosmicBeamComparison::analyze(), air::AirKalmanAna::analyze(), calib::CalibAna::analyze(), ncs::Xeff::analyze(), ncs::ROCKMRE::analyze(), slid::LIDTraining::analyze(), ncs::NCAna::analyze(), nnbar::RecoAnalysis::analyze(), beamlinereco::ToFPositionRecoAnalysis::analyze(), sn::SNMichelAnalyzer::analyze(), htk::HoughTrack::analyze(), trk::CosmicTrackAna::analyze(), comi::FEBFlash::analyze(), meta::Metadata::beginRun(), util::RunEventFilter::beginRun(), novatb::TriggerRateAna::beginRun(), util::TimeFilter::beginRun(), calib::PEResponse::beginRun(), rsim::ReadoutSim::beginRun(), testbeam::BeamlineEventDisplay::beginRun(), runh::BadDataFilter::beginRun(), DataCheck::HardwareStatusCheck::beginSubRun(), comi::DataCheck::beginSubRun(), meta::Metadata::beginSubRun(), util::RunEventFilter::beginSubRun(), chaninfo::BadChanValidate::beginSubRun(), util::TimeFilter::beginSubRun(), testbeam::BeamlineEventDisplay::beginSubRun(), skim::SkimmerAna::beginSubRun(), skim::CosmicBeamComparison::beginSubRun(), skim::CellHitSkimmer::CheckEvent(), evd::TZProjPad::Draw(), calib::SumRunsCalib::endRun(), calib::DriftResponseCalc::endRun(), calib::DCMTimingOffset::endRun(), novaddt::NoiseMapAna::endRun(), skim::CellHitSkimmer::endRun(), comi::ChanOcc::endSubRun(), mono::DataCheckMonopole::endSubRun(), skim::CellHitSkimmer::EvaluateSlices(), numue::NumuEAlg::FDEnergy(), mono::SlowMonopoleAna::fill_track_tree(), skim::CosmicBeamComparison::FillNumuHistograms(), caf::CAFMaker::FillSpillVars(), util::MergeSubruns::filter(), calib::CosmicCalib::filter(), util::EventFilterNoSlice::filter(), calib::TimingCalFilter::filter(), mono::SlowMonopoleFilt::filter(), bsf::BremShowerFilter::filter(), chaninfo::FindSwappedChannels::filter(), util::RunEventFilter::filter(), calib::DetRespDrift::filter(), util::TimeFilter::filter(), calib::MuonTrackHits::filter(), skim::CellHitSkimmer::filter(), calib::MuondEdxAna::filter(), runh::BadDataFilter::filter(), trident::DimuonSliceFilter::filter(), LSTME::SliceVars::getCoarseTiming(), LSTME::SliceVars::getLowGain(), skim::EvaluatorNumuCCpi::Initialize(), skim::EvaluatorNumu::Initialize(), skim::EvaluatorNue::Initialize(), MakeFileName(), daq2raw::DAQHit2Raw::PopulateRawTrig(), rsim::ReadoutSim::PopulateRawTrig(), cmap::CMap::postBeginRun(), calib::Calibrator::postBeginRun(), novaddt::RunInfoStatic::preBeginRun(), evd::SliceNavigator::preBeginRun(), geo::Geometry::preBeginRun(), nova::dbi::RunHistoryService::preBeginRun(), chaninfo::BadChanList::preBeginRun(), novaddt::RunInfoStatic::preBeginSubRun(), noe::noe::produce(), lem::UnTranspose::produce(), presel::CosmicVeto::produce(), presel::CosmicCVNVeto::produce(), tut::yn2020::FancyScience::produce(), calib::FiberCalibration::produce(), cosrej::CosRej::produce(), numue::NumuEnergy::produce(), lem::FindMatchesTranspose::produce(), airshower::AirSlicer::produce(), lem::MakeLibrary::produce(), calib::TimingCalibration::produce(), earms::ElasticArmsHS::produce(), comi::Cana::produce(), zcl::SMMCluster::produce(), lem::FindLEMMatches::produce(), ifdb::IFDBSpillInfo::produce(), vdt::VertexDT::produce(), zcl::FmmTriggerEvd::produce(), lem::LEM::produce(), jmshower::NueSel::produce(), dif::DiFShowerFinder::produce(), jmshower::NueSelLID::produce(), photrans::ImprovedTransport::produce(), fuzz::FuzzyKVertex::produce(), bpfit::DimuonFitter::produce(), bpfit::BreakPoint::produce(), numue::NumuEAlg::QEFormulaEnergy(), evdb::ScanFrame::Record(), evd::HeaderDrawer::Text(), moonshadowana::MoonShadowAna::WriteEventInfo(), moonshadowana::MoonShadowAnaHough::WriteEventInfo(), cvn::CVNEventDump::WriteMapTH2(), cvn::CVNCosmicEventDump::WriteMapTH2(), and cvn::CVNEventProngDump::WriteMapTH2().

RunID art::DataViewImpl::runID ( ) const
SubRunNumber_t art::DataViewImpl::subRun ( ) const

Referenced by caf::CAFMaker::AddMCTruthToVec(), tbana::RawFileDumper::analyze(), jmshower::RecoJMShowerAna::analyze(), comi::CosmicMetrics::analyze(), chaninfo::PedestalThresholdValidation::analyze(), align::AlignInspect::analyze(), novaddt::DAQHeaderAna::analyze(), tut::yn2017::AnalysisModule::analyze(), zcl::SMMTriggerAna::analyze(), tut::yn2017::DebugThis::analyze(), neut::RegenAna::analyze(), BeamlineAna::analyze(), numue::NumuEAna::analyze(), febstat::EventFEBStatus::analyze(), tbana::DSToFAna::analyze(), comi::DataCheck::analyze(), calib::EnergyStandardCandles::analyze(), novaddt::HorizontalMuonAna::analyze(), comi::NumiFilteringAna::analyze(), zcl::FmmTriggerAna::analyze(), comi::Leana::analyze(), tbem::TBRecoAna::analyze(), calib::PEResponse::analyze(), zcl::FmmTrackerAna::analyze(), beamlinereco::EventWaveformDump::analyze(), trigmon::LongReadoutAnalyzer::analyze(), hough::HoughValidate::analyze(), Mono::Mono::analyze(), mono::SlowMonopoleAna::analyze(), slicer::SlicerAna::analyze(), comi::NearlineAna::analyze(), mono::Monopole::analyze(), fuzz::FuzzyKValidate::analyze(), zcl::FastMMStudy::analyze(), testbeam::BeamlineEventDisplay::analyze(), skim::SkimmerAna::analyze(), bpf::BPFCVNAna::analyze(), skim::CosmicBeamComparison::analyze(), air::AirKalmanAna::analyze(), ncs::Xeff::analyze(), calib::CalibAna::analyze(), ncs::ROCKMRE::analyze(), slid::LIDTraining::analyze(), ncs::NCAna::analyze(), nnbar::RecoAnalysis::analyze(), beamlinereco::ToFPositionRecoAnalysis::analyze(), sn::SNMichelAnalyzer::analyze(), htk::HoughTrack::analyze(), novatb::BeamTuning::analyze(), trk::CosmicTrackAna::analyze(), comi::FEBFlash::analyze(), meta::Metadata::beginSubRun(), util::RunEventFilter::beginSubRun(), comi::NumiFilteringAna::beginSubRun(), calhit::RemoveBadChannels::beginSubRun(), chaninfo::BadChanValidate::beginSubRun(), tbana::BeamlineTriggerAna::beginSubRun(), util::TimeFilter::beginSubRun(), calhit::CalHit::beginSubRun(), testbeam::BeamlineEventDisplay::beginSubRun(), caf::CAFMaker::beginSubRun(), runh::BadDataFilter::beginSubRun(), comi::ChanOcc::endSubRun(), mcchk::POTAna::endSubRun(), mono::DataCheckMonopole::endSubRun(), tbana::BeamlineTriggerAna::endSubRun(), ncs::Xbeam::endSubRun(), ncs::Xeff::endSubRun(), ncs::ROCKMRE::endSubRun(), ncs::NCAna::endSubRun(), novatb::BeamTuning::endSubRun(), caf::CAFMaker::endSubRun(), skim::CellHitSkimmer::EvaluateSlices(), mono::SlowMonopoleAna::fill_track_tree(), skim::CosmicBeamComparison::FillNumuHistograms(), caf::CAFMaker::FillSpillVars(), calib::CosmicCalib::filter(), comi::NumiFiltering::filter(), calib::TimingCalFilter::filter(), util::EventFilterNoSlice::filter(), bsf::BremShowerFilter::filter(), util::RunEventFilter::filter(), chaninfo::FindSwappedChannels::filter(), util::TimeFilter::filter(), calib::MuonTrackHits::filter(), skim::CellHitSkimmer::filter(), runh::BadDataFilter::filter(), trident::DimuonSliceFilter::filter(), skim::EvaluatorNue::Initialize(), daq2raw::DAQHit2Raw::PopulateRawTrig(), rsim::ReadoutSim::PopulateRawTrig(), chaninfo::BadChanList::postBeginSubRun(), novaddt::RunInfoStatic::preBeginSubRun(), nova::dbi::RunHistoryService::preBeginSubrun(), noe::noe::produce(), lem::UnTranspose::produce(), tut::yn2020::FancyScience::produce(), calib::FiberCalibration::produce(), lem::FindMatchesTranspose::produce(), airshower::AirSlicer::produce(), lem::MakeLibrary::produce(), calib::TimingCalibration::produce(), earms::ElasticArmsHS::produce(), comi::Cana::produce(), zcl::SMMCluster::produce(), lem::FindLEMMatches::produce(), vdt::VertexDT::produce(), zcl::FmmTriggerEvd::produce(), lem::LEM::produce(), jmshower::NueSel::produce(), dif::DiFShowerFinder::produce(), jmshower::NueSelLID::produce(), photrans::ImprovedTransport::produce(), fuzz::FuzzyKVertex::produce(), bpfit::DimuonFitter::produce(), bpfit::BreakPoint::produce(), evdb::ScanFrame::Record(), evd::HeaderDrawer::Text(), moonshadowana::MoonShadowAna::WriteEventInfo(), moonshadowana::MoonShadowAnaHough::WriteEventInfo(), cvn::CVNEventDump::WriteMapTH2(), cvn::CVNCosmicEventDump::WriteMapTH2(), and cvn::CVNEventProngDump::WriteMapTH2().

SubRunID art::DataViewImpl::subRunID ( ) const
Timestamp art::DataViewImpl::time ( ) const

Friends And Related Function Documentation

friend class detail::Analyzer
friend

Definition at line 77 of file DataViewImpl.h.

friend class detail::Filter
friend

Definition at line 78 of file DataViewImpl.h.

friend class detail::Producer
friend

Definition at line 79 of file DataViewImpl.h.

friend class ProducingService
friend

Definition at line 81 of file DataViewImpl.h.

friend class ResultsProducer
friend

Definition at line 80 of file DataViewImpl.h.

Member Data Documentation

BranchType const art::DataViewImpl::branchType_
private

Definition at line 324 of file DataViewImpl.h.

ModuleContext const& art::DataViewImpl::mc_
private

Definition at line 330 of file DataViewImpl.h.

ModuleDescription const& art::DataViewImpl::md_
private

Definition at line 333 of file DataViewImpl.h.

std::recursive_mutex art::DataViewImpl::mutex_ {}
mutableprivate

Definition at line 321 of file DataViewImpl.h.

Principal const& art::DataViewImpl::principal_
private

Definition at line 327 of file DataViewImpl.h.

std::map<TypeLabel, PMValue> art::DataViewImpl::putProducts_ {}
private

Definition at line 353 of file DataViewImpl.h.

RangeSet art::DataViewImpl::rangeSet_ {RangeSet::invalid()}
private

Definition at line 344 of file DataViewImpl.h.

bool const art::DataViewImpl::recordParents_
private

Definition at line 340 of file DataViewImpl.h.

std::set<ProductID> art::DataViewImpl::retrievedProducts_ {}
mutableprivate

Definition at line 349 of file DataViewImpl.h.


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