Processing MUDPI data received by UDP receiver: rtctk::telRepub::UdpReceiver. More...

Public Member Functions
	MudpiProcessor (mudpi::uint16_t mudpi_topic_id, PubThreadBase<> &pub, componentFramework::ComponentMetricsIf &metrics, uint32_t statistic_msg_update_rate=60)
	MUDPI Processor constructor. More...

	MudpiProcessor (MudpiProcessor const &rhs)=delete
	Copy construction. More...

MudpiProcessor &	operator= (MudpiProcessor const &rhs)=delete

virtual	~MudpiProcessor ()

std::error_code	ProcessMudpi (mudpi::mudpiHeader *packet)
	Here the actual processing is done (frame by frame (MUDPI datagram)). More...

void	Statistics ()
	Dump statistics. More...

Detailed Description

Processing MUDPI data received by UDP receiver: rtctk::telRepub::UdpReceiver.

Checks for missing frames, and samples.
Assembles MUDPI frames (payload) to agnostic DDS topic, and pushes it to the queue for publishing via DDS.

Constructor & Destructor Documentation

rtctk::telRepub::MudpiProcessor::MudpiProcessor	(	mudpi::uint16_t	mudpi_topic_id,
		PubThreadBase<> &	pub,
		componentFramework::ComponentMetricsIf &	metrics,
		uint32_t	statistic_msg_update_rate = `60`
	)

explicit

MUDPI Processor constructor.

Parameters

mudpi_topic_id	MUDPI topic Id
pub	reference to publisher thread
metrics	reference to component Metrics Service
statistic_msg_update_rate	update rate for statistic message: default every 60s

rtctk::telRepub::MudpiProcessor::MudpiProcessor ( MudpiProcessor const & rhs )

delete

Copy construction.

It needs to be redefined because we use atomics.

rtctk::telRepub::MudpiProcessor::~MudpiProcessor ( )

virtual

MudpiProcessor& rtctk::telRepub::MudpiProcessor::operator= ( MudpiProcessor const & rhs )

delete

std::error_code rtctk::telRepub::MudpiProcessor::ProcessMudpi ( mudpi::mudpiHeader * packet )

Here the actual processing is done (frame by frame (MUDPI datagram)).

Parameters

packet MUDPI packet to process.

Returns: In case of an error: missing frame, sample, frame out of range ... returns an error code of type: rtctk::telRepub::MudpiProcessingError

... but we report every time (frame) until synchronized again

void rtctk::telRepub::MudpiProcessor::Statistics ( )

Dump statistics.

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