DdtDataConsumerFake Class Reference

Inheritance diagram for DdtDataConsumerFake:

Public Member Functions
	DdtDataConsumerFake (const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger)
DdtMemoryAccessor *	get_mem_acc ()
std::string	get_stream_id ()
int32_t	get_num_samples ()
int32_t	get_noti_port ()
std::string	get_pub_uri ()
void	Initialize (const std::string &dsi, DdtLogger *logger)
void	set_total_bytes (uint64_t bytes)
void	set_total_latency (uint64_t latency)
Public Member Functions inherited from ddt::DdtDataConsumer
	DdtDataConsumer (const std::string &data_stream_identifier, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger)
	DdtDataConsumer (const std::string &data_stream_identifier, const std::string &subscription_uri, const int32_t latency, const int32_t deadline, DdtLogger *ddt_logger)
	~DdtDataConsumer () override
void	StartSubscription ()
void	StopSubscription ()
void	AddUuid (std::string uuid, SubscriberType type)
void	RemoveUuid (const std::string uuid)
void	Notify (const NotificationType type) override
int32_t	get_number_of_subscribers ()
int32_t	get_number_of_remote_subscribers ()
std::map< std::string, SubscriberType >	get_subscribers ()
std::string	get_remote_broker_uri () const
int32_t	get_notification_port () const
DdtStatistics	get_statistics ()
void	ResetStatistics ()
std::string	get_publishing_uri () const
void	set_remote_broker_uri (const std::string &remote_uri)
void	set_number_of_samples (const int32_t num_samples)
void	set_memory_accessor (DdtMemoryAccessor *mem_accessor)
void	set_notification_port (const int32_t noti_port)
void	set_publishing_uri (const std::string pub_uri)
void	set_originating_broker (const std::string orig_broker)
Public Member Functions inherited from ddt::DdtProducerConsumerBase
	DdtProducerConsumerBase (DdtLogger *ddt_logger)
virtual	~DdtProducerConsumerBase ()

Additional Inherited Members
Public Types inherited from ddt::DdtDataConsumer
enum	SubscriberType { LOCAL , REMOTE }
Public Types inherited from ddt::DdtProducerConsumerBase
enum	NotificationType { NEW_DATA , PUB_REG , PUB_UNREG , SHM_DEL }
Public Attributes inherited from ddt::DdtDataConsumer
signal_n	notification_signal
Protected Member Functions inherited from ddt::DdtDataConsumer
void	Init (const std::string &ds_id, DdtLogger *ddt_logger)
Protected Member Functions inherited from ddt::DdtProducerConsumerBase
void	Init (DdtLogger *ddt_logger)
void	LoadDefaults ()
void	ReadIni ()
void	PrintConfigValues ()
int32_t	GetFreePort () const
Protected Attributes inherited from ddt::DdtDataConsumer
DdtMemoryAccessor *	memory_accessor
std::string	data_stream_identifier
int32_t	number_of_samples
int32_t	notification_port
std::string	publishing_uri
std::chrono::system_clock::time_point	last_received
uint64_t	total_samples = 0
uint64_t	total_bytes = 0
uint64_t	total_latency = 0
Protected Attributes inherited from ddt::DdtProducerConsumerBase
int32_t	min_port
int32_t	max_port
DdtLogger *	logger
const int	MIN_PORT_DEFAULT = 5100
const int	MAX_PORT_DEFAULT = 5500
const int	MIN_RANGE = 3
const int	LINE_LENGTH = 256

Constructor & Destructor Documentation

DdtDataConsumerFake()

DdtDataConsumerFake::DdtDataConsumerFake ( const std::string & data_stream_identifier, const int32_t latency, const int32_t deadline, DdtLogger * ddt_logger )

inline

Member Function Documentation

get_mem_acc()

DdtMemoryAccessor * DdtDataConsumerFake::get_mem_acc ( )

inline

get_noti_port()

int32_t DdtDataConsumerFake::get_noti_port ( )

inline

get_num_samples()

int32_t DdtDataConsumerFake::get_num_samples ( )

inline

get_pub_uri()

std::string DdtDataConsumerFake::get_pub_uri ( )

inline

get_stream_id()

std::string DdtDataConsumerFake::get_stream_id ( )

inline

Initialize()

void DdtDataConsumerFake::Initialize ( const std::string & dsi, DdtLogger * logger )

inline

set_total_bytes()

void DdtDataConsumerFake::set_total_bytes ( uint64_t bytes )

inline

set_total_latency()

void DdtDataConsumerFake::set_total_latency ( uint64_t latency )

inline

---

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

• datatransfer/databrokerlib/test/testDataConsumer.cpp