DdtDataSubscriberFake Class Reference

Inheritance diagram for DdtDataSubscriberFake:

Public Member Functions
	DdtDataSubscriberFake (DdtLogger *logger)
int32_t	get_max_age_data_sample_default ()
int32_t	get_max_age_data_sample ()
int32_t	get_reply_time_default ()
int32_t	get_reply_time ()
void	set_max_age_data_sample (int32_t max_age)
void	set_reply_time (int32_t repl_time)
void	LoadDefaultValues ()
void	ReadIniFile ()
Public Member Functions inherited from ddt::DdtDataSubscriber
	DdtDataSubscriber (DdtLogger *logger)
	DdtDataSubscriber (log4cplus::Logger const &log4cplus_logger)
	~DdtDataSubscriber () override
int	RegisterSubscriber (const std::string uri, const std::string dsi, const std::string remote_uri, const int32_t interval=10) override
int	UnregisterSubscriber () override
DataSample *	ReadData () override
void	StartNotificationSubscription ()
void	StopNotificationSubscription ()
DdtStatistics	get_statistics ()
boost::signals2::connection	connect (const SignalT::slot_type &event_listener)
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::DdtDataSubscriber
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::DdtDataSubscriber
int32_t	max_age_data_sample
const int32_t	MAX_AGE_DATA_SAMPLE_DEFAULT = 10000
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

DdtDataSubscriberFake()

DdtDataSubscriberFake::DdtDataSubscriberFake ( DdtLogger *  logger )

inline

Member Function Documentation

get_max_age_data_sample()

int32_t DdtDataSubscriberFake::get_max_age_data_sample ( )

inline

get_max_age_data_sample_default()

int32_t DdtDataSubscriberFake::get_max_age_data_sample_default ( )

inline

get_reply_time()

int32_t DdtDataSubscriberFake::get_reply_time ( )

inline

get_reply_time_default()

int32_t DdtDataSubscriberFake::get_reply_time_default ( )

inline

LoadDefaultValues()

void DdtDataSubscriberFake::LoadDefaultValues ( )

inline

ReadIniFile()

void DdtDataSubscriberFake::ReadIniFile ( )

inline

set_max_age_data_sample()

void DdtDataSubscriberFake::set_max_age_data_sample ( int32_t  max_age )

inline

set_reply_time()

void DdtDataSubscriberFake::set_reply_time ( int32_t  repl_time )

inline

---

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

• datatransfer/datatransferlib/test/testDataSubscriber.cpp