#include <SourceEmulatorModel.hpp>

Inheritance diagram for dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >:

Collaboration diagram for dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >:

Public Member Functions
	SourceEmulatorModel (std::string name, std::atomic< bool > &run_marker, uint64_t time_tick_diff, double dropout_rate, double frame_error_rate, double rate_khz, uint16_t frames_per_tick=1)

void	set_sender (const appmodel::DataMoveCallbackConf *conf)

void	conf (const confmodel::DetectorStream stream_conf, const appmodel::StreamEmulationParameters emu_conf)

void	scrap (const appfwk::DAQModule::CommandData_t &)

bool	is_configured () override

void	start (const appfwk::DAQModule::CommandData_t &)

void	stop (const appfwk::DAQModule::CommandData_t &)

Public Member Functions inherited from dunedaq::datahandlinglibs::SourceEmulatorConcept
	SourceEmulatorConcept ()

virtual	~SourceEmulatorConcept ()

	SourceEmulatorConcept (const SourceEmulatorConcept &)=delete
	SourceEmulatorConcept is not copy-constructible.

SourceEmulatorConcept &	operator= (const SourceEmulatorConcept &)=delete
	SourceEmulatorConcept is not copy-assginable.

	SourceEmulatorConcept (SourceEmulatorConcept &&)=delete
	SourceEmulatorConcept is not move-constructible.

SourceEmulatorConcept &	operator= (SourceEmulatorConcept &&)=delete
	SourceEmulatorConcept is not move-assignable.

Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject (const MonitorableObject &)=delete

MonitorableObject &	operator= (const MonitorableObject &)=delete

	MonitorableObject (MonitorableObject &&)=delete

MonitorableObject &	operator= (MonitorableObject &&)=delete

virtual	~MonitorableObject ()=default

auto	get_opmon_id () const noexcept

auto	get_opmon_level () const noexcept

Protected Member Functions
void	run_produce ()

virtual void	generate_opmon_data () override

Protected Member Functions inherited from dunedaq::opmonlib::MonitorableObject
	MonitorableObject ()=default

void	register_node (ElementId name, NewNodePtr)

void	publish (google::protobuf::Message &&, CustomOrigin &&co={}, OpMonLevel l=to_level(EntryOpMonLevel::kDefault)) const noexcept

Private Attributes
std::atomic< bool > &	m_run_marker

uint32_t	m_this_apa_number

uint32_t	m_this_link_number

uint64_t	m_time_tick_diff

double	m_dropout_rate

double	m_frame_error_rate

std::atomic< int >	m_packet_count { 0 }

std::atomic< int >	m_packet_count_tot { 0 }

bool	m_sender_is_set = false

std::shared_ptr< std::function< void(ReadoutType &&)> >	m_raw_data_callback

std::unique_ptr< RateLimiter >	m_rate_limiter

std::unique_ptr< FileSourceBuffer >	m_file_source

ErrorBitGenerator	m_error_bit_generator

utilities::ReusableThread	m_producer_thread

std::string	m_name

bool	m_is_configured = false

double	m_rate_khz

uint16_t	m_frames_per_tick

std::vector< bool >	m_dropouts

std::vector< bool >	m_frame_errors

uint	m_dropouts_length

uint	m_frame_errors_length

daqdataformats::SourceID	m_sourceid

int	m_crateid

int	m_slotid

int	m_linkid

bool	m_t0_now

bool	m_generate_periodic_adc_pattern

SourceEmulatorPatternGenerator	m_pattern_generator

uint64_t	m_pattern_generator_previous_ts

uint32_t	m_time_to_wait = 9768

Additional Inherited Members
Public Types inherited from dunedaq::opmonlib::MonitorableObject
using	NodePtr = std::weak_ptr<MonitorableObject>

using	NewNodePtr = std::shared_ptr<MonitorableObject>

using	ElementId = std::string

Static Public Member Functions inherited from dunedaq::opmonlib::MonitorableObject
static bool	publishable_metric (OpMonLevel entry, OpMonLevel system) noexcept

Detailed Description

template<class ReadoutType>
class dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >

Definition at line 68 of file SourceEmulatorModel.hpp.

Constructor & Destructor Documentation

◆ SourceEmulatorModel()

template<class ReadoutType >

dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::SourceEmulatorModel	(	std::string	name,
		std::atomic< bool > &	run_marker,
		uint64_t	time_tick_diff,
		double	dropout_rate,
		double	frame_error_rate,
		double	rate_khz,
		uint16_t	frames_per_tick = 1 )

inlineexplicit

Definition at line 71 of file SourceEmulatorModel.hpp.

    : m_run_marker(run_marker)
    , m_time_tick_diff(time_tick_diff)
    , m_dropout_rate(dropout_rate)
    , m_frame_error_rate(frame_error_rate)
    , m_packet_count{ 0 }
    , m_producer_thread(0)
    , m_name(name)
    , m_rate_khz(rate_khz)
    ,m_frames_per_tick(frames_per_tick)
  {}

Member Function Documentation

◆ conf()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::conf	(	const confmodel::DetectorStream *	stream_conf,
		const appmodel::StreamEmulationParameters *	emu_conf )

virtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 35 of file SourceEmulatorModel.hxx.

{
  if (m_is_configured) {
    TLOG_DEBUG(TLVL_WORK_STEPS) << "This emulator is already configured!";
  } else {
    //m_conf = args.get<module_conf_t>();
    //m_link_conf = link_conf.get<link_conf_t>();
 
    std::mt19937 mt(rand()); // NOLINT(runtime/threadsafe_fn)
    std::uniform_real_distribution<double> dis(0.0, 1.0);
 
    m_sourceid.id = link_conf->get_source_id();
    m_sourceid.subsystem = ReadoutType::subsystem;
 
    m_crateid = link_conf->get_geo_id()->get_crate_id();
    m_slotid = link_conf->get_geo_id()->get_slot_id();
    m_linkid = link_conf->get_geo_id()->get_stream_id();
 
    m_t0_now = emu_params->get_set_t0();
    m_file_source = std::make_unique<FileSourceBuffer>(emu_params->get_input_file_size_limit(), sizeof(ReadoutType));
    try {
      m_file_source->read(emu_params->get_data_file_name());
    } catch (const ers::Issue& ex) {
      ers::fatal(ex);
      throw ConfigurationError(ERS_HERE, m_sourceid, "", ex);
    }
    m_dropouts_length = emu_params->get_random_population_size();
    if (m_dropout_rate == 0.0) {
      m_dropouts = std::vector<bool>(1);
    } else {
      m_dropouts = std::vector<bool>(m_dropouts_length);
    }
    for (size_t i = 0; i < m_dropouts.size(); ++i) {
      m_dropouts[i] = dis(mt) >= m_dropout_rate;
    }
 
    m_frame_errors_length = emu_params->get_random_population_size();
    m_frame_error_rate = emu_params->get_frame_error_rate_hz();
    m_error_bit_generator = ErrorBitGenerator(m_frame_error_rate);
    m_error_bit_generator.generate();
 
    // Generate random ADC pattern
    m_generate_periodic_adc_pattern = emu_params->get_generate_periodic_adc_pattern();
    auto vec_size = emu_params->get_random_population_size();
    if (m_generate_periodic_adc_pattern) {
      TLOG() << "Generated pattern.";
      m_pattern_generator.generate(m_sourceid.id, vec_size);
 
      if (emu_params->get_TP_rate_per_channel() != 0) {
       TLOG() << "TP rate per channel multiplier (base of 100 Hz/ch): " << emu_params->get_TP_rate_per_channel();
       // Define time to wait when adding an ADC above threshold
       // Adding a hit every 9768 gives a total Sent TP rate of approx 100 Hz/wire with WIBEth
        m_time_to_wait = m_time_to_wait / emu_params->get_TP_rate_per_channel();
      }
    }
 
    m_is_configured = true;
  }
  // Configure thread:
  m_producer_thread.set_name("fakeprod", m_sourceid.id);
}

◆ generate_opmon_data()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::generate_opmon_data ( )

overrideprotectedvirtual

Hook for customisable pubblication. The function can throw, exception will be caught by the monitoring thread

Reimplemented from dunedaq::opmonlib::MonitorableObject.

Definition at line 120 of file SourceEmulatorModel.hxx.

{
   opmon::DataSourceInfo info;
   info.set_sum_packets(m_packet_count_tot.load());
   info.set_num_packets(m_packet_count.exchange(0));
 
   this->publish(std::move(info));
}

◆ is_configured()

template<class ReadoutType >

bool dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::is_configured ( )

inlineoverridevirtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 98 of file SourceEmulatorModel.hpp.

98{ return m_is_configured; }

◆ run_produce()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::run_produce ( )

protected

Definition at line 131 of file SourceEmulatorModel.hxx.

{
  TLOG_DEBUG(TLVL_WORK_STEPS) << "Data generation thread " << m_this_link_number << " started";
 
  // pthread_setname_np(pthread_self(), get_name().c_str());
 
  uint offset = 0; // NOLINT(build/unsigned)
  auto& source = m_file_source->get();
 
  uint num_elem = m_file_source->num_elements();
  if (num_elem == 0) {
    TLOG_DEBUG(TLVL_WORK_STEPS) << "No elements to read from buffer! Sleeping...";
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
    num_elem = m_file_source->num_elements();
  }
 
  auto rptr = reinterpret_cast<ReadoutType*>(source.data()); // NOLINT
 
  // set the initial timestamp to a configured value, otherwise just use the timestamp from the header
  uint64_t ts_0 = rptr->get_timestamp(); // NOLINT(build/unsigned)
  if (m_t0_now) {
    auto time_now = std::chrono::system_clock::now().time_since_epoch();
    uint64_t current_time = // NOLINT (build/unsigned)
      std::chrono::duration_cast<std::chrono::microseconds>(time_now).count();
    // FIXME: where do I get the clockspeed from?
    // ts_0 = (m_conf.clock_speed_hz / 100000) * current_time;
    ts_0 = 625 * current_time / 10;
 
  }
  TLOG_DEBUG(TLVL_BOOKKEEPING) << "Using first timestamp: " << ts_0;
  uint64_t timestamp = ts_0; // NOLINT(build/unsigned)
  int dropout_index = 0;
 
  while (m_run_marker.load()) {
    // TLOG() << "Generating " << m_frames_per_tick << " for TS " << timestamp;
    for (uint16_t i = 0; i < m_frames_per_tick; i++) {
      // Which element to push to the buffer
      if (offset == num_elem || (offset + 1) * sizeof(ReadoutType) > source.size()) {
        offset = 0;
      }
 
      bool create_frame = m_dropouts[dropout_index]; // NOLINT(runtime/threadsafe_fn)
      dropout_index = (dropout_index + 1) % m_dropouts.size();
      if (create_frame) {
        ReadoutType payload;
        // Memcpy from file buffer to flat char array
        ::memcpy(static_cast<void*>(&payload),
                 static_cast<void*>(source.data() + offset * sizeof(ReadoutType)),
                 sizeof(ReadoutType));
 
        // Fake timestamp
        payload.fake_timestamps(timestamp, m_time_tick_diff);
 
        // Fake geoid
        payload.fake_geoid(m_crateid, m_slotid, m_linkid);
 
        // Introducing frame errors
        std::vector<uint16_t> frame_errs; // NOLINT(build/unsigned)
        for (size_t i = 0; i < rptr->get_num_frames(); ++i) {
          frame_errs.push_back(m_error_bit_generator.next());
        }
        payload.fake_frame_errors(&frame_errs);
 
        if (m_generate_periodic_adc_pattern) {
          if (timestamp - m_pattern_generator_previous_ts > m_time_to_wait) {
 
            /* Reset the pattern from the beginning if it reaches the maximum
            m_pattern_index++;
            if (m_pattern_index == m_pattern_generator.get_total_size()) {
              m_pattern_index = 0;
            }
            */
            // Set the ADC to the uint16 maximum value
            try {
              payload.fake_adc_pattern(m_pattern_generator.get_channel_number());
            }
            catch (std::exception & ex) {
              //FIXME: should not happen
            }
 
            //TLOG() << "Lift channel " << channel;
 
            // Update the previous timestamp of the pattern generator
            m_pattern_generator_previous_ts = timestamp;
 
          } // timestamp difference
        }
 
        // send it
        try {
          (*m_raw_data_callback)(std::move(payload));
        } catch (ers::Issue& excpt) {
          ers::warning(CannotWriteToQueue(ERS_HERE, m_sourceid, "raw data input queue", excpt));
          // std::runtime_error("Queue timed out...");
        }
 
        // Count packet and limit rate if needed.
        ++offset;
        ++m_packet_count;
        ++m_packet_count_tot;
 
 
      }
    }
    timestamp += m_time_tick_diff * rptr->get_num_frames();
 
 
 
    m_rate_limiter->limit();
  }
  TLOG_DEBUG(TLVL_WORK_STEPS) << "Data generation thread " << m_sourceid.to_string() << " finished";
}

◆ scrap()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::scrap ( const appfwk::DAQModule::CommandData_t & )

inlinevirtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 93 of file SourceEmulatorModel.hpp.

  {
    m_file_source.reset();
    m_is_configured = false;
  }

◆ set_sender()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::set_sender ( const appmodel::DataMoveCallbackConf * conf )

virtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 23 of file SourceEmulatorModel.hxx.

{
  if (!m_sender_is_set) {
    m_raw_data_callback = datahandlinglibs::DataMoveCallbackRegistry::get()->get_callback<ReadoutType>(conf);
    m_sender_is_set = true;
  } else {
    // ers::error();
  }
}

◆ start()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::start ( const appfwk::DAQModule::CommandData_t & )

virtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 99 of file SourceEmulatorModel.hxx.

{
  m_packet_count_tot = 0;
  TLOG_DEBUG(TLVL_WORK_STEPS) << "Starting threads...";
  // FIXME: don't know where to take the slowdown from... m_rate_limiter = std::make_unique<RateLimiter>(m_rate_khz / m_link_conf.slowdown);
  m_rate_limiter = std::make_unique<RateLimiter>(m_rate_khz);
  // m_stats_thread.set_work(&SourceEmulatorModel<ReadoutType>::run_stats, this);
  m_producer_thread.set_work(&SourceEmulatorModel<ReadoutType>::run_produce, this);
}

◆ stop()

template<class ReadoutType >

void dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::stop ( const appfwk::DAQModule::CommandData_t & )

virtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 111 of file SourceEmulatorModel.hxx.

{
  while (!m_producer_thread.get_readiness()) {
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
  }
}

Member Data Documentation

◆ m_crateid

template<class ReadoutType >

int dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_crateid

private

Definition at line 151 of file SourceEmulatorModel.hpp.

◆ m_dropout_rate

template<class ReadoutType >

double dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_dropout_rate

private

Definition at line 118 of file SourceEmulatorModel.hpp.

◆ m_dropouts

template<class ReadoutType >

std::vector<bool> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_dropouts

private

Definition at line 145 of file SourceEmulatorModel.hpp.

◆ m_dropouts_length

template<class ReadoutType >

uint dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_dropouts_length

private

Definition at line 148 of file SourceEmulatorModel.hpp.

◆ m_error_bit_generator

template<class ReadoutType >

ErrorBitGenerator dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_error_bit_generator

private

Definition at line 136 of file SourceEmulatorModel.hpp.

◆ m_file_source

template<class ReadoutType >

std::unique_ptr<FileSourceBuffer> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_file_source

private

Definition at line 135 of file SourceEmulatorModel.hpp.

◆ m_frame_error_rate

template<class ReadoutType >

double dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_frame_error_rate

private

Definition at line 119 of file SourceEmulatorModel.hpp.

◆ m_frame_errors

template<class ReadoutType >

std::vector<bool> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_frame_errors

private

Definition at line 146 of file SourceEmulatorModel.hpp.

◆ m_frame_errors_length

template<class ReadoutType >

uint dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_frame_errors_length

private

Definition at line 149 of file SourceEmulatorModel.hpp.

◆ m_frames_per_tick

template<class ReadoutType >

uint16_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_frames_per_tick

private

Definition at line 143 of file SourceEmulatorModel.hpp.

◆ m_generate_periodic_adc_pattern

template<class ReadoutType >

bool dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_generate_periodic_adc_pattern

private

Definition at line 157 of file SourceEmulatorModel.hpp.

◆ m_is_configured

template<class ReadoutType >

bool dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_is_configured = false

private

Definition at line 141 of file SourceEmulatorModel.hpp.

◆ m_linkid

template<class ReadoutType >

int dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_linkid

private

Definition at line 153 of file SourceEmulatorModel.hpp.

◆ m_name

template<class ReadoutType >

std::string dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_name

private

Definition at line 140 of file SourceEmulatorModel.hpp.

◆ m_packet_count

template<class ReadoutType >

std::atomic<int> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_packet_count { 0 }

private

