Inheritance diagram for nnet::WaveformDenoiseTest:

Public Types
using	ModuleType = EDAnalyzer

Public Member Functions
	WaveformDenoiseTest (fhicl::ParameterSet const &p)

	WaveformDenoiseTest (WaveformDenoiseTest const &)=delete

	WaveformDenoiseTest (WaveformDenoiseTest &&)=delete

WaveformDenoiseTest &	operator= (WaveformDenoiseTest const &)=delete

WaveformDenoiseTest &	operator= (WaveformDenoiseTest &&)=delete

void	analyze (art::Event const &e) override

void	beginJob () override

void	endJob () override

void	doBeginJob (SharedResources const &resources)

void	doEndJob ()

void	doRespondToOpenInputFile (FileBlock const &fb)

void	doRespondToCloseInputFile (FileBlock const &fb)

void	doRespondToOpenOutputFiles (FileBlock const &fb)

void	doRespondToCloseOutputFiles (FileBlock const &fb)

bool	doBeginRun (RunPrincipal &rp, ModuleContext const &mc)

bool	doEndRun (RunPrincipal &rp, ModuleContext const &mc)

bool	doBeginSubRun (SubRunPrincipal &srp, ModuleContext const &mc)

bool	doEndSubRun (SubRunPrincipal &srp, ModuleContext const &mc)

bool	doEvent (EventPrincipal &ep, ModuleContext const &mc, std::atomic< std::size_t > &counts_run, std::atomic< std::size_t > &counts_passed, std::atomic< std::size_t > &counts_failed)

ModuleDescription const &	moduleDescription () const

void	setModuleDescription (ModuleDescription const &)

std::array< std::vector< ProductInfo >, NumBranchTypes > const &	getConsumables () const

void	sortConsumables (std::string const &current_process_name)

std::unique_ptr< Worker >	makeWorker (WorkerParams const &wp)

template<typename T , BranchType BT>
ViewToken< T >	consumesView (InputTag const &tag)

template<typename T , BranchType BT>
ViewToken< T >	mayConsumeView (InputTag const &tag)

Protected Member Functions
std::string const &	processName () const

bool	wantAllEvents () const noexcept

bool	wantEvent (ScheduleID id, Event const &e) const

Handle< TriggerResults >	getTriggerResults (Event const &e) const

ConsumesCollector &	consumesCollector ()

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

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

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

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

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

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

Private Attributes
std::string	fDumpWaveformsFileName

std::string	fDumpCleanSignalFileName

std::string	fDumpDenoisedFileName

unsigned int	fDisplayWindowSize

std::string	fSimChannelLabel
	module that made simchannels More...

std::string	fDigitModuleLabel
	module that made digits More...

std::string	fCleanSignalDigitModuleLabel
	module that made the signal-only digits More...

std::string	fPlaneToDump

std::string	fCollectionPlaneLabel

art::ServiceHandle< geo::Geometry >	fgeom

std::vector< std::unique_ptr< wavrec_tool::IWaveformRecog > >	fWaveformRecogToolVec

std::vector< std::unique_ptr< wavdenoise_tool::IWaveformDenoise > >	fWaveformDenoiseToolVec

int	fNPlanes

std::ofstream	_fileout1

c2numpy_writer	npywriter

c2numpy_writer	npywriter2

c2numpy_writer	npywriter3

Detailed Description

Definition at line 47 of file WaveformDenoiseTest_module.cc.

Member Typedef Documentation

using art::EDAnalyzer::ModuleType = EDAnalyzer

inherited

Definition at line 22 of file EDAnalyzer.h.

Constructor & Destructor Documentation

nnet::WaveformDenoiseTest::WaveformDenoiseTest ( fhicl::ParameterSet const & p )

explicit

Definition at line 92 of file WaveformDenoiseTest_module.cc.

References fCleanSignalDigitModuleLabel, fCollectionPlaneLabel, fDigitModuleLabel, fDisplayWindowSize, fDumpCleanSignalFileName, fDumpDenoisedFileName, fDumpWaveformsFileName, fgeom, fNPlanes, fPlaneToDump, fSimChannelLabel, fWaveformDenoiseToolVec, fWaveformRecogToolVec, and geo::GeometryCore::Nplanes().

   : EDAnalyzer{p}
   , fDumpWaveformsFileName(p.get<std::string>("DumpWaveformsFileName", "dumpwaveforms"))
   , fDumpCleanSignalFileName(p.get<std::string>("CleanSignalFileName", "dumpcleansignal"))
   , fDumpDenoisedFileName(p.get<std::string>("DenoisedFileName", "dumpdenoised"))
   , fDisplayWindowSize(p.get<unsigned int>("DisplayWindowSize", 500))
   , fSimChannelLabel(p.get<std::string>("SimChannelLabel", "elecDrift"))
   , fDigitModuleLabel(p.get<std::string>("DigitModuleLabel", "simWire"))
   , fCleanSignalDigitModuleLabel(
       p.get<std::string>("CleanSignalDigitModuleLabel", "simWire:signal"))
   , fPlaneToDump(p.get<std::string>("PlaneToDump", "U"))
   , fCollectionPlaneLabel(p.get<std::string>("CollectionPlaneLabel", "Z"))
 {
 
   if (fDigitModuleLabel.empty() && fCleanSignalDigitModuleLabel.empty()) {
     throw cet::exception("WaveformDenoiseTest")
       << "Both DigitModuleLabel and CleanSignalModuleLabel are empty";
   }
 
   fNPlanes = fgeom->Nplanes();
 
   // Signal/Noise waveform recognition tool
   fWaveformRecogToolVec.reserve(fNPlanes);
   auto const tool_psets1 = p.get<std::vector<fhicl::ParameterSet>>("WaveformRecogs");
   for (auto const& pset : tool_psets1) {
     fWaveformRecogToolVec.push_back(art::make_tool<wavrec_tool::IWaveformRecog>(pset));
   }
 
   // AE based waveform denoising tool
   fWaveformDenoiseToolVec.reserve(fNPlanes);
   auto const tool_psets2 = p.get<std::vector<fhicl::ParameterSet>>("WaveformDenoisers");
   for (auto const& pset : tool_psets2) {
     fWaveformDenoiseToolVec.push_back(art::make_tool<wavdenoise_tool::IWaveformDenoise>(pset));
   }
 }

nnet::WaveformDenoiseTest::WaveformDenoiseTest ( WaveformDenoiseTest const & )

delete

nnet::WaveformDenoiseTest::WaveformDenoiseTest ( WaveformDenoiseTest && )

delete

Member Function Documentation

void nnet::WaveformDenoiseTest::analyze ( art::Event const & e )

overridevirtual

Implements art::EDAnalyzer.

Definition at line 171 of file WaveformDenoiseTest_module.cc.

References c2numpy_float32(), c2numpy_int16(), c2numpy_string(), c2numpy_uint16(), c2numpy_uint32(), raw::RawDigit::Channel(), DEFINE_ART_MODULE, CnnROI::end, art::EventID::event(), fCleanSignalDigitModuleLabel, fDigitModuleLabel, fDisplayWindowSize, fgeom, fPlaneToDump, fWaveformDenoiseToolVec, fWaveformRecogToolVec, art::ProductRetriever::getValidHandle(), art::Event::id(), raw::InvalidChannelID, npywriter, npywriter2, npywriter3, art::EventID::run(), raw::RawDigit::Samples(), CnnROI::start, art::EventID::subRun(), raw::Uncompress(), geo::GeometryCore::View(), geo::PlaneGeo::ViewName(), and x.

 {
   cout << "Event "
        << " " << evt.id().run() << " " << evt.id().subRun() << " " << evt.id().event() << endl;
 
   // ... Read in the digit List object(s).
   auto digitVecHandle = evt.getValidHandle<std::vector<raw::RawDigit>>(fDigitModuleLabel);
 
   // ... Read in the signal-only digit List object(s).
   auto digitVecHandle2 =
     evt.getValidHandle<std::vector<raw::RawDigit>>(fCleanSignalDigitModuleLabel);
 
   if (!digitVecHandle->size() || !digitVecHandle2->size()) {
     throw cet::exception("NoiseWaveformRoiAnalyzer")
       << "At least one of the raw digits lists is empty.";
   }
 
   auto const clockData = art::ServiceHandle<detinfo::DetectorClocksService const>()->DataFor(evt);
   auto const detProp =
     art::ServiceHandle<detinfo::DetectorPropertiesService const>()->DataFor(evt, clockData);
 
   // ... Use the handle to get a particular (0th) element of collection.
   std::vector<raw::RawDigit> const& rawDigits = *digitVecHandle;
   raw::RawDigit const& digitVec0 = rawDigits[0];
   unsigned int dataSize = digitVec0.Samples(); //size of raw data vectors
   if (dataSize != detProp.ReadOutWindowSize()) {
     throw cet::exception("NoiseWaveformRoiAnalyzer") << "Bad dataSize: " << dataSize;
   }
   std::vector<raw::RawDigit> const& rawDigits2 = *digitVecHandle2;
   raw::RawDigit const& digitVec20 = rawDigits2[0];
   unsigned int dataSize2 = digitVec20.Samples(); //size of raw data vectors
   if (dataSize != dataSize2) {
     throw cet::exception("NoiseWaveformRoiAnalyzer")
       << "RawDigits from the 2 data products have different dataSizes: " << dataSize << "not eq to"
       << dataSize2;
   }
 
   // ... Build a map from channel number -> rawdigitVec
   std::map<raw::ChannelID_t, art::Ptr<raw::RawDigit>> rawdigitMap;
   raw::ChannelID_t chnum = raw::InvalidChannelID; // channel number
   for (size_t rdIter = 0; rdIter < rawDigits.size(); ++rdIter) {
     art::Ptr<raw::RawDigit> digitVec(digitVecHandle, rdIter);
     chnum = digitVec->Channel();
     if (chnum == raw::InvalidChannelID) continue;
     if (geo::PlaneGeo::ViewName(fgeom->View(chnum)) != fPlaneToDump[0]) continue;
     rawdigitMap[chnum] = digitVec;
   }
   std::map<raw::ChannelID_t, art::Ptr<raw::RawDigit>> rawdigitMap2;
   raw::ChannelID_t chnum2 = raw::InvalidChannelID; // channel number
   for (size_t rdIter = 0; rdIter < rawDigits2.size(); ++rdIter) {
     art::Ptr<raw::RawDigit> digitVec2(digitVecHandle2, rdIter);
     chnum2 = digitVec2->Channel();
     if (chnum2 == raw::InvalidChannelID) continue;
     if (geo::PlaneGeo::ViewName(fgeom->View(chnum2)) != fPlaneToDump[0]) continue;
     rawdigitMap2[chnum2] = digitVec2;
   }
 
   // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
   // ... First find all channels that have non-zero raw digits and erase them
   //     from the raw digit maps
   // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
   std::vector<raw::ChannelID_t> signalchannels;
 
   for (std::map<raw::ChannelID_t, art::Ptr<raw::RawDigit>>::iterator iter = rawdigitMap2.begin();
        iter != rawdigitMap2.end();
        ++iter) {
     std::vector<short> rawadc(dataSize);  // vector to hold uncompressed adc values later
     std::vector<short> adcvec2(dataSize); // vector to pedestal-subtracted adc values
 
     auto rawdig2 = iter->second;
     raw::Uncompress(rawdig2->ADCs(), rawadc, rawdig2->GetPedestal(), rawdig2->Compression());
     for (size_t j = 0; j < rawadc.size(); ++j) {
       adcvec2[j] = rawadc[j] - rawdig2->GetPedestal();
     }
 
     auto itnz = find_if(adcvec2.begin(), adcvec2.end(), [](auto x) { return x != 0; });
     if (itnz != adcvec2.end()) signalchannels.push_back(iter->first);
   }
 
   for (size_t ich = 0; ich < signalchannels.size(); ++ich) {
 
     // .. get signal-containing channel number
     auto ch1 = signalchannels[ich];
     if (ch1 == raw::InvalidChannelID) continue;
     if (geo::PlaneGeo::ViewName(fgeom->View(ch1)) != fPlaneToDump[0]) continue;
 
     std::vector<short> rawadc(dataSize);  // vector to hold uncompressed adc values later
     std::vector<short> adcvec(dataSize);  // vector to hold zero-padded full waveform
     std::vector<short> adcvec2(dataSize); // vector to hold zero-padded full signal-only waveform
     std::vector<float> inputsignal(dataSize); // float version of adcvec
 
     auto search = rawdigitMap.find(ch1);
     if (search == rawdigitMap.end()) continue;
     auto rawdig = (*search).second;
     raw::Uncompress(rawdig->ADCs(), rawadc, rawdig->GetPedestal(), rawdig->Compression());
     for (size_t j = 0; j < rawadc.size(); ++j) {
       adcvec[j] = rawadc[j] - rawdig->GetPedestal();
       inputsignal[j] = adcvec[j];
     }
 
     auto search2 = rawdigitMap2.find(ch1);
     if (search2 == rawdigitMap2.end()) continue;
     auto rawdig2 = (*search2).second;
     raw::Uncompress(rawdig2->ADCs(), rawadc, rawdig2->GetPedestal(), rawdig2->Compression());
     for (size_t i = 0; i < rawadc.size(); ++i) {
       adcvec2[i] = rawadc[i] - rawdig2->GetPedestal();
     }
 
     // ... use waveform recognition CNN to perform inference on each window
     std::vector<bool> inroi(dataSize, false);
     inroi = fWaveformRecogToolVec[fgeom->View(ch1)]->findROI(inputsignal);
 
     auto itnf = find_if(inroi.begin(), inroi.end(), [](auto x) { return x; });
     if (itnf == inroi.end()) continue;
 
     CnnROI roi;
     std::vector<CnnROI> cnn_rois;
 
     bool is_roi = false;
     bool was_roi = false;
 
     for (size_t itck = 0; itck < inroi.size() - 1; ++itck) {
       is_roi = inroi[itck];
       if (is_roi && !was_roi) { roi.start = itck; }
       else if (!is_roi && was_roi) {
         roi.end = itck - 1;
         cnn_rois.push_back(roi);
       }
       was_roi = is_roi;
     }
 
     for (size_t i = 0; i < cnn_rois.size(); ++i) {
       std::vector<short> wavraw(fDisplayWindowSize, 0);
       std::vector<short> wavcln(fDisplayWindowSize, 0);
       std::vector<float> wavdns(fDisplayWindowSize, 0);
 
       unsigned int tcka = cnn_rois[i].start;
       unsigned int tckb = cnn_rois[i].end;
       unsigned int ntcks_roi = tckb - tcka + 1;
       unsigned int ntcks_dis = ntcks_roi;
       if (ntcks_dis > fDisplayWindowSize) {
         tckb = tcka + fDisplayWindowSize - 1;
         ntcks_dis = tckb - tcka + 1;
       }
 
       unsigned jtck = 0;
       for (unsigned int itck = tcka; itck < tckb; ++itck) {
         wavraw[jtck] = adcvec[itck];
         wavcln[jtck] = adcvec2[itck];
         jtck++;
       }
 
       std::vector<float> wavinp(ntcks_roi, 0);
       std::vector<float> wavout(ntcks_roi, 0);
 
       jtck = 0;
       for (unsigned int itck = tcka; itck < tcka + ntcks_roi; ++itck) {
         wavinp[jtck] = float(adcvec[itck]);
         jtck++;
       }
       wavout = fWaveformDenoiseToolVec[fgeom->View(ch1)]->denoiseWaveform(wavinp);
 
       for (unsigned int itck = 0; itck < ntcks_dis; ++itck) {
         wavdns[itck] = wavout[itck];
       }
 
       c2numpy_uint32(&npywriter, evt.id().event());
       c2numpy_uint32(&npywriter, ch1);
       c2numpy_uint16(&npywriter, i); // roi
       c2numpy_string(&npywriter, geo::PlaneGeo::ViewName(fgeom->View(ch1)).c_str());
 
       for (unsigned int j = 0; j < fDisplayWindowSize; ++j) {
         c2numpy_int16(&npywriter, wavraw[j]);
       }
       for (unsigned int j = 0; j < fDisplayWindowSize; ++j) {
         c2numpy_int16(&npywriter2, wavcln[j]);
       }
       for (unsigned int j = 0; j < fDisplayWindowSize; ++j) {
         c2numpy_float32(&npywriter3, wavdns[j]);
       }
     }
   }
 }

void nnet::WaveformDenoiseTest::beginJob ( )

overridevirtual

Reimplemented from art::EDAnalyzer.

Definition at line 129 of file WaveformDenoiseTest_module.cc.

References c2numpy_addcolumn(), C2NUMPY_FLOAT32, c2numpy_init(), C2NUMPY_INT16, C2NUMPY_STRING, C2NUMPY_UINT16, C2NUMPY_UINT32, fDisplayWindowSize, fDumpCleanSignalFileName, fDumpDenoisedFileName, fDumpWaveformsFileName, npywriter, npywriter2, and npywriter3.

 {
 
   c2numpy_init(&npywriter, fDumpWaveformsFileName, 50000);
   c2numpy_addcolumn(&npywriter, "evt", C2NUMPY_UINT32);
   c2numpy_addcolumn(&npywriter, "chan", C2NUMPY_UINT32);
   c2numpy_addcolumn(&npywriter, "roi", C2NUMPY_UINT16);
   c2numpy_addcolumn(&npywriter, "view", (c2numpy_type)((int)C2NUMPY_STRING + 1));
   for (unsigned int i = 0; i < fDisplayWindowSize; i++) {
     std::ostringstream name;
     name << "tck_" << i;
     c2numpy_addcolumn(&npywriter, name.str().c_str(), C2NUMPY_INT16);
   }
 
   // ... this is for storing the clean signal (no noise) waveform
   c2numpy_init(&npywriter2, fDumpCleanSignalFileName, 50000);
 
   for (unsigned int i = 0; i < fDisplayWindowSize; i++) {
     std::ostringstream name;
     name << "tck_" << i;
     c2numpy_addcolumn(&npywriter2, name.str().c_str(), C2NUMPY_INT16);
   }
 
   // ... this is for storing the denoised raw waveform
   c2numpy_init(&npywriter3, fDumpDenoisedFileName, 50000);
 
   for (unsigned int i = 0; i < fDisplayWindowSize; i++) {
     std::ostringstream name;
     name << "tck_" << i;
     c2numpy_addcolumn(&npywriter3, name.str().c_str(), C2NUMPY_FLOAT32);
   }
 }

template<typename T , BranchType BT>

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

protectedinherited

Definition at line 61 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::consumes().

   {
     return collector_.consumes<T, BT>(tag);
   }

ConsumesCollector & art::ModuleBase::consumesCollector ( )

protectedinherited

Definition at line 57 of file ModuleBase.cc.

References art::ModuleBase::collector_.

   {
     return collector_;
   }

template<typename T , BranchType BT>

void art::ModuleBase::consumesMany ( )

protectedinherited

Definition at line 75 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::consumesMany().

   {
     collector_.consumesMany<T, BT>();
   }

template<typename Element , BranchType = InEvent>

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

protectedinherited

template<typename T , BranchType BT>

ViewToken<T> art::ModuleBase::consumesView ( InputTag const & tag )

inherited

Definition at line 68 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::consumesView().

   {
     return collector_.consumesView<T, BT>(tag);
   }

void art::detail::Analyzer::doBeginJob ( SharedResources const & resources )

inherited

Definition at line 25 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     setupQueues(resources);
     ProcessingFrame const frame{ScheduleID{}};
     beginJobWithFrame(frame);
   }

bool art::detail::Analyzer::doBeginRun	(	RunPrincipal &	rp,
		ModuleContext const &	mc
	)

inherited

Definition at line 68 of file Analyzer.cc.

References art::ModuleContext::scheduleID().

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{mc.scheduleID()};
     beginRunWithFrame(std::as_const(rp).makeRun(mc), frame);
     return true;
   }

bool art::detail::Analyzer::doBeginSubRun	(	SubRunPrincipal &	srp,
		ModuleContext const &	mc
	)

inherited

Definition at line 84 of file Analyzer.cc.

References art::ModuleContext::scheduleID().

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{mc.scheduleID()};
     beginSubRunWithFrame(std::as_const(srp).makeSubRun(mc), frame);
     return true;
   }

void art::detail::Analyzer::doEndJob ( )

inherited

Definition at line 33 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{ScheduleID{}};
     endJobWithFrame(frame);
   }

bool art::detail::Analyzer::doEndRun	(	RunPrincipal &	rp,
		ModuleContext const &	mc
	)

inherited

Definition at line 76 of file Analyzer.cc.

References art::ModuleContext::scheduleID().

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{mc.scheduleID()};
     endRunWithFrame(std::as_const(rp).makeRun(mc), frame);
     return true;
   }

bool art::detail::Analyzer::doEndSubRun	(	SubRunPrincipal &	srp,
		ModuleContext const &	mc
	)

inherited

Definition at line 92 of file Analyzer.cc.

References art::ModuleContext::scheduleID().

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{mc.scheduleID()};
     endSubRunWithFrame(std::as_const(srp).makeSubRun(mc), frame);
     return true;
   }

bool art::detail::Analyzer::doEvent	(	EventPrincipal &	ep,
		ModuleContext const &	mc,
		std::atomic< std::size_t > &	counts_run,
		std::atomic< std::size_t > &	counts_passed,
		std::atomic< std::size_t > &	counts_failed
	)

inherited

Definition at line 100 of file Analyzer.cc.

References e, and art::ModuleContext::scheduleID().

Referenced by art::detail::Analyzer::Analyzer().

   {
     auto const e = std::as_const(ep).makeEvent(mc);
     if (wantEvent(mc.scheduleID(), e)) {
       ++counts_run;
       ProcessingFrame const frame{mc.scheduleID()};
       analyzeWithFrame(e, frame);
       ++counts_passed;
     }
     return true;
   }

void art::detail::Analyzer::doRespondToCloseInputFile ( FileBlock const & fb )

inherited

Definition at line 47 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{ScheduleID{}};
     respondToCloseInputFileWithFrame(fb, frame);
   }

void art::detail::Analyzer::doRespondToCloseOutputFiles ( FileBlock const & fb )

inherited

Definition at line 61 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{ScheduleID{}};
     respondToCloseOutputFilesWithFrame(fb, frame);
   }

void art::detail::Analyzer::doRespondToOpenInputFile ( FileBlock const & fb )

inherited

Definition at line 40 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{ScheduleID{}};
     respondToOpenInputFileWithFrame(fb, frame);
   }

void art::detail::Analyzer::doRespondToOpenOutputFiles ( FileBlock const & fb )

inherited

Definition at line 54 of file Analyzer.cc.

Referenced by art::detail::Analyzer::Analyzer().

   {
     ProcessingFrame const frame{ScheduleID{}};
     respondToOpenOutputFilesWithFrame(fb, frame);
   }

void nnet::WaveformDenoiseTest::endJob ( )

overridevirtual

Reimplemented from art::EDAnalyzer.

Definition at line 163 of file WaveformDenoiseTest_module.cc.

References c2numpy_close(), npywriter, npywriter2, and npywriter3.

 {
   c2numpy_close(&npywriter);
   c2numpy_close(&npywriter2);
   c2numpy_close(&npywriter3);
 }

std::array< std::vector< ProductInfo >, NumBranchTypes > const & art::ModuleBase::getConsumables ( ) const

inherited

Definition at line 43 of file ModuleBase.cc.

References art::ModuleBase::collector_, and art::ConsumesCollector::getConsumables().

   {
     return collector_.getConsumables();
   }

Handle< TriggerResults > art::Observer::getTriggerResults ( Event const & e ) const

protectedinherited

Definition at line 75 of file Observer.cc.

References art::ProductRetriever::get(), and art::Observer::selectors_.

Referenced by art::OutputModule::doWriteEvent(), and art::Observer::wantAllEvents().

   {
     if (selectors_) {
       return selectors_->getOneTriggerResults(e);
     }
 
     // The following applies for cases where no SelectEvents entries
     // exist.
     Handle<TriggerResults> h;
     if (e.get(empty_process_name, h)) {
       return h;
     }
     return Handle<TriggerResults>{};
   }

std::unique_ptr< Worker > art::ModuleBase::makeWorker ( WorkerParams const & wp )

inherited

Definition at line 37 of file ModuleBase.cc.

References art::ModuleBase::doMakeWorker(), and art::NumBranchTypes.

   {
     return doMakeWorker(wp);
   }

template<typename T , BranchType BT>

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

protectedinherited

Definition at line 82 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::mayConsume().

   {
     return collector_.mayConsume<T, BT>(tag);
   }

template<typename T , BranchType BT>

void art::ModuleBase::mayConsumeMany ( )

protectedinherited

Definition at line 96 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::mayConsumeMany().

   {
     collector_.mayConsumeMany<T, BT>();
   }

template<typename Element , BranchType = InEvent>

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

protectedinherited

template<typename T , BranchType BT>

ViewToken<T> art::ModuleBase::mayConsumeView ( InputTag const & tag )

inherited

Definition at line 89 of file ModuleBase.h.

References art::ModuleBase::collector_, and art::ConsumesCollector::mayConsumeView().

   {
     return collector_.mayConsumeView<T, BT>(tag);
   }

ModuleDescription const & art::ModuleBase::moduleDescription ( ) const

inherited

Definition at line 13 of file ModuleBase.cc.

References art::errors::LogicError.

Referenced by art::OutputModule::doRespondToOpenInputFile(), art::OutputModule::doWriteEvent(), art::Modifier::fillProductDescriptions(), art::OutputModule::makePlugins_(), art::OutputWorker::OutputWorker(), reco::shower::LArPandoraModularShowerCreation::produce(), art::Modifier::registerProducts(), and art::OutputModule::registerProducts().

   {
     if (md_.has_value()) {
       return *md_;
     }
 
     throw Exception{errors::LogicError,
                     "There was an error while calling moduleDescription().\n"}
       << "The moduleDescription() base-class member function cannot be called\n"
          "during module construction.  To determine which module is "
          "responsible\n"
          "for calling it, find the '<module type>:<module "
          "label>@Construction'\n"
          "tag in the message prefix above.  Please contact artists@fnal.gov\n"
          "for guidance.\n";
   }

WaveformDenoiseTest& nnet::WaveformDenoiseTest::operator= ( WaveformDenoiseTest const & )

delete

WaveformDenoiseTest& nnet::WaveformDenoiseTest::operator= ( WaveformDenoiseTest && )

delete

string const & art::Observer::processName ( ) const

protectedinherited

Definition at line 57 of file Observer.cc.

References art::Observer::process_name_.

Referenced by art::FileDumperOutput::printPrincipal().

   {
     return process_name_;
   }

void art::ModuleBase::setModuleDescription ( ModuleDescription const & md )

inherited

Definition at line 31 of file ModuleBase.cc.

References art::ModuleBase::md_.

   {
     md_ = md;
   }

void art::ModuleBase::sortConsumables ( std::string const & current_process_name )

inherited

Definition at line 49 of file ModuleBase.cc.

References art::ModuleBase::collector_, and art::ConsumesCollector::sortConsumables().

   {
     // Now that we know we have seen all the consumes declarations,
     // sort the results for fast lookup later.
     collector_.sortConsumables(current_process_name);
   }

bool art::Observer::wantAllEvents ( ) const

inlineprotectednoexceptinherited

Definition at line 31 of file Observer.h.

References e, art::Observer::getTriggerResults(), art::Observer::wantAllEvents_, and art::Observer::wantEvent().

     {
       return wantAllEvents_;
     }

bool art::Observer::wantEvent	(	ScheduleID	id,
		Event const &	e
	)		const

protectedinherited

Definition at line 63 of file Observer.cc.

References art::Observer::rejectors_, art::Observer::selectors_, and art::Observer::wantAllEvents_.

Referenced by art::OutputModule::doEvent(), art::OutputModule::doWriteEvent(), and art::Observer::wantAllEvents().

   {
     if (wantAllEvents_) {
       return true;
     }
     bool const select_event = selectors_ ? selectors_->matchEvent(id, e) : true;
     bool const reject_event =
       rejectors_ ? rejectors_->matchEvent(id, e) : false;
     return select_event and not reject_event;
   }