dunedaq::daqdataformats::Fragment Class Reference

C++ Representation of a DUNE Fragment, wrapping the flat byte array that is the Fragment's "actual" form. More...

#include <Fragment.hpp>

Public Types
enum class	BufferAdoptionMode { kReadOnlyMode , kTakeOverBuffer , kCopyFromBuffer }
	Describes how the "existing Fragment buffer" Constructor should treat the given buffer. More...

Public Member Functions
	Fragment (const std::vector< std::pair< void *, size_t > > &pieces)
	Fragment constructor using a vector of buffer pointers.
	Fragment (void *buffer, size_t size)
	Fragment constructor using a buffer and size.
	Fragment (void *existing_fragment_buffer, BufferAdoptionMode adoption_mode)
	Framgnet constructor using existing Fragment array.
	Fragment (Fragment const &)=delete
	Fragment copy constructor is deleted.
Fragment &	operator= (Fragment const &)=delete
	Fragment copy assignment operator is deleted.
	Fragment (Fragment &&other)
Fragment &	operator= (Fragment &&other)
	~Fragment ()
	Fragment destructor.
FragmentHeader	get_header () const
	Get a copy of the FragmentHeader struct.
void	set_header_fields (const FragmentHeader &header)
	Copy fields from the provided header in this Fragment's header.
const void *	get_storage_location () const
	Get a pointer to the Fragment's data array to read its contents directly.
trigger_number_t	get_trigger_number () const
	Get the trigger_number field from the header.
void	set_trigger_number (trigger_number_t trigger_number)
	Set the trigger_number for the Fragment.
run_number_t	get_run_number () const
	Get the run_number field from the header.
void	set_run_number (run_number_t run_number)
	Set the run_number for the Fragment.
timestamp_t	get_trigger_timestamp () const
	Get the trigger_timestamp field from the header.
void	set_trigger_timestamp (timestamp_t trigger_timestamp)
	Set the trigger_timestamp for the Fragment.
timestamp_t	get_window_begin () const
	Get the window_begin field from the header.
void	set_window_begin (timestamp_t window_begin)
	Set the window_begin for the Fragment.
timestamp_t	get_window_end () const
	Get the window_end field from the header.
void	set_window_end (timestamp_t window_end)
	Set the window_end for the Fragment.
SourceID	get_element_id () const
	Get the SourceID for the Fragment.
void	set_element_id (SourceID element_id)
	Set the SourceID for the Fragment.
uint16_t	get_detector_id () const noexcept
	Get the DetID for the Fragment.
void	set_detector_id (const uint16_t &detector_id) noexcept
	Set the DetID for the Fragment.
std::bitset< 32 >	get_status_bits () const
	Get the status_bits header field.
void	set_status_bits (std::bitset< 32 > status_bits)
	Overwrite the status_bits header field.
bool	get_status_bit (FragmentStatusBits bit) const
	Get the value of a designated status bit.
void	set_status_bit (FragmentStatusBits bit, bool value)
	Set the designated status bit.
fragment_type_t	get_fragment_type_code () const
	Get the fragment_type_t value stored in the header.
FragmentType	get_fragment_type () const
	Get the fragment_type header field.
void	set_type (FragmentType fragment_type)
	Set the fragment_type header field.
sequence_number_t	get_sequence_number () const
	Get the sequence_number field from the header.
void	set_sequence_number (sequence_number_t number)
	Set the sequence_number for the Fragment.
fragment_size_t	get_size () const
	Get the total size of the Fragment.
fragment_size_t	get_data_size () const
	Get the size of the Fragment data.
void *	get_data () const
	Get a pointer to the data payload in the Fragmnet.

Private Member Functions
FragmentHeader *	header_ () const
	Get the FragmentHeader from the m_data_arr array.

Private Attributes
void *	m_data_arr { nullptr }
	Flat memory containing a FragmentHeader and the data payload.
bool	m_alloc { false }
	Whether the Fragment owns the memory pointed by m_data_arr.

Detailed Description

C++ Representation of a DUNE Fragment, wrapping the flat byte array that is the Fragment's "actual" form.

Definition at line 35 of file Fragment.hpp.

Member Enumeration Documentation

BufferAdoptionMode

enum class dunedaq::daqdataformats::Fragment::BufferAdoptionMode

strong

Describes how the "existing Fragment buffer" Constructor should treat the given buffer.

Enumerator
kReadOnlyMode	Just use the buffer in non-owning mode.
kTakeOverBuffer	Take over control of the buffer.
kCopyFromBuffer	Copy the contents of the buffer into a new Fragment array.

Definition at line 41 of file Fragment.hpp.

  {
    kReadOnlyMode,   
    kTakeOverBuffer, 
    kCopyFromBuffer  
  };

Constructor & Destructor Documentation

Fragment() [1/5]

