ddt 1.2.1
|
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 () |
![]() | |
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) |
![]() | |
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 | |
![]() | |
void | LoadDefaults () |
void | ReadIni () |
![]() | |
void | StartHeartbeat (const int32_t interval, const std::string id) |
void | StopHeartbeat () |
void | CheckHeartbeatTimeout (int32_t &new_reply_time) |
const std::string | GetConfigFilePath () |
![]() | |
int32_t | max_age_data_sample |
const int32_t | MAX_AGE_DATA_SAMPLE_DEFAULT = 10000 |
![]() | |
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 |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |