Inheritance diagram for ddt::DdtDataProducer:

Public Member Functions
	DdtDataProducer (const std::string &data_stream_identifier, DdtLogger *logger)

	DdtDataProducer (const std::string &data_stream_identifier, int32_t latency, int32_t deadline, std::string publishing_uri, DdtLogger *logger)

virtual	~DdtDataProducer ()

void	Publish (DataPacket data_packet)

void	Notify (NotificationType)

std::string	get_publishing_uri ()

Public Member Functions inherited from ddt::DdtProducerConsumerBase
	DdtProducerConsumerBase (DdtLogger *logger)

virtual	~DdtProducerConsumerBase ()

Additional Inherited Members
Public Types inherited from ddt::DdtProducerConsumerBase
enum	NotificationType { NEW_DATA, PUB_REG, PUB_UNREG, SHM_DEL }

Protected Member Functions inherited from ddt::DdtProducerConsumerBase
void	LoadDefaults ()

void	ReadIni ()

void	PrintConfigValues ()

int32_t	GetFreePort ()

Protected Attributes inherited from ddt::DdtProducerConsumerBase
int32_t	min_port

int32_t	max_port

DdtLogger *	logger

const int	MIN_PORT_DEFAULT = 5100

const int	MAX_PORT_DEFAULT = 5500

const int	MIN_RANGE = 3

const int	LINE_LENGTH = 256

Detailed Description

This class provides the functionality to publish data over network and enables sending new data notifications.

Constructor & Destructor Documentation

DdtDataProducer::DdtDataProducer	(	const std::string &	data_stream_identifier,
		DdtLogger *	logger
	)

Constructor

DdtDataProducer::DdtDataProducer	(	const std::string &	data_stream_identifier,
		int32_t	latency,
		int32_t	deadline,
		std::string	publishing_uri,
		DdtLogger *	logger
	)

Constructor

DdtDataProducer::~DdtDataProducer ( )

virtualdefault

Destructor

std::string DdtDataProducer::get_publishing_uri ( )

Returns publishing_uri.

void DdtDataProducer::Notify ( NotificationType type )

virtual

Attaches a notification to the data packet and sends it via MALps to remote brokers.

void DdtDataProducer::Publish ( DataPacket data_packet )

Publishes the data over network.

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