#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	acquire_callback () override
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.
void	set_sink_config (const appmodel::DataMoveCallbackConf *sink_conf)
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
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
Public Attributes inherited from dunedaq::datahandlinglibs::SourceEmulatorConcept
const appmodel::DataMoveCallbackConf *	m_sink_conf

Detailed Description

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

Definition at line 69 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 72 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

◆ acquire_callback()

template<class ReadoutType>

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

overridevirtual

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>(SourceEmulatorConcept::m_sink_conf);
    m_sender_is_set = true;
  } else {
    // ers::error();
  }
}

◆ 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 36 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 123 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 100 of file SourceEmulatorModel.hpp.

100{ return m_is_configured; }

◆ run_produce()

template<class ReadoutType>

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

protected

Definition at line 134 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;
  uint64_t number_pattern_hits_generated = 0;
  // 64 total channels, placing on slot 0 gives 64 available slots.
  const uint64_t max_tps_per_frame = 64;
 
  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) {
          uint64_t number_pattern_hits_expected = (timestamp - ts_0) / m_time_to_wait;
 
          // Calculate how many TPs to generate in this frame
          uint64_t tps_this_frame = 0;
          if (number_pattern_hits_expected > number_pattern_hits_generated) {
            tps_this_frame = number_pattern_hits_expected - number_pattern_hits_generated;
          }
 
          if (tps_this_frame > max_tps_per_frame) {
            tps_this_frame = max_tps_per_frame;
          }
 
          // Distribute TPs across channels via the pattern generator.
          for (uint64_t tp_idx = 0; tp_idx < tps_this_frame; ++tp_idx) {
            int channel = m_pattern_generator.get_channel_number();
            // The pattern generator draws channel in range 0-63, current
            // behaviour for frame type with 32 channels is silent dropping.
            try {
              payload.fake_adc_pattern(channel);
            } catch (const std::out_of_range&) {
            }
          }
 
          // Count the number of patterns attempted to inject. Prevents
          // expected - generated deficit from accumulating in case of
          // injection failure.
          number_pattern_hits_generated += tps_this_frame;
        }
 
        // 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 95 of file SourceEmulatorModel.hpp.

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

◆ start()

template<class ReadoutType>

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

virtual

Implements dunedaq::datahandlinglibs::SourceEmulatorConcept.

Definition at line 101 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 114 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 153 of file SourceEmulatorModel.hpp.

◆ m_dropout_rate

template<class ReadoutType>

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

private

Definition at line 120 of file SourceEmulatorModel.hpp.

◆ m_dropouts

template<class ReadoutType>

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

private

Definition at line 147 of file SourceEmulatorModel.hpp.

◆ m_dropouts_length

template<class ReadoutType>

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

private

Definition at line 150 of file SourceEmulatorModel.hpp.

◆ m_error_bit_generator

template<class ReadoutType>

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

private

Definition at line 138 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 137 of file SourceEmulatorModel.hpp.

◆ m_frame_error_rate

template<class ReadoutType>

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

private

Definition at line 121 of file SourceEmulatorModel.hpp.

◆ m_frame_errors

template<class ReadoutType>

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

private

Definition at line 148 of file SourceEmulatorModel.hpp.

◆ m_frame_errors_length

template<class ReadoutType>

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

private

Definition at line 151 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 145 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 159 of file SourceEmulatorModel.hpp.

◆ m_is_configured

template<class ReadoutType>

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

private

Definition at line 143 of file SourceEmulatorModel.hpp.

◆ m_linkid

template<class ReadoutType>

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

private

Definition at line 155 of file SourceEmulatorModel.hpp.

◆ m_name

template<class ReadoutType>

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

private

Definition at line 142 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 124 of file SourceEmulatorModel.hpp.

◆ m_packet_count_tot

template<class ReadoutType>

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

private

Definition at line 125 of file SourceEmulatorModel.hpp.

◆ m_pattern_generator

template<class ReadoutType>

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

private

Definition at line 160 of file SourceEmulatorModel.hpp.

◆ m_producer_thread

template<class ReadoutType>

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

private

Definition at line 140 of file SourceEmulatorModel.hpp.

◆ m_rate_khz

template<class ReadoutType>

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

private

Definition at line 144 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 136 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 130 of file SourceEmulatorModel.hpp.

◆ m_run_marker

template<class ReadoutType>

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

private

Definition at line 113 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 129 of file SourceEmulatorModel.hpp.

◆ m_slotid

template<class ReadoutType>

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

private

Definition at line 154 of file SourceEmulatorModel.hpp.

◆ m_sourceid

template<class ReadoutType>

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

private

Definition at line 152 of file SourceEmulatorModel.hpp.

◆ m_t0_now

template<class ReadoutType>

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

private

Definition at line 157 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 116 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 117 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 119 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 162 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

◆ acquire_callback()

◆ conf()

◆ generate_opmon_data()

◆ is_configured()

◆ run_produce()

◆ scrap()

◆ 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_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