Telemetry Republisher business logic. More...

#include <telRepubBusinessLogic.hpp>

Inheritance diagram for rtctk::telRepub::TelRepubBusinessLogic:

Public Types
using	ComponentType = LifeCycle

Public Member Functions
	TelRepubBusinessLogic (std::string name, ServiceContainer &service, RepubWranglerFactory &&factory=[](auto x) { return nullptr;})

virtual	~TelRepubBusinessLogic ()

void	ActivityStarting (StopToken st) override

void	ActionClearAlerts () override

void	ActivityRecovering (StopToken st) override

void	ActivityInitialising (StopToken st) override

void	ActivityEnabling (StopToken st) override

void	ActivityDisabling (StopToken st) override

void	ActivityGoingRunning (StopToken st) override

void	ActivityGoingIdle (StopToken st) override

void	ActivityRunning (StopToken st) override

void	ActivityUpdating (StopToken st, const JsonPayload &args) override

bool	GuardUpdatingAllowed (const JsonPayload &args) override

Protected Member Functions
void	ReadGlobalCfg ()
	Reads Global configuration.

void	CreateMudpiReceivers ()
	Creates MUDPI receivers (rtctk::telRepub::UdpReceiver) incl corresponding Publisher threads, reading configuration from the Runtime Configuration Repository.

void	DeleteMudpiReceivers ()
	Deletes UDPI receivers (rtctk::telRepub::UdpReceiver).

PubThreadMudpi &	CreatePubThread (const std::string &dds_topic_path_static)
	Creates Publisher Thread (rtctk::telRepub::PubThread), reading configuration from the Runtime Configuration Repository.

void	CreateSimPubThreads ()
	Creates all Simulated Publisher Threads (rtctk::telRepub::PubThread), reading configuration from the Runtime Configuration Repository.

void	DeletePubThreads ()
	Deletes all (incl.

void	CreateDdsPubs ()
	Creates DDS publishers (rtctk::componentFramework::DdsPub), reading configuration from the Runtime Configuration Repository.

void	DeleteDdsPubs ()
	Deletes DDS publishers (rtctk::componentFramework::DdsPub).

void	Monitor ()
	Monitoring alerts etc that is executed in a loop.

Protected Attributes
log4cplus::Logger &	m_logger
	Logger object reference of this class.

const std::string	m_name
	Component name.

std::unique_ptr< DdsPub >	m_dds_pub

rtctk::componentFramework::ServiceContainer &	m_service
	Reference to container service.

componentFramework::RuntimeRepoIf &	m_rtr
	Reference to run-time repository needed to access the configuration.

componentFramework::ComponentMetricsIf &	m_metrics
	references to component metrices service

AlertServiceIf &	m_alerts
	references to component alert service

std::vector< std::unique_ptr< UdpReceiver > >	m_udp_receivers
	vector of UDP receivers

std::vector< std::unique_ptr< PubThread > >	m_pub_threads
	DDS publishers.

RepubWranglerFactory	m_wrangler_factory
	Factory for wrangler functions, depending on the topic id.

std::chrono::milliseconds	m_monitor_report_interval_ms = std::chrono::milliseconds(1000)
	Monitoring report interval in msecs.

std::optional< numapp::NumaPolicies >	monitoring_thread_policies = std::nullopt
	Monitoring thread policies.

Detailed Description

Telemetry Republisher business logic.

Member Typedef Documentation

◆ ComponentType

using rtctk::telRepub::TelRepubBusinessLogic::ComponentType = LifeCycle

Constructor & Destructor Documentation

◆ TelRepubBusinessLogic()

rtctk::telRepub::TelRepubBusinessLogic::TelRepubBusinessLogic	(	std::string	name,
		ServiceContainer &	service,
		RepubWranglerFactory &&	factory = [](auto x) { return nullptr; } )

◆ ~TelRepubBusinessLogic()

rtctk::telRepub::TelRepubBusinessLogic::~TelRepubBusinessLogic ( )

virtual

Member Function Documentation

◆ ActionClearAlerts()

void rtctk::telRepub::TelRepubBusinessLogic::ActionClearAlerts ( )

override

◆ ActivityDisabling()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityDisabling ( StopToken st )

override

◆ ActivityEnabling()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityEnabling ( StopToken st )

override

◆ ActivityGoingIdle()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityGoingIdle ( StopToken st )

overridevirtual

Reimplemented from rtctk::componentFramework::Runnable< Super >::BizLogicIf.

◆ ActivityGoingRunning()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityGoingRunning ( StopToken st )

overridevirtual

Reimplemented from rtctk::componentFramework::Runnable< Super >::BizLogicIf.

◆ ActivityInitialising()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityInitialising ( StopToken st )

override

◆ ActivityRecovering()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityRecovering ( StopToken st )

overridevirtual

Reimplemented from rtctk::componentFramework::Runnable< Super >::BizLogicIf.

◆ ActivityRunning()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityRunning ( StopToken st )

overridevirtual

Reimplemented from rtctk::componentFramework::Runnable< Super >::BizLogicIf.

◆ ActivityStarting()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityStarting ( StopToken st )

override

◆ ActivityUpdating()

void rtctk::telRepub::TelRepubBusinessLogic::ActivityUpdating	(	StopToken	st,
		const JsonPayload &	args )

override

◆ CreateDdsPubs()

void rtctk::telRepub::TelRepubBusinessLogic::CreateDdsPubs ( )

protected

Creates DDS publishers (rtctk::componentFramework::DdsPub), reading configuration from the Runtime Configuration Repository.

◆ CreateMudpiReceivers()

void rtctk::telRepub::TelRepubBusinessLogic::CreateMudpiReceivers ( )

protected

Creates MUDPI receivers (rtctk::telRepub::UdpReceiver) incl corresponding Publisher threads, reading configuration from the Runtime Configuration Repository.

◆ CreatePubThread()

PubThreadMudpi & rtctk::telRepub::TelRepubBusinessLogic::CreatePubThread ( const std::string & dds_topic_path_static )

protected

Creates Publisher Thread (rtctk::telRepub::PubThread), reading configuration from the Runtime Configuration Repository.

Parameters

dds_topic_path_static path to dds_topic/<topic-name> static cfg

◆ CreateSimPubThreads()

void rtctk::telRepub::TelRepubBusinessLogic::CreateSimPubThreads ( )

protected

Creates all Simulated Publisher Threads (rtctk::telRepub::PubThread), reading configuration from the Runtime Configuration Repository.

◆ DeleteDdsPubs()

void rtctk::telRepub::TelRepubBusinessLogic::DeleteDdsPubs ( )

protected

Deletes DDS publishers (rtctk::componentFramework::DdsPub).

◆ DeleteMudpiReceivers()

void rtctk::telRepub::TelRepubBusinessLogic::DeleteMudpiReceivers ( )

protected

Deletes UDPI receivers (rtctk::telRepub::UdpReceiver).

◆ DeletePubThreads()

void rtctk::telRepub::TelRepubBusinessLogic::DeletePubThreads ( )

protected

Deletes all (incl.

Sim) Pub Threads.

◆ GuardUpdatingAllowed()

bool rtctk::telRepub::TelRepubBusinessLogic::GuardUpdatingAllowed ( const JsonPayload & args )

override

◆ Monitor()

void rtctk::telRepub::TelRepubBusinessLogic::Monitor ( )

protected

Monitoring alerts etc that is executed in a loop.

◆ ReadGlobalCfg()

void rtctk::telRepub::TelRepubBusinessLogic::ReadGlobalCfg ( )

protected

Reads Global configuration.

Member Data Documentation

◆ m_alerts

AlertServiceIf& rtctk::telRepub::TelRepubBusinessLogic::m_alerts

protected

references to component alert service

◆ m_dds_pub

std::unique_ptr<DdsPub> rtctk::telRepub::TelRepubBusinessLogic::m_dds_pub

protected

◆ m_logger

log4cplus::Logger& rtctk::telRepub::TelRepubBusinessLogic::m_logger

protected

Logger object reference of this class.

◆ m_metrics

componentFramework::ComponentMetricsIf& rtctk::telRepub::TelRepubBusinessLogic::m_metrics

protected

references to component metrices service

◆ m_monitor_report_interval_ms

std::chrono::milliseconds rtctk::telRepub::TelRepubBusinessLogic::m_monitor_report_interval_ms = std::chrono::milliseconds(1000)

protected

Monitoring report interval in msecs.

◆ m_name

const std::string rtctk::telRepub::TelRepubBusinessLogic::m_name

protected

Component name.

◆ m_pub_threads

std::vector<std::unique_ptr<PubThread> > rtctk::telRepub::TelRepubBusinessLogic::m_pub_threads

protected

DDS publishers.

◆ m_rtr

componentFramework::RuntimeRepoIf& rtctk::telRepub::TelRepubBusinessLogic::m_rtr

protected

Reference to run-time repository needed to access the configuration.

◆ m_service

rtctk::componentFramework::ServiceContainer& rtctk::telRepub::TelRepubBusinessLogic::m_service

protected

Reference to container service.

◆ m_udp_receivers

std::vector<std::unique_ptr<UdpReceiver> > rtctk::telRepub::TelRepubBusinessLogic::m_udp_receivers

protected

vector of UDP receivers

◆ m_wrangler_factory

RepubWranglerFactory rtctk::telRepub::TelRepubBusinessLogic::m_wrangler_factory

protected

Factory for wrangler functions, depending on the topic id.

◆ monitoring_thread_policies

std::optional<numapp::NumaPolicies> rtctk::telRepub::TelRepubBusinessLogic::monitoring_thread_policies = std::nullopt

protected

Monitoring thread policies.

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

reusableComponents/telRepub/lib/src/include/rtctk/telRepub/telRepubBusinessLogic.hpp
reusableComponents/telRepub/lib/src/telRepubBusinessLogic.cpp

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

◆ ComponentType

Constructor & Destructor Documentation

◆ TelRepubBusinessLogic()

◆ ~TelRepubBusinessLogic()

Member Function Documentation

◆ ActionClearAlerts()

◆ ActivityDisabling()

◆ ActivityEnabling()

◆ ActivityGoingIdle()

◆ ActivityGoingRunning()

◆ ActivityInitialising()

◆ ActivityRecovering()

◆ ActivityRunning()

◆ ActivityStarting()

◆ ActivityUpdating()

◆ CreateDdsPubs()

◆ CreateMudpiReceivers()

◆ CreatePubThread()

◆ CreateSimPubThreads()

◆ DeleteDdsPubs()

◆ DeleteMudpiReceivers()

◆ DeletePubThreads()

◆ GuardUpdatingAllowed()

◆ Monitor()

◆ ReadGlobalCfg()

Member Data Documentation

◆ m_alerts

◆ m_dds_pub

◆ m_logger

◆ m_metrics

◆ m_monitor_report_interval_ms

◆ m_name

◆ m_pub_threads

◆ m_rtr

◆ m_service

◆ m_udp_receivers

◆ m_wrangler_factory

◆ monitoring_thread_policies