DDS publisher thread class that supports simulation mode. More...

Inheritance diagram for rtctk::telRepub::PubThreadSim:

Public Member Functions
	PubThreadSim (DataWriter &data_writer, componentFramework::ServiceContainer &service, const numapp::NumaPolicies &thread_policies, std::uint32_t sample_id_increment, std::uint16_t sim_freq, std::uint32_t sim_payload_size)
	Spawns publisher thread and sets up performance counters for monitoring.

virtual	~PubThreadSim ()
	Joins publisher thread and prints some statistics information.

Public Member Functions inherited from rtctk::telRepub::PubThread
	PubThread (DataWriter &data_writer, componentFramework::ServiceContainer &service, const numapp::NumaPolicies &thread_policies, std::uint32_t sample_id_increment)
	Spawns publisher thread and sets up performance counters for monitoring.

virtual	~PubThread ()
	Joins publisher thread and prints some statistics information.

virtual void	RunAsync ()
	Enable publishing data.

void	IdleAsync ()
	Disable publishing data.

std::string	GetTopicName ()

virtual bool	Monitor ()

Additional Inherited Members
Protected Types inherited from rtctk::telRepub::PubThread
enum class	State { Idle , Run , Exit }

Protected Attributes inherited from rtctk::telRepub::PubThread
std::string	m_topic_name

log4cplus::Logger	m_logger

std::atomic< State >	m_requested_state

std::thread	m_thread

std::string	m_thread_name

DataWriter &	m_data_writer

ComponentMetricsIf &	m_metrics

componentFramework::AlertSource	m_topic_publish_alert
	Alerts.

componentFramework::AlertSource	m_wrangler_alert

perfc::CounterI64	m_pc_published_samples
	Diverse Performance counters.

perfc::ScopedRegistration	m_pc_published_samples_reg

perfc::CounterI64	m_pc_publication_errors

perfc::ScopedRegistration	m_pc_publication_errors_reg

perfc::CounterI64	m_pc_last_sample_id_published

perfc::ScopedRegistration	m_pc_last_sample_id_published_reg

std::unique_ptr< DurationMonitor<> >	m_dur_mon

std::uint32_t	m_expected_sample_id_increment

Static Protected Attributes inherited from rtctk::telRepub::PubThread
static std::atomic< std::uint16_t >	s_count = 0

Detailed Description

DDS publisher thread class that supports simulation mode.

Constructor & Destructor Documentation

rtctk::telRepub::PubThreadSim::PubThreadSim	(	DataWriter &	data_writer,
		componentFramework::ServiceContainer &	service,
		const numapp::NumaPolicies &	thread_policies,
		std::uint32_t	sample_id_increment,
		std::uint16_t	sim_freq,
		std::uint32_t	sim_payload_size )

Spawns publisher thread and sets up performance counters for monitoring.

Parameters

[in,out]	data_writer	DDS data writer.
[in,out]	service	Component service.
[in]	thread_policies	Thread policies to apply to the publisher thread.
[in]	sample_id_increment	Subsample factor (1 or larger).
[in]	sim_freq	Set this to a value > 0 Hz to enable simulation mode.
[in]	sim_payload_size	Payload size if simulation mode is enabled.

rtctk::telRepub::PubThreadSim::~PubThreadSim ( )

virtual

Joins publisher thread and prints some statistics information.

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