| CheckHeartbeatTimeout(int32_t &new_reply_time) | ddt::DdtDataTransferLib | protected |
| client | ddt::DdtDataTransferLib | protected |
| connected_to_broker | ddt::DdtDataTransferLib | protected |
| connection_listener | ddt::DdtDataTransferLib | protected |
| connection_state_signal | ddt::DdtDataTransferLib | protected |
| ConnectionState enum name | ddt::DdtDataTransferLib | |
| ConnectionStateSignalT typedef | ddt::DdtDataTransferLib | |
| ConnectToConnectionState(const std::function< void(ConnectionState)> &callback) | ddt::DdtDataTransferLib | |
| DdtDataPublisher(DdtLogger *logger) | ddt::DdtDataPublisher | explicit |
| DdtDataPublisher(log4cplus::Logger const &log4cplus_logger) | ddt::DdtDataPublisher | explicit |
| DdtDataPublisher2Fake(log4cplus::Logger const &log4cplus_logger) | DdtDataPublisher2Fake | inline |
| DdtDataTransferLib(DdtLogger *ddt_logger) | ddt::DdtDataTransferLib | explicit |
| DdtDataTransferLib(log4cplus::Logger const &log4cplus_logger) | ddt::DdtDataTransferLib | explicit |
| deadline | ddt::DdtDataTransferLib | protected |
| get_connected_to_broker() const | ddt::DdtDataPublisher | |
| get_reply_time() | DdtDataPublisher2Fake | inline |
| get_reply_time_default() | DdtDataPublisher2Fake | inline |
| get_topic_id() | DdtDataPublisher2Fake | inline |
| GetBrokerClient() | ddt::DdtDataTransferLib | |
| GetConfigFilePath() | ddt::DdtDataTransferLib | protected |
| hb_cv | ddt::DdtDataTransferLib | protected |
| hb_cv_mutex | ddt::DdtDataTransferLib | protected |
| hb_thread | ddt::DdtDataTransferLib | protected |
| heartbeat_active | ddt::DdtDataTransferLib | protected |
| heartbeat_interval | ddt::DdtDataTransferLib | protected |
| InitMAL(const std::string broker_uri) | ddt::DdtDataTransferLib | |
| last_notified_state | ddt::DdtDataTransferLib | protected |
| latency | ddt::DdtDataTransferLib | protected |
| LoadDefaults() | ddt::DdtDataPublisher | protected |
| LoadDefaultValues() | DdtDataPublisher2Fake | inline |
| logger | ddt::DdtDataTransferLib | protected |
| max_consecutive_failures | ddt::DdtDataTransferLib | protected |
| MAX_CONSECUTIVE_FAILURES_DEFAULT | ddt::DdtDataTransferLib | protected |
| MAX_CONSECUTIVE_FAILURES_MIN | ddt::DdtDataTransferLib | protected |
| my_logger | ddt::DdtDataTransferLib | protected |
| NotifyConnectionState(ConnectionState state) | ddt::DdtDataTransferLib | protected |
| PublishData() override | ddt::DdtDataPublisher | virtual |
| ReadData() | ddt::DdtDataTransferLib | inlinevirtual |
| ReadIni() | ddt::DdtDataPublisher | protected |
| ReadIniFile() | DdtDataPublisher2Fake | inline |
| Reconnect() | ddt::DdtDataTransferLib | protected |
| reconnect_pending | ddt::DdtDataTransferLib | protected |
| reconnect_thread | ddt::DdtDataTransferLib | protected |
| RegisterPublisher(const std::string uri, const std::string dsi, const bool compute_crc) override | ddt::DdtDataPublisher | virtual |
| RegisterSubscriber(const std::string uri, const std::string dsi, const std::string remote_uri, const int32_t interval=10) | ddt::DdtDataTransferLib | inlinevirtual |
| reply_time | ddt::DdtDataTransferLib | protected |
| REPLY_TIME_DEFAULT | ddt::DdtDataTransferLib | protected |
| REPLY_TIME_MIN | ddt::DdtDataTransferLib | protected |
| set_reply_time(int32_t repl_time) | DdtDataPublisher2Fake | inline |
| set_topic_id(const int id) | ddt::DdtDataPublisher | |
| SetBufferSize(const int max_sample_size, const int number_samples) | ddt::DdtDataPublisher | |
| SetQoS(const int ddt_latency, const int ddt_deadline) | ddt::DdtDataTransferLib | |
| shutdown_in_progress | ddt::DdtDataTransferLib | protected |
| SpawnReconnectionThread() | ddt::DdtDataTransferLib | protected |
| StartHeartbeat(const int32_t interval, const std::string id) | ddt::DdtDataTransferLib | protected |
| StopHeartbeat() | ddt::DdtDataTransferLib | protected |
| StopThreads() | ddt::DdtDataTransferLib | protectedvirtual |
| topic_id | ddt::DdtDataPublisher | protected |
| UnregisterPublisher() override | ddt::DdtDataPublisher | virtual |
| UnregisterSubscriber() | ddt::DdtDataTransferLib | inlinevirtual |
| VerifyPathInBrokerUri(std::string broker_uri) | ddt::DdtDataTransferLib | |
| wait_for_connection | ddt::DdtDataTransferLib | protected |
| WAIT_FOR_CONNECTION_DEFAULT | ddt::DdtDataTransferLib | protected |
| WAIT_FOR_CONNECTION_MIN | ddt::DdtDataTransferLib | protected |
| WriteData(const int32_t sample_id, const std::vector< uint8_t > &datavec, const std::vector< uint8_t > &metadatavec) | ddt::DdtDataPublisher | |
| WriteData(const int32_t sample_id, const uint8_t *const data, const int32_t data_size, const uint8_t *const metadata, const int32_t metadata_size) | ddt::DdtDataPublisher | |
| ~DdtDataPublisher() override | ddt::DdtDataPublisher | |
| ~DdtDataTransferLib() | ddt::DdtDataTransferLib | virtual |