Inheritance diagram for ifdb::TBSpillInfo:

Public Types
using	ModuleType = EDProducer

using	WorkerType = WorkerT< EDProducer >

template<typename UserConfig , typename KeysToIgnore = void>
using	Table = ProducerBase::Table< UserConfig, KeysToIgnore >

Public Member Functions
	TBSpillInfo (fhicl::ParameterSet const &pset)

virtual	~TBSpillInfo ()

void	produce (art::Event &evt)

void	reconfigure (const fhicl::ParameterSet &pset)

template<typename PROD , BranchType B = InEvent>
ProductID	getProductID (std::string const &instanceName={}) const

template<typename PROD , BranchType B>
ProductID	getProductID (ModuleDescription const &moduleDescription, std::string const &instanceName) const

bool	modifiesEvent () const

template<typename T , BranchType = InEvent>
ProductToken< T >	consumes (InputTag const &)

template<typename T , art::BranchType BT>
art::ProductToken< T >	consumes (InputTag const &it)

template<typename T , BranchType = InEvent>
void	consumesMany ()

template<typename Element , BranchType = InEvent>
ViewToken< Element >	consumesView (InputTag const &)

template<typename T , art::BranchType BT>
art::ViewToken< T >	consumesView (InputTag const &it)

template<typename T , BranchType = InEvent>
ProductToken< T >	mayConsume (InputTag const &)

template<typename T , art::BranchType BT>
art::ProductToken< T >	mayConsume (InputTag const &it)

template<typename T , BranchType = InEvent>
void	mayConsumeMany ()

template<typename Element , BranchType = InEvent>
ViewToken< Element >	mayConsumeView (InputTag const &)

template<typename T , art::BranchType BT>
art::ViewToken< T >	mayConsumeView (InputTag const &it)

base_engine_t &	createEngine (seed_t seed)

base_engine_t &	createEngine (seed_t seed, std::string const &kind_of_engine_to_make)

base_engine_t &	createEngine (seed_t seed, std::string const &kind_of_engine_to_make, label_t const &engine_label)

seed_t	get_seed_value (fhicl::ParameterSet const &pset, char const key[]="seed", seed_t const implicit_seed=-1)

Static Public Member Functions
static cet::exempt_ptr< Consumer >	non_module_context ()

Protected Member Functions
CurrentProcessingContext const *	currentContext () const

void	validateConsumedProduct (BranchType const bt, ProductInfo const &pi)

void	prepareForJob (fhicl::ParameterSet const &pset)

void	showMissingConsumes () const

Private Attributes
double	fOffset

std::string	pRawDataLabel

std::string	pRawBLTrigLabel

art::ServiceHandle< ifbeam_ns::IFBeam >	ifbeam_handle

std::unique_ptr< BeamFolder >	bfp

bool	isMC

Detailed Description

Definition at line 48 of file TBSpillInfo_module.cc.

Member Typedef Documentation

using art::EDProducer::ModuleType = EDProducer

inherited

Definition at line 34 of file EDProducer.h.

template<typename UserConfig , typename KeysToIgnore = void>

using art::EDProducer::Table = ProducerBase::Table<UserConfig, KeysToIgnore>

inherited

Definition at line 43 of file EDProducer.h.

using art::EDProducer::WorkerType = WorkerT<EDProducer>

inherited

Definition at line 35 of file EDProducer.h.

Constructor & Destructor Documentation

ifdb::TBSpillInfo::TBSpillInfo ( fhicl::ParameterSet const & pset )

explicit

Definition at line 76 of file TBSpillInfo_module.cc.

References bfp.

                                                         :
     fOffset         (pset.get< double      >("Offset")         ),
     pRawDataLabel   (pset.get< std::string >("RawDataLabel")   ),
     pRawBLTrigLabel (pset.get< std::string >("RawBLTrigLabel") ),
     bfp( ifbeam_handle->getBeamFolder(pset.get< std::string >("Bundle"), pset.get< std::string >("URL"), pset.get< double >("TimeWindow"))),
     isMC(false)
   {
     // how close in time does the spill time have to be from the DAQ tims [seconds]
     // TB has one 4.2 second spill every minute.
     bfp->set_epsilon(5); 
     // tell the module what it is making as this is a EDProducer
     produces< sumdata::MCenterData >();
     // Be noisy to demonstrate what's happening
     mf::LogInfo("TBSpillInfo") << "In TBSpillInfo Constructor\n";
   
   }

