PDSPCTBRawDecoder Class Reference

Inheritance diagram for PDSPCTBRawDecoder:

Public Member Functions
	PDSPCTBRawDecoder (fhicl::ParameterSet const &p)
	PDSPCTBRawDecoder (PDSPCTBRawDecoder const &)=delete
	PDSPCTBRawDecoder (PDSPCTBRawDecoder &&)=delete
PDSPCTBRawDecoder &	operator= (PDSPCTBRawDecoder const &)=delete
PDSPCTBRawDecoder &	operator= (PDSPCTBRawDecoder &&)=delete
void	produce (art::Event &e) 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 (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 Member Functions
void	_process_CTB_AUX (const artdaq::Fragment &frag)

Private Attributes
std::string	fInputLabel
std::string	fInputContainerInstance
std::string	fInputNonContainerInstance
std::string	fOutputLabel
std::vector< raw::ctb::Trigger >	fTrigs
std::vector< raw::ctb::ChStatus >	fChStats
std::vector< raw::ctb::Feedback >	fFeedbacks
std::vector< raw::ctb::Misc >	fMiscs
std::vector< raw::ctb::WordIndex >	fWordIndexes

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 35 of file PDSPCTBRawDecoder_module.cc.

Constructor & Destructor Documentation

PDSPCTBRawDecoder::PDSPCTBRawDecoder ( fhicl::ParameterSet const &  p )

explicit

Definition at line 70 of file PDSPCTBRawDecoder_module.cc.

  : EDProducer{p}
// Initialize member data here.
{
  fInputLabel = p.get<std::string>("InputLabel");
  fInputContainerInstance = p.get<std::string>("InputContainerInstance");
  fInputNonContainerInstance = p.get<std::string>("InputNonContainerInstance");
  fOutputLabel = p.get<std::string>("OutputLabel");

  produces<std::vector<raw::ctb::pdspctb> >(fOutputLabel);
}

PDSPCTBRawDecoder::PDSPCTBRawDecoder ( PDSPCTBRawDecoder const &  )

delete

PDSPCTBRawDecoder::PDSPCTBRawDecoder ( PDSPCTBRawDecoder &&  )

delete

Member Function Documentation

void PDSPCTBRawDecoder::_process_CTB_AUX ( const artdaq::Fragment &  frag )

private

Definition at line 125 of file PDSPCTBRawDecoder_module.cc.

{
  dune::CTBFragment ctbfrag(frag);

  // use the same logic in dune-raw-data/Overlays/CTBFragment.cc:operator<<

  for (size_t iword = 0; iword < ctbfrag.NWords(); ++iword)
    {
      size_t ix=0;
      uint32_t wt=0;
      if (ctbfrag.Trigger(iword))
        {
          raw::ctb::Trigger tstruct;
          tstruct.word_type = ctbfrag.Trigger(iword)->word_type;
          wt = tstruct.word_type;
          tstruct.trigger_word = ctbfrag.Trigger(iword)->trigger_word;
          tstruct.timestamp = ctbfrag.Trigger(iword)->timestamp;
          ix = fTrigs.size();
          fTrigs.push_back(tstruct);
        }
      else if (ctbfrag.ChStatus(iword))
        {
          raw::ctb::ChStatus cstruct;
          cstruct.word_type = ctbfrag.ChStatus(iword)->word_type;
          wt = cstruct.word_type;
          cstruct.pds = ctbfrag.ChStatus(iword)->pds;
          cstruct.crt = ctbfrag.ChStatus(iword)->crt;
          cstruct.beam_hi = ctbfrag.ChStatus(iword)->beam_hi;
          cstruct.beam_lo = ctbfrag.ChStatus(iword)->beam_lo;
          cstruct.timestamp = ctbfrag.ChStatus(iword)->timestamp;
          ix = fChStats.size();
          fChStats.push_back(cstruct);
        }
      else if (ctbfrag.Feedback(iword))
        {
          raw::ctb::Feedback fstruct;
          fstruct.word_type = ctbfrag.Feedback(iword)->word_type;
          wt = fstruct.word_type;
          fstruct.padding = ctbfrag.Feedback(iword)->padding;
          fstruct.source = ctbfrag.Feedback(iword)->source;
          fstruct.code = ctbfrag.Feedback(iword)->code;
          fstruct.timestamp = ctbfrag.Feedback(iword)->timestamp;
          ix = fFeedbacks.size();
          fFeedbacks.push_back(fstruct);
        }
      else
        {
          raw::ctb::Misc mstruct;
          mstruct.word_type = ctbfrag.Word(iword)->word_type;
          wt = mstruct.word_type;
          mstruct.payload = ctbfrag.Word(iword)->payload;
          mstruct.timestamp = ctbfrag.Word(iword)->timestamp;
          ix = fMiscs.size();
          fMiscs.push_back(mstruct);
        }

      raw::ctb::WordIndex wstruct;
      wstruct.word_type = wt;
      wstruct.index = ix;
      fWordIndexes.push_back(wstruct);

    }
}

PDSPCTBRawDecoder& PDSPCTBRawDecoder::operator= ( PDSPCTBRawDecoder const &  )

delete

PDSPCTBRawDecoder& PDSPCTBRawDecoder::operator= ( PDSPCTBRawDecoder &&  )

delete

void PDSPCTBRawDecoder::produce ( art::Event &  e )

overridevirtual

Implements art::EDProducer.

Definition at line 82 of file PDSPCTBRawDecoder_module.cc.

{

  fTrigs.clear();
  fChStats.clear();
  fFeedbacks.clear();
  fMiscs.clear();
  fWordIndexes.clear();

  // look first for container fragments and then non-container fragments

  std::vector<raw::ctb::pdspctb> pdspctbs;

  art::InputTag itag1(fInputLabel, fInputContainerInstance);
  auto cont_frags = evt.getHandle<artdaq::Fragments>(itag1);
  if (cont_frags)
    {
      for (auto const& cont : *cont_frags)
        {
          artdaq::ContainerFragment cont_frag(cont);
          for (size_t ii = 0; ii < cont_frag.block_count(); ++ii)
            {
              _process_CTB_AUX(*cont_frag[ii]);
            }
        }
    }

  art::InputTag itag2(fInputLabel, fInputNonContainerInstance);
  auto frags = evt.getHandle<artdaq::Fragments>(itag2);
  if (frags)
    {
      for(auto const& frag: *frags)
        {
          _process_CTB_AUX(frag);
        }
    }

  raw::ctb::pdspctb ctbdp(fTrigs,fChStats,fFeedbacks,fMiscs,fWordIndexes);
  pdspctbs.push_back(ctbdp);  // just one for now
  evt.put(std::make_unique<std::vector<raw::ctb::pdspctb>>(std::move(pdspctbs)),fOutputLabel);

}

Member Data Documentation

std::vector<raw::ctb::ChStatus> PDSPCTBRawDecoder::fChStats

private

Definition at line 62 of file PDSPCTBRawDecoder_module.cc.

std::vector<raw::ctb::Feedback> PDSPCTBRawDecoder::fFeedbacks

private

Definition at line 63 of file PDSPCTBRawDecoder_module.cc.

std::string PDSPCTBRawDecoder::fInputContainerInstance

private

Definition at line 55 of file PDSPCTBRawDecoder_module.cc.

std::string PDSPCTBRawDecoder::fInputLabel

private

Definition at line 54 of file PDSPCTBRawDecoder_module.cc.

std::string PDSPCTBRawDecoder::fInputNonContainerInstance

private

Definition at line 56 of file PDSPCTBRawDecoder_module.cc.

std::vector<raw::ctb::Misc> PDSPCTBRawDecoder::fMiscs

private

Definition at line 64 of file PDSPCTBRawDecoder_module.cc.

std::string PDSPCTBRawDecoder::fOutputLabel

private

Definition at line 57 of file PDSPCTBRawDecoder_module.cc.

std::vector<raw::ctb::Trigger> PDSPCTBRawDecoder::fTrigs

private

Definition at line 61 of file PDSPCTBRawDecoder_module.cc.

std::vector<raw::ctb::WordIndex> PDSPCTBRawDecoder::fWordIndexes

private

Definition at line 65 of file PDSPCTBRawDecoder_module.cc.

---

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

• duneprototypes/duneprototypes/Protodune/singlephase/RawDecoding/PDSPCTBRawDecoder_module.cc