DdtDataPublisherFake Class Reference

Inheritance diagram for DdtDataPublisherFake:

Public Member Functions
	DdtDataPublisherFake (DdtLogger *logger)
int	get_topic_id ()
int32_t	get_reply_time_default ()
int32_t	get_reply_time ()
void	set_reply_time (int32_t repl_time)
void	LoadDefaultValues ()
void	ReadIniFile ()
Public Member Functions inherited from ddt::DdtDataPublisher
	DdtDataPublisher (DdtLogger *logger)
	DdtDataPublisher (log4cplus::Logger const &log4cplus_logger)
	~DdtDataPublisher () override
int	RegisterPublisher (const std::string uri, const std::string dsi, const bool compute_crc) override
int	UnregisterPublisher () override
void	PublishData () override
void	SetBufferSize (const int max_sample_size, const int number_samples)
void	WriteData (const int32_t sample_id, const std::vector< uint8_t > &datavec, const std::vector< uint8_t > &metadatavec)
void	WriteData (const int32_t sample_id, const uint8_t *const data, const int32_t data_size, const uint8_t *const metadata, const int32_t metadata_size)
void	set_topic_id (const int id)
bool	get_connected_to_broker () const
Public Member Functions inherited from ddt::DdtDataTransferLib
virtual int	RegisterPublisher (const std::string uri, const std::string dsi, const bool compute_crc)
virtual int	UnregisterPublisher ()
virtual void	PublishData ()
virtual int	RegisterSubscriber (const std::string uri, const std::string dsi, const std::string remote_uri, const int32_t interval=10)
virtual int	UnregisterSubscriber ()
virtual DataSample *	ReadData ()
	DdtDataTransferLib (DdtLogger *ddt_logger)
	DdtDataTransferLib (log4cplus::Logger const &log4cplus_logger)
virtual	~DdtDataTransferLib ()
void	SetQoS (const int ddt_latency, const int ddt_deadline)
const std::string	VerifyPathInBrokerUri (std::string broker_uri)
int	InitMAL (const std::string broker_uri)
std::unique_ptr< datatransfer::DataBrokerRegistrationSync, std::default_delete< datatransfer::DataBrokerRegistrationSync > >	GetBrokerClient ()

Additional Inherited Members
Protected Member Functions inherited from ddt::DdtDataPublisher
void	LoadDefaults ()
void	ReadIni ()
Protected Member Functions inherited from ddt::DdtDataTransferLib
void	StartHeartbeat (const int32_t interval, const std::string id)
void	StopHeartbeat ()
void	CheckHeartbeatTimeout (int32_t &new_reply_time)
const std::string	GetConfigFilePath ()
Protected Attributes inherited from ddt::DdtDataPublisher
int	topic_id
Protected Attributes inherited from ddt::DdtDataTransferLib
int	latency
int	deadline
int32_t	reply_time
int32_t	heartbeat_interval
std::promise< void >	exit_signal_heartbeat
std::future< void >	future_object_heartbeat
std::atomic< bool >	heartbeat_active
std::unique_ptr< datatransfer::DataBrokerRegistrationSync, std::default_delete< datatransfer::DataBrokerRegistrationSync > >	client
std::atomic< bool >	connected_to_broker
elt::mal::rr::ListenerRegistration	connection_listener
DdtLogger *	logger
DdtLogger *	my_logger = nullptr
const int32_t	REPLY_TIME_DEFAULT = 6
const int32_t	REPLY_TIME_MIN = 2

Constructor & Destructor Documentation

DdtDataPublisherFake()

DdtDataPublisherFake::DdtDataPublisherFake ( DdtLogger *  logger )

inline

Member Function Documentation

get_reply_time()

int32_t DdtDataPublisherFake::get_reply_time ( )

inline

get_reply_time_default()

int32_t DdtDataPublisherFake::get_reply_time_default ( )

inline

get_topic_id()

int DdtDataPublisherFake::get_topic_id ( )

inline

LoadDefaultValues()

void DdtDataPublisherFake::LoadDefaultValues ( )

inline

ReadIniFile()

void DdtDataPublisherFake::ReadIniFile ( )

inline

set_reply_time()

void DdtDataPublisherFake::set_reply_time ( int32_t  repl_time )

inline

---

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

• datatransfer/datatransferlib/test/testDataPublisher.cpp