TimeSlice.hpp

Go to the documentation of this file.

 
#ifndef DAQDATAFORMATS_INCLUDE_DAQDATAFORMATS_TIMESLICE_HPP_
#define DAQDATAFORMATS_INCLUDE_DAQDATAFORMATS_TIMESLICE_HPP_
 
#include "daqdataformats/Fragment.hpp"
#include "daqdataformats/TimeSliceHeader.hpp"
#include "daqdataformats/Types.hpp"
 
#include <memory>
#include <utility>
#include <vector>
 
namespace dunedaq::daqdataformats {

class TimeSlice
{
public:
  explicit TimeSlice(timeslice_number_t timeslice_number, run_number_t run_number);

  explicit TimeSlice(TimeSliceHeader const& header);

  TimeSliceHeader get_header() const { return m_header; }
  void set_header(TimeSliceHeader header) { m_header = header; }

  const std::vector<std::unique_ptr<Fragment>>& get_fragments_ref() const { return m_fragments; }

  void set_fragments(std::vector<std::unique_ptr<Fragment>>&& fragments) { m_fragments = std::move(fragments); }

  void add_fragment(std::unique_ptr<Fragment>&& fragment) { m_fragments.emplace_back(std::move(fragment)); }

  void set_element_id(SourceID source_id) { m_header.element_id = source_id; }

  size_t get_total_size_bytes() const
  {
    size_t total_size = sizeof(get_header());
 
    for (auto const& frag_ptr : m_fragments)
      total_size += frag_ptr->get_size();
 
    return total_size;
  }

  size_t get_sum_of_fragment_payload_sizes() const
  {
    size_t total_size = 0;
 
    for (auto const& frag_ptr : m_fragments)
      total_size += frag_ptr->get_data_size();
 
    return total_size;
  }
 
  TimeSlice(TimeSlice const&) = delete;            
  TimeSlice& operator=(TimeSlice const&) = delete; 
  TimeSlice(TimeSlice&&) = default;                
  TimeSlice& operator=(TimeSlice&&) = default;     
 
  ~TimeSlice() = default; 
 
private:
  TimeSliceHeader m_header;                           
  std::vector<std::unique_ptr<Fragment>> m_fragments; 
};
 
//-------
 
inline TimeSlice::TimeSlice(timeslice_number_t timeslice_number, run_number_t run_number)
  : m_header()
  , m_fragments()
{
  m_header.timeslice_number = timeslice_number;
  m_header.run_number = run_number;
}
 
inline TimeSlice::TimeSlice(TimeSliceHeader const& header)
  : m_header(header)
  , m_fragments()
{
}
 
} // namespace dunedaq::daqdataformats
 
#endif // DAQDATAFORMATS_INCLUDE_DAQDATAFORMATS_TIMESLICE_HPP_