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 () |
| 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()
|
inline |
Member Function Documentation
◆ get_max_age_data_sample()
|
inline |
◆ get_max_age_data_sample_default()
|
inline |
◆ get_reply_time()
|
inline |
◆ get_reply_time_default()
|
inline |
◆ LoadDefaultValues()
|
inline |
◆ ReadIniFile()
|
inline |
◆ set_max_age_data_sample()
|
inline |
◆ set_reply_time()
|
inline |
The documentation for this class was generated from the following file:
- datatransfer/datatransferlib/test/testDataSubscriber.cpp
