ddt 1.2.1
Loading...
Searching...
No Matches
Public Member Functions | List of all members
DdtDataSubscriber2Fake Class Reference
Inheritance diagram for DdtDataSubscriber2Fake:
ddt::DdtDataSubscriber ddt::DdtDataTransferLib

Public Member Functions

 DdtDataSubscriber2Fake (log4cplus::Logger const &log4cplus_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
 
DataSampleReadData () 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 ()
 
 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
 
DdtLoggerlogger
 
DdtLoggermy_logger = nullptr
 
const int32_t REPLY_TIME_DEFAULT = 6
 
const int32_t REPLY_TIME_MIN = 2
 

Constructor & Destructor Documentation

◆ DdtDataSubscriber2Fake()

DdtDataSubscriber2Fake::DdtDataSubscriber2Fake ( log4cplus::Logger const & log4cplus_logger)
inline

Member Function Documentation

◆ get_max_age_data_sample()

int32_t DdtDataSubscriber2Fake::get_max_age_data_sample ( )
inline

◆ get_max_age_data_sample_default()

int32_t DdtDataSubscriber2Fake::get_max_age_data_sample_default ( )
inline

◆ get_reply_time()

int32_t DdtDataSubscriber2Fake::get_reply_time ( )
inline

◆ get_reply_time_default()

int32_t DdtDataSubscriber2Fake::get_reply_time_default ( )
inline

◆ LoadDefaultValues()

void DdtDataSubscriber2Fake::LoadDefaultValues ( )
inline

◆ ReadIniFile()

void DdtDataSubscriber2Fake::ReadIniFile ( )
inline

◆ set_max_age_data_sample()

void DdtDataSubscriber2Fake::set_max_age_data_sample ( int32_t max_age)
inline

◆ set_reply_time()

void DdtDataSubscriber2Fake::set_reply_time ( int32_t repl_time)
inline

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