Definition at line 122 of file SourceEmulatorModel.hpp.

122{ 0 };

◆ m_packet_count_tot

template<class ReadoutType >

std::atomic<int> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_packet_count_tot { 0 }

private

Definition at line 123 of file SourceEmulatorModel.hpp.

123{ 0 };

◆ m_pattern_generator

template<class ReadoutType >

SourceEmulatorPatternGenerator dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_pattern_generator

private

Definition at line 158 of file SourceEmulatorModel.hpp.

◆ m_pattern_generator_previous_ts

template<class ReadoutType >

uint64_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_pattern_generator_previous_ts

private

Definition at line 159 of file SourceEmulatorModel.hpp.

◆ m_producer_thread

template<class ReadoutType >

utilities::ReusableThread dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_producer_thread

private

Definition at line 138 of file SourceEmulatorModel.hpp.

◆ m_rate_khz

template<class ReadoutType >

double dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_rate_khz

private

Definition at line 142 of file SourceEmulatorModel.hpp.

◆ m_rate_limiter

template<class ReadoutType >

std::unique_ptr<RateLimiter> dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_rate_limiter

private

Definition at line 134 of file SourceEmulatorModel.hpp.

◆ m_raw_data_callback

template<class ReadoutType >

std::shared_ptr<std::function<void(ReadoutType&&)> > dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_raw_data_callback

private

Definition at line 128 of file SourceEmulatorModel.hpp.

◆ m_run_marker

template<class ReadoutType >

std::atomic<bool>& dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_run_marker

private

Definition at line 111 of file SourceEmulatorModel.hpp.

◆ m_sender_is_set

template<class ReadoutType >

bool dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_sender_is_set = false

private

Definition at line 127 of file SourceEmulatorModel.hpp.

◆ m_slotid

template<class ReadoutType >

int dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_slotid

private

Definition at line 152 of file SourceEmulatorModel.hpp.

◆ m_sourceid

template<class ReadoutType >

daqdataformats::SourceID dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_sourceid

private

Definition at line 150 of file SourceEmulatorModel.hpp.

◆ m_t0_now

template<class ReadoutType >

bool dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_t0_now

private

Definition at line 155 of file SourceEmulatorModel.hpp.

◆ m_this_apa_number

template<class ReadoutType >

uint32_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_this_apa_number

private

Definition at line 114 of file SourceEmulatorModel.hpp.

◆ m_this_link_number

template<class ReadoutType >

uint32_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_this_link_number

private

Definition at line 115 of file SourceEmulatorModel.hpp.

◆ m_time_tick_diff

template<class ReadoutType >

uint64_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_time_tick_diff

private

Definition at line 117 of file SourceEmulatorModel.hpp.

◆ m_time_to_wait

template<class ReadoutType >

uint32_t dunedaq::datahandlinglibs::SourceEmulatorModel< ReadoutType >::m_time_to_wait = 9768

private

Definition at line 161 of file SourceEmulatorModel.hpp.

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

/github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/models/SourceEmulatorModel.hpp
/github/workspace/dunedaq/sourcecode/datahandlinglibs/include/datahandlinglibs/models/detail/SourceEmulatorModel.hxx

Public Member Functions

Protected Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ SourceEmulatorModel()

Member Function Documentation

◆ conf()

◆ generate_opmon_data()

◆ is_configured()

◆ run_produce()

◆ scrap()

◆ set_sender()

◆ start()

◆ stop()

Member Data Documentation

◆ m_crateid

◆ m_dropout_rate

◆ m_dropouts

◆ m_dropouts_length

◆ m_error_bit_generator

◆ m_file_source

◆ m_frame_error_rate

◆ m_frame_errors

◆ m_frame_errors_length

◆ m_frames_per_tick

◆ m_generate_periodic_adc_pattern

◆ m_is_configured

◆ m_linkid

◆ m_name

◆ m_packet_count

◆ m_packet_count_tot

◆ m_pattern_generator

◆ m_pattern_generator_previous_ts

◆ m_producer_thread

◆ m_rate_khz

◆ m_rate_limiter

◆ m_raw_data_callback

◆ m_run_marker

◆ m_sender_is_set

◆ m_slotid

◆ m_sourceid

◆ m_t0_now

◆ m_this_apa_number

◆ m_this_link_number

◆ m_time_tick_diff

◆ m_time_to_wait