dune::TimingRawDecoder Class Reference

Inheritance diagram for dune::TimingRawDecoder:

Public Member Functions
	TimingRawDecoder (fhicl::ParameterSet const &p)
	TimingRawDecoder (TimingRawDecoder const &)=delete
	TimingRawDecoder (TimingRawDecoder &&)=delete
TimingRawDecoder &	operator= (TimingRawDecoder const &)=delete
TimingRawDecoder &	operator= (TimingRawDecoder &&)=delete
void	produce (art::Event &e) override
void	reconfigure (const fhicl::ParameterSet &pset)
void	printParameterSet ()
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 Attributes
std::string	fRawDataLabel
std::string	fOutputDataLabel
bool	fUseChannelMap
bool	fDebug
bool	fMakeTree
bool	fMakeEventTimeFile = false
TH1I *	fHTimestamp
TH1I *	fHTrigType
TH1I *	fHTimestampDelta
ULong64_t	fPrevTimestamp

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 47 of file TimingRawDecoder_module.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 85 of file TimingRawDecoder_module.cc.

  : EDProducer{pset}
// Initialize member data here.
{
  art::ServiceHandle<art::TFileService> fs;
  //fs->registerFileSwitchCallback(this, &TimingRawDecoder::setRootObjects);
  setRootObjects();

  reconfigure(pset);
  // Call appropriate produces<>() functions here.
  produces< std::vector<raw::RDTimeStamp> > (fOutputDataLabel);
  produces< std::vector<dune::ProtoDUNETimeStamp> > (fOutputDataLabel);
}

dune::TimingRawDecoder::TimingRawDecoder ( TimingRawDecoder const &  )

delete

dune::TimingRawDecoder::TimingRawDecoder ( TimingRawDecoder &&  )

delete

Member Function Documentation

void dune::TimingRawDecoder::beginJob ( )

overridevirtual

Reimplemented from art::EDProducer.

Definition at line 144 of file TimingRawDecoder_module.cc.

                                   {
}

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

delete

TimingRawDecoder& dune::TimingRawDecoder::operator= ( TimingRawDecoder &&  )

delete

void dune::TimingRawDecoder::printParameterSet

(

)

Definition at line 112 of file TimingRawDecoder_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 << "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 dune::TimingRawDecoder::produce ( art::Event &  e )

overridevirtual

Implements art::EDProducer.

Definition at line 147 of file TimingRawDecoder_module.cc.

                                                {
  //std::cout<<"-------------------- Timing RawDecoder -------------------"<<std::endl;
  // Implementation of required member function here.
  art::InputTag itag1(fRawDataLabel, "TIMING");
  auto rawFragments = evt.getHandle<artdaq::Fragments>(itag1);

  art::EventNumber_t eventNumber = evt.event();
  art::RunNumber_t runNumber = evt.run();

  std::vector<raw::RDTimeStamp> rdtimestamps;
  std::vector<dune::ProtoDUNETimeStamp> pdtimestamps;

  if(rawFragments.isValid()){

    ULong64_t evtTimestamp = 0;
    for(auto const& rawFrag : *rawFragments){
      dune::TimingFragment frag(rawFrag);
      // Try to determine the version of the fragment. This is
      // complicated because early versions of the fragment didn't
      // have a metadata object with the version, so for those, we
      // have to look at the size of the fragment (actually the size
      // of the payload, which excludes the header and metadata)
      int fragmentVersion=0;
      if(rawFrag.hasMetadata()){
          dune::TimingFragment::Metadata const* metadata=rawFrag.metadata<dune::TimingFragment::Metadata>();
          fragmentVersion=metadata->fragment_version;
      }
      else{
          size_t dataSizeBytes=rawFrag.dataSizeBytes();
          // The first version of the fragment had 6 uint32_t words
          if(dataSizeBytes==6*sizeof(uint32_t)){
              fragmentVersion=1;
          }
          // The second version of the fragment had 12 uint32_t words,
          // as the last spill start/end and last run start timestamps
          // were added
          else if(dataSizeBytes==12*sizeof(uint32_t)){
              fragmentVersion=2;
          }
          else{
              throw cet::exception("TimingRawDecoder::produce") << "Fragment had no metadata and unexpected size " << dataSizeBytes << " bytes. Can't determined timing fragment version";
          }
      }

      //std::cout << "  Run " << runNumber << ", event " << eventNumber << ": ArtDaq Fragment Timestamp: "  << std::dec << rawFrag.timestamp() << std::endl;
      ULong64_t currentTimestamp=frag.get_tstamp();
      uint16_t scmd = (frag.get_scmd() & 0xFFFF);  // mask this just to make sure.  Though scmd only has four relevant bits, the method is declared uint32_t.
      rdtimestamps.emplace_back(currentTimestamp,scmd);

      dune::ProtoDUNETimeStamp pdts;
      pdts.setCookie(frag.get_cookie());
      pdts.setTriggerType((dune::ProtoDUNETimingCommand)frag.get_scmd());
      pdts.setReservedBits(frag.get_tcmd());
      pdts.setTimeStamp(frag.get_tstamp());
      pdts.setEventCounter(frag.get_evtctr());
      // TODO: Checksum isn't set by the board reader yet
      pdts.setChecksumGood(true);
      pdts.setVersion(fragmentVersion);
      // The additional timestamps were not added until version 2 of the timing fragment
      if(fragmentVersion>=2){
          pdts.setLastRunStart(frag.get_last_runstart_timestamp());
          pdts.setLastSpillStart(frag.get_last_spillstart_timestamp());
          pdts.setLastSpillEnd(frag.get_last_spillend_timestamp());
      }
      else{
          // Set to 0xfff... if not present
          pdts.setLastRunStart(~0ul);
          pdts.setLastSpillStart(~0ul);
          pdts.setLastSpillEnd(~0ul);
      }

      pdtimestamps.push_back(pdts);

      fHTimestamp->Fill(currentTimestamp/1e6);
      fHTrigType->Fill(frag.get_scmd());

      if(fPrevTimestamp!=0) fHTimestampDelta->Fill((currentTimestamp-fPrevTimestamp)/1e6);

      fPrevTimestamp=currentTimestamp;
      //      fHTimestamp->Fill(rawFrag.timestamp());

      if ( fMakeEventTimeFile ) {
        if ( evtTimestamp == 0 ) {
          evtTimestamp = rawFrag.timestamp();
          string foutName = "artdaqTimestamp-Run" + std::to_string(runNumber);
          int subrun = evt.subRun();
          if ( subrun != 1 ) {
            cout << "TimingRawDecoder::produce: WARNING: Unexpected subrun number: " << subrun << endl;
            foutName += "-Sub" + std::to_string(subrun);
          }
          foutName += "-Event" + std::to_string(eventNumber) + ".dat";
          ofstream fout(foutName);
          fout << evtTimestamp << endl;
        } 
        else 
          {
            if ( rawFrag.timestamp() != evtTimestamp ) {
              cout << "TimingRawDecoder::produce: WARNING: Fragments have inconsistent timestamps." << endl;
            }
          }
      }
    }
  }
  evt.put(std::make_unique<decltype(rdtimestamps)>(std::move(rdtimestamps)), fOutputDataLabel);
  evt.put(std::make_unique<decltype(pdtimestamps)>(std::move(pdtimestamps)), fOutputDataLabel);
}

