rtctk::telRepub Namespace Reference

Classes
struct	CfgMudpiProc
	Structure to hold MudpiProcessor's configuration. More...
struct	CfgPubThread
	Structure to hold PubThread's configuration. More...
struct	CfgPubThreadMudpi
	Structure to hold PubThreadMudpi's configuration. More...
struct	ErrorCode
class	MudpiProcessor
	Processing MUDPI data received by UDP receiver: rtctk::telRepub::UdpReceiver. More...
struct	MudpiProcessorError
	MUDPI Processor errors. More...
struct	PacketFrame
class	PubThread
	DDS publisher thread class that supports production and simulation mode. More...
class	PubThreadMudpi
	DDS publisher thread class that supports (re)publishing of MUDPI samples. More...
class	PubThreadSim
	DDS publisher thread class that supports simulation mode. More...
class	TelRepubBusinessLogic
	Telemetry Republisher business logic. More...
class	UdpReceiver
	Receiving UDP data asynchronously and forwards received packets to provided packet processors. More...
struct	UdpReceiverCfg
	Structure to hold UDP receiver's configuration. More...

Typedefs
using	LifeCycle = Runnable<RtcComponent>
using	RepubWranglerFactory = std::function<WranglerFunction(int32_t)>
using	WranglerFunction
	The wrangler function that is called with a span of spans containing the payload and an vector where the wrangled data should be written to.
using	QueueElement = PacketFrame
using	Queue = tbb::concurrent_bounded_queue<QueueElement>
using	QueuePtr = std::shared_ptr<Queue>

Functions
std::error_code	DefaultWrangler (const gsl::span< const gsl::span< const uint8_t > > input, std::vector< uint8_t > &output)
std::ostream &	operator<< (std::ostream &stream, const std::vector< std::string > &data)

Variables
constexpr uint16_t	DATAGRAM_SIZE = 9500
	maximal UDP datagram size

Typedef Documentation

LifeCycle

using rtctk::telRepub::LifeCycle = Runnable<RtcComponent>

Queue

using rtctk::telRepub::Queue = tbb::concurrent_bounded_queue<QueueElement>

QueueElement

using rtctk::telRepub::QueueElement = PacketFrame

QueuePtr

using rtctk::telRepub::QueuePtr = std::shared_ptr<Queue>

RepubWranglerFactory

using rtctk::telRepub::RepubWranglerFactory = std::function<WranglerFunction(int32_t)>

WranglerFunction

using rtctk::telRepub::WranglerFunction

Initial value:

 std::function<std::error_code(
    const gsl::span<const gsl::span<const uint8_t>>, std::vector<uint8_t>&)>

The wrangler function that is called with a span of spans containing the payload and an vector where the wrangled data should be written to.

Function Documentation

DefaultWrangler()

std::error_code rtctk::telRepub::DefaultWrangler	(	const gsl::span< const gsl::span< const uint8_t > >	input,
		std::vector< uint8_t > &	output )

operator<<()

std::ostream & rtctk::telRepub::operator<<	(	std::ostream &	stream,
		const std::vector< std::string > &	data )

Variable Documentation

DATAGRAM_SIZE

constexpr uint16_t rtctk::telRepub::DATAGRAM_SIZE = 9500

constexpr

maximal UDP datagram size