Inheritance diagram for DAQToOffline::TpcDAQToOffline:

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

	TpcDAQToOffline (TpcDAQToOffline const &)=delete

	TpcDAQToOffline (TpcDAQToOffline &&)=delete

TpcDAQToOffline &	operator= (TpcDAQToOffline const &)=delete

TpcDAQToOffline &	operator= (TpcDAQToOffline &&)=delete

void	produce (art::Event &evt) override

void	reconfigure (const fhicl::ParameterSet &pset)

void	printParameterSet ()

void	beginJob () override

Public Member Functions inherited from art::EDProducer
	EDProducer (fhicl::ParameterSet const &pset)

template<typename Config >
	EDProducer (Table< Config > const &config)

std::string	workerType () const

Public Member Functions inherited from art::detail::Producer
virtual	~Producer () noexcept

	Producer (fhicl::ParameterSet const &)

	Producer (Producer const &)=delete

	Producer (Producer &&)=delete

Producer &	operator= (Producer const &)=delete

Producer &	operator= (Producer &&)=delete

void	doBeginJob ()

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)

Public Member Functions inherited from art::Modifier
	~Modifier () noexcept

	Modifier ()

	Modifier (Modifier const &)=delete

	Modifier (Modifier &&)=delete

Modifier &	operator= (Modifier const &)=delete

Modifier &	operator= (Modifier &&)=delete

Public Member Functions inherited from art::ModuleBase
virtual	~ModuleBase () noexcept

	ModuleBase ()

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)

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

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

Private Member Functions
void	Reset ()

Private Attributes
std::string	fFragType

std::string	fRawDataLabel

std::string	fOutputDataLabel

bool	fUseChannelMap

bool	fDebug

bool	fMakeTree

raw::Compress_t	fCompression
	compression type to use More...

unsigned int	fZeroThreshold
	Zero suppression threshold. More...

art::ServiceHandle< lbne::ChannelMapService >	fChannelMap

TTree *	fTree

int	DigSize

int	NSamples

float	Channel [MaxChannels]

float	ADCs [MaxChannels][MaxSamples]

float	Pedestal [MaxChannels]

Additional Inherited Members
Public Types inherited from art::EDProducer
using	ModuleType = EDProducer

using	WorkerType = WorkerT< EDProducer >

Public Types inherited from art::detail::Producer
template<typename UserConfig , typename KeysToIgnore = void>
using	Table = Modifier::Table< UserConfig, KeysToIgnore >

Public Types inherited from art::Modifier
template<typename UserConfig , typename UserKeysToIgnore = void>
using	Table = ProducerTable< UserConfig, detail::ModuleConfig, UserKeysToIgnore >

Static Public Member Functions inherited from art::EDProducer
static void	commitEvent (EventPrincipal &ep, Event &e)

Protected Member Functions inherited from art::ModuleBase
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 ()

Detailed Description

Definition at line 52 of file TpcDAQToOffline_module.cc.

Constructor & Destructor Documentation

DAQToOffline::TpcDAQToOffline::TpcDAQToOffline ( fhicl::ParameterSet const & pset )

explicit

Definition at line 90 of file TpcDAQToOffline_module.cc.

                                                                            : EDProducer{pset} {
 
   this->reconfigure(pset);
 
   produces< std::vector<raw::RawDigit> > (fOutputDataLabel);  
 
 }

DAQToOffline::TpcDAQToOffline::TpcDAQToOffline ( TpcDAQToOffline const & )

delete

DAQToOffline::TpcDAQToOffline::TpcDAQToOffline ( TpcDAQToOffline && )

delete

Member Function Documentation

void DAQToOffline::TpcDAQToOffline::beginJob ( )

overridevirtual

Reimplemented from art::EDProducer.

Definition at line 112 of file TpcDAQToOffline_module.cc.

                                            {
   art::ServiceHandle<art::TFileService> tfs;
   fTree = tfs->make<TTree>("FlatDigitTree","FlatDigitTree");
   fTree->Branch("NSamples",&NSamples,"NSamples/I"      );
   fTree->Branch("DigSize" ,&DigSize, "DigSize/I"      );
   fTree->Branch("Channel" ,&Channel ,"Channel[DigSize]/F" );
   fTree->Branch("Pedestal",&Pedestal,"Pedestal[DigSize]/F");
   fTree->Branch("ADCs"    ,&ADCs    ,"ADCs[DigSize][15000]/F");
 }

TpcDAQToOffline& DAQToOffline::TpcDAQToOffline::operator= ( TpcDAQToOffline const & )

delete

TpcDAQToOffline& DAQToOffline::TpcDAQToOffline::operator= ( TpcDAQToOffline && )

delete

void DAQToOffline::TpcDAQToOffline::printParameterSet ( )

Definition at line 122 of file TpcDAQToOffline_module.cc.

                                                    {
 
   for(int i=0;i<20;i++) std::cout << "=";
   std::cout << std::endl;
   std::cout << "Parameter Set" << std::endl;
   for(int i=0;i<20;i++) std::cout << "=";
   std::cout << std::endl;
 
   std::cout << "fFragType: " << fFragType << std::endl;
   std::cout << "fRawDataLabel: " << fRawDataLabel << std::endl;
   std::cout << "fOutputDataLabel: " << fOutputDataLabel << std::endl;
   std::cout << "fDebug: ";
   if(fDebug) std::cout << "true" << std::endl;
   else std::cout << "false" << std::endl;
 
   for(int i=0;i<20;i++) std::cout << "=";
   std::cout << std::endl;    
 
 
 }

void DAQToOffline::TpcDAQToOffline::produce ( art::Event & evt )

overridevirtual

Implements art::EDProducer.

Definition at line 143 of file TpcDAQToOffline_module.cc.

 {
   art::Handle<artdaq::Fragments> rawFragments;
   evt.getByLabel(fRawDataLabel, fFragType, rawFragments);
 
   art::EventNumber_t eventNumber = evt.event();
 
   // Check if there is RCE data in this event
   // Don't crash code if not present, just don't save anything
   try { rawFragments->size(); }
   catch(std::exception const&) {
     std::cout << "WARNING: Raw RCE data not found in event " << eventNumber << std::endl;
     std::vector<raw::RawDigit> digits;
     evt.put(std::make_unique<std::vector<raw::RawDigit>>(std::move(digits)), fOutputDataLabel);
     return;
   }
 
   //Check that the data is valid
   if(!rawFragments.isValid()){
     std::cerr << "Run: " << evt.run()
               << ", SubRun: " << evt.subRun()
               << ", Event: " << eventNumber
               << " is NOT VALID" << std::endl;
     throw cet::exception("rawFragments NOT VALID");
   }
 
   lbne::TpcNanoSlice::Header::nova_timestamp_t firstTimestamp;
   std::vector<std::pair< std::pair<unsigned int,unsigned int>, lbne::TpcNanoSlice::Header::nova_timestamp_t> > DigitsIndexList;
   auto digits = tpcFragmentToRawDigits(*rawFragments, DigitsIndexList, firstTimestamp, fChannelMap, fUseChannelMap, fDebug, fCompression, fZeroThreshold);
 
   // Make a flat rce tree.....
   Reset();
   DigSize = digits.size();
   NSamples = digits[0].Samples();
   if (NSamples && fMakeTree) {
     std::cout << "Digits has size " << digits.size() << " digits[0] has " << digits[0].Samples() << std::endl;
     dune::DetPedestalDUNE pedestals("dune35t");
     pedestals.SetDetName("dune35t");
     pedestals.SetUseDefaults(false);
     pedestals.SetUseDB(true);
     pedestals.Update(evt.run());
     
     for (int dig=0; dig<DigSize; ++dig ) {
       int Chan = digits[dig].Channel();
       Channel[dig]  = Chan;
       Pedestal[dig] = pedestals.PedMean(Chan);
       for (int tick=0; tick<NSamples; ++tick) {
         ADCs[dig][tick] = digits[dig].ADC(tick);
       }
     }
     fTree->Fill();
   }
 
   art::Timestamp this_time_stamp = DAQToOffline::make_art_timestamp_from_nova_timestamp(firstTimestamp);
   std::cout << "JPD: this_time_stamp: " << this_time_stamp.value() << std::endl;
   std::cout << "JPD: event.time().value(): " << evt.time().value() << std::endl;
 
   evt.put(std::make_unique<decltype(digits)>(std::move(digits)), fOutputDataLabel);
 }

void DAQToOffline::TpcDAQToOffline::reconfigure ( const fhicl::ParameterSet & pset )

Definition at line 98 of file TpcDAQToOffline_module.cc.

                                                                            {
 
   fFragType = pset.get<std::string>("FragType");
   fRawDataLabel = pset.get<std::string>("RawDataLabel");
   fOutputDataLabel = pset.get<std::string>("OutputDataLabel");
   fUseChannelMap = pset.get<bool>("UseChannelMap");
   fDebug = pset.get<bool>("Debug");
   fMakeTree = pset.get<bool>("MakeTree");
   fZeroThreshold=0;
   fCompression=raw::kNone;
   if(fDebug) printParameterSet();
 
 }

void DAQToOffline::TpcDAQToOffline::Reset ( )

private

Definition at line 203 of file TpcDAQToOffline_module.cc.

                                         {
   for (int ii=0; ii<MaxChannels; ++ii) {
     Channel[ii]  = -1;
     Pedestal[ii] = -1;
     for (int kk=0; kk<MaxSamples; ++kk) {
       ADCs[ii][kk] = -1;
     }
   }
 }

Member Data Documentation

float DAQToOffline::TpcDAQToOffline::ADCs[MaxChannels][MaxSamples]

private

Definition at line 85 of file TpcDAQToOffline_module.cc.

float DAQToOffline::TpcDAQToOffline::Channel[MaxChannels]

private

Definition at line 84 of file TpcDAQToOffline_module.cc.

int DAQToOffline::TpcDAQToOffline::DigSize

private

Definition at line 82 of file TpcDAQToOffline_module.cc.

art::ServiceHandle<lbne::ChannelMapService> DAQToOffline::TpcDAQToOffline::fChannelMap

private

Definition at line 79 of file TpcDAQToOffline_module.cc.

raw::Compress_t DAQToOffline::TpcDAQToOffline::fCompression

private

compression type to use

Definition at line 76 of file TpcDAQToOffline_module.cc.

bool DAQToOffline::TpcDAQToOffline::fDebug

private

Definition at line 74 of file TpcDAQToOffline_module.cc.

std::string DAQToOffline::TpcDAQToOffline::fFragType

private

Definition at line 70 of file TpcDAQToOffline_module.cc.

bool DAQToOffline::TpcDAQToOffline::fMakeTree

private

Definition at line 75 of file TpcDAQToOffline_module.cc.

std::string DAQToOffline::TpcDAQToOffline::fOutputDataLabel

private

Definition at line 72 of file TpcDAQToOffline_module.cc.

std::string DAQToOffline::TpcDAQToOffline::fRawDataLabel

private

Definition at line 71 of file TpcDAQToOffline_module.cc.

TTree* DAQToOffline::TpcDAQToOffline::fTree

private

Definition at line 81 of file TpcDAQToOffline_module.cc.

bool DAQToOffline::TpcDAQToOffline::fUseChannelMap

private

Definition at line 73 of file TpcDAQToOffline_module.cc.

unsigned int DAQToOffline::TpcDAQToOffline::fZeroThreshold

private

Zero suppression threshold.

Definition at line 77 of file TpcDAQToOffline_module.cc.

int DAQToOffline::TpcDAQToOffline::NSamples

private

Definition at line 83 of file TpcDAQToOffline_module.cc.

float DAQToOffline::TpcDAQToOffline::Pedestal[MaxChannels]

private

Definition at line 86 of file TpcDAQToOffline_module.cc.

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

dunetpc/dune/daqinput35t/TpcDAQToOffline_module.cc

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation