| CheckPublisherExists(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| CheckPubRegistrationPermitted(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| CheckRemotePublisherExists(const std::string &remote_broker_uri, const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| DdtConnectionManager(DdtLogger *ddt_logger, const std::string uri_string) | ddt::DdtConnectionManager | explicit |
| DdtConnectionManager(DdtMemoryManager *mmgr, DdtLogger *ddt_logger, const std::string uri_string) | ddt::DdtConnectionManager | explicit |
| DdtConnectionManagerFake(DdtLogger *logger) | DdtConnectionManagerFake | inline |
| get_compute_checksum(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_heartbeat_interval() override | ddt::DdtConnectionManager | |
| get_heartbeat_interval_default() | DdtConnectionManagerFake | inline |
| get_heartbeat_timeout() override | ddt::DdtConnectionManager | |
| get_heartbeat_timeout_default() | DdtConnectionManagerFake | inline |
| get_max_data_sample_size(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_notification_port(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_number_of_samples(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_publishing_uri(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_reply_time() | DdtConnectionManagerFake | inline |
| get_reply_time_default() | DdtConnectionManagerFake | inline |
| get_shm_id(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_shm_timeout() | DdtConnectionManagerFake | inline |
| get_shm_timeout_default() | DdtConnectionManagerFake | inline |
| get_statistics(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| get_waiting_time() | DdtConnectionManagerFake | inline |
| get_waiting_time_default() | DdtConnectionManagerFake | inline |
| GetConfigFilePath() | DdtConnectionManagerFake | inline |
| GetConfigPath() | ddt::DdtConnectionManager | protected |
| GetConnectedBrokers() override | ddt::DdtConnectionManager | |
| GetMaxPossibleBufferSize(int32_t max_data_sample_size) override | ddt::DdtConnectionManager | |
| GetRegisteredStreams() override | ddt::DdtConnectionManager | |
| heartbeat_interval | ddt::DdtConnectionManager | protected |
| HEARTBEAT_INTERVAL_DEFAULT | ddt::DdtConnectionManager | protected |
| heartbeat_timeout | ddt::DdtConnectionManager | protected |
| HEARTBEAT_TIMEOUT_DEFAULT | ddt::DdtConnectionManager | protected |
| LoadDefaults() | ddt::DdtConnectionManager | protected |
| LoadDefaultValues() | DdtConnectionManagerFake | inline |
| PublishData(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| ReadIni() | ddt::DdtConnectionManager | protected |
| ReadIniFile() | DdtConnectionManagerFake | inline |
| RegisterPublisher(const std::string &data_stream_identifier, int32_t latency, int32_t deadline, int32_t max_data_sample_size, int32_t number_of_samples, bool compute_checksum, const std::string &publishing_uri) override | ddt::DdtConnectionManager | |
| RegisterRemoteSubscriber(const std::string &remote_broker, const std::string &subscriber_uuid, const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline) override | ddt::DdtConnectionManager | |
| RegisterSubscriber(const std::string &subscriber_uuid, const std::string &data_stream_identifier, const std::string &remote_broker_uri, int32_t latency, int32_t deadline) override | ddt::DdtConnectionManager | |
| reply_time | ddt::DdtConnectionManager | protected |
| REPLY_TIME_DEFAULT | ddt::DdtConnectionManager | protected |
| shm_timeout | ddt::DdtConnectionManager | protected |
| SHM_TIMEOUT_DEFAULT | ddt::DdtConnectionManager | protected |
| UnregisterPublisher(const std::string &data_stream_identifier) override | ddt::DdtConnectionManager | |
| UnregisterPublishers() | ddt::DdtConnectionManager | |
| UnregisterSubscriber(const std::string &data_stream_identifier, const std::string &subscriber_uuid) override | ddt::DdtConnectionManager | |
| UnregisterSubscribers() | ddt::DdtConnectionManager | |
| UpdateHeartbeat(const std::string &identifier) override | ddt::DdtConnectionManager | |
| UpdateStatistics(const std::string &data_stream_identifier, const int32_t datavec_size, const uint64_t source_timestamp) override | ddt::DdtConnectionManager | |
| waiting_time | ddt::DdtConnectionManager | protected |
| WAITING_TIME_DEFAULT | ddt::DdtConnectionManager | protected |
| ~DdtConnectionManager() | ddt::DdtConnectionManager | virtual |