void dune::TimingRawDecoder::reconfigure

(

const fhicl::ParameterSet &

pset

)

Definition at line 99 of file TimingRawDecoder_module.cc.

                                                                    {

  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");
  pset.get_if_present<bool>("MakeEventTimeFile", fMakeEventTimeFile);
  fPrevTimestamp=0;
  if(fDebug) printParameterSet();

}

void dune::TimingRawDecoder::setRootObjects

(

)

Definition at line 130 of file TimingRawDecoder_module.cc.

                                         {
  art::ServiceHandle<art::TFileService> tFileService;

  fHTimestamp = tFileService->make<TH1I>("Timestamp","Timing Timestamp",  1e3, 0, 1e9);
  fHTimestamp->GetXaxis()->SetTitle("Timestamp (ms)");

  fHTimestampDelta = tFileService->make<TH1I>("TimestampDelta","Timing Timestamp Delta", 100, 0, 1e3);
  fHTimestampDelta->GetXaxis()->SetTitle("Delta Timestamp (ms)");

  fHTrigType = tFileService->make<TH1I>("TrigType","Timing trigger type", 20, -0.5, 19.5);
  fHTrigType->GetXaxis()->SetTitle("Trigger type");


}

Member Data Documentation

bool dune::TimingRawDecoder::fDebug

private

Definition at line 73 of file TimingRawDecoder_module.cc.

TH1I* dune::TimingRawDecoder::fHTimestamp

private

Definition at line 77 of file TimingRawDecoder_module.cc.

TH1I* dune::TimingRawDecoder::fHTimestampDelta

private

Definition at line 79 of file TimingRawDecoder_module.cc.

TH1I* dune::TimingRawDecoder::fHTrigType

private

Definition at line 78 of file TimingRawDecoder_module.cc.

bool dune::TimingRawDecoder::fMakeEventTimeFile = false

private

Definition at line 75 of file TimingRawDecoder_module.cc.

bool dune::TimingRawDecoder::fMakeTree

private

Definition at line 74 of file TimingRawDecoder_module.cc.

std::string dune::TimingRawDecoder::fOutputDataLabel

private

Definition at line 71 of file TimingRawDecoder_module.cc.

ULong64_t dune::TimingRawDecoder::fPrevTimestamp

private

Definition at line 81 of file TimingRawDecoder_module.cc.

std::string dune::TimingRawDecoder::fRawDataLabel

private

Definition at line 70 of file TimingRawDecoder_module.cc.

bool dune::TimingRawDecoder::fUseChannelMap

private

Definition at line 72 of file TimingRawDecoder_module.cc.

---

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

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