rtctk::telRepub Namespace Reference

Classes
struct	ErrorCode
struct	MockComponentMetrics
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	TelRepubBusinessLogic
	Telemetry Republisher business logic. More...
class	UdpReceiver
	Receiving UDP data asynchronously and forwards received packets to provided packet processors. More...

Typedefs
using	LifeCycle = Runnable< RtcComponent >
using	RepubWranglerFactory = std::function< WranglerFunction(int32_t)>
using	WranglerFunction = 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.
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
uint32_t const	MAX_TOPIC_SIZE = 2560000
constexpr int	DATAGRAM_SIZE = 9500
	maximal UDP datagram size

Typedef Documentation

LifeCycle

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

Queue

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

QueueElement

using rtctk::telRepub::QueueElement = typedef PacketFrame

QueuePtr

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

RepubWranglerFactory

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

WranglerFunction

using rtctk::telRepub::WranglerFunction = typedef 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 int rtctk::telRepub::DATAGRAM_SIZE = 9500

constexpr

maximal UDP datagram size

MAX_TOPIC_SIZE

uint32_t const rtctk::telRepub::MAX_TOPIC_SIZE = 2560000