ReadoutTypes.hpp

Go to the documentation of this file.

#ifndef DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_READOUTTYPES_HPP_
#define DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_READOUTTYPES_HPP_
 
#include "daqdataformats/FragmentHeader.hpp"
 
#include <cstdint> // uint_t types
#include <memory>  // unique_ptr
#include <tuple>   // std::tie
 
#include <iostream>
 
namespace dunedaq {
namespace datahandlinglibs {
namespace types {
 
const constexpr std::size_t DUMMY_FRAME_SIZE = 1024;
struct DUMMY_FRAME_STRUCT
{
  using FrameType = DUMMY_FRAME_STRUCT;
 
  // header
  uint64_t timestamp;   // NOLINT(build/unsigned)
  uint64_t another_key; // NOLINT(build/unsigned)
 
  // data
  char data[DUMMY_FRAME_SIZE];
 
  // comparable based on composite key (timestamp + other unique keys)
  bool operator<(const DUMMY_FRAME_STRUCT& other) const
  {
    auto const& f1 = std::tie(this->timestamp, this->another_key);
    auto const& f2 = std::tie(other.timestamp, other.another_key);
    return f1 < f2;
  }
 
  uint64_t get_timestamp() const // NOLINT(build/unsigned)
  {
    return timestamp;
  }
 
  size_t get_num_frames() const { return frames_per_element; }
 
  size_t get_frame_size() const { return frame_size; }
 
  size_t get_payload_size() const { return get_num_frames() * get_frame_size(); }
 
  void set_another_key(uint64_t compkey) { another_key = compkey; }
 
  void set_timestamp(uint64_t ts) // NOLINT(build/unsigned)
  {
    timestamp = ts;
  }
 
  void fake_timestamp(uint64_t /*first_timestamp*/, uint64_t /*offset = 25*/) // NOLINT(build/unsigned)
  {
    // tp.time_start = first_timestamp;
  }
 
  FrameType* begin() { return this; }
 
  FrameType* end() { return (this + 1); } // NOLINT
 
  static const constexpr size_t frame_size = DUMMY_FRAME_SIZE;
  static const constexpr uint8_t frames_per_element = 1; // NOLINT(build/unsigned)
  static const constexpr size_t element_size = DUMMY_FRAME_SIZE;
  static const constexpr dunedaq::daqdataformats::SourceID::Subsystem subsystem =
    dunedaq::daqdataformats::SourceID::Subsystem::kUnknown;
  static const constexpr dunedaq::daqdataformats::FragmentType fragment_type =
    dunedaq::daqdataformats::FragmentType::kUnknown;
  static const constexpr uint64_t expected_tick_difference = 1; // NOLINT(build/unsigned)
};
 
} // namespace types
} // namespace datahandlinglibs
} // namespace dunedaq
 
#endif // DATAHANDLINGLIBS_INCLUDE_DATAHANDLINGLIBS_READOUTTYPES_HPP_