dunedaq::daqdataformats::Fragment::Fragment ( const std::vector< std::pair< void *, size_t > > & pieces )

inlineexplicit

Fragment constructor using a vector of buffer pointers.

Parameters

pieces

Vector of pairs of pointer/size pairs used to initialize Fragment payload

Definition at line 267 of file Fragment.hpp.

{
 
  size_t size =
    sizeof(FragmentHeader) +
    std::accumulate(pieces.begin(), pieces.end(), 0ULL, [](const size_t& a, const std::pair<void*, size_t>& b) {
      return a + b.second;
    });
 
  if (size < sizeof(FragmentHeader)) {
    throw std::length_error("The Fragment size is smaller than the Fragment header size.");
  }
 
  m_data_arr = malloc(size); // NOLINT
  if (m_data_arr == nullptr) {
    throw std::bad_alloc();
  }
  m_alloc = true;
 
  FragmentHeader header;
  header.size = size;
  memcpy(m_data_arr, &header, sizeof(header));
 
  size_t offset = sizeof(FragmentHeader);
  for (auto& piece : pieces) {
    if (piece.first == nullptr) {
      throw std::invalid_argument("The Fragment buffer point to NULL.");
    }
    memcpy(static_cast<uint8_t*>(m_data_arr) + offset, piece.first, piece.second); // NOLINT
    offset += piece.second;
  }
}

Fragment() [2/5]

dunedaq::daqdataformats::Fragment::Fragment ( void * buffer, size_t size )

inline

Fragment constructor using a buffer and size.

Parameters

buffer	Pointer to Fragment payload
size	Size of payload

Definition at line 300 of file Fragment.hpp.

  : Fragment({ std::make_pair(buffer, size) })
{
}

Fragment() [3/5]

dunedaq::daqdataformats::Fragment::Fragment ( void * existing_fragment_buffer, BufferAdoptionMode adoption_mode )

inlineexplicit

Framgnet constructor using existing Fragment array.

Parameters

existing_fragment_buffer	Pointer to existing Fragment array
adoption_mode	How the constructor should treat the existing_fragment_buffer

Definition at line 305 of file Fragment.hpp.

{
  if (adoption_mode == BufferAdoptionMode::kReadOnlyMode) {
    m_data_arr = existing_fragment_buffer;
  } else if (adoption_mode == BufferAdoptionMode::kTakeOverBuffer) {
    m_data_arr = existing_fragment_buffer;
    m_alloc = true;
  } else if (adoption_mode == BufferAdoptionMode::kCopyFromBuffer) {
    auto header = reinterpret_cast<FragmentHeader*>(existing_fragment_buffer); // NOLINT
    m_data_arr = malloc(header->size); // NOLINT
    if (m_data_arr == nullptr) {
      throw std::bad_alloc();
    }
    m_alloc = true;
    memcpy(m_data_arr, existing_fragment_buffer, header->size);
  }
}

Fragment() [4/5]

dunedaq::daqdataformats::Fragment::Fragment ( Fragment const & )

delete

Fragment copy constructor is deleted.

Fragment() [5/5]

dunedaq::daqdataformats::Fragment::Fragment ( Fragment && other )

inline

Definition at line 68 of file Fragment.hpp.

  {
    m_alloc = other.m_alloc;
    other.m_alloc = false;
    m_data_arr = other.m_data_arr;
  }

~Fragment()

dunedaq::daqdataformats::Fragment::~Fragment ( )

inline

Fragment destructor.

Definition at line 323 of file Fragment.hpp.

{
  if (m_alloc)
    free(m_data_arr); // NOLINT
}

Member Function Documentation

get_data()

void * dunedaq::daqdataformats::Fragment::get_data ( ) const

inline

Get a pointer to the data payload in the Fragmnet.

Returns

Pointer to the data payload in the Fragment

Definition at line 249 of file Fragment.hpp.

  {
    // Increment header pointer by one to skip header
    return static_cast<void*>(header_() + 1); // NOLINT
  }

get_data_size()

fragment_size_t dunedaq::daqdataformats::Fragment::get_data_size ( ) const

inline

Get the size of the Fragment data.

Returns

The size of the Fragment data, payload only

Definition at line 243 of file Fragment.hpp.

{ return header_()->size - sizeof(FragmentHeader); }

get_detector_id()

uint16_t dunedaq::daqdataformats::Fragment::get_detector_id ( ) const

inlinenoexcept

Get the DetID for the Fragment.

Returns

The detector_id header field

Definition at line 174 of file Fragment.hpp.

{ return header_()->detector_id; } // NOLINT

get_element_id()

SourceID dunedaq::daqdataformats::Fragment::get_element_id ( ) const

inline

Get the SourceID for the Fragment.

Returns

The element_id header field

Definition at line 162 of file Fragment.hpp.

{ return header_()->element_id; }

get_fragment_type()

