ddt 1.2.1
|
Public Member Functions | |
DdtDataTransferLibFake (DdtLogger *logger) | |
int | getLatency () |
int | getDeadline () |
std::string | TestVerifyPathInBrokerUri (std::string broker_uri) |
std::string | GetConfigFile () |
![]() | |
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 | |
![]() | |
void | StartHeartbeat (const int32_t interval, const std::string id) |
void | StopHeartbeat () |
void | CheckHeartbeatTimeout (int32_t &new_reply_time) |
const std::string | GetConfigFilePath () |
![]() | |
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 |