ifdb::TBSpillInfo::~TBSpillInfo ( )

virtual

Definition at line 94 of file TBSpillInfo_module.cc.

95 {

96 }

Member Function Documentation

template<typename T , BranchType = InEvent>

ProductToken<T> art::Consumer::consumes ( InputTag const & )

inherited

template<typename T , art::BranchType BT>

art::ProductToken<T> art::Consumer::consumes ( InputTag const & it )

inherited

Definition at line 146 of file Consumer.h.

References art::InputTag::instance(), PandAna.reco_validation.prod5_pid_validation::invalid, art::InputTag::label(), art::InputTag::process(), and T.

 {
   if (!moduleContext_)
     return ProductToken<T>::invalid();
 
   consumables_[BT].emplace_back(ConsumableType::Product,
                                 TypeID{typeid(T)},
                                 it.label(),
                                 it.instance(),
                                 it.process());
   return ProductToken<T>{it};
 }

template<typename T , art::BranchType BT>

void art::Consumer::consumesMany ( )

inherited

Definition at line 161 of file Consumer.h.

References T.

 {
   if (!moduleContext_)
     return;
 
   consumables_[BT].emplace_back(ConsumableType::Many, TypeID{typeid(T)});
 }

template<typename Element , BranchType = InEvent>

ViewToken<Element> art::Consumer::consumesView ( InputTag const & )

inherited

template<typename T , art::BranchType BT>

art::ViewToken<T> art::Consumer::consumesView ( InputTag const & it )

inherited

Definition at line 171 of file Consumer.h.

References art::InputTag::instance(), PandAna.reco_validation.prod5_pid_validation::invalid, art::InputTag::label(), art::InputTag::process(), and T.

 {
   if (!moduleContext_)
     return ViewToken<T>::invalid();
 
   consumables_[BT].emplace_back(ConsumableType::ViewElement,
                                 TypeID{typeid(T)},
                                 it.label(),
                                 it.instance(),
                                 it.process());
   return ViewToken<T>{it};
 }

base_engine_t& art::EngineCreator::createEngine ( seed_t seed )

inherited

Referenced by evgen::CosmicPionGen::CosmicPionGen(), evgen::CosmicsGen::CosmicsGen(), fuzz::FuzzyKVertex::FuzzyKVertex(), g4n::G4Gen::G4Gen(), photrans::ImprovedTransport::ImprovedTransport(), art::MixFilter< T >::initEngine_(), evgen::IsoGen::IsoGen(), rsim::MakeNoiseSpectrumFile::MakeNoiseSpectrumFile(), photrans::PhotonSystRewriter::PhotonSystRewriter(), photrans::PhotonTransport::PhotonTransport(), rsim::ReadoutSim::ReadoutSim(), evgen::SingleGen::SingleGen(), and evgen::SupernovaGen::SupernovaGen().

base_engine_t& art::EngineCreator::createEngine	(	seed_t	seed,
		std::string const &	kind_of_engine_to_make
	)

inherited

base_engine_t& art::EngineCreator::createEngine	(	seed_t	seed,
		std::string const &	kind_of_engine_to_make,
		label_t const &	engine_label
	)

inherited

CurrentProcessingContext const* art::EDProducer::currentContext ( ) const

protectedinherited

seed_t art::EngineCreator::get_seed_value	(	fhicl::ParameterSet const &	pset,
		char const	key[] = `"seed"`,
		seed_t const	implicit_seed = `-1`
	)

inherited

Referenced by art::MixFilter< T >::initEngine_().

template<typename PROD , BranchType B>

ProductID art::EDProducer::getProductID ( std::string const & instanceName = {} ) const

inlineinherited

Definition at line 123 of file EDProducer.h.

References art::EDProducer::moduleDescription_.

Referenced by skim::NueSkimmer::CopyMichelSlice(), and skim::NueSkimmer::CopyMichelTrack().

   {
     return ProducerBase::getProductID<PROD, B>(moduleDescription_,
                                                instanceName);
   }

template<typename PROD , BranchType B>

ProductID art::ProducerBase::getProductID	(	ModuleDescription const &	moduleDescription,
		std::string const &	instanceName
	)		const

inherited

Definition at line 56 of file ProducerBase.h.

References art::ModuleDescription::moduleLabel().

Referenced by art::ProducerBase::modifiesEvent().

   {
     auto const& pd =
       get_ProductDescription<PROD>(B, md.moduleLabel(), instanceName);
     return pd.productID();
   }

template<typename T , BranchType = InEvent>

ProductToken<T> art::Consumer::mayConsume ( InputTag const & )

inherited

template<typename T , art::BranchType BT>

art::ProductToken<T> art::Consumer::mayConsume ( InputTag const & it )

inherited

Definition at line 189 of file Consumer.h.

References art::InputTag::instance(), PandAna.reco_validation.prod5_pid_validation::invalid, art::InputTag::label(), art::InputTag::process(), and T.

 {
   if (!moduleContext_)
     return ProductToken<T>::invalid();
 
   consumables_[BT].emplace_back(ConsumableType::Product,
                                 TypeID{typeid(T)},
                                 it.label(),
                                 it.instance(),
                                 it.process());
   return ProductToken<T>{it};
 }

template<typename T , art::BranchType BT>

void art::Consumer::mayConsumeMany ( )

inherited

Definition at line 204 of file Consumer.h.

References T.

 {
   if (!moduleContext_)
     return;
 
   consumables_[BT].emplace_back(ConsumableType::Many, TypeID{typeid(T)});
 }

template<typename Element , BranchType = InEvent>

ViewToken<Element> art::Consumer::mayConsumeView ( InputTag const & )

inherited

template<typename T , art::BranchType BT>

art::ViewToken<T> art::Consumer::mayConsumeView ( InputTag const & it )

inherited

Definition at line 214 of file Consumer.h.

References art::InputTag::instance(), PandAna.reco_validation.prod5_pid_validation::invalid, art::InputTag::label(), art::InputTag::process(), and T.

 {
   if (!moduleContext_)
     return ViewToken<T>::invalid();
 
   consumables_[BT].emplace_back(ConsumableType::ViewElement,
                                 TypeID{typeid(T)},
                                 it.label(),
                                 it.instance(),
                                 it.process());
   return ViewToken<T>{it};
 }

bool art::ProducerBase::modifiesEvent ( ) const

inlineinherited

Definition at line 40 of file ProducerBase.h.

References art::ProducerBase::getProductID(), and string.

     {
       return true;
     }

static cet::exempt_ptr<Consumer> art::Consumer::non_module_context ( )

staticinherited

Referenced by art::RootOutput::beginSubRun(), art::ProcessPackage< L >::postScheduleSignal(), art::BeginEndPackage< Level::Run >::Begin::postScheduleSignal(), art::BeginEndPackage< Level::Run >::End::postScheduleSignal(), art::BeginEndPackage< Level::SubRun >::Begin::postScheduleSignal(), art::BeginEndPackage< Level::SubRun >::End::postScheduleSignal(), art::ProcessPackage< L >::preScheduleSignal(), art::BeginEndPackage< Level::Run >::Begin::preScheduleSignal(), art::BeginEndPackage< Level::SubRun >::Begin::preScheduleSignal(), art::EmptyEvent::readRun_(), and art::EmptyEvent::readSubRun_().

void art::Consumer::prepareForJob ( fhicl::ParameterSet const & pset )

protectedinherited

void ifdb::TBSpillInfo::produce ( art::Event & evt )

virtual

Implements art::EDProducer.

Definition at line 105 of file TBSpillInfo_module.cc.

References bfp, novadaq::timeutils::convertNovaTimeToUnixTime(), DEFINE_ART_MODULE(), release_diff::diff, fOffset, rawdata::RawTrigger::fTriggerMask_TriggerType, rawdata::RawTrigger::fTriggerTimingMarker_TimeStart, art::DataViewImpl::getByLabel(), makeTrainCVSamples::int, isMC, art::Event::isRealData(), pRawBLTrigLabel, pRawDataLabel, art::Event::put(), string, rawdata::RawBeamlineTrigger::TDUTime(), and msf_helper::timespec.

   {
     std::unique_ptr<sumdata::MCenterData> mcenterdata(new sumdata::MCenterData());
     
     if(!evt.isRealData()){
       // remove empty spill info write from here, move to GENIEGen and fill
       isMC = true;
       // don't have any beam sim to put in here      
       return;
     }
 
     //this will be the CORRECT UTC time we want ultimately
     struct timespec unixTime;
 
     art::Handle<std::vector<rawdata::RawTrigger> > trigv;
     art::Handle<std::vector<rawdata::RawBeamlineTrigger> > bltrigv;
     
     // Case: use NOvA DAQ trigger
     if (evt.getByLabel<std::vector<rawdata::RawTrigger> >(pRawDataLabel, trigv)) {
 
       const rawdata::RawTrigger& trig = (*trigv)[0];
     
       if( !(trig.fTriggerMask_TriggerType == 1 || trig.fTriggerMask_TriggerType == 43) ){
         // This isn't a Beamline or TBSpill trigger. Don't try to get beam info
         evt.put(std::move(mcenterdata));
         return;
       }
     
       novadaq::timeutils::convertNovaTimeToUnixTime(trig.fTriggerTimingMarker_TimeStart, unixTime);
 
     }
 
     // Case: use Beamline DAQ trigger
     else if (evt.getByLabel<std::vector<rawdata::RawBeamlineTrigger> >(pRawBLTrigLabel, bltrigv)) {
 
       const rawdata::RawBeamlineTrigger& trig = (*bltrigv)[0];
       novadaq::timeutils::convertNovaTimeToUnixTime(trig.TDUTime(), unixTime);
 
     }
 
     else
       throw cet::exception("TBSpillInfo") << "failed to get valid trigger handle";
     
     unsigned long int uevt_sec = unixTime.tv_sec; //utval >> 32 & 0xFFFFFFFFF;
     unsigned long int uevt_nsec = unixTime.tv_nsec; //utval & 0xFFFFFFFFF;
     
     //DAQ event time 
     double DAQtime = (double)(uevt_sec + (0.000000001)*uevt_nsec);
             
     // beam parameters
     double mcnrg=0.;
     double mc6ic=0.;
     double mc6ictime=0.;
     double mc6cv=0.;
     double mc7sc1=0.;
     double mc7an1=0.;
 
     // NOvA scintillator counters
     double novtsc01=0.;
     double novtsc07=0.;
 
     // start with what was originally in bundle - split up the beam devices due to
     // some issues querying around March 4th. Looks like devices that were added to the bundle
     // later don't have data for some time on the 4th.
     try{
 
       // Query the database to get post-spill sample device info. We are querying $36, so an offset
       // is added to the event time to match the db time. Epsilon for the beam folder is large enough
       // to encompass full spill
     
       bfp->GetNamedData(DAQtime+fOffset,"F:MC6IC@,F:MC7SC1", &mc6ic, &mc6ictime, &mc7sc1);
    
       //Check time close to DB time later
       
       // Epsilon provided on beam folder should already guarantee matching spill time (if one exists)
 
       unsigned long int spill_time_sec = (int) mc6ictime;
       unsigned long int spill_time_nsec = (mc6ictime-spill_time_sec)*1e9;
       double diff = DAQtime+fOffset-mc6ictime;
 
       mcenterdata->spilltimesec = spill_time_sec;
       mcenterdata->spilltimensec = spill_time_nsec;
       mcenterdata->deltaspilltimensec = diff*1e9;
       mcenterdata->mc6int = mc6ic;
       mcenterdata->mc7int = mc7sc1;      
       
     }
     catch (WebAPIException we){
       std::string err(we.what());
       // If the varialbe can't be found, it means there was no spill within epsilon of DAQtime+fOffset
       // In this case, just enter zeros for all spill data.
       // If it's a different error, force and abort and print out error
       if (!err.find("variable not found")) {
         mf::LogError("TBSpillInfo") << "Exception encountered: " << we.what();
         std::abort();
         }
     } // end try/catch
 
     // Get other beam devices
     try{
 
       bfp->GetNamedData(DAQtime+fOffset,"F:MCENRG,F:MC6CV,F:MC7AN1", &mcnrg, &mc6cv, &mc7an1);
     
       mcenterdata->mcenrg = mcnrg;
       mcenterdata->mc6col = mc6cv;
       mcenterdata->mc7magnet = mc7an1;
 
     }
     catch (WebAPIException we){
       std::string err(we.what());
       // If the varialbe can't be found, it means there was no spill within epsilon of DAQtime+fOffset
       // or there is no reading for the scintillator counters at this time
       // In this case, just enter zeros for the counters
       // If it's a different error, force and abort and print out error
       if (!err.find("variable not found")) {
         mf::LogError("TBSpillInfo") << "Exception encountered: " << we.what();
         std::abort();
         }
     } // end try/catch
 
 
     // Get NOvA scintillator counters
     try{
 
       bfp->GetNamedData(DAQtime+fOffset,"Z:NOVTSC01,Z:NOVTSC07", &novtsc01, &novtsc07);
     
       mcenterdata->targetsc = novtsc01;
       mcenterdata->daqtrigger = novtsc07;
 
     }
     catch (WebAPIException we){
       std::string err(we.what());
       // If the varialbe can't be found, it means there was no spill within epsilon of DAQtime+fOffset
       // or there is no reading for the scintillator counters at this time
       // In this case, just enter zeros for the counters
       // If it's a different error, force and abort and print out error
       if (!err.find("variable not found")) {
         mf::LogError("TBSpillInfo") << "Exception encountered: " << we.what();
         std::abort();
         }
     } // end try/catch
 
 
     evt.put(std::move(mcenterdata));
     
   } //end event loop

void ifdb::TBSpillInfo::reconfigure ( const fhicl::ParameterSet & pset )

Definition at line 99 of file TBSpillInfo_module.cc.

References fOffset, and fhicl::ParameterSet::get().

   {
     fOffset = pset.get< double >("Offset");
   }

void art::Consumer::showMissingConsumes ( ) const

protectedinherited

Referenced by art::RootOutput::endJob().

void art::Consumer::validateConsumedProduct	(	BranchType const	bt,
		ProductInfo const &	pi
	)

protectedinherited

Member Data Documentation

std::unique_ptr<BeamFolder> ifdb::TBSpillInfo::bfp

private

Definition at line 65 of file TBSpillInfo_module.cc.

Referenced by produce(), and TBSpillInfo().

double ifdb::TBSpillInfo::fOffset

private

Definition at line 60 of file TBSpillInfo_module.cc.

Referenced by produce(), and reconfigure().

art::ServiceHandle<ifbeam_ns::IFBeam> ifdb::TBSpillInfo::ifbeam_handle

private

Definition at line 64 of file TBSpillInfo_module.cc.

bool ifdb::TBSpillInfo::isMC

private

Definition at line 66 of file TBSpillInfo_module.cc.

Referenced by produce().

std::string ifdb::TBSpillInfo::pRawBLTrigLabel

private

Definition at line 62 of file TBSpillInfo_module.cc.

Referenced by produce().

std::string ifdb::TBSpillInfo::pRawDataLabel

private

Definition at line 61 of file TBSpillInfo_module.cc.

Referenced by produce().

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

/cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N20-11-28/IFDBSpillInfo/TBSpillInfo_module.cc

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation