Telemetry Republisher business logic. More...

#include <telRepubBusinessLogic.hpp>

Inheritance diagram for rtctk::telRepub::TelRepubBusinessLogic:

Classes
struct	DdsPublisherContext

Public Types
using	ComponentType = LifeCycle

Public Member Functions
	TelRepubBusinessLogic (const std::string &name, ServiceContainer &services)

virtual	~TelRepubBusinessLogic ()

void	ActivityStarting (StopToken st) 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, Payload args) override

bool	GuardUpdatingAllowed (Payload args) override

Protected Member Functions
std::map< mudpi::uint16_t, PubThreadBase<> & >	BuildUdpReceiverAssociation (std::uint16_t receiver_idx)
	Creates a map of associated DDS publishers for provided UDP receiver index receiver_idx. More...

void	CreateMudpiReceivers ()
	creates UDPI receivers (rtctk::telRepub::UdpReceiver) reading configuration from run-time repository More...

void	DeleteMudpiReceivers ()
	deletes UDPI receivers (rtctk::telRepub::UdpReceiver) More...

void	CreateDdsPubs ()
	creates DDS publishers (rtctk::componentFramework::DdsPub) reading configuration from run-time repository More...

void	DeleteDdsPubs ()
	deletes DDS publishers (rtctk::componentFramework::DdsPub) More...

Protected Attributes
const std::string	m_name
	component name More...

uint16_t	m_sim_freq
	Determines if this is simulating DDS publishing (>0) and which frequency. More...

std::unique_ptr< DdsPub >	m_dds_pub

rtctk::componentFramework::ServiceContainer &	m_service_container
	reference to container services needed to access run-time repository for configuration, and other services More...

componentFramework::ComponentMetricsIf &	m_component_metrics
	references to component metrices service More...

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

std::vector< DdsPublisherContext >	m_pub_threads
	DDS publishers. More...

Detailed Description

Telemetry Republisher business logic.

Member Typedef Documentation

◆ ComponentType

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

Constructor & Destructor Documentation

◆ TelRepubBusinessLogic()

rtctk::telRepub::TelRepubBusinessLogic::TelRepubBusinessLogic	(	const std::string &	name,
		ServiceContainer &	services
	)

◆ ~TelRepubBusinessLogic()

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

virtual

Member Function Documentation

◆ 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,
		Payload	args
	)

override

◆ BuildUdpReceiverAssociation()

std::map< mudpi::uint16_t, PubThreadBase<> & > rtctk::telRepub::TelRepubBusinessLogic::BuildUdpReceiverAssociation ( std::uint16_t receiver_idx )

protected

Creates a map of associated DDS publishers for provided UDP receiver index receiver_idx.

◆ CreateDdsPubs()

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

protected

creates DDS publishers (rtctk::componentFramework::DdsPub) reading configuration from run-time repository

@exception_unsafe

◆ CreateMudpiReceivers()

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

protected

creates UDPI receivers (rtctk::telRepub::UdpReceiver) reading configuration from run-time 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)

◆ GuardUpdatingAllowed()

bool rtctk::telRepub::TelRepubBusinessLogic::GuardUpdatingAllowed ( Payload args )

override

Member Data Documentation

◆ m_component_metrics

componentFramework::ComponentMetricsIf& rtctk::telRepub::TelRepubBusinessLogic::m_component_metrics

protected

references to component metrices service

◆ m_dds_pub

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

protected

◆ m_name

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

protected

component name

◆ m_pub_threads

std::vector<DdsPublisherContext> rtctk::telRepub::TelRepubBusinessLogic::m_pub_threads

protected

DDS publishers.

◆ m_service_container

rtctk::componentFramework::ServiceContainer& rtctk::telRepub::TelRepubBusinessLogic::m_service_container

protected

reference to container services needed to access run-time repository for configuration, and other services

◆ m_sim_freq

uint16_t rtctk::telRepub::TelRepubBusinessLogic::m_sim_freq

protected

Determines if this is simulating DDS publishing (>0) and which frequency.

◆ m_udp_receivers

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

protected

vector of UDP receivers

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

reusableComponents/telRepub/src/telRepubBusinessLogic.hpp
reusableComponents/telRepub/src/telRepubBusinessLogic.cpp

Classes

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

◆ ComponentType

Constructor & Destructor Documentation

◆ TelRepubBusinessLogic()

◆ ~TelRepubBusinessLogic()

Member Function Documentation

◆ ActivityDisabling()

◆ ActivityEnabling()

◆ ActivityGoingIdle()

◆ ActivityGoingRunning()

◆ ActivityInitialising()

◆ ActivityRecovering()

◆ ActivityRunning()

◆ ActivityStarting()

◆ ActivityUpdating()

◆ BuildUdpReceiverAssociation()

◆ CreateDdsPubs()

◆ CreateMudpiReceivers()

◆ DeleteDdsPubs()

◆ DeleteMudpiReceivers()

◆ GuardUpdatingAllowed()

Member Data Documentation

◆ m_component_metrics

◆ m_dds_pub

◆ m_name

◆ m_pub_threads

◆ m_service_container

◆ m_sim_freq

◆ m_udp_receivers