TAWrapper.hpp

Go to the documentation of this file.

 
#ifndef TRIGGER_INCLUDE_TRIGGER_TAWRAPPER_HPP_
#define TRIGGER_INCLUDE_TRIGGER_TAWRAPPER_HPP_
 
#include "daqdataformats/Fragment.hpp"
#include "iomanager/Receiver.hpp"
#include "triggeralgs/TriggerActivity.hpp"
#include "triggeralgs/TriggerObjectOverlay.hpp"
#include "triggeralgs/TriggerPrimitive.hpp"
 
namespace dunedaq {
namespace trigger {
struct TAWrapper
{
 
  using FrameType = TAWrapper;
 
  triggeralgs::TriggerActivity activity;
  std::vector<uint8_t> activity_overlay_buffer;
 
  // Don't really want this default ctor, but IterableQueueModel requires it
  // TAWrapper() {}
 
  TAWrapper(triggeralgs::TriggerActivity a = triggeralgs::TriggerActivity())
    : activity(a)
  {
    populate_buffer();
  }
 
  void populate_buffer()
  {
    activity_overlay_buffer.resize(triggeralgs::get_overlay_nbytes(activity));
    triggeralgs::write_overlay(activity, activity_overlay_buffer.data());
  }
 
  // comparable based on first timestamp
  bool operator<(const TAWrapper& other) const
  {
    return std::tie(this->activity.time_start, this->activity.channel_start) <
           std::tie(other.activity.time_start, other.activity.channel_start);
  }
 
  uint64_t get_timestamp() const // NOLINT(build/unsigned)
  {
    return activity.time_start;
  }
 
  void set_timestamp(uint64_t ts) // NOLINT(build/unsigned)
  {
    activity.time_start = ts;
  }
 
  void fake_timestamps(uint64_t first_timestamp, uint64_t /*offset */ = 0) // NOLINT(build/unsigned)
  {
    activity.time_start = first_timestamp;
    populate_buffer();
  }
 
  size_t get_payload_size() { return activity_overlay_buffer.size(); }
 
  size_t get_num_frames() { return 1; }
 
  size_t get_frame_size() { return get_payload_size(); }
 
  TAWrapper* begin() { return (TAWrapper*)(activity_overlay_buffer.data()); }
 
  TAWrapper* end() { return (TAWrapper*)(activity_overlay_buffer.data() + activity_overlay_buffer.size()); }
 
  static const constexpr daqdataformats::SourceID::Subsystem subsystem = daqdataformats::SourceID::Subsystem::kTrigger;
  static const constexpr daqdataformats::FragmentType fragment_type = daqdataformats::FragmentType::kTriggerActivity;
  // No idea what this should really be set to
  static const constexpr uint64_t expected_tick_difference = 1; // NOLINT(build/unsigned)
};
 
} // namespace trigger
} // namespace dunedaq
/*
namespace dunedaq {
namespace datahandlinglibs {
 
template<>
uint64_t
get_frame_iterator_timestamp(uint8_t* it)
{
  trgdataformats::TriggerActivity* activity = reinterpret_cast<trgdataformats::TriggerActivity*>(it);
  return activity->data.time_start;
}
 
}
}
*/
#endif // TRIGGER_INCLUDE_TRIGGER_TAWRAPPER_HPP_