DDS publisher thread class that supports (re)publishing of MUDPI samples. More...

Inheritance diagram for rtctk::telRepub::PubThreadMudpi:

Public Member Functions
	PubThreadMudpi (DataWriter &data_writer, componentFramework::ServiceContainer &service, CfgPubThreadMudpi &cfg, WranglerFunction &&wrangler)
	Spawns publisher thread and sets up performance counters for monitoring.

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

void	RunAsync () override
	Enable publishing data.

MudpiProcessor &	GetMudpiProcessor ()
	Get MudpiProcessor.

std::shared_ptr< Queue >	GetQueue ()

bool	Monitor () override

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.

void	IdleAsync ()
	Disable publishing data.

std::string	GetTopicName ()

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 (re)publishing of MUDPI samples.

Constructor & Destructor Documentation

rtctk::telRepub::PubThreadMudpi::PubThreadMudpi	(	DataWriter &	data_writer,
		componentFramework::ServiceContainer &	service,
		CfgPubThreadMudpi &	cfg,
		WranglerFunction &&	wrangler )

Spawns publisher thread and sets up performance counters for monitoring.

Parameters

[in,out]	data_writer	DDS data writer.
[in,out]	service	Component service.
[in]	cfg	MUDPI publisher thread configuration
[in]	wrangler	The wrangler function to perform optional low level data transformations.

rtctk::telRepub::PubThreadMudpi::~PubThreadMudpi ( )

virtual

Joins publisher thread and prints some statistics information.

MudpiProcessor & rtctk::telRepub::PubThreadMudpi::GetMudpiProcessor ( )

std::shared_ptr< Queue > rtctk::telRepub::PubThreadMudpi::GetQueue ( )

bool rtctk::telRepub::PubThreadMudpi::Monitor ( )

overridevirtual

void rtctk::telRepub::PubThreadMudpi::RunAsync ( )

overridevirtual

Enable publishing data.

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