daq2raw::SpillWrapper Class Reference

#include "/cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N20-09-26/DAQ2RawDigit/testbeam/BeamlineUnpack.h"

Public Member Functions
	SpillWrapper (std::size_t nfragments)
void	add (const art::Event &evt, const art::InputTag &tag)
void	add (const artdaq::Fragment &frag)
const uint8_t *	get () const
std::size_t	size () const
bool	ready () const

Private Attributes
const std::size_t	nfragments_
std::vector< uint8_t >	buffer_
std::size_t	nfragments_processed_
std::size_t	size_

Detailed Description

Definition at line 68 of file BeamlineUnpack.h.

Constructor & Destructor Documentation

daq2raw::SpillWrapper::SpillWrapper ( std::size_t  nfragments )

inline

Definition at line 72 of file BeamlineUnpack.h.

References add(), evt, and getGoodRuns4SAM::tag.

                                     :
    nfragments_(nfragments),
      nfragments_processed_(0),
      size_(0)
        {}

Member Function Documentation

void daq2raw::SpillWrapper::add	(	const art::Event &	evt,
		const art::InputTag &	tag
	)

Definition at line 40 of file BeamlineUnpack.cxx.

References allTimeWatchdog::endl, art::DataViewImpl::getValidHandle(), and getGoodRuns4SAM::tag.

Referenced by daq2raw::BeamlineRawInputDriver::loadSpillFragments(), daq2raw::TestBeamRawInputDriver::loadSpillFragments(), and SpillWrapper().

                                                                         {

  art::ValidHandle<artdaq::Fragments> raw = evt.getValidHandle<artdaq::Fragments>(tag);
  if (raw->size() != 1)
    throw cet::exception("SpillWrapper") << "Error in SpillWrapper::add(): expected 1 artdaq fragment in event, found " 
                                         << raw->size() << std::endl;

  this->add((*raw)[0]);
  return;

}

void daq2raw::SpillWrapper::add

(

const artdaq::Fragment &

frag

)

Definition at line 20 of file BeamlineUnpack.cxx.

References buffer_, nfragments_, nfragments_processed_, and size_.

                                                        {

  if (nfragments_processed_ == 0) {
    // Basically, it's the LAST of the fragments which is the
    // largest if the spill couldn't be evenly split into four
    // fragments, so that's why we add the "+1" padding to the
    // buffer
    size_t bufsize = (frag.dataSize() + 1) * sizeof(artdaq::RawDataType) * nfragments_ ;
    buffer_.resize( bufsize );
  }

  memcpy( &*buffer_.begin() + size_, frag.dataBeginBytes(), frag.dataSizeBytes() );

  // Bookkeeping
  size_ += frag.dataSizeBytes();
  nfragments_processed_++;

}

const uint8_t* daq2raw::SpillWrapper::get ( ) const

inline

Definition at line 82 of file BeamlineUnpack.h.

References buffer_.

Referenced by daq2raw::BeamlineRawInputDriver::getSpillFrag(), and daq2raw::TestBeamRawInputDriver::getSpillFrag().

{return &*buffer_.begin(); } 

bool daq2raw::SpillWrapper::ready ( ) const

inline

Definition at line 86 of file BeamlineUnpack.h.

References nfragments_, and nfragments_processed_.

Referenced by daq2raw::BeamlineRawInputDriver::loadSpillFragments(), and daq2raw::TestBeamRawInputDriver::loadSpillFragments().

{ return (nfragments_processed_ == nfragments_) ? true : false; }

std::size_t daq2raw::SpillWrapper::size ( ) const

inline

Definition at line 84 of file BeamlineUnpack.h.

References size_.

Referenced by daq2raw::BeamlineRawInputDriver::getSpillFrag(), and daq2raw::TestBeamRawInputDriver::getSpillFrag().

{return size_; }

Member Data Documentation

std::vector<uint8_t> daq2raw::SpillWrapper::buffer_

private

Definition at line 91 of file BeamlineUnpack.h.

Referenced by add(), and get().

const std::size_t daq2raw::SpillWrapper::nfragments_

private

Definition at line 90 of file BeamlineUnpack.h.

Referenced by add(), and ready().

std::size_t daq2raw::SpillWrapper::nfragments_processed_

private

Definition at line 93 of file BeamlineUnpack.h.

Referenced by add(), and ready().

std::size_t daq2raw::SpillWrapper::size_

private

Definition at line 94 of file BeamlineUnpack.h.

Referenced by add(), and size().

---

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

• /cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N20-09-26/DAQ2RawDigit/testbeam/BeamlineUnpack.h
• /cvmfs/nova-development.opensciencegrid.org/novasoft/releases/N20-09-26/DAQ2RawDigit/testbeam/BeamlineUnpack.cxx