Inheritance diagram for lbne::SSPDump:

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

virtual	~SSPDump ()

virtual void	analyze (art::Event const &evt) override

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

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

std::string	workerType () const

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

	Analyzer (fhicl::ParameterSet const &pset)

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

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::Observer
	~Observer () noexcept

	Observer (Observer const &)=delete

	Observer (Observer &&)=delete

Observer &	operator= (Observer const &)=delete

Observer &	operator= (Observer &&)=delete

void	registerProducts (ProductDescriptions &, ModuleDescription const &)

void	fillDescriptions (ModuleDescription const &)

std::string const &	processName () const

bool	wantAllEvents () const

bool	wantEvent (Event const &e)

fhicl::ParameterSetID	selectorConfig () const

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

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	beginJob () override

void	endJob () override

void	beginEvent (art::EventNumber_t eventNumber)

void	endEvent (art::EventNumber_t eventNumber)

Private Attributes
std::string	raw_data_label_

std::string	frag_type_

uint32_t	verb_adcs_

bool	verb_meta_

TH1D *	adc_values_

uint32_t	n_adc_counter_

uint64_t	adc_cumulative_

Additional Inherited Members
Public Types inherited from art::EDAnalyzer
using	WorkerType = WorkerT< EDAnalyzer >

using	ModuleType = EDAnalyzer

Protected Member Functions inherited from art::Observer
	Observer (fhicl::ParameterSet const &config)

	Observer (std::vector< std::string > const &paths, fhicl::ParameterSet const &config)

detail::ProcessAndEventSelectors &	processAndEventSelectors ()

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 34 of file SSPDump_module.cc.

Constructor & Destructor Documentation

lbne::SSPDump::SSPDump ( fhicl::ParameterSet const & pset )

explicit

Definition at line 63 of file SSPDump_module.cc.

     : EDAnalyzer(pset),
       raw_data_label_(pset.get<std::string>("raw_data_label")),
       frag_type_(pset.get<std::string>("frag_type")),
       //verb_microslice_ids_(pset.get<std::vector<int>>("verbose_microslice_ids", std::vector<int>(1,0))),
       //verb_nanoslice_ids_ (pset.get<std::vector<int>>("verbose_nanoslice_ids",  std::vector<int>(1,0))),
       verb_adcs_(pset.get<uint32_t>        ("verbose_adcs", 10000)),
       verb_meta_(pset.get<bool>            ("verbose_metadata", true)),
       adc_values_(nullptr),
       n_adc_counter_(0),
       adc_cumulative_(0)
 {
 }

lbne::SSPDump::~SSPDump ( )

virtual

Definition at line 104 of file SSPDump_module.cc.

105 {

106 }

Member Function Documentation

void lbne::SSPDump::analyze ( art::Event const & evt )

overridevirtual

Implements art::EDAnalyzer.

Definition at line 108 of file SSPDump_module.cc.

 {
   art::EventNumber_t eventNumber = evt.event();
   beginEvent(eventNumber);
   
   //  TFile f("hists.root","RECREATE");
   // ***********************
   // *** SSP Fragments ***
   // ***********************
   
   // look for raw SSP data
   
   art::Handle<artdaq::Fragments> raw;
   evt.getByLabel(raw_data_label_, frag_type_, raw);
   
   if (raw.isValid()) {
     std::cout << "######################################################################" << std::endl;
     std::cout << std::endl;
     std::cout << "Run " << evt.run() << ", subrun " << evt.subRun()
               << ", event " << eventNumber << " has " << raw->size()
               << " fragment(s) of type " << frag_type_ << std::endl;
     
     for (size_t idx = 0; idx < raw->size(); ++idx) {
       const auto& frag((*raw)[idx]);
       
       SSPFragment sspf(frag);
       
       std::cout << std::endl;
       std::cout << "SSP fragment "     << frag.fragmentID() 
                 << " has total size: " << sspf.hdr_event_size()
                 << " and run number: " << sspf.hdr_run_number()
                 << " with " << sspf.total_adc_values() << " total ADC values"
                 << std::endl;
       std::cout << std::endl;
       
       const SSPDAQ::MillisliceHeader* meta=0;
       //get the information from the header
       if(frag.hasMetadata())
         {
           meta = &(frag.metadata<SSPFragment::Metadata>()->sliceHeader);
           
           std::cout
             <<"===Slice metadata:"<<std::endl
             <<"Start time         "<<meta->startTime<<std::endl
             <<"End time           "<<meta->endTime<<std::endl
             <<"Packet length      "<<meta->length<<std::endl
             <<"Number of triggers "<<meta->nTriggers<<std::endl<<std::endl;
         }
       else
         {
           std::cout << "SSP fragment has no metadata associated with it." << std::endl;
         }
       
       const unsigned int* dataPointer = sspf.dataBegin();
       
       unsigned int triggersProcessed=0;
       while((meta==0||triggersProcessed<meta->nTriggers)&&dataPointer<sspf.dataEnd()){
         const SSPDAQ::EventHeader* daqHeader=reinterpret_cast<const SSPDAQ::EventHeader*>(dataPointer);
         
         uint32_t peaksum = ((daqHeader->group3 & 0x00FF) >> 16) + daqHeader->peakSumLow;
         if(peaksum & 0x00800000) {
           peaksum |= 0xFF000000;
         }
         if(verb_meta_) {
           std::cout
             << "Header:                             " << daqHeader->header   << std::endl
             << "Length:                             " << daqHeader->length   << std::endl
             << "Trigger type:                       " << ((daqHeader->group1 & 0xFF00) >> 8) << std::endl
             << "Status flags:                       " << ((daqHeader->group1 & 0x00F0) >> 4) << std::endl
             << "Header type:                        " << ((daqHeader->group1 & 0x000F) >> 0) << std::endl
             << "Trigger ID:                         " << daqHeader->triggerID << std::endl
             << "Module ID:                          " << ((daqHeader->group2 & 0xFFF0) >> 4) << std::endl
             << "Channel ID:                         " << ((daqHeader->group2 & 0x000F) >> 0) << std::endl
             << "External timestamp (FP mode):       " << std::endl
             << "  Sync delay:                       " << ((unsigned int)(daqHeader->timestamp[1]) << 16) + (unsigned int)(daqHeader->timestamp[0]) << std::endl
             << "  Sync count:                       " << ((unsigned int)(daqHeader->timestamp[3]) << 16) + (unsigned int)(daqHeader->timestamp[2]) << std::endl
             << "External timestamp (NOvA mode):     " << (unsigned long)daqHeader->timestamp[3] << 48 + (unsigned long)daqHeader->timestamp[2] << 32
                                                        + (unsigned long)daqHeader->timestamp[1] << 16 + (unsigned long)daqHeader->timestamp[0] <<std::endl
             << "Peak sum:                           " << peaksum << std::endl
             << "Peak time:                          " << ((daqHeader->group3 & 0xFF00) >> 8) << std::endl
             << "Prerise:                            " << ((daqHeader->group4 & 0x00FF) << 16) + daqHeader->preriseLow << std::endl
             << "Integrated sum:                     " << ((unsigned int)(daqHeader->intSumHigh) << 8) + (((unsigned int)(daqHeader->group4) & 0xFF00) >> 8) << std::endl
             << "Baseline:                           " << daqHeader->baseline << std::endl
             << "CFD Timestamp interpolation points: " << daqHeader->cfdPoint[0] << " " << daqHeader->cfdPoint[1] << " " << daqHeader->cfdPoint[2] << " " << daqHeader->cfdPoint[3] << std::endl
             << "Internal interpolation point:       " << daqHeader->intTimestamp[0] << std::endl
             << "Internal timestamp:                 " << ((uint64_t)((uint64_t)daqHeader->intTimestamp[3] << 32)) + ((uint64_t)((uint64_t)daqHeader->intTimestamp[2]) << 16) + ((uint64_t)((uint64_t)daqHeader->intTimestamp[1])) << std::endl
             << std::endl;
         }
         dataPointer+=sizeof(SSPDAQ::EventHeader)/sizeof(unsigned int);
         
         
         //get the information from the data
         bool verb_values = true;
         unsigned int nADC=(daqHeader->length-sizeof(SSPDAQ::EventHeader)/sizeof(unsigned int))*2;
         const unsigned short* adcPointer=reinterpret_cast<const unsigned short*>(dataPointer);
         char histName[100];
         sprintf(histName,"event%d",triggersProcessed);
         //TH1F* hist=new TH1F(histName,histName,nADC,0,nADC*1./150.);
         //      hist->SetDirectory(&f);
         for(size_t idata = 0; idata < nADC; idata++) {
           if(idata >= verb_adcs_)
             verb_values = false;
           else if(idata == 0&&verb_adcs_>0)
             std::cout << "Data values: ";
           
           const unsigned short* adc = adcPointer + idata;
           adc_values_->Fill(*adc);
           n_adc_counter_++;
           adc_cumulative_ += (uint64_t)(*adc);
           //      hist->SetBinContent(idata+1,*adc);
 
           if(verb_values)
             std::cout << *adc << " ";
         }
         dataPointer+=nADC/2;
         ++triggersProcessed;
         std::cout<<std::endl<<"Triggers processed: "<<triggersProcessed<<std::endl<<std::endl;
       }
     }   
     std::cout << std::endl
               << "Event ADC average is (from counter):   " << (double)adc_cumulative_/(double)n_adc_counter_
               << std::endl
               << "Event ADC average is (from histogram): " << adc_values_->GetMean()
               << std::endl;
   }//raw.IsValid()?
   else {
     std::cout << "Run " << evt.run() << ", subrun " << evt.subRun()
               << ", event " << eventNumber << " has zero"
               << " SSP fragments." << std::endl;
   }
   std::cout << std::endl;
   //  f.Write();
   beginEvent(eventNumber);
 }

void lbne::SSPDump::beginEvent ( art::EventNumber_t eventNumber )

private

Definition at line 83 of file SSPDump_module.cc.

 {
   //reset ADC histogram
   adc_values_->Reset();
   //reset counters
   n_adc_counter_  = 0;
   adc_cumulative_ = 0;
 }

void lbne::SSPDump::beginJob ( )

overrideprivatevirtual

Reimplemented from art::EDAnalyzer.

Definition at line 77 of file SSPDump_module.cc.

 {
   art::ServiceHandle<art::TFileService> tfs;
   adc_values_ = tfs->make<TH1D>("adc_values","adc_values",4096,-0.5,4095.5);  
 }

void lbne::SSPDump::endEvent ( art::EventNumber_t eventNumber )

private

Definition at line 92 of file SSPDump_module.cc.

 {
   //write the ADC histogram for the given event
   if(n_adc_counter_)
     adc_values_->Write(Form("adc_values:event_%d", eventNumber));
 }

void lbne::SSPDump::endJob ( )

overrideprivatevirtual

Reimplemented from art::EDAnalyzer.

Definition at line 99 of file SSPDump_module.cc.

 {
   delete adc_values_;
 }

Member Data Documentation

uint64_t lbne::SSPDump::adc_cumulative_

private

Definition at line 59 of file SSPDump_module.cc.

TH1D* lbne::SSPDump::adc_values_

private

Definition at line 57 of file SSPDump_module.cc.

std::string lbne::SSPDump::frag_type_

private

Definition at line 48 of file SSPDump_module.cc.

uint32_t lbne::SSPDump::n_adc_counter_

private

Definition at line 58 of file SSPDump_module.cc.

std::string lbne::SSPDump::raw_data_label_

private

Definition at line 47 of file SSPDump_module.cc.

uint32_t lbne::SSPDump::verb_adcs_

private

Definition at line 53 of file SSPDump_module.cc.

bool lbne::SSPDump::verb_meta_

private

Definition at line 54 of file SSPDump_module.cc.

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

dunetpc/dune/daqinput35t/SSPDump_module.cc

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation