Inheritance diagram for dune::FelixRawDecoder:

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

	FelixRawDecoder (FelixRawDecoder const &)=delete

	FelixRawDecoder (FelixRawDecoder &&)=delete

FelixRawDecoder &	operator= (FelixRawDecoder const &)=delete

FelixRawDecoder &	operator= (FelixRawDecoder &&)=delete

void	produce (art::Event &e) override

void	reconfigure (const fhicl::ParameterSet &pset)

void	beginJob () override

void	setRootObjects ()

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

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 Types
typedef std::vector< raw::RawDigit >	RawDigits

Private Member Functions
bool	_process (const artdaq::Fragment &frag, RawDigits &raw_digits)

Private Attributes
std::string	_input_label

std::string	_output_label

bool	_expect_container_fragments

TH1D *	_h_nframes

std::vector< uint16_t >	_buffer

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

Member Typedef Documentation

typedef std::vector<raw::RawDigit> dune::FelixRawDecoder::RawDigits

private

Definition at line 54 of file FelixRawDecoder_module.cc.

Constructor & Destructor Documentation

dune::FelixRawDecoder::FelixRawDecoder ( fhicl::ParameterSet const & p )

explicit

Definition at line 70 of file FelixRawDecoder_module.cc.

   : EDProducer{pset}
 // Initialize member data here.
 {
   art::ServiceHandle<art::TFileService> fs;
   //fs->registerFileSwitchCallback(this, &FelixRawDecoder::setRootObjects);
   setRootObjects();
 
   reconfigure(pset);
   // Call appropriate produces<>() functions here.
   //produces< std::vector<raw::RawDigit> > ( _output_label );  
   produces<RawDigits>( _output_label );  
 }

dune::FelixRawDecoder::FelixRawDecoder ( FelixRawDecoder const & )

delete

dune::FelixRawDecoder::FelixRawDecoder ( FelixRawDecoder && )

delete

Member Function Documentation

bool dune::FelixRawDecoder::_process	(	const artdaq::Fragment &	frag,
		RawDigits &	raw_digits
	)

private

Definition at line 183 of file FelixRawDecoder_module.cc.

 {
   // FIXME: Remove hard-coded fragment type
   //if((unsigned)frag.type() != 2) return false;
 
   MF_LOG_INFO("FelixRawDecoder")
       << "   SequenceID = " << frag.sequenceID()
       << "   fragmentID = " << frag.fragmentID()
       << "   fragmentType = " << (unsigned)frag.type()
       << "   Timestamp =  " << frag.timestamp();
   art::ServiceHandle<dune::PdspChannelMapService> channelMap;
   //Load overlay class.
   dune::FelixFragment felix(frag);
   //Get detector elemen number
   uint8_t crate = felix.crate_no(0);
   uint8_t slot = felix.slot_no(0);
   uint8_t fiber = felix.fiber_no(0); // two numbers? 
   const unsigned n_frames = felix.total_frames(); // One frame contains 20 ticks.
   std::cout<<" Nframes = "<<n_frames<<std::endl;
   _h_nframes->Fill(n_frames);
   const unsigned n_channels = dune::FelixFrame::num_ch_per_frame;// 256
   raw::RawDigit::ADCvector_t v_adc;
   //v_adc.reserve(n_frames*n_channels);
   // Fill the adc vector.
   //typedef std::tuple<uint8_t, uint8_t, uint8_t, unsigned> WireInfo_tuple; // unused
   for(unsigned ch = 0; ch < n_channels; ++ch) {
     v_adc.clear();
     std::cout<<"crate:slot:fiber = "<<crate<<", "<<slot<<", "<<fiber<<std::endl;
     std::vector<dune::adc_t> waveform( felix.get_ADCs_by_channel(ch) );
     for(unsigned int nframe=0;nframe<waveform.size();nframe++){
       if(ch==0 && nframe<100) {
         if(nframe==0) std::cout<<"Print the first 100 ADCs of Channel#1"<<std::endl;  
         std::cout<<waveform.at(nframe)<<"  ";
         if(nframe==99) std::cout<<std::endl;
       }
       v_adc.push_back(waveform.at(nframe));  
     }
     int offlineChannel = -1;
     offlineChannel = channelMap->GetOfflineNumberFromDetectorElements(crate, slot, fiber, ch,dune::PdspChannelMapService::kFELIX); // FIXME
     // Push to raw_digits.
     raw::RawDigit raw_digit(offlineChannel, n_frames, v_adc);
     raw_digits.push_back(raw_digit);
   }
   return true;
 }

void dune::FelixRawDecoder::beginJob ( )

overridevirtual

Reimplemented from art::EDProducer.

Definition at line 95 of file FelixRawDecoder_module.cc.

95 {

96 }

FelixRawDecoder& dune::FelixRawDecoder::operator= ( FelixRawDecoder const & )

delete

FelixRawDecoder& dune::FelixRawDecoder::operator= ( FelixRawDecoder && )

delete

void dune::FelixRawDecoder::produce ( art::Event & e )

overridevirtual

Implements art::EDProducer.

Definition at line 98 of file FelixRawDecoder_module.cc.

                                                {
     // TODO Use MF_LOG_DEBUG
     MF_LOG_INFO("FelixRawDecoder")
       << "-------------------- FELIX RawDecoder -------------------";
 
   RawDigits raw_digits;
   unsigned int n_felix_frags = 0;  
 
   if (_expect_container_fragments) {
     art::InputTag itag1(_input_label, "ContainerFELIX");
     auto cont_frags = evt.getHandle<artdaq::Fragments>(itag1);
     art::EventNumber_t eventNumber = evt.event();
     // Check if there is Timing data in this event
     // Don't crash code if not present, just don't save anything
     try { cont_frags->size(); }
     catch(std::exception const&) {
       std::cout << "WARNING: Container FELIX 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)), _output_label);
       return;
     }
     //Check that the data is valid
     if(!cont_frags){
       MF_LOG_ERROR("FelixRawDecoder")
           << "Run: " << evt.run()
                   << ", SubRun: " << evt.subRun()
           << ", Event: " << evt.event()
                   << " Container Fragments is NOT VALID";
     }
     
     for (auto const& cont : *cont_frags)
     {
       artdaq::ContainerFragment cont_frag(cont);
       for (size_t ii = 0; ii < cont_frag.block_count(); ++ii)
         {
           //artdaq::Fragment frag;
           //size_t frag_size = cont_frag.fragSize(ii);
           //frag.resizeBytes(frag_size);
           //memcpy(frag.headerAddress(), cont_frag.at(ii), frag_size);
           //if (_process(frag, raw_digits)) ++n_felix_frags;
           if (_process(*cont_frag[ii], raw_digits)) ++n_felix_frags;
         }
     }
   }
   else
   {
     art::InputTag itag2(_input_label, "FELIX");
     auto frags = evt.getHandle<artdaq::Fragments>(itag2);
     // Check if there is Timing data in this event
     // Don't crash code if not present, just don't save anything
     art::EventNumber_t eventNumber = evt.event();
     try { frags->size(); }
     catch(std::exception const&) {
       std::cout << "WARNING: Raw FELIX 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)), _output_label);
       return;
     }
 
     //Check that the data is valid
     if(!frags.isValid()){
       MF_LOG_ERROR("FelixRawDecoder")
           << "Run: " << evt.run()
                   << ", SubRun: " << evt.subRun()
           << ", Event: " << evt.event()
                   << " Fragments is NOT VALID";
     }
 
     for(auto const& frag: *frags)
     {
       if (_process(frag, raw_digits)) ++n_felix_frags;
     }
   }
 
   MF_LOG_INFO("FelixRawDecoder")
       << " Processed " << n_felix_frags
       << " FELIX Fragments, "
       << raw_digits.size()
       << " RawDigits.";
 
   evt.put(std::make_unique<decltype(raw_digits)>(std::move(raw_digits)),
           _output_label);
 }

void dune::FelixRawDecoder::reconfigure ( const fhicl::ParameterSet & pset )

Definition at line 84 of file FelixRawDecoder_module.cc.

                                                                    {
 
   _input_label = pset.get<std::string>("RawDataLabel");
   _output_label = pset.get<std::string>("OutputDataLabel");
   _expect_container_fragments = pset.get<bool>("ExpectContainerFragments", true);
 }

void dune::FelixRawDecoder::setRootObjects ( )

Definition at line 91 of file FelixRawDecoder_module.cc.

                                         {
   art::ServiceHandle<art::TFileService> file_srv;
   _h_nframes = file_srv->make<TH1D>("felix_NFrames","FELIX: Number of frames",  1000, 0, 1000);
 }

Member Data Documentation

std::vector<uint16_t> dune::FelixRawDecoder::_buffer

private

Definition at line 66 of file FelixRawDecoder_module.cc.

bool dune::FelixRawDecoder::_expect_container_fragments

private

Definition at line 63 of file FelixRawDecoder_module.cc.

TH1D* dune::FelixRawDecoder::_h_nframes

private

Definition at line 64 of file FelixRawDecoder_module.cc.

std::string dune::FelixRawDecoder::_input_label

private

Definition at line 61 of file FelixRawDecoder_module.cc.

std::string dune::FelixRawDecoder::_output_label

private

Definition at line 62 of file FelixRawDecoder_module.cc.

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

duneprototypes/duneprototypes/Protodune/singlephase/RawDecoding/FelixRawDecoder_module.cc

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation