AcsBulkdata::BulkDataNTStream Class Reference

#include <bulkDataNTStream.h>

Inheritance diagram for AcsBulkdata::BulkDataNTStream:

Collaboration diagram for AcsBulkdata::BulkDataNTStream:

List of all members.

Public Member Functions
	BulkDataNTStream (const char *name, const StreamConfiguration &cfg)
virtual	~BulkDataNTStream ()
std::string	getName ()
Friends
class	BulkDataNTReceiverFlow
: flow or stream name
adding and applying DDS QoS profile. Setting qoS from XML for a stream or a flow configuration
static unsigned int	factoryRefCount_m
std::string	streamName_m
StreamConfiguration	configuration_m
DDS::DomainParticipant *	participant_m
	if we use just one participant
ACE_Recursive_Thread_Mutex	globalPartMutex_m
	could be a newly created per stream or used global one
ACE_Recursive_Thread_Mutex	DDSFactoryMutex_m
	protection global participant + counter
static DDS::DomainParticipantFactory *	factory_m
static unsigned int	globalParticipantRefCount_m
static DDS::DomainParticipant *	globalParticipant_m
	how many streams do need the participant
void	addDDSQoSProfile (DDSConfiguration &cfg, const char *name)
void	removeDDSQoSProfile (const DDSConfiguration &cfg)
	removing DDS QoS profile (from XML for a stream or a flow)
DDS::DomainParticipant *	getDDSParticipant ()
	how many time / streams need the factory
virtual void	removeFlowFromMap (const char *flow)=0
void	createDDSFactory ()
void	destroyDDSFactory ()
DDS::DomainParticipant *	createDDSParticipant ()
void	destroyDDSParticipant (DDS::DomainParticipant *domainParticipant)

---

Detailed Description

base class for Bulk data sender and receiver TBD probably we do not need it

---

Constructor & Destructor Documentation

AcsBulkdata::BulkDataNTStream::BulkDataNTStream	(	const char *	name,
		const StreamConfiguration &	cfg
	)

Constructor

virtual AcsBulkdata::BulkDataNTStream::~BulkDataNTStream

(

)

[virtual]

Destructor

---

Member Function Documentation

void AcsBulkdata::BulkDataNTStream::addDDSQoSProfile	(	DDSConfiguration &	cfg,
		const char *	name
	)

void AcsBulkdata::BulkDataNTStream::createDDSFactory

(

)

[protected]

DDS::DomainParticipant* AcsBulkdata::BulkDataNTStream::createDDSParticipant

(

)

[protected]

void AcsBulkdata::BulkDataNTStream::destroyDDSFactory

(

)

[protected]

void AcsBulkdata::BulkDataNTStream::destroyDDSParticipant

(

DDS::DomainParticipant *

domainParticipant

)

[protected]

DDS::DomainParticipant* AcsBulkdata::BulkDataNTStream::getDDSParticipant

(

)

[inline, protected]

how many time / streams need the factory

References participant_m.

std::string AcsBulkdata::BulkDataNTStream::getName

(

void

)

[inline]

References streamName_m.

void AcsBulkdata::BulkDataNTStream::removeDDSQoSProfile

(

const DDSConfiguration &

cfg

)

removing DDS QoS profile (from XML for a stream or a flow)

virtual void AcsBulkdata::BulkDataNTStream::removeFlowFromMap

(

const char *

flow

)

[protected, pure virtual]

Implemented in AcsBulkdata::BulkDataNTReceiverStream< TReceiverCallback >, AcsBulkdata::BulkDataNTSenderStream, and AcsBulkdata::BulkDataNTReceiverStream< TestCB >.

---

Friends And Related Function Documentation

friend class BulkDataNTReceiverFlow [friend]

---

Member Data Documentation

StreamConfiguration AcsBulkdata::BulkDataNTStream::configuration_m [protected]

ACE_Recursive_Thread_Mutex AcsBulkdata::BulkDataNTStream::DDSFactoryMutex_m [protected]

protection global participant + counter

DDS::DomainParticipantFactory* AcsBulkdata::BulkDataNTStream::factory_m [static, protected]

unsigned int AcsBulkdata::BulkDataNTStream::factoryRefCount_m [static]

DDS::DomainParticipant* AcsBulkdata::BulkDataNTStream::globalParticipant_m [static, protected]

how many streams do need the participant

unsigned int AcsBulkdata::BulkDataNTStream::globalParticipantRefCount_m [static, protected]

ACE_Recursive_Thread_Mutex AcsBulkdata::BulkDataNTStream::globalPartMutex_m [protected]

could be a newly created per stream or used global one

DDS::DomainParticipant* AcsBulkdata::BulkDataNTStream::participant_m [protected]

if we use just one participant

Referenced by getDDSParticipant().

std::string AcsBulkdata::BulkDataNTStream::streamName_m [protected]

Referenced by getName().

---

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

• bulkDataNTStream.h