
Classes
struct	AssociationData
class	BuiltinTopicKeyLess
class	BIT_Helper_1
class	BIT_Helper_2
class	Cached_Allocator_With_Overflow
	A fixed-size allocator that caches items for quicker access but if the pool is exhausted it will use the heap. More...
class	DataDurabilityCache
	Underlying data cache for both OpenDDS `TRANSIENT` and `PERSISTENT` `DURABILITY` implementations.. More...
class	WriterInfo
	Keeps track of a DataWriter's liveliness for a DataReader. More...
class	DataReaderImpl
	Implements the DDS::DataReader interface. More...
class	DataReaderRemoteImpl
	Implements the OpenDDS::DCPS::ReaderRemote interface that is used to add and remove associations. More...
struct	DataSampleHeader
struct	DataSampleListElement
struct	DataSampleListIterator
	`DataSampleList` STL-style iterator implementation. More...
class	DataSampleList
class	DataWriterImpl
	Implements the OpenDDS::DCPS::DataWriterRemote interfaces and DDS::DataWrite interfaces. More...
class	DataWriterRemoteImpl
	Implements the OpenDDS::DCPS::DataWriterRemote interface. More...
struct	SequenceNumber
struct	Objref_Servant_Pair
	This struct holds both object reference and the corresponding servant. More...
class	DomainParticipantFactoryImpl
	Implements the OpenDDS::DCPS::DomainParticipantFactory interfaces. More...
class	DomainParticipantImpl
	Implements the OpenDDS::DCPS::DomainParticipant interfaces. More...
class	DurabilityArray
	Array class that provides a means to reset the underlying `ACE_Allocator`. More...
class	DurabilityQueue
	Queue class that provides a means to reset the underlying `ACE_Allocator`. More...
class	Dynamic_Cached_Allocator_With_Overflow
	A size-based allocator that caches blocks for quicker access, but if the pool is exhausted it will use the heap. More...
class	EntityImpl
	Implements the OpenDDS::DCPS::Entity interfaces. More...
class	InstanceState
	manage the states of a received data instance. More...
class	LocalObject
class	LocalObject_NoRefCount
class	Marked_Default_Qos
class	OfferedDeadlineWatchdog
	Watchdog responsible calling the `DataWriterListener` when the deadline period expires. More...
class	PublicationInstance
	Struct that has information about an instance and the instance sample list. More...
struct	PublisherDataWriterInfo
	Information about a DataWriter. More...
class	PublisherImpl
	Implements the OpenDDS::DCPS::Publisher interfaces. More...
class	Qos_Helper
	This class implements methods that verify whether a qos is valid, consistent and changeable. More...
class	RcHandle
class	RcObject
class	ReceivedDataElement
class	ReceivedDataElementList
class	Data_Types_Register
class	RequestedDeadlineWatchdog
	Watchdog responsible calling the `DataReaderListener` when the deadline period expires. More...
class	Service_Participant
	Service entrypoint. More...
struct	SubscriberDataReaderInfo
class	SubscriberImpl
class	SubscriptionInstance
	Struct that has information about an instance and the instance sample list. More...
class	TopicDescriptionImpl
	Implements the DDS::TopicDescription interface. More...
class	TopicImpl
	Implements the DDS::Topic interface. More...
class	Transient_Kludge
class	BasicQueue
class	BasicQueueLink
class	BasicQueueLinkAllocator
struct	BasicQueueLinkChunk
class	BasicQueueLinkPool
class	BasicQueueVisitor
class	BuildChainVisitor
class	DataLink
class	DataLinkCleanupTask
	Active Object responsible for cleaning up DataLink resources. More...
class	DataLinkSet
class	DataLinkSetMap
struct	HostnameInfo
struct	NetworkAddress
	Defines a wrapper around address info which is used for advertise. More...
class	NullSynch
class	NullSynchStrategy
class	PacketRemoveVisitor
class	PerConnectionSynch
class	PerConnectionSynchStrategy
class	PoolSynch
class	PoolSynchStrategy
class	QueueRemoveVisitor
class	QueueTaskBase
	A simple ACE task that manages a queue of request. More...
class	ReceivedDataSample
	Holds a data sample received by the transport. More...
class	ReceiveListenerSet
class	ReceiveListenerSetMap
class	RemoveAllVisitor
class	RepoIdSet
class	RepoIdSetMap
struct	SendRequest
class	ThreadPerConnectionSendTask
	Execute the requests of sending a sample or control message. More...
class	ThreadPerConRemoveVisitor
class	ThreadSynch
class	ThreadSynchResource
class	ThreadSynchStrategy
class	ThreadSynchWorker
class	TransportConfiguration
	Base class to hold configuration settings for TransportImpls. More...
class	TransportControlElement
class	TransportFactory
class	TransportGenerator
	Base class for concrete transports to provide new objects. More...
struct	TransportHeader
	Defines class that represents a transport packet header. More...
struct	AssociationInfo
class	TransportImpl
class	TransportImplFactory
class	TransportInterface
class	TransportQueueElement
	Base wrapper class around a data/control sample to be sent. More...
class	TransportReactorTask
class	TransportReceiveListener
class	TransportReceiveStrategy
class	TransportReplacedElement
class	TransportSendControlElement
class	TransportSendElement
class	TransportSendListener
class	TransportSendStrategy
class	ReliableMulticastDataLink
class	ReliableMulticastThreadSynchResource
class	ReliableMulticastTransportConfiguration
class	ReliableMulticastTransportGenerator
class	ReliableMulticastTransportImpl
class	ReliableMulticastTransportImplFactory
class	ReliableMulticastTransportReceiveStrategy
class	ReliableMulticastTransportSendStrategy
class	SimpleTcpAcceptor
class	SimpleTcpConfiguration
class	SimpleTcpConnection
class	SimpleTcpConnectionReplaceTask
	Active Object managing a queue of connection info objects. More...
class	SimpleTcpDataLink
class	SimpleTcpFactory
class	SimpleTcpGenerator
class	SimpleTcpReceiveStrategy
class	SimpleTcpReconnectTask
	Active Object managing a queue of reconnecting request. More...
class	SimpleTcpSendStrategy
class	SimpleTcpSynchResource
class	SimpleTcpTransport
class	SimpleMcastConfiguration
class	SimpleMcastFactory
class	SimpleMcastGenerator
class	SimpleMcastSocket
class	SimpleMcastTransport
class	SimpleUdpConfiguration
class	SimpleUdpFactory
class	SimpleUdpGenerator
class	SimpleUdpSocket
class	SimpleUdpTransport
class	SimpleUnreliableDgramConfiguration
class	SimpleUnreliableDgramDataLink
class	SimpleUnreliableDgramReceiveStrategy
class	SimpleUnreliableDgramSendStrategy
class	SimpleUnreliableDgramSocket
class	SimpleUnreliableDgramSynchResource
class	SimpleUnreliableDgramTransport
class	Watchdog
class	WatchdogTimer
	Event handler responsible for calling watchdog when timer expires. More...
class	WriteDataContainer
	A container for instances sample data. More...
class	FirstTimeFastAllocator
struct	WriterAssociation
interface	DataReaderRemote
struct	ReaderAssociation
interface	DataWriterRemote
interface	DCPSInfo
struct	TransportInterfaceInfo
exception	Invalid_Domain
exception	Invalid_Participant
exception	Invalid_Publication
exception	Invalid_Subscription
exception	Invalid_Topic
struct	IncompatibleQosStatus
struct	PublicationLostStatus
interface	DataWriterListener
struct	SubscriptionLostStatus
interface	DataReaderListener
interface	TypeSupport
Namespaces
namespace	ReliableMulticast
namespace	Transport
Typedefs
typedef Cached_Allocator_With_Overflow< ::OpenDDS::DCPS::ReceivedDataElement, ACE_Null_Mutex >	ReceivedDataAllocator
typedef Cached_Allocator_With_Overflow< DataSampleHeader, ACE_Null_Mutex >	DataSampleHeaderAllocator
	Used to allocator the DataSampleHeader object.
typedef Dynamic_Cached_Allocator_With_Overflow< ACE_Thread_Mutex >	TransportSendElementAllocator
typedef ACE_Message_Block	DataSample
typedef Cached_Allocator_With_Overflow< DataSampleListElement, ACE_Null_Mutex >	DataSampleListElementAllocator
	Used to allocator the DataSampleListElement object.
typedef ACE_UINT16	CoherencyGroup
typedef RepoId	PublicationId
typedef Cached_Allocator_With_Overflow< ACE_Message_Block, ACE_Thread_Mutex >	MessageBlockAllocator
typedef Cached_Allocator_With_Overflow< ACE_Data_Block, ACE_Null_Mutex >	DataBlockAllocator
typedef CORBA::LocalObject_ptr	LocalObject_ptr
typedef CORBA::LocalObject_var	LocalObject_var
typedef std::multimap< ACE_CString, PublisherDataWriterInfo * >	DataWriterMap
typedef std::map< PublicationId, PublisherDataWriterInfo * >	PublicationMap
typedef std::map< RepoId, ::DDS::DataWriterQos >	DwIdToQosMap
typedef std::map< std::string, OpenDDS::DCPS::TypeSupport_ptr >	TypeSupportHash
typedef std::map< void , TypeSupportHash >	DomainHash
typedef std::multimap< ACE_CString, SubscriberDataReaderInfo * >	DataReaderMap
typedef std::set< DataReaderImpl * >	DataReaderSet
typedef std::map< RepoId, ::DDS::DataReaderQos >	DrIdToQosMap
typedef RcHandle< DataLink >	DataLink_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< DataLinkSet >	DataLinkSet_rch
	The type definition for the smart-pointer to the underlying type.
typedef std::vector< HostnameInfo >	HostnameInfoVector
typedef RcHandle< ReceiveListenerSet >	ReceiveListenerSet_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< RepoIdSet >	RepoIdSet_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< TransportConfiguration >	TransportConfiguration_rch
	The type definition for the smart-pointer to the underlying type.
typedef ACE_TString	FactoryIdType
	The TransportImplFactory instance ID type.
typedef ACE_UINT32	TransportIdType
	The TransportImpl instance ID type.
typedef std::vector< TransportIdType >	TransportIdList
typedef ACE_UINT64	DataLinkIdType
	Identifier type for DataLink objects.
typedef Cached_Allocator_With_Overflow< ACE_Message_Block, RECEIVE_SYNCH >	TransportMessageBlockAllocator
typedef Cached_Allocator_With_Overflow< ACE_Data_Block, RECEIVE_SYNCH >	TransportDataBlockAllocator
typedef Cached_Allocator_With_Overflow< ACE_TCHAR[RECEIVE_DATA_BUFFER_SIZE], RECEIVE_SYNCH >	TransportDataAllocator
typedef RcHandle< TransportGenerator >	TransportGenerator_rch
	The type definition for the smart-pointer to the underlying type.
typedef ACE_Vector< AssociationInfo >	AssociationInfoList
typedef RcHandle< TransportImpl >	TransportImpl_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< TransportImplFactory >	TransportImplFactory_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< TransportReactorTask >	TransportReactorTask_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< TransportReceiveStrategy >	TransportReceiveStrategy_rch
	The type definition for the smart-pointer to the underlying type.
typedef Cached_Allocator_With_Overflow< TransportReplacedElement, ACE_SYNCH_NULL_MUTEX >	TransportReplacedElementAllocator
typedef Cached_Allocator_With_Overflow< TransportSendControlElement, ACE_SYNCH_NULL_MUTEX >	TransportSendControlElementAllocator
typedef RcHandle< TransportSendStrategy >	TransportSendStrategy_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< ReliableMulticastDataLink >	ReliableMulticastDataLink_rch
typedef RcHandle< ReliableMulticastTransportImpl >	ReliableMulticastTransportImpl_rch
typedef RcHandle< ReliableMulticastTransportConfiguration >	ReliableMulticastTransportConfiguration_rch
typedef RcHandle< SimpleTcpConfiguration >	SimpleTcpConfiguration_rch
typedef RcHandle< SimpleTcpConnection >	SimpleTcpConnection_rch
typedef RcHandle< SimpleTcpDataLink >	SimpleTcpDataLink_rch
typedef RcHandle< SimpleTcpSendStrategy >	SimpleTcpSendStrategy_rch
typedef RcHandle< SimpleTcpTransport >	SimpleTcpTransport_rch
typedef RcHandle< SimpleUdpTransport >	SimpleUdpTransport_rch
typedef RcHandle< SimpleUnreliableDgramConfiguration >	SimpleUnreliableDgramConfiguration_rch
typedef RcHandle< SimpleUnreliableDgramDataLink >	SimpleUnreliableDgramDataLink_rch
typedef RcHandle< SimpleUnreliableDgramSocket >	SimpleUnreliableDgramSocket_rch
typedef RcHandle< SimpleUnreliableDgramTransport >	SimpleUnreliableDgramTransport_rch
typedef std::map< ::DDS::InstanceHandle_t, PublicationInstance * >	PublicationInstanceMapType
typedef sequence< WriterAssociation >	WriterAssociationSeq
typedef sequence< OpenDDS::DCPS::RepoId >	WriterIdSeq
typedef sequence< ReaderAssociation >	ReaderAssociationSeq
typedef sequence< OpenDDS::DCPS::RepoId >	ReaderIdSeq
typedef long	RepoId
typedef long	TransportInterfaceId
typedef sequence< octet >	TransportInterfaceBLOB
typedef PublicationLostStatus	PublicationDisconnectedStatus
typedef PublicationLostStatus	PublicationReconnectedStatus
typedef PublicationLostStatus	DisassociationStatus
typedef SubscriptionLostStatus	SubscriptionDisconnectedStatus
typedef SubscriptionLostStatus	SubscriptionReconnectedStatus
Enumerations
enum	BuiltInTopicTransportTypeId { BIT_SIMPLE_TCP = 0xb17b17 }
enum	BuiltInTopicTransportInstanceId { BIT_ALL_TRAFFIC = 0xb17b17 }
enum	MessageId { SAMPLE_DATA, DATAWRITER_LIVELINESS, INSTANCE_REGISTRATION, UNREGISTER_INSTANCE, DISPOSE_INSTANCE, GRACEFUL_DISCONNECT, FULLY_ASSOCIATED }
	One byte message id (< 256). More...
enum	SendStrategyOpType { SEND_START, SEND, SEND_STOP, REMOVE_SAMPLE, REMOVE_ALL_CONTROL_SAMPLES }
enum	SendControlStatus { SEND_CONTROL_ERROR, SEND_CONTROL_OK }
	Return code type for send_control() operations. More...
enum	AttachStatus { ATTACH_BAD_TRANSPORT, ATTACH_ERROR, ATTACH_INCOMPATIBLE_QOS, ATTACH_OK }
	Return code type for attach_transport() operations. More...
enum	{ MAX_SEND_BLOCKS = 50 }
	Controls the maximum size of the iovec array used for a send packet. More...
enum	{ RECEIVE_DATA_BUFFER_SIZE = 65536 }
	Allocators used for transport receiving logic. More...
enum	{ DEFAULT_CONFIG_QUEUE_MESSAGES_PER_POOL = 10, DEFAULT_CONFIG_QUEUE_INITIAL_POOLS = 5, DEFAULT_CONFIG_MAX_PACKET_SIZE = 2147481599, DEFAULT_CONFIG_MAX_SAMPLES_PER_PACKET = 10, DEFAULT_CONFIG_OPTIMUM_PACKET_SIZE = 4096 }
	Default TransportConfiguration settings. More...
enum	Association_Status { Fully_Associated, Not_Fully_Associated, Association_Error }
enum	ReconnectOpType { DO_RECONNECT }
enum	TopicStatus { CREATED, ENABLED, FOUND, NOT_FOUND, REMOVED, CONFLICTING_TYPENAME }
Functions
OpenDDS_Dcps_Export void	set_DCPS_debug_level (unsigned int lvl)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export ACE_Time_Value	time_to_time_value (const ::DDS::Time_t &t)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export::DDS::Time_t	time_value_to_time (const ACE_Time_Value &tv)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export ACE_Time_Value	duration_to_time_value (const ::DDS::Duration_t &t)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export::DDS::Duration_t	time_value_to_duration (const ACE_Time_Value &tv)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export CORBA::Long	get_instance_sample_list_depth (::DDS::HistoryQosPolicyKind history, long history_depth, long max_samples_per_instance)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export bool	valid_duration (::DDS::Duration_t const &t)
EXTERN_OR_INLINE_HELPER_METHOD OpenDDS_Dcps_Export bool	non_negative_duration (::DDS::Duration_t const &t)
template<typename TO, typename FROM>
TO	truncate_cast (FROM val)
static ACE_TString	config_fname (ACE_TEXT(""))
template<class T_impl, class T_ptr>
T_impl *	remote_reference_to_servant (T_ptr p)
template<class T>
T::_stub_ptr_type	servant_to_remote_reference (T *servant)
template<class T>
void	deactivate_remote_object (T obj)
template<typename Container, typename FirstType, typename SecondType>
int	bind (Container &c, const FirstType &first, const SecondType &second)
template<typename Container>
int	unbind (Container &c, const typename Container::key_type &k, typename Container::mapped_type &v)
template<typename Container>
int	unbind (Container &c, const typename Container::key_type &k)
template<typename Container, typename Key>
int	find (Container &c, const Key &key, typename Container::mapped_type *&value)
template<typename Container, typename Key>
int	find (Container &c, const Key &key, typename Container::mapped_type &value)
template<typename Container, typename ValueType>
int	insert (Container &c, const ValueType &v)
template<typename Container, typename ValueType>
int	remove (Container &c, const ValueType &v)
bool	resend_data_expired (DataSampleListElement const &element,::DDS::LifespanQosPolicy const &lifespan)
Variables
const char *const	BUILT_IN_PARTICIPANT_TOPIC = "DCPSParticipant"
const char *const	BUILT_IN_PARTICIPANT_TOPIC_TYPE = "PARTICIPANT_BUILT_IN_TOPIC_TYPE"
const char *const	BUILT_IN_TOPIC_TOPIC = "DCPSTopic"
const char *const	BUILT_IN_TOPIC_TOPIC_TYPE = "TOPIC_BUILT_IN_TOPIC_TYPE"
const char *const	BUILT_IN_SUBSCRIPTION_TOPIC = "DCPSSubscription"
const char *const	BUILT_IN_SUBSCRIPTION_TOPIC_TYPE = "SUBSCRIPTION_BUILT_IN_TOPIC_TYPE"
const char *const	BUILT_IN_PUBLICATION_TOPIC = "DCPSPublication"
const char *const	BUILT_IN_PUBLICATION_TOPIC_TYPE = "PUBLICATION_BUILT_IN_TOPIC_TYPE"
OpenDDS_Dcps_Export const char *const	BUILT_IN_PARTICIPANT_TOPIC
OpenDDS_Dcps_Export const char *const	BUILT_IN_PARTICIPANT_TOPIC_TYPE
OpenDDS_Dcps_Export const char *const	BUILT_IN_TOPIC_TOPIC
OpenDDS_Dcps_Export const char *const	BUILT_IN_TOPIC_TOPIC_TYPE
OpenDDS_Dcps_Export const char *const	BUILT_IN_SUBSCRIPTION_TOPIC
OpenDDS_Dcps_Export const char *const	BUILT_IN_SUBSCRIPTION_TOPIC_TYPE
OpenDDS_Dcps_Export const char *const	BUILT_IN_PUBLICATION_TOPIC
OpenDDS_Dcps_Export const char *const	BUILT_IN_PUBLICATION_TOPIC_TYPE
const CORBA::ULong	MAX_READERS_PER_ELEM = 5
const int	MAX_READERS_TO_RESEND = 5
OpenDDS_Dcps_Export unsigned int	DCPS_debug_level = 0
const ::DDS::InstanceHandle_t	HANDLE_NIL = 0
const ::CORBA::ULong	DEFAULT_STATUS_KIND_MASK = 0xFFFF
int const	INVALID_ENUM_VALUE = 999
const CoherencyGroup	DEFAULT_GROUP_ID = 0
const int	DEFAULT_BIT_TRANSPORT_PORT = 0
const size_t	DEFAULT_NUM_CHUNKS = 20
const size_t	DEFAULT_CHUNK_MULTIPLIER = 10
const int	BIT_LOOKUP_DURATION_MSEC = 2000
static const ACE_TCHAR	DEFAULT_REPO_IOR [] = ACE_TEXT("file://repo.ior")
static const ACE_TCHAR	COMMON_SECTION_NAME [] = ACE_TEXT("common")
static const ACE_TCHAR	DOMAIN_SECTION_NAME [] = ACE_TEXT("domain")
static const ACE_TCHAR	REPO_SECTION_NAME [] = ACE_TEXT("repository")
static bool	got_debug_level = false
static bool	got_info = false
static bool	got_chunks = false
static bool	got_chunk_association_multiplier = false
static bool	got_liveliness_factor = false
static bool	got_bit_transport_port = false
static bool	got_bit_transport_ip = false
static bool	got_bit_lookup_duration_msec = false
static bool	got_bit_flag = false
OpenDDS_Dcps_Export unsigned int	Transport_debug_level = 0
	Transport Logging verbosity level.
const bool	AUTO_CONFIG = 1
const bool	DONT_AUTO_CONFIG = 0
const TransportIdType	DEFAULT_SIMPLE_TCP_ID = 0xFFFFFF00
const TransportIdType	DEFAULT_SIMPLE_UDP_ID = 0xFFFFFF01
const TransportIdType	DEFAULT_SIMPLE_MCAST_PUB_ID = 0xFFFFFF02
const TransportIdType	DEFAULT_SIMPLE_MCAST_SUB_ID = 0xFFFFFF03
const TransportIdType	DEFAULT_RELIABLE_MULTICAST_PUB_ID = 0xFFFFFF04
const TransportIdType	DEFAULT_RELIABLE_MULTICAST_SUB_ID = 0xFFFFFF05
const TransportIdType	DEFAULT_DUMMY_TCP_ID = 0xFFFFFF06