DdtDataPublisher2Fake Class Reference

Inheritance diagram for DdtDataPublisher2Fake:

Public Member Functions
	DdtDataPublisher2Fake (log4cplus::Logger const &log4cplus_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
	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 ()
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 ()
boost::signals2::connection	ConnectToConnectionState (const std::function< void(ConnectionState)> &callback)

Additional Inherited Members
Public Types inherited from ddt::DdtDataTransferLib
enum class	ConnectionState { Disconnected = 0 , Connected , Reconnecting , PublisherDisconnected }
using	ConnectionStateSignalT = boost::signals2::signal<void(ConnectionState)>
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 ()
virtual void	StopThreads ()
void	Reconnect ()
void	CheckHeartbeatTimeout (int32_t &new_reply_time)
void	NotifyConnectionState (ConnectionState state)
const std::string	GetConfigFilePath ()
void	SpawnReconnectionThread ()
Protected Attributes inherited from ddt::DdtDataPublisher
int	topic_id = 0
Protected Attributes inherited from ddt::DdtDataTransferLib
int	latency = 0
int	deadline = 0
int32_t	reply_time = 0
int32_t	heartbeat_interval = 0
std::thread	hb_thread
std::thread	reconnect_thread
std::atomic< bool >	reconnect_pending {false}
std::mutex	hb_cv_mutex
std::condition_variable	hb_cv
std::atomic< bool >	heartbeat_active {false}
std::atomic< bool >	shutdown_in_progress {false}
std::unique_ptr< datatransfer::DataBrokerRegistrationSync, std::default_delete< datatransfer::DataBrokerRegistrationSync > >	client
std::atomic< bool >	connected_to_broker {false}
ConnectionStateSignalT	connection_state_signal
std::atomic< ConnectionState >	last_notified_state {ConnectionState::Disconnected}
std::string	broker_uri
elt::mal::rr::ListenerRegistration	connection_listener
DdtLogger *	logger = nullptr
DdtLogger *	my_logger = nullptr
const int32_t	REPLY_TIME_DEFAULT = 6
const int32_t	REPLY_TIME_MIN = 2
int32_t	wait_for_connection = 0
const int32_t	WAIT_FOR_CONNECTION_DEFAULT = 10
const int32_t	WAIT_FOR_CONNECTION_MIN = 2
int32_t	max_consecutive_failures = 0
const int32_t	MAX_CONSECUTIVE_FAILURES_DEFAULT = 3
const int32_t	MAX_CONSECUTIVE_FAILURES_MIN = 1

Constructor & Destructor Documentation

DdtDataPublisher2Fake()

DdtDataPublisher2Fake::DdtDataPublisher2Fake ( log4cplus::Logger const & log4cplus_logger )

inline

Member Function Documentation

get_reply_time()

int32_t DdtDataPublisher2Fake::get_reply_time ( )

inline

get_reply_time_default()

int32_t DdtDataPublisher2Fake::get_reply_time_default ( )

inline

get_topic_id()

int DdtDataPublisher2Fake::get_topic_id ( )

inline

LoadDefaultValues()

void DdtDataPublisher2Fake::LoadDefaultValues ( )

inline

ReadIniFile()

void DdtDataPublisher2Fake::ReadIniFile ( )

inline

set_reply_time()

void DdtDataPublisher2Fake::set_reply_time ( int32_t repl_time )

inline

---

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

• datatransfer/datatransferlib/test/testDataPublisher2.cpp