FragmentType dunedaq::daqdataformats::Fragment::get_fragment_type ( ) const

inline

Get the fragment_type header field.

Returns

Current value of the fragment_type header field

Definition at line 215 of file Fragment.hpp.

{ return static_cast<FragmentType>(get_fragment_type_code()); }

get_fragment_type_code()

fragment_type_t dunedaq::daqdataformats::Fragment::get_fragment_type_code ( ) const

inline

Get the fragment_type_t value stored in the header.

Returns

Current value of the fragment_type header field

Definition at line 210 of file Fragment.hpp.

{ return header_()->fragment_type; }

get_header()

FragmentHeader dunedaq::daqdataformats::Fragment::get_header ( ) const

inline

Get a copy of the FragmentHeader struct.

Returns

A copy of the FragmentHeader struct stored in this Fragment

Definition at line 90 of file Fragment.hpp.

{ return *header_(); }

get_run_number()

run_number_t dunedaq::daqdataformats::Fragment::get_run_number ( ) const

inline

Get the run_number field from the header.

Returns

The run_number header field

Definition at line 120 of file Fragment.hpp.

{ return header_()->run_number; }

get_sequence_number()

sequence_number_t dunedaq::daqdataformats::Fragment::get_sequence_number ( ) const

inline

Get the sequence_number field from the header.

Returns

The sequence_number header field

Definition at line 226 of file Fragment.hpp.

{ return header_()->sequence_number; }

get_size()

fragment_size_t dunedaq::daqdataformats::Fragment::get_size ( ) const

inline

Get the total size of the Fragment.

Returns

The size of the Fragment, including header and all payload pieces

Definition at line 237 of file Fragment.hpp.

{ return header_()->size; }

get_status_bit()

bool dunedaq::daqdataformats::Fragment::get_status_bit ( FragmentStatusBits bit ) const

inline

Get the value of a designated status bit.

Parameters

bit	Bit to query

Returns

Value of bit (true/false)

Definition at line 197 of file Fragment.hpp.

{ return get_status_bits()[static_cast<size_t>(bit)]; }

get_status_bits()

std::bitset< 32 > dunedaq::daqdataformats::Fragment::get_status_bits ( ) const

inline

Get the status_bits header field.

Returns

Bitset generated from header's status_bits field

Definition at line 186 of file Fragment.hpp.

{ return header_()->status_bits; }

get_storage_location()

const void * dunedaq::daqdataformats::Fragment::get_storage_location ( ) const

inline

Get a pointer to the Fragment's data array to read its contents directly.

Returns

Pointer to the Fragment's data array

Definition at line 103 of file Fragment.hpp.

{ return m_data_arr; }

get_trigger_number()

trigger_number_t dunedaq::daqdataformats::Fragment::get_trigger_number ( ) const

inline

Get the trigger_number field from the header.

Returns

The trigger_number header field

Definition at line 110 of file Fragment.hpp.

{ return header_()->trigger_number; }

get_trigger_timestamp()

timestamp_t dunedaq::daqdataformats::Fragment::get_trigger_timestamp ( ) const

inline

Get the trigger_timestamp field from the header.

Returns

The trigger_timestamp header field

Definition at line 131 of file Fragment.hpp.

{ return header_()->trigger_timestamp; }

get_window_begin()

timestamp_t dunedaq::daqdataformats::Fragment::get_window_begin ( ) const

inline

Get the window_begin field from the header.

Returns

The window_begin header field

Definition at line 141 of file Fragment.hpp.

{ return header_()->window_begin; }

get_window_end()

timestamp_t dunedaq::daqdataformats::Fragment::get_window_end ( ) const

inline

Get the window_end field from the header.

Returns

The window_end header field

Definition at line 151 of file Fragment.hpp.

{ return header_()->window_end; }

header_()

FragmentHeader * dunedaq::daqdataformats::Fragment::header_ ( ) const

inlineprivate

Get the FragmentHeader from the m_data_arr array.

Returns

Pointer to the FragmentHeader

Definition at line 260 of file Fragment.hpp.

{ return static_cast<FragmentHeader*>(m_data_arr); }

operator=() [1/2]

Fragment & dunedaq::daqdataformats::Fragment::operator= ( Fragment && other )

inline

Definition at line 74 of file Fragment.hpp.

  {
    m_alloc = other.m_alloc;
    other.m_alloc = false;
    m_data_arr = other.m_data_arr;
    return *this;
  }

operator=() [2/2]

Fragment & dunedaq::daqdataformats::Fragment::operator= ( Fragment const & )

delete

Fragment copy assignment operator is deleted.

set_detector_id()

void dunedaq::daqdataformats::Fragment::set_detector_id ( const uint16_t & detector_id )

inlinenoexcept

Set the DetID for the Fragment.

Parameters

detector_id

DetID to use as the detector_id

Definition at line 180 of file Fragment.hpp.

{ header_()->detector_id = detector_id; } // NOLINT

set_element_id()

void dunedaq::daqdataformats::Fragment::set_element_id ( SourceID element_id )

inline

Set the SourceID for the Fragment.

Parameters

element_id

SourceID to use as element_id

Definition at line 168 of file Fragment.hpp.

{ header_()->element_id = element_id; }

set_header_fields()

void dunedaq::daqdataformats::Fragment::set_header_fields ( const FragmentHeader & header )

inline

Copy fields from the provided header in this Fragment's header.

Parameters

header

Header to copy into the Fragment data array

The size FragmentHeader field is not copied from the given FragmentHeader

Definition at line 330 of file Fragment.hpp.

{
  header_()->trigger_number = header.trigger_number;
  header_()->trigger_timestamp = header.trigger_timestamp;
  header_()->window_begin = header.window_begin;
  header_()->window_end = header.window_end;
  header_()->run_number = header.run_number;
  header_()->element_id = header.element_id;
  header_()->detector_id = header.detector_id;
  header_()->status_bits = header.status_bits;
  header_()->fragment_type = header.fragment_type;
  header_()->sequence_number = header.sequence_number;
}

set_run_number()

void dunedaq::daqdataformats::Fragment::set_run_number ( run_number_t run_number )

inline

Set the run_number for the Fragment.

Parameters

run_number

Value of run_number to set

Definition at line 125 of file Fragment.hpp.

{ header_()->run_number = run_number; }

set_sequence_number()

void dunedaq::daqdataformats::Fragment::set_sequence_number ( sequence_number_t number )

inline

Set the sequence_number for the Fragment.

Parameters

sequence_number

Value of sequence_number to set

Definition at line 231 of file Fragment.hpp.

{ header_()->sequence_number = number; }

set_status_bit()

void dunedaq::daqdataformats::Fragment::set_status_bit ( FragmentStatusBits bit, bool value )

inline

Set the designated status bit.

Parameters

bit	Bit to set
value	Value (true/false) for the status bit

Definition at line 345 of file Fragment.hpp.

{
  auto bits = get_status_bits();
  bits[static_cast<size_t>(bit)] = value;
  set_status_bits(bits);
}

set_status_bits()

void dunedaq::daqdataformats::Fragment::set_status_bits ( std::bitset< 32 > status_bits )

inline

Overwrite the status_bits header field.

Parameters

status_bits

Bitset of status bits to set

Definition at line 191 of file Fragment.hpp.

{ header_()->status_bits = status_bits.to_ulong(); }

set_trigger_number()

void dunedaq::daqdataformats::Fragment::set_trigger_number ( trigger_number_t trigger_number )

inline

Set the trigger_number for the Fragment.

Parameters

trigger_number

Value of trigger_number to set

Definition at line 115 of file Fragment.hpp.

{ header_()->trigger_number = trigger_number; }

set_trigger_timestamp()

void dunedaq::daqdataformats::Fragment::set_trigger_timestamp ( timestamp_t trigger_timestamp )

inline

Set the trigger_timestamp for the Fragment.

Parameters

trigger_timestamp

Value of trigger_timestamp to set

Definition at line 136 of file Fragment.hpp.

{ header_()->trigger_timestamp = trigger_timestamp; }

set_type()

void dunedaq::daqdataformats::Fragment::set_type ( FragmentType fragment_type )

inline

Set the fragment_type header field.

Parameters

fragment_type

Value to set

Definition at line 220 of file Fragment.hpp.

{ header_()->fragment_type = static_cast<fragment_type_t>(fragment_type); }

set_window_begin()

void dunedaq::daqdataformats::Fragment::set_window_begin ( timestamp_t window_begin )

inline

Set the window_begin for the Fragment.

Parameters

window_begin

Value of the window_begin to set

Definition at line 146 of file Fragment.hpp.

{ header_()->window_begin = window_begin; }

set_window_end()

void dunedaq::daqdataformats::Fragment::set_window_end ( timestamp_t window_end )

inline

Set the window_end for the Fragment.

Parameters

window_end

Value of the window_end to set

Definition at line 156 of file Fragment.hpp.

{ header_()->window_end = window_end; }

Member Data Documentation

m_alloc

bool dunedaq::daqdataformats::Fragment::m_alloc { false }

private

Whether the Fragment owns the memory pointed by m_data_arr.

Definition at line 262 of file Fragment.hpp.

{ false };       

m_data_arr

void* dunedaq::daqdataformats::Fragment::m_data_arr { nullptr }

private

Flat memory containing a FragmentHeader and the data payload.

Definition at line 261 of file Fragment.hpp.

{ nullptr }; 

---

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

• /github/workspace/dunedaq/sourcecode/daqdataformats/include/daqdataformats/Fragment.hpp