|
AcsBulkdata::BulkDataNTStream − |
|
#include <bulkDataNTStream.h> Inherited by AcsBulkdata::BulkDataNTReceiverStreamBase, and AcsBulkdata::BulkDataNTSenderStream. |
|
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) |
|
base class for Bulk data sender and receiver TBD probably we do not need it |
|
AcsBulkdata::BulkDataNTStream::BulkDataNTStream (const char * name, const StreamConfiguration & cfg) Constructor |
|
virtual AcsBulkdata::BulkDataNTStream::~BulkDataNTStream () [virtual] Destructor |
|
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 >. |
|
friend class BulkDataNTReceiverFlow [friend] |
|
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(). |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |