DdtConnectionManagerFake Class Reference

Inheritance diagram for DdtConnectionManagerFake:

Public Member Functions
	DdtConnectionManagerFake (DdtLogger *logger)
int32_t	get_shm_timeout_default ()
int32_t	get_waiting_time_default ()
int32_t	get_reply_time_default ()
int32_t	get_heartbeat_interval_default ()
int32_t	get_heartbeat_timeout_default ()
int32_t	get_shm_timeout ()
int32_t	get_waiting_time ()
int32_t	get_reply_time ()
void	LoadDefaultValues ()
void	ReadIniFile ()
std::string	GetConfigFilePath ()
std::string	CreateSubUri (const std::string publishing_uri, const std::string remote_broker_uri)
bool	CheckIdInUse (const std::string &data_stream_identifier)
void	InsertRegisteredPublisher (std::string dsi)
void	CreateStats (const std::string &dsi, const int32_t num_samples)
std::map< std::string, DdtStatistics >	GetStatisticsMap ()
void	ResetStats (const std::string &dsi)
Public Member Functions inherited from ddt::DdtConnectionManager
	DdtConnectionManager (DdtLogger *ddt_logger, const std::string uri_string, const std::string config)
	DdtConnectionManager (DdtMemoryManager *const mmgr, DdtLogger *ddt_logger, const std::string uri_string, const std::string config)
	~DdtConnectionManager () override
int32_t	RegisterPublisher (const std::string &data_stream_identifier, const int32_t latency, int32_t deadline, const int32_t max_data_sample_size, const int32_t number_of_samples, const bool compute_checksum, const std::string &publishing_uri) override
int32_t	UnregisterPublisher (const std::string &data_stream_identifier) override
int32_t	UnregisterPublishers ()
void	PublishData (const std::string &data_stream_identifier) override
int32_t	RegisterSubscriber (const std::string &subscriber_uuid, const std::string &data_stream_identifier, const std::string &remote_broker_uri, const int32_t latency, const int32_t deadline) override
int32_t	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
int32_t	UnregisterSubscriber (const std::string &data_stream_identifier, const std::string &subscriber_uuid) override
int32_t	UnregisterSubscribers ()
int32_t	get_max_data_sample_size (const std::string &data_stream_identifier) override
int32_t	get_number_of_samples (const std::string &data_stream_identifier) override
std::string	get_publishing_uri (const std::string &data_stream_identifier) override
int32_t	get_notification_port (const std::string &data_stream_identifier) override
std::vector< std::string >	get_statistics (const std::string &data_stream_identifier) override
int32_t	get_heartbeat_interval () override
int32_t	get_heartbeat_timeout () override
bool	get_compute_checksum (const std::string &data_stream_identifier) override
std::string	get_shm_id (const std::string &data_stream_identifier) override
std::string	get_broker_uri () override
void	UpdateHeartbeat (const std::string &identifier) override
bool	CheckPubRegistrationPermitted (const std::string &data_stream_identifier) override
bool	CheckPublisherExists (const std::string &data_stream_identifier) override
bool	CheckRemotePublisherExists (const std::string &remote_broker_uri, const std::string &data_stream_identifier) override
void	UpdateStatistics (const std::string &data_stream_identifier, const int32_t datavec_size, const uint64_t source_timestamp) override
int32_t	GetMaxPossibleBufferSize (int32_t max_data_sample_size) override
std::vector< std::string >	GetRegisteredStreams () override
std::vector< std::string >	GetConnectedBrokers () override

Additional Inherited Members
Protected Member Functions inherited from ddt::DdtConnectionManager
void	LoadDefaults ()
std::string	GetConfigPath () const
void	ReadIni ()
std::string	CreateSubscriptionUri (const std::string publishing_uri, const std::string remote_broker_uri) const
bool	CheckStreamIdInUse (const std::string &data_stream_identifier)
void	CreateStatistics (const std::string &data_stream_identifier, const int32_t number_of_samples)
void	ResetStatistics (const std::string &data_stream_identifier)
Protected Attributes inherited from ddt::DdtConnectionManager
const int32_t	SHM_TIMEOUT_DEFAULT = 10
const int32_t	WAITING_TIME_DEFAULT = 1000
const int32_t	REPLY_TIME_DEFAULT = 6
const int32_t	HEARTBEAT_INTERVAL_DEFAULT = 1
const int32_t	HEARTBEAT_TIMEOUT_DEFAULT = 10
int32_t	shm_timeout
int32_t	waiting_time
int32_t	reply_time
int32_t	heartbeat_interval
int32_t	heartbeat_timeout
std::set< std::string >	registered_publishers
std::map< std::string, DdtStatistics >	statistics_map

Constructor & Destructor Documentation

DdtConnectionManagerFake()

DdtConnectionManagerFake::DdtConnectionManagerFake ( DdtLogger *  logger )

inline

Member Function Documentation

CheckIdInUse()

bool DdtConnectionManagerFake::CheckIdInUse ( const std::string &  data_stream_identifier )

inline

CreateStats()

void DdtConnectionManagerFake::CreateStats ( const std::string &  dsi, const int32_t  num_samples  )

inline

CreateSubUri()

std::string DdtConnectionManagerFake::CreateSubUri ( const std::string  publishing_uri, const std::string  remote_broker_uri  )

inline

get_heartbeat_interval_default()

int32_t DdtConnectionManagerFake::get_heartbeat_interval_default ( )

inline

get_heartbeat_timeout_default()

int32_t DdtConnectionManagerFake::get_heartbeat_timeout_default ( )

inline

get_reply_time()

int32_t DdtConnectionManagerFake::get_reply_time ( )

inline

get_reply_time_default()

int32_t DdtConnectionManagerFake::get_reply_time_default ( )

inline

get_shm_timeout()

int32_t DdtConnectionManagerFake::get_shm_timeout ( )

inline

get_shm_timeout_default()

int32_t DdtConnectionManagerFake::get_shm_timeout_default ( )

inline

get_waiting_time()

int32_t DdtConnectionManagerFake::get_waiting_time ( )

inline

get_waiting_time_default()

int32_t DdtConnectionManagerFake::get_waiting_time_default ( )

inline

GetConfigFilePath()

std::string DdtConnectionManagerFake::GetConfigFilePath ( )

inline

GetStatisticsMap()

std::map< std::string, DdtStatistics > DdtConnectionManagerFake::GetStatisticsMap ( )

inline

InsertRegisteredPublisher()

void DdtConnectionManagerFake::InsertRegisteredPublisher ( std::string  dsi )

inline

LoadDefaultValues()

void DdtConnectionManagerFake::LoadDefaultValues ( )

inline

ReadIniFile()

void DdtConnectionManagerFake::ReadIniFile ( )

inline

ResetStats()

void DdtConnectionManagerFake::ResetStats ( const std::string &  dsi )

inline

---

The documentation for this class was generated from the following file:

• datatransfer/databrokerlib/test/testConnectionManager.cpp