OpenDDS::DCPS Namespace Reference

Namespaces
namespace	FilterExpressionGrammar
namespace	GrammarUtils
namespace	TopicExpressionGrammar
namespace	Transport
namespace	Util
Classes
struct	AssociationData
class	BitPubListenerImpl
class	BuiltinTopicKeyLess
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...
struct	WriterCoherentSample
struct	CoherentChangeControl
	End Coherent Change message. More...
class	ComparatorBase
class	FieldComparator
class	StructComparator
class	ConditionImpl
class	ContentFilteredTopicImpl
class	DataCollector
	Collect data in a buffer. More...
class	DataDurabilityCache
	Underlying data cache for both OpenDDS `TRANSIENT` and `PERSISTENT` `DURABILITY` implementations.. More...
class	DataReaderCallbacks
	Defines the interface for Discovery callbacks into the DataReader. More...
class	WriterStats
	Elements stored for managing statistical data. More...
class	AbstractSamples
class	EndHistoricSamplesMissedSweeper
class	DataReaderImpl
	Implements the DDS::DataReader interface. More...
class	DataReaderImpl_T
class	DataSampleElement
struct	DataSampleHeader
class	DataWriterCallbacks
	Defines the interface for Discovery callbacks into the DataWriter. More...
class	DataWriterImpl
	Implements the OpenDDS::DCPS::DataWriterRemote interfaces and DDS::DataWriter interfaces. More...
class	LivenessTimer
class	DataWriterImpl_T
class	PartitionName
struct	Objref_Servant_Pair
	This struct holds both object reference and the corresponding servant. More...
struct	VarLess
class	Discovery
	Discovery Strategy interface class. More...
struct	DcpsUpcalls
class	EndpointManager
class	LocalParticipant
class	PeerDiscovery
class	DiscoveryListener
	Defines the interface that allows DataWriters (and lower levels) to inform discovery. More...
class	DisjointSequence
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...
struct	Value
class	FilterEvaluator
class	MetaStruct
class	GroupRakeData
class	GuidBuilder
class	GuidConverter
	Conversion processing and value testing utilities for RTPS GUID_t types. More...
struct	LogGuid
struct	GUID_tKeyLessThan
struct	GuidPrefixEqual
struct	EntityIdConverter
interface	DataReaderRemote
class	DataReaderRemoteImpl
	Implements the OpenDDS::DCPS::ReaderRemote interface that is used to add and remove associations. More...
interface	DataWriterRemote
class	DataWriterRemoteImpl
	Implements the OpenDDS::DCPS::DataWriterRemote interface. More...
class	FailoverListener
exception	Invalid_Domain
exception	Invalid_Participant
exception	Invalid_Publication
exception	Invalid_Subscription
exception	Invalid_Topic
interface	DCPSInfo
class	InfoRepoDiscovery
	Discovery Strategy class that implements InfoRepo discovery. More...
class	IRDiscoveryLoader
class	InstanceDataSampleList
class	InstanceHandleGenerator
class	InstanceState
	manage the states of a received data instance. More...
class	LocalObjectBase
class	LocalObject
class	Marked_Default_Qos
class	AllocHeader
class	FreeHeader
class	FreeIndexNode
class	FreeIndex
class	MemoryPool
struct	Message_Block_Deleter
class	MessageTracker
class	Monitor
class	MonitorFactory
	Null implementation of the MonitorFactory. More...
class	MultiTopicDataReader_T
class	MultiTopicDataReaderBase
class	MultiTopicImpl
class	OfferedDeadlineWatchdog
	Watchdog responsible calling the `DataWriterListener` when the deadline period expires. More...
class	OwnershipManager
class	PoolAllocationBase
class	PublicationInstance
	Struct that has information about an instance and the instance sample list. 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	QOS_XML_Loader
class	QOS_XML_File_Handler
class	QueryConditionImpl
struct	RakeData
class	RakeResults
class	RawDataSample
class	RcEventHandler
struct	inc_count
struct	keep_count
class	RcHandle
class	reference_wrapper
class	WeakObject
class	RcObject
class	WeakRcHandle
class	ReactorInterceptor
class	ReadConditionImpl
class	ReceivedDataElement
struct	ReceivedDataElementMemoryBlock
class	ReceivedDataElementWithType
class	ReceivedDataFilter
class	ReceivedDataOperation
class	ReceivedDataElementList
class	ReceivedDataStrategy
class	ReceptionDataStrategy
class	SourceDataStrategy
class	RecorderListener
	Listener for handling callbacks from the Recorder. More...
class	Recorder
class	RecorderImpl
	Implementation of Recorder functionality. More...
class	Data_Types_Register
class	RemoveAssociationSweeper
class	ReplayerListener
	Listener for handling callbacks from the Replayer. More...
class	Replayer
	Send raw data samples in the system. More...
class	ReplayerImpl
	Implementation of Replayer functionality. More...
class	RepoIdBuilder
class	RepoIdConverter
	Conversion processing and value testing utilities for DCPS Information Repository identifiers. More...
class	RepoIdGenerator
	Create RepoId values for use within DDS. More...
class	RequestedDeadlineWatchdog
	Watchdog responsible calling the `DataReaderListener` when the deadline period expires. More...
struct	RestoreOutputStreamState
class	SafetyProfilePool
	Memory pool for use when the Safety Profile is enabled. More...
struct	SendStateDataSampleListIterator
	`SendStateDataSampleList` STL-style iterator implementation. More...
struct	SendStateDataSampleListConstIterator
	`SendStateDataSampleList` STL-style const iterator implementation. More...
class	SendStateDataSampleList
class	SequenceBackInsertIterator
struct	SequenceIterTraits
struct	ConstSequenceIterTraits
struct	SequenceIteratorBase
struct	SequenceIterator
struct	ConstSequenceIterator
class	SequenceNumber
	Sequence number abstraction. Only allows positive 64 bit values. More...
class	Serializer
	Class to serialize and deserialize data for DDS. More...
struct	KeyOnly
class	Service_Participant
	Service entrypoint. More...
class	EndpointRegistry
struct	StaticDiscoveredParticipantData
class	StaticEndpointManager
class	StaticParticipant
class	StaticDiscovery
class	Stats
	Accumulates average, n, variance, minimum, and maximum statistics. More...
class	StatusConditionImpl
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	TopicDescriptionPtr
class	TopicImpl
	Implements the DDS::Topic interface. More...
class	Transient_Kludge
class	BasicQueue
class	BasicQueueVisitor
class	BuildChainVisitor
class	CopyChainVisitor
class	DataLink
class	DataLinkCleanupTask
	Active Object responsible for cleaning up DataLink resources. More...
class	DataLinkSet
class	DataLinkWatchdog
class	DirectPriorityMapper
	map TRANSPORT_PRIORITY values directly. More...
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	PriorityKey
	Encapsulate a priority value and internet address as a key. More...
class	PriorityMapper
	Encapsulate a TRANSPORT_PRIORITY value. More...
class	QueueRemoveVisitor
class	QueueTaskBase
	A simple ACE task that manages a queue of request. More...
class	ReactorSynch
	Send thread synchronization utilizing a reactor. More...
class	ReactorSynchStrategy
	strategy to construct ReactorSynch implementations of ThreadSynch. More...
class	ReceivedDataSample
	Holds a data sample received by the transport. More...
class	ReceiveListenerSet
class	ReceiveListenerSetMap
class	RemoveAllVisitor
class	ScheduleOutputHandler
	event handler used to enable and disable output processing. More...
class	SendResponseListener
	Simple listener to discard response samples. More...
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	TransportClient
	Mix-in class for DDS entities which directly use the transport layer. More...
class	TransportConfig
class	TransportControlElement
class	TransportCustomizedElement
struct	TransportHeader
	Defines class that represents a transport packet header. More...
class	TransportImpl
class	TransportInst
	Base class to hold configuration settings for TransportImpls. More...
class	TransportQueueElement
	Base wrapper class around a data/control sample to be sent. More...
class	TransportReactorTask
class	TransportReassembly
class	TransportReceiveListener
class	TransportReceiveStrategy
class	TransportRegistry
class	TransportReplacedElement
class	TransportRetainedElement
class	TransportSendBuffer
class	SingleSendBuffer
class	TransportSendControlElement
class	TransportSendElement
class	TransportSendListener
class	TransportSendStrategy
class	TransportStrategy
class	TransportType
	Base class for concrete transports to provide new objects. More...
class	BestEffortSession
class	BestEffortSessionFactory
class	MulticastInitializer
class	MulticastDataLink
class	MulticastInst
class	MulticastType
class	MulticastLoader
class	MulticastReceiveStrategy
class	MulticastSendStrategy
class	SynWatchdog
class	MulticastSession
class	MulticastSessionFactory
class	MulticastTransport
class	NakWatchdog
class	ReliableSession
class	ReliableSessionFactory
class	RtpsCustomizedElement
class	RtpsSampleHeader
	Adapt the TransportReceiveStrategy for RTPS's "sample" (submessage) Header. More...
struct	RtpsTransportHeader
	Adapt the TransportReceiveStrategy for RTPS's "transport" (message) Header. More...
class	RtpsUdpInitializer
class	RtpsUdpDataLink
class	RtpsUdpInst
class	RtpsUdpType
class	RtpsUdpLoader
class	RtpsUdpReceiveStrategy
class	RtpsUdpSendStrategy
class	RtpsUdpTransport
class	ShmemInitializer
struct	ShmemData
class	ShmemDataLink
class	ShmemInst
class	ShmemType
class	ShmemLoader
class	ShmemReceiveStrategy
class	ShmemSendStrategy
class	ShmemTransport
class	Tcp_Initializer
class	TcpAcceptor
class	TcpConnection
class	TcpConnectionReplaceTask
	Active Object managing a queue of connection info objects. More...
class	TcpDataLink
class	TcpInst
class	TcpType
class	TcpLoader
class	TcpReceiveStrategy
class	TcpReconnectTask
	Active Object managing a queue of reconnecting request. More...
class	TcpSendStrategy
class	TcpSynchResource
class	TcpTransport
class	UdpInitializer
class	UdpDataLink
class	UdpInst
class	UdpType
class	UdpLoader
class	UdpReceiveStrategy
class	UdpSendStrategy
class	UdpTransport
class	TypeSupportImpl
class	rv
struct	default_deleter
class	unique_ptr
class	container_supported_unique_ptr
class	EnableContainerSupportedUniquePtr
class	V8TypeConverter
class	Watchdog
	Watchdog abstract base class. More...
class	WriteDataContainer
	A container for instances sample data. More...
class	WriterDataSampleList
class	WriterInfoListener
class	WriterInfo
	Keeps track of a DataWriter's liveliness for a DataReader. More...
class	FirstTimeFastAllocator
struct	EntityId_t
struct	GUID_t
struct	TransportLocator
struct	IncompatibleQosStatus
struct	AddDomainStatus
struct	WriterAssociation
struct	ReaderAssociation
struct	Locator_t
struct	ContentFilterProperty_t
struct	ReaderProxy_t
struct	DiscoveredReaderData
struct	WriterProxy_t
struct	DiscoveredWriterData
struct	PublicationLostStatus
interface	DataWriterListener
struct	SubscriptionLostStatus
struct	BudgetExceededStatus
struct	LatencyStatistics
	Collection of latency statistics for a single association. More...
interface	DataReaderListener
interface	DataReaderEx
interface	TypeSupport
class	DPMonitorImpl
class	DRMonitorImpl
class	DRPeriodicMonitorImpl
class	DWMonitorImpl
class	DWPeriodicMonitorImpl
struct	Statistics
union	ValueUnion
struct	NameValuePair
struct	ServiceParticipantReport
struct	DomainParticipantReport
struct	TopicReport
struct	PublisherReport
struct	SubscriberReport
struct	DataWriterAssociation
struct	DataWriterReport
struct	DataWriterAssociationPeriodic
struct	DataWriterPeriodicReport
struct	DataReaderAssociation
struct	DataReaderReport
struct	DataReaderAssociationPeriodic
struct	DataReaderPeriodicReport
struct	TransportReport
union	GenericReport
interface	ProcessMonitor
class	MonitorFactoryImpl
	Full implementation of the MonitorFactoryImpl. More...
class	PublisherMonitorImpl
class	SPMonitorImpl
class	SubscriberMonitorImpl
class	TopicMonitorImpl
class	TransportMonitorImpl
Typedefs
typedef yard::TreeBuildingParser< char > ::Node	AstNode
typedef std::pair < OPENDDS_STRING, ACE_Configuration_Section_Key >	SubsectionPair
typedef Cached_Allocator_With_Overflow < OpenDDS::DCPS::ReceivedDataElementMemoryBlock, ACE_Null_Mutex >	ReceivedDataAllocator
typedef RcHandle< DataReaderImpl >	DataReaderImpl_rch
typedef Cached_Allocator_With_Overflow < DataSampleElement, ACE_Null_Mutex >	DataSampleElementAllocator
typedef RcHandle < PublicationInstance >	PublicationInstance_rch
typedef ACE_Message_Block	DataSample
typedef RcHandle< DataWriterImpl >	DataWriterImpl_rch
typedef Cached_Allocator_With_Overflow < ACE_Message_Block, ACE_Thread_Mutex >	MessageBlockAllocator
typedef Cached_Allocator_With_Overflow < ACE_Data_Block, ACE_Thread_Mutex >	DataBlockAllocator
typedef Cached_Allocator_With_Overflow < DataSampleHeader, ACE_Null_Mutex >	DataSampleHeaderAllocator
typedef RcHandle< Discovery >	Discovery_rch
typedef DataReaderImpl_T < DDS::ParticipantBuiltinTopicData >	ParticipantBuiltinTopicDataDataReaderImpl
typedef DataReaderImpl_T < DDS::PublicationBuiltinTopicData >	PublicationBuiltinTopicDataDataReaderImpl
typedef DataReaderImpl_T < DDS::SubscriptionBuiltinTopicData >	SubscriptionBuiltinTopicDataDataReaderImpl
typedef DataReaderImpl_T < DDS::TopicBuiltinTopicData >	TopicBuiltinTopicDataDataReaderImpl
typedef RcHandle < InfoRepoDiscovery >	InfoRepoDiscovery_rch
typedef CORBA::LocalObject_ptr	LocalObject_ptr
typedef CORBA::LocalObject_var	LocalObject_var
typedef unique_ptr < ACE_Message_Block, Message_Block_Deleter >	Message_Block_Ptr
typedef ACE_UINT16	CoherencyGroup
typedef RcHandle < RecorderListener >	RecorderListener_rch
typedef Recorder *	Recorder_ptr
typedef TAO_Objref_Var_T < Recorder >	Recorder_var
typedef RcHandle < ReplayerListener >	ReplayerListener_rch
typedef Replayer *	Replayer_ptr
typedef TAO_Objref_Var_T < Replayer >	Replayer_var
typedef ::CORBA::Long	ParticipantId
typedef RepoId	PublicationId
typedef RepoId	SubscriptionId
typedef ACE_Allocator	SafetyProfilePool
typedef std::pair < SequenceNumber, SequenceNumber >	SequenceRange
typedef RcHandle< StaticDiscovery >	StaticDiscovery_rch
typedef RcHandle < SubscriptionInstance >	SubscriptionInstance_rch
typedef WeakRcHandle < TransportSendListener >	TransportSendListener_wrch
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 WeakRcHandle < TransportReceiveListener >	TransportReceiveListener_wrch
typedef RcHandle < ReceiveListenerSet >	ReceiveListenerSet_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle < ThreadSynchStrategy >	ThreadSynchStrategy_rch
typedef RcHandle < ThreadSynchWorker >	ThreadSynchWorker_rch
typedef RcHandle< TransportClient >	TransportClient_rch
typedef RcHandle< TransportConfig >	TransportConfig_rch
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 < char[RECEIVE_DATA_BUFFER_SIZE], RECEIVE_SYNCH >	TransportDataAllocator
typedef ACE_CDR::Long	Priority
typedef WeakRcHandle < TransportClient >	TransportClient_wrch
typedef RcHandle< TransportImpl >	TransportImpl_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle< TransportInst >	TransportInst_rch
	The type definition for the smart-pointer to the underlying type.
typedef std::pair < TransportQueueElement , TransportQueueElement >	ElementPair
typedef RcHandle < TransportReactorTask >	TransportReactorTask_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle < TransportReceiveListener >	TransportReceiveListener_rch
typedef RcHandle < TransportReceiveStrategy >	TransportReceiveStrategy_rch
	The type definition for the smart-pointer to the underlying type.
typedef Cached_Allocator_With_Overflow < TransportSendControlElement, ACE_SYNCH_NULL_MUTEX >	TransportSendControlElementAllocator
typedef RcHandle < TransportSendListener >	TransportSendListener_rch
typedef RcHandle < TransportSendStrategy >	TransportSendStrategy_rch
	The type definition for the smart-pointer to the underlying type.
typedef RcHandle < TransportStrategy >	TransportStrategy_rch
typedef RcHandle< TransportType >	TransportType_rch
typedef RcHandle < MulticastTransport >	MulticastTransport_rch
typedef RcHandle < MulticastDataLink >	MulticastDataLink_rch
typedef RcHandle< MulticastInst >	MulticastInst_rch
typedef RcHandle < MulticastReceiveStrategy >	MulticastReceiveStrategy_rch
typedef RcHandle < MulticastSendStrategy >	MulticastSendStrategy_rch
typedef RcHandle < MulticastSession >	MulticastSession_rch
typedef RcHandle < MulticastSessionFactory >	MulticastSessionFactory_rch
typedef ACE_INT64	MulticastPeer
typedef Dynamic_Cached_Allocator_With_Overflow < ACE_Thread_Mutex >	RtpsCustomizedElementAllocator
typedef RcHandle< RtpsUdpInst >	RtpsUdpInst_rch
typedef RcHandle < RtpsUdpTransport >	RtpsUdpTransport_rch
typedef RcHandle< RtpsUdpDataLink >	RtpsUdpDataLink_rch
typedef RcHandle < RtpsUdpReceiveStrategy >	RtpsUdpReceiveStrategy_rch
typedef RcHandle < RtpsUdpSendStrategy >	RtpsUdpSendStrategy_rch
typedef RcHandle< ShmemTransport >	ShmemTransport_rch
typedef ACE_Shared_Memory_Pool	ShmemPool
typedef int	ShmemSharedSemaphore
typedef ACE_Malloc_T < ShmemPool, ACE_Process_Mutex, ACE_PI_Control_Block >	ShmemAllocator
typedef RcHandle< ShmemDataLink >	ShmemDataLink_rch
typedef RcHandle< ShmemInst >	ShmemInst_rch
typedef RcHandle < ShmemReceiveStrategy >	ShmemReceiveStrategy_rch
typedef RcHandle < ShmemSendStrategy >	ShmemSendStrategy_rch
typedef RcHandle< TcpConnection >	TcpConnection_rch
typedef RcHandle< TcpDataLink >	TcpDataLink_rch
typedef RcHandle< TcpInst >	TcpInst_rch
typedef RcHandle < TcpReceiveStrategy >	TcpReceiveStrategy_rch
typedef RcHandle< TcpSendStrategy >	TcpSendStrategy_rch
typedef RcHandle< TcpTransport >	TcpTransport_rch
typedef RcHandle< UdpTransport >	UdpTransport_rch
typedef RcHandle< UdpDataLink >	UdpDataLink_rch
typedef RcHandle< UdpInst >	UdpInst_rch
typedef RcHandle < UdpReceiveStrategy >	UdpReceiveStrategy_rch
typedef RcHandle< UdpSendStrategy >	UdpSendStrategy_rch
typedef octet	GuidVendorId_t [2]
typedef octet	GuidPrefix_t [12]
typedef octet	EntityKey_t [3]
typedef sequence< GUID_t >	GUIDSeq
typedef GUID_t	RepoId
typedef DDS::OctetSeq	TransportBLOB
typedef sequence < TransportLocator >	TransportLocatorSeq
typedef sequence< RepoId >	WriterIdSeq
typedef sequence< RepoId >	ReaderIdSeq
typedef octet	OctetArray16 [16]
typedef sequence< Locator_t >	LocatorSeq
typedef string< 256 >	String256
typedef PublicationLostStatus	PublicationDisconnectedStatus
typedef PublicationLostStatus	PublicationReconnectedStatus
typedef PublicationLostStatus	DisassociationStatus
typedef SubscriptionLostStatus	SubscriptionDisconnectedStatus
typedef SubscriptionLostStatus	SubscriptionReconnectedStatus
typedef sequence < LatencyStatistics >	LatencyStatisticsSeq
typedef sequence< NameValuePair >	NVPSeq
typedef sequence < DataWriterAssociation >	DWAssociations
typedef sequence < DataWriterAssociationPeriodic >	DWAssociationsPeriodic
typedef sequence < DataReaderAssociation >	DRAssociations
typedef sequence < DataReaderAssociationPeriodic >	DRAssociationsPeriodic
Enumerations
enum	MarshalingType { FULL_MARSHALING, KEY_ONLY_MARSHALING }
enum	MessageId { SAMPLE_DATA, DATAWRITER_LIVELINESS, INSTANCE_REGISTRATION, UNREGISTER_INSTANCE, DISPOSE_INSTANCE, GRACEFUL_DISCONNECT, REQUEST_ACK, SAMPLE_ACK, END_COHERENT_CHANGES, TRANSPORT_CONTROL, DISPOSE_UNREGISTER_INSTANCE, END_HISTORIC_SAMPLES, MESSAGE_ID_MAX }
	One byte message id (<256). More...
enum	SubMessageId { SUBMESSAGE_NONE, MULTICAST_SYN, MULTICAST_SYNACK, MULTICAST_NAK, MULTICAST_NAKACK, SUBMESSAGE_ID_MAX }
enum	DataSampleHeaderFlag { BYTE_ORDER_FLAG, COHERENT_CHANGE_FLAG, HISTORIC_SAMPLE_FLAG, LIFESPAN_DURATION_FLAG, GROUP_COHERENT_FLAG, CONTENT_FILTER_FLAG, SEQUENCE_REPAIR_FLAG, MORE_FRAGMENTS_FLAG }
enum	DataSampleHeaderFlag2 { CDR_ENCAP_FLAG, KEY_ONLY_FLAG }
enum	EntityKind { KIND_UNKNOWN, KIND_PARTICIPANT, KIND_WRITER, KIND_READER, KIND_TOPIC, KIND_BUILTIN_WRITER, KIND_BUILTIN_READER, KIND_BUILTIN_TOPIC, KIND_PUBLISHER, KIND_SUBSCRIBER, KIND_USER }
enum	Operation_t { DDS_OPERATION_READ, DDS_OPERATION_TAKE }
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 TransportInst settings. More...
enum	RemoveResult { REMOVE_ERROR, REMOVE_NOT_FOUND, REMOVE_FOUND, REMOVE_RELEASED }
	used by DataLink::remove_sample(), TransportSendStrategy, *RemoveVisitor More...
enum	{ SHMEM_DATA_FREE = 0, SHMEM_DATA_IN_USE = 1, SHMEM_DATA_RECV_DONE = 2, SHMEM_DATA_END_OF_ALLOC = -1 }
enum	ReconnectOpType { DO_RECONNECT }
enum	Coherent_State { NOT_COMPLETED_YET, COMPLETED, REJECTED }
enum	TopicStatus { CREATED, ENABLED, FOUND, NOT_FOUND, REMOVED, CONFLICTING_TYPENAME, PRECONDITION_NOT_MET, INTERNAL_ERROR, TOPIC_DISABLED }
enum	ValueEnumType { INTEGER_TYPE, DOUBLE_TYPE, STRING_TYPE, STATISTICS_TYPE, STRING_LIST_TYPE }
enum	ReportType { SERVICE_PARTICIPANT_REPORT_TYPE, DOMAIN_PARTICIPANT_REPORT_TYPE, TOPIC_REPORT_TYPE, PUBLISHER_REPORT_TYPE, SUBSCRIBER_REPORT_TYPE, DATA_WRITER_REPORT_TYPE, DATA_WRITER_PERIODIC_REPORT_TYPE, DATA_READER_REPORT_TYPE, DATA_READER_PERIODIC_REPORT_TYPE, TRANSPORT_REPORT_TYPE }
Functions
void	reportErrors (yard::SimpleTextParser &parser, const char *input)
	called after parsing has failed, throws std::exception with details
OPENDDS_STRING	toString (yard::TreeBuildingParser< char >::Node *iter)
bool	topicIsBIT (const char name, const char type)
template<typename TopicType >
DDS::BuiltinTopicKey_t	keyFromSample (TopicType *sample)
template<class BIT_Reader_var , class BIT_DataSeq >
DDS::ReturnCode_t	instance_handle_to_bit_data (DomainParticipantImpl dp, const char bit_name, const DDS::InstanceHandle_t &handle, BIT_DataSeq &data)
template<>
DDS::BuiltinTopicKey_t	keyFromSample< DDS::ParticipantBuiltinTopicData > (DDS::ParticipantBuiltinTopicData *sample)
template<>
DDS::BuiltinTopicKey_t	keyFromSample< DDS::TopicBuiltinTopicData > (DDS::TopicBuiltinTopicData *sample)
template<>
DDS::BuiltinTopicKey_t	keyFromSample< DDS::SubscriptionBuiltinTopicData > (DDS::SubscriptionBuiltinTopicData *sample)
template<>
DDS::BuiltinTopicKey_t	keyFromSample< DDS::PublicationBuiltinTopicData > (DDS::PublicationBuiltinTopicData *sample)
ACE_CDR::Boolean	operator<< (OpenDDS::DCPS::Serializer &serializer, OpenDDS::DCPS::CoherentChangeControl &value)
	Marshal/Insertion into a buffer.
ACE_CDR::Boolean	operator>> (Serializer &serializer, CoherentChangeControl &value)
OpenDDS_Dcps_Export std::ostream &	operator<< (std::ostream &str, const CoherentChangeControl &value)
	Message header insertion onto an ostream.
typedef	OPENDDS_MAP_CMP (PublicationId, WriterCoherentSample, GUID_tKeyLessThan) GroupCoherentSamples
template<class Sample , class Field >
ComparatorBase::Ptr	make_field_cmp (Field Sample::*mp, ComparatorBase::Ptr next)
template<class Sample , class Field >
ComparatorBase::Ptr	make_struct_cmp (Field Sample::*mp, ComparatorBase::Ptr delegate, ComparatorBase::Ptr next)
int	pullValues (ACE_Configuration_Heap &cf, const ACE_Configuration_Section_Key &key, ValueMap &values)
int	processSections (ACE_Configuration_Heap &cf, const ACE_Configuration_Section_Key &key, KeyList &subsections)
typedef	OPENDDS_MAP (OPENDDS_STRING, OPENDDS_STRING) ValueMap
	Helper types and functions for config file parsing.
typedef	OPENDDS_LIST (SubsectionPair) KeyList
template<typename T >
bool	convertToInteger (const OPENDDS_STRING &s, T &value)
template<typename DatumType >
std::ostream &	operator<< (std::ostream &str, const DataCollector< DatumType > &value)
	Insert collected data onto an ostream.
bool	operator<< (ACE_Message_Block &, const DataSampleHeader &value)
	Marshal/Insertion into a buffer.
const char *	to_string (const MessageId value)
const char *	to_string (const SubMessageId value)
OPENDDS_STRING	to_string (const DataSampleHeader &value)
std::ostream &	operator<< (std::ostream &str, const MessageId value)
	Message Id enumeration insertion onto an ostream.
std::ostream &	operator<< (std::ostream &os, const SubMessageId rhs)
	Sub-Message Id enumeration insertion onto an ostream.
OpenDDS_Dcps_Export std::ostream &	operator<< (std::ostream &str, const DataSampleHeader &value)
	Message header insertion onto an ostream.
bool	is_wildcard (const char *str)
bool	matches_name (const DDS::PartitionQosPolicy &qos, const PartitionName &name)
bool	matches_default (const DDS::PartitionQosPolicy &qos)
bool	matching_partitions (const DDS::PartitionQosPolicy &pub, const DDS::PartitionQosPolicy &sub)
void	increment_incompatibility_count (OpenDDS::DCPS::IncompatibleQosStatus *status, DDS::QosPolicyId_t incompatible_policy)
bool	compatibleTransports (const OpenDDS::DCPS::TransportLocatorSeq &s1, const OpenDDS::DCPS::TransportLocatorSeq &s2)
bool	compatibleQOS (OpenDDS::DCPS::IncompatibleQosStatus writerStatus, OpenDDS::DCPS::IncompatibleQosStatus readerStatus, const OpenDDS::DCPS::TransportLocatorSeq &pubTLS, const OpenDDS::DCPS::TransportLocatorSeq &subTLS, DDS::DataWriterQos const const writerQos, DDS::DataReaderQos const const readerQos, DDS::PublisherQos const const pubQos, DDS::SubscriberQos const const subQos)
bool	compatibleQOS (const DDS::PublisherQos pubQos, const DDS::SubscriberQos subQos, OpenDDS::DCPS::IncompatibleQosStatus writerStatus, OpenDDS::DCPS::IncompatibleQosStatus readerStatus)
bool	compatibleQOS (const DDS::DataWriterQos writerQos, const DDS::DataReaderQos readerQos, OpenDDS::DCPS::IncompatibleQosStatus writerStatus, OpenDDS::DCPS::IncompatibleQosStatus readerStatus)
bool	should_check_association_upon_change (const DDS::DataReaderQos &qos1, const DDS::DataReaderQos &qos2)
bool	should_check_association_upon_change (const DDS::DataWriterQos &qos1, const DDS::DataWriterQos &qos2)
bool	should_check_association_upon_change (const DDS::SubscriberQos &qos1, const DDS::SubscriberQos &qos2)
bool	should_check_association_upon_change (const DDS::PublisherQos &qos1, const DDS::PublisherQos &qos2)
bool	should_check_association_upon_change (const DDS::TopicQos &, const DDS::TopicQos &)
bool	should_check_association_upon_change (const DDS::DomainParticipantQos &, const DDS::DomainParticipantQos &)
OpenDDS_Dcps_Export void	set_DCPS_debug_level (unsigned int lvl)
void	assign (DCPS::EntityKey_t &lhs, unsigned int rhs)
static size_t	arity (const FilterEvaluator::AstNodeWrapper &node)
static FilterEvaluator::AstNodeWrapper	child (const FilterEvaluator::AstNodeWrapper &node, size_t idx)
template<typename T >
const MetaStruct &	getMetaStruct ()
std::ostream &	operator<< (std::ostream &os, const GuidConverter &rhs)
OPENDDS_STRING	to_string (const GUID_t &guid)
std::ostream &	operator<< (std::ostream &os, const GUID_t &rhs)
std::istream &	operator>> (std::istream &is, GUID_t &rhs)
typedef	OPENDDS_SET_CMP (RepoId, GUID_tKeyLessThan) RepoIdSet
size_t	gen_max_marshaled_size (const GUID_t &)
bool	operator== (const GUID_t &lhs, const GUID_t &rhs)
bool	operator!= (const GUID_t &lhs, const GUID_t &rhs)
bool	operator== (const EntityId_t &lhs, const EntityId_t &rhs)
bool	operator!= (const EntityId_t &lhs, const EntityId_t &rhs)
	ACE_FACTORY_DEFINE (OpenDDS_InfoRepoDiscovery, IRDiscoveryLoader)
const DDS::InstanceHandle_t	HANDLE_UNKNOWN (0)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::UserDataQosPolicy &qos1, const DDS::UserDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::TopicDataQosPolicy &qos1, const DDS::TopicDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::GroupDataQosPolicy &qos1, const DDS::GroupDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::TransportPriorityQosPolicy &qos1, const DDS::TransportPriorityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::LifespanQosPolicy &qos1, const DDS::LifespanQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DurabilityQosPolicy &qos1, const DDS::DurabilityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DurabilityServiceQosPolicy &qos1, const DDS::DurabilityServiceQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::PresentationQosPolicy &qos1, const DDS::PresentationQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DeadlineQosPolicy &qos1, const DDS::DeadlineQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::LatencyBudgetQosPolicy &qos1, const DDS::LatencyBudgetQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::OwnershipQosPolicy &qos1, const DDS::OwnershipQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::OwnershipStrengthQosPolicy &qos1, const DDS::OwnershipStrengthQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::LivelinessQosPolicy &qos1, const DDS::LivelinessQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::TimeBasedFilterQosPolicy &qos1, const DDS::TimeBasedFilterQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::PartitionQosPolicy &qos1, const DDS::PartitionQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::ReliabilityQosPolicy &qos1, const DDS::ReliabilityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DestinationOrderQosPolicy &qos1, const DDS::DestinationOrderQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::HistoryQosPolicy &qos1, const DDS::HistoryQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::ResourceLimitsQosPolicy &qos1, const DDS::ResourceLimitsQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::EntityFactoryQosPolicy &qos1, const DDS::EntityFactoryQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::WriterDataLifecycleQosPolicy &qos1, const DDS::WriterDataLifecycleQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::ReaderDataLifecycleQosPolicy &qos1, const DDS::ReaderDataLifecycleQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DomainParticipantQos &qos1, const DDS::DomainParticipantQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::TopicQos &qos1, const DDS::TopicQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DataWriterQos &qos1, const DDS::DataWriterQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::PublisherQos &qos1, const DDS::PublisherQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DataReaderQos &qos1, const DDS::DataReaderQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::SubscriberQos &qos1, const DDS::SubscriberQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::DomainParticipantFactoryQos &qos1, const DDS::DomainParticipantFactoryQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::UserDataQosPolicy &qos1, const DDS::UserDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::TopicDataQosPolicy &qos1, const DDS::TopicDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::GroupDataQosPolicy &qos1, const DDS::GroupDataQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::TransportPriorityQosPolicy &qos1, const DDS::TransportPriorityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::LifespanQosPolicy &qos1, const DDS::LifespanQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DurabilityQosPolicy &qos1, const DDS::DurabilityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DurabilityServiceQosPolicy &qos1, const DDS::DurabilityServiceQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::PresentationQosPolicy &qos1, const DDS::PresentationQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DeadlineQosPolicy &qos1, const DDS::DeadlineQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::LatencyBudgetQosPolicy &qos1, const DDS::LatencyBudgetQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::OwnershipQosPolicy &qos1, const DDS::OwnershipQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::OwnershipStrengthQosPolicy &qos1, const DDS::OwnershipStrengthQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::LivelinessQosPolicy &qos1, const DDS::LivelinessQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::TimeBasedFilterQosPolicy &qos1, const DDS::TimeBasedFilterQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::PartitionQosPolicy &qos1, const DDS::PartitionQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::ReliabilityQosPolicy &qos1, const DDS::ReliabilityQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DestinationOrderQosPolicy &qos1, const DDS::DestinationOrderQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::HistoryQosPolicy &qos1, const DDS::HistoryQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::ResourceLimitsQosPolicy &qos1, const DDS::ResourceLimitsQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::EntityFactoryQosPolicy &qos1, const DDS::EntityFactoryQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::WriterDataLifecycleQosPolicy &qos1, const DDS::WriterDataLifecycleQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::ReaderDataLifecycleQosPolicy &qos1, const DDS::ReaderDataLifecycleQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::PropertyQosPolicy &qos1, const DDS::PropertyQosPolicy &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DomainParticipantQos &qos1, const DDS::DomainParticipantQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::TopicQos &qos1, const DDS::TopicQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DataWriterQos &qos1, const DDS::DataWriterQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::PublisherQos &qos1, const DDS::PublisherQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DataReaderQos &qos1, const DDS::DataReaderQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::SubscriberQos &qos1, const DDS::SubscriberQos &qos2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::DomainParticipantFactoryQos &qos1, const DDS::DomainParticipantFactoryQos &qos2)
template<typename T >
ACE_INLINE bool	operator== (const TAO::unbounded_value_sequence< T > &seq1, const TAO::unbounded_value_sequence< T > &seq2)
ACE_INLINE bool	operator== (const DDS::PropertyQosPolicy &qos1, const DDS::PropertyQosPolicy &qos2)
void	swap (RawDataSample &lhs, RawDataSample &rhs)
template<typename T >
void	swap (RcHandle< T > &lhs, RcHandle< T > &rhs)
template<typename T , typename U >
RcHandle< T >	static_rchandle_cast (const RcHandle< U > &h)
template<typename T , typename U >
RcHandle< T >	const_rchandle_cast (const RcHandle< U > &h)
template<typename T , typename U >
RcHandle< T >	dynamic_rchandle_cast (const RcHandle< U > &h)
template<typename T >
reference_wrapper< T >	ref (T &r)
template<typename T >
T const &	unwrap_reference (T const &t)
template<typename T >
T &	unwrap_reference (reference_wrapper< T > const &t)
template<typename T >
RcHandle< T >	make_rch ()
template<typename T , typename U >
RcHandle< T >	make_rch (U const &u)
template<typename T , typename U0 , typename U1 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1)
template<typename T , typename U0 , typename U1 , typename U2 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2)
template<typename T , typename U0 , typename U1 , typename U2 , typename U3 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2, U3 const &u3)
template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2, U3 const &u3, U4 const &u4)
template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2, U3 const &u3, U4 const &u4, U5 const &u5)
template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 , typename U6 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2, U3 const &u3, U4 const &u4, U5 const &u5, U6 const &u6)
template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 , typename U6 , typename U7 >
RcHandle< T >	make_rch (U0 const &u0, U1 const &u1, U2 const &u2, U3 const &u3, U4 const &u4, U5 const &u5, U6 const &u6, U7 const &u7)
template<typename T >
RcHandle< T >	rchandle_from (T *pointer)
typedef	OPENDDS_MAP (OPENDDS_STRING, TypeSupport_var) TypeSupportMap
typedef	OPENDDS_MAP (DDS::DomainParticipant_ptr, TypeSupportMap) ParticipantMap
typedef	OPENDDS_VECTOR (RawDataSample) RawDataSampleList
OPENDDS_STRING	to_dds_string (::CORBA::UShort to_convert)
OPENDDS_STRING	to_dds_string (int to_convert)
OPENDDS_STRING	to_dds_string (unsigned int to_convert, bool as_hex)
OPENDDS_STRING	to_dds_string (long to_convert)
OPENDDS_STRING	to_dds_string (long long to_convert)
OPENDDS_STRING	to_dds_string (unsigned long long to_convert, bool as_hex)
OPENDDS_STRING	to_dds_string (unsigned long to_convert, bool as_hex)
template<typename T >
OPENDDS_STRING	to_dds_string (const T *to_convert)
template<typename Sequence >
SequenceBackInsertIterator < Sequence >	back_inserter (Sequence &seq)
template<typename Sequence >
SequenceIterator< Sequence >	sequence_begin (Sequence &seq)
template<typename Sequence >
SequenceIterator< Sequence >	sequence_end (Sequence &seq)
template<typename Sequence >
ConstSequenceIterator< Sequence >	const_sequence_begin (Sequence &seq)
template<typename Sequence >
ConstSequenceIterator< Sequence >	const_sequence_end (Sequence &seq)
ACE_CDR::Boolean	operator<< (Serializer &s, const SequenceNumber &x)
ACE_CDR::Boolean	operator>> (Serializer &s, SequenceNumber &x)
SequenceNumber	operator+ (const SequenceNumber &lhs, int rhs)
SequenceNumber	operator+= (SequenceNumber &lhs, int rhs)
SequenceNumber	operator+ (int lhs, const SequenceNumber &rhs)
void	gen_find_size (const SequenceNumber &, size_t &size, size_t &padding)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::Short &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::UShort &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::Long &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::ULong &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::LongLong &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::ULongLong &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::LongDouble &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::Float &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_CDR::Double &x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_OutputCDR::from_boolean x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_OutputCDR::from_char x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_OutputCDR::from_wchar x)
OpenDDS_Dcps_Export size_t	gen_max_marshaled_size (const ACE_OutputCDR::from_octet x)
OpenDDS_Dcps_Export size_t	max_marshaled_size_boolean ()
	predefined type max_marshaled_size method explicit disambiguators.
OpenDDS_Dcps_Export size_t	max_marshaled_size_char ()
OpenDDS_Dcps_Export size_t	max_marshaled_size_wchar ()
OpenDDS_Dcps_Export size_t	max_marshaled_size_octet ()
OpenDDS_Dcps_Export size_t	max_marshaled_size_ulong ()
	lengths of strings and sequences are ulong
OpenDDS_Dcps_Export void	find_size_ulong (size_t &size, size_t &padding)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::Char x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::Short x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::UShort x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::Long x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::ULong x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::LongLong x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::ULongLong x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::LongDouble x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::Float x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_CDR::Double x)
ACE_INLINE bool	operator<< (Serializer &s, const ACE_CDR::Char *x)
ACE_INLINE bool	operator<< (Serializer &s, const ACE_CDR::WChar *x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_boolean x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_char x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_wchar x)
ACE_INLINE bool	operator<< (Serializer &s, const std::string &x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_octet x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_string x)
ACE_INLINE bool	operator<< (Serializer &s, ACE_OutputCDR::from_wstring x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Char &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Short &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::UShort &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Long &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::ULong &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::LongLong &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::ULongLong &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::LongDouble &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Float &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Double &x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::Char *&x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_CDR::WChar *&x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_boolean x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_char x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_wchar x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_octet x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_string x)
ACE_INLINE bool	operator>> (Serializer &s, ACE_InputCDR::to_wstring x)
ACE_INLINE bool	operator>> (Serializer &s, std::string &x)
ACE_INLINE OpenDDS_Dcps_Export ACE_Time_Value	time_to_time_value (const DDS::Time_t &t)
ACE_INLINE OpenDDS_Dcps_Export DDS::Time_t	time_value_to_time (const ACE_Time_Value &tv)
ACE_INLINE OpenDDS_Dcps_Export ACE_Time_Value	duration_to_time_value (const DDS::Duration_t &t)
ACE_INLINE OpenDDS_Dcps_Export ACE_Time_Value	duration_to_absolute_time_value (const DDS::Duration_t &t, const ACE_Time_Value &now=ACE_OS::gettimeofday())
ACE_INLINE OpenDDS_Dcps_Export DDS::Duration_t	time_value_to_duration (const ACE_Time_Value &tv)
ACE_INLINE OpenDDS_Dcps_Export DDS::Duration_t	time_to_duration (const DDS::Time_t &t)
ACE_INLINE OpenDDS_Dcps_Export bool	valid_duration (DDS::Duration_t const &t)
ACE_INLINE OpenDDS_Dcps_Export bool	non_negative_duration (const DDS::Duration_t &t)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator< (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator<= (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator> (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator>= (const DDS::Duration_t &t1, const DDS::Duration_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator! (const DDS::Time_t &t)
ACE_INLINE OpenDDS_Dcps_Export bool	operator== (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator!= (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator< (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator<= (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator> (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export bool	operator>= (const DDS::Time_t &t1, const DDS::Time_t &t2)
ACE_INLINE OpenDDS_Dcps_Export DDS::Time_t	operator- (const DDS::Time_t &t1, const DDS::Time_t &t2)
template<typename Seq >
void	set_to_seq (const RepoIdSet &rids, Seq &seq)
std::ostream &	operator<< (std::ostream &str, const DataLink &value)
typedef	OPENDDS_MAP_CMP (RepoId, DataLinkSet_rch, GUID_tKeyLessThan) DataLinkSetMap
OPENDDS_STRING	get_fully_qualified_hostname (ACE_INET_Addr *addr)
void	get_interface_addrs (OPENDDS_VECTOR(ACE_INET_Addr)&addrs)
bool	set_socket_multicast_ttl (const ACE_SOCK_Dgram &socket, const unsigned char &ttl)
bool	open_appropriate_socket_type (ACE_SOCK_Dgram &socket, const ACE_INET_Addr &local_address)
typedef	OPENDDS_VECTOR (HostnameInfo) HostnameInfoVector
void	swap (ReceivedDataSample &, ReceivedDataSample &)
bool	operator<< (ACE_Message_Block &buffer, const TransportHeader &value)
static const ACE_UINT32	TRANSPORT_HDR_SERIALIZED_SZ (28)
static bool	get_remote_reliability (const TransportImpl::RemoteTransport &remote)
	ACE_FACTORY_DEFINE (OpenDDS_Rtps_Udp, RtpsUdpLoader)
	ACE_FACTORY_DEFINE (OpenDDS_Shmem, ShmemLoader)
	ACE_FACTORY_DEFINE (OpenDDS_Udp, UdpLoader)
template<typename T >
T::rv_reference	move (T &p)
template<typename T , typename Deleter >
void	swap (unique_ptr< T, Deleter > &a, unique_ptr< T, Deleter > &b)
template<typename T >
void	swap (container_supported_unique_ptr< T > &lhs, container_supported_unique_ptr< T > &rhs)
template<typename T >
unique_ptr< T >::rv_reference	move (container_supported_unique_ptr< T > &ptr)
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 (const 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)
template<typename Seq >
void	push_back (Seq &seq, const typename Seq::value_type &val)
	std::vector-style push_back() for CORBA Sequences
bool	resend_data_expired (DataSampleElement const &element, DDS::LifespanQosPolicy const &lifespan)
typedef	OPENDDS_MAP (DDS::InstanceHandle_t, PublicationInstance_rch) PublicationInstanceMapType
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"
const CORBA::ULong	MAX_READERS_PER_ELEM = 5
OpenDDS_Dcps_Export unsigned int	DCPS_debug_level = 0
const GuidVendorId_t	VENDORID_OCI = { 0x01, 0x03 }
	Vendor Id value specified for OCI is used for OpenDDS.
const GuidPrefix_t	GUIDPREFIX_UNKNOWN = { 0 }
	Nil value for the GUID prefix (participant identifier).
const GUID_t	GUID_UNKNOWN = { { 0 }, { { 0 }, 0 } }
	Nil value for GUID.
static InfoRepoDiscovery::StaticInitializer	initialize_inforepodisco
int const	INVALID_ENUM_VALUE = 999
static int	OpenDDS_Requires_MonitorFactory_Initializer
const int	MAX_READERS_TO_RESEND = 5
const size_t	DEFAULT_NUM_CHUNKS = 20
const size_t	DEFAULT_CHUNK_MULTIPLIER = 10
const int	DEFAULT_FEDERATION_RECOVERY_DURATION = 900
const int	DEFAULT_FEDERATION_INITIAL_BACKOFF_SECONDS = 1
const int	DEFAULT_FEDERATION_BACKOFF_MULTIPLIER = 2
const int	DEFAULT_FEDERATION_LIVELINESS = 60
const int	BIT_LOOKUP_DURATION_MSEC = 2000
static ACE_TString	config_fname (ACE_TEXT(""))
static const ACE_TCHAR	DEFAULT_REPO_IOR [] = ACE_TEXT("file://repo.ior")
static const ACE_CString	DEFAULT_PERSISTENT_DATA_DIR = "OpenDDS-durable-data-dir"
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 const ACE_TCHAR	RTPS_SECTION_NAME [] = ACE_TEXT("rtps_discovery")
static bool	got_debug_level = false
static bool	got_use_rti_serialization = 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_global_transport_config = false
static bool	got_bit_flag = false
static bool	got_publisher_content_filter = false
static bool	got_transport_debug_level = false
static bool	got_pending_timeout = false
static bool	got_persistent_data_dir = false
static bool	got_default_discovery = false
static bool	got_log_fname = false
static bool	got_log_verbose = false
static bool	got_default_address = false
static bool	got_bidir_giop = false
static bool	got_monitor = false
const char	DEFAULT_ORB_NAME [] = "OpenDDS_DCPS"
OpenDDS_Dcps_Export unsigned int	Transport_debug_level = 0
	Transport Logging verbosity level.
static const ACE_TCHAR	TRANSPORT_SECTION_NAME [] = ACE_TEXT("transport")
static const ACE_TCHAR	CONFIG_SECTION_NAME [] = ACE_TEXT("config")
static MulticastInitializer	multicast_init
static RtpsUdpInitializer	rtps_udp_init
static ShmemInitializer	shmem_init
static Tcp_Initializer	tcp_initializer
static UdpInitializer	udp_init
const octet	ENTITYKIND_BUILTIN_UNKNOWN = 0xc0
const octet	ENTITYKIND_BUILTIN_PARTICIPANT = 0xc1
const octet	ENTITYKIND_BUILTIN_WRITER_WITH_KEY = 0xc2
const octet	ENTITYKIND_BUILTIN_WRITER_NO_KEY = 0xc3
const octet	ENTITYKIND_BUILTIN_READER_NO_KEY = 0xc4
const octet	ENTITYKIND_BUILTIN_READER_WITH_KEY = 0xc7
const octet	ENTITYKIND_BUILTIN_TOPIC = 0xc5
const octet	ENTITYKIND_USER_UNKNOWN = 0x00
const octet	ENTITYKIND_USER_WRITER_WITH_KEY = 0x02
const octet	ENTITYKIND_USER_WRITER_NO_KEY = 0x03
const octet	ENTITYKIND_USER_READER_NO_KEY = 0x04
const octet	ENTITYKIND_USER_READER_WITH_KEY = 0x07
const octet	ENTITYKIND_OPENDDS_SUBSCRIBER = 0x41
const octet	ENTITYKIND_OPENDDS_PUBLISHER = 0x42
const octet	ENTITYKIND_OPENDDS_TOPIC = 0x45
const octet	ENTITYKIND_OPENDDS_USER = 0x4a
const octet	ENTITYKIND_OPENDDS_NIL_WRITER = 0x4e
const DDS::StatusMask	ALL_STATUS_MASK = 0xffffffff
const DDS::StatusMask	NO_STATUS_MASK = 0x00000000
const DDS::StatusMask	DEFAULT_STATUS_MASK = ALL_STATUS_MASK
const long	MONITOR_DOMAIN_ID = -999
const long	MONITOR_TRANSPORT_ID = 999
const string	SERVICE_PARTICIPANT_MONITOR_TOPIC = "Service Participant Monitor"
const string	DOMAIN_PARTICIPANT_MONITOR_TOPIC = "Domain Participant Monitor"
const string	TOPIC_MONITOR_TOPIC = "Topic Monitor"
const string	PUBLISHER_MONITOR_TOPIC = "Publisher Monitor"
const string	SUBSCRIBER_MONITOR_TOPIC = "Subscriber Monitor"
const string	DATA_WRITER_MONITOR_TOPIC = "Data Writer Monitor"
const string	DATA_WRITER_PERIODIC_MONITOR_TOPIC = "Data Writer Periodic Monitor"
const string	DATA_READER_MONITOR_TOPIC = "Data Reader Monitor"
const string	DATA_READER_PERIODIC_MONITOR_TOPIC = "Data Reader Periodic Monitor"
const string	TRANSPORT_MONITOR_TOPIC = "Transport Monitor"
static int	OpenDDS_Requires_MonitorFactoryImpl_Initializer


const EntityId_t	ENTITYID_UNKNOWN = { {0x00,0x00,0x00}, 0x00}
const EntityId_t	ENTITYID_PARTICIPANT = { {0x00,0x00,0x01}, 0xc1}
const EntityId_t	ENTITYID_SEDP_BUILTIN_TOPIC_WRITER = { {0x00,0x00,0x02}, 0xc2}
const EntityId_t	ENTITYID_SEDP_BUILTIN_TOPIC_READER = { {0x00,0x00,0x02}, 0xc7}
const EntityId_t	ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER = { {0x00,0x00,0x03}, 0xc2}
const EntityId_t	ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER = { {0x00,0x00,0x03}, 0xc7}
const EntityId_t	ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER = { {0x00,0x00,0x04}, 0xc2}
const EntityId_t	ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER = { {0x00,0x00,0x04}, 0xc7}
const EntityId_t	ENTITYID_SPDP_BUILTIN_PARTICIPANT_WRITER = { {0x00,0x01,0x00}, 0xc2}
const EntityId_t	ENTITYID_SPDP_BUILTIN_PARTICIPANT_READER = { {0x00,0x01,0x00}, 0xc7}
const EntityId_t	ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER = { {0x00,0x02,0x00}, 0xc2}
const EntityId_t	ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER = { {0x00,0x02,0x00}, 0xc7}

Typedef Documentation

typedef yard::TreeBuildingParser<char>::Node OpenDDS::DCPS::AstNode

Definition at line 24 of file AstNodeWrapper.h.

typedef ACE_UINT16 OpenDDS::DCPS::CoherencyGroup

Definition at line 28 of file PublicationInstance.h.

typedef Cached_Allocator_With_Overflow<ACE_Data_Block, ACE_Thread_Mutex> OpenDDS::DCPS::DataBlockAllocator

Definition at line 70 of file Definitions.h.

typedef RcHandle<DataLink> OpenDDS::DCPS::DataLink_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file DataLink_rch.h.

typedef ACE_UINT64 OpenDDS::DCPS::DataLinkIdType

Identifier type for DataLink objects.

Definition at line 175 of file TransportDefs.h.

typedef RcHandle< DataLinkSet > OpenDDS::DCPS::DataLinkSet_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 27 of file DataLinkSet.h.

typedef RcHandle<DataReaderImpl> OpenDDS::DCPS::DataReaderImpl_rch

Definition at line 865 of file DataReaderImpl.h.

typedef ACE_Message_Block OpenDDS::DCPS::DataSample

Currently we contain entire messages in a single ACE_Message_Block chain.

Definition at line 39 of file DataSampleElement.h.

typedef Cached_Allocator_With_Overflow<DataSampleElement, ACE_Null_Mutex> OpenDDS::DCPS::DataSampleElementAllocator

Definition at line 27 of file DataSampleElement.h.

typedef Cached_Allocator_With_Overflow<DataSampleHeader, ACE_Null_Mutex> OpenDDS::DCPS::DataSampleHeaderAllocator

Definition at line 71 of file Definitions.h.

typedef RcHandle<DataWriterImpl> OpenDDS::DCPS::DataWriterImpl_rch

Definition at line 691 of file DataWriterImpl.h.

typedef PublicationLostStatus OpenDDS::DCPS::DisassociationStatus

Definition at line 183 of file DdsDcpsPublication.idl.

typedef RcHandle<Discovery> OpenDDS::DCPS::Discovery_rch

Definition at line 257 of file Discovery.h.

typedef sequence<DataReaderAssociation> OpenDDS::DCPS::DRAssociations

Definition at line 291 of file monitor.idl.

typedef sequence<DataReaderAssociationPeriodic> OpenDDS::DCPS::DRAssociationsPeriodic

Definition at line 334 of file monitor.idl.

typedef sequence<DataWriterAssociation> OpenDDS::DCPS::DWAssociations

Definition at line 213 of file monitor.idl.

typedef sequence<DataWriterAssociationPeriodic> OpenDDS::DCPS::DWAssociationsPeriodic

Definition at line 255 of file monitor.idl.

typedef std::pair<TransportQueueElement*, TransportQueueElement*> OpenDDS::DCPS::ElementPair

Definition at line 30 of file TransportQueueElement.h.

typedef octet OpenDDS::DCPS::EntityKey_t[3]

Definition at line 22 of file DdsDcpsGuid.idl.

typedef octet OpenDDS::DCPS::GuidPrefix_t[12]

Definition at line 19 of file DdsDcpsGuid.idl.

typedef sequence<GUID_t> OpenDDS::DCPS::GUIDSeq

Definition at line 82 of file DdsDcpsGuid.idl.

typedef octet OpenDDS::DCPS::GuidVendorId_t[2]

Definition at line 16 of file DdsDcpsGuid.idl.

typedef RcHandle<InfoRepoDiscovery> OpenDDS::DCPS::InfoRepoDiscovery_rch

Definition at line 285 of file InfoRepoDiscovery.h.

typedef sequence<LatencyStatistics> OpenDDS::DCPS::LatencyStatisticsSeq

Definition at line 75 of file DdsDcpsSubscriptionExt.idl.

typedef CORBA::LocalObject_ptr OpenDDS::DCPS::LocalObject_ptr

Definition at line 22 of file LocalObject.h.

typedef CORBA::LocalObject_var OpenDDS::DCPS::LocalObject_var

Definition at line 23 of file LocalObject.h.

typedef sequence<Locator_t> OpenDDS::DCPS::LocatorSeq

Definition at line 90 of file DdsDcpsInfoUtils.idl.

typedef unique_ptr<ACE_Message_Block,Message_Block_Deleter> OpenDDS::DCPS::Message_Block_Ptr

Definition at line 23 of file Message_Block_Ptr.h.

typedef Cached_Allocator_With_Overflow<ACE_Message_Block, ACE_Thread_Mutex> OpenDDS::DCPS::MessageBlockAllocator

Definition at line 69 of file Definitions.h.

typedef RcHandle< MulticastDataLink > OpenDDS::DCPS::MulticastDataLink_rch

Definition at line 18 of file MulticastDataLink_rch.h.

typedef RcHandle<MulticastInst> OpenDDS::DCPS::MulticastInst_rch

Definition at line 18 of file MulticastInst_rch.h.

typedef ACE_INT64 OpenDDS::DCPS::MulticastPeer

Definition at line 19 of file MulticastTypes.h.

typedef RcHandle<MulticastReceiveStrategy> OpenDDS::DCPS::MulticastReceiveStrategy_rch

Definition at line 18 of file MulticastReceiveStrategy_rch.h.

typedef RcHandle<MulticastSendStrategy> OpenDDS::DCPS::MulticastSendStrategy_rch

Definition at line 18 of file MulticastSendStrategy_rch.h.

typedef RcHandle< MulticastSession > OpenDDS::DCPS::MulticastSession_rch

Definition at line 18 of file MulticastSession_rch.h.

typedef RcHandle<MulticastSessionFactory> OpenDDS::DCPS::MulticastSessionFactory_rch

Definition at line 18 of file MulticastSessionFactory_rch.h.

typedef RcHandle<MulticastTransport> OpenDDS::DCPS::MulticastTransport_rch

Definition at line 39 of file MulticastDataLink.h.

typedef sequence<NameValuePair> OpenDDS::DCPS::NVPSeq

Definition at line 44 of file monitor.idl.

typedef octet OpenDDS::DCPS::OctetArray16[16]

Definition at line 80 of file DdsDcpsInfoUtils.idl.

typedef DataReaderImpl_T<DDS::ParticipantBuiltinTopicData> OpenDDS::DCPS::ParticipantBuiltinTopicDataDataReaderImpl

Definition at line 32 of file DiscoveryBase.h.

typedef ::CORBA::Long OpenDDS::DCPS::ParticipantId

Definition at line 28 of file RepoIdConverter.h.

typedef ACE_CDR::Long OpenDDS::DCPS::Priority

Definition at line 236 of file TransportDefs.h.

typedef DataReaderImpl_T<DDS::PublicationBuiltinTopicData> OpenDDS::DCPS::PublicationBuiltinTopicDataDataReaderImpl

Definition at line 33 of file DiscoveryBase.h.

typedef PublicationLostStatus OpenDDS::DCPS::PublicationDisconnectedStatus

Definition at line 181 of file DdsDcpsPublication.idl.

typedef RepoId OpenDDS::DCPS::PublicationId

Definition at line 22 of file RepoIdTypes.h.

typedef RcHandle< PublicationInstance > OpenDDS::DCPS::PublicationInstance_rch

Definition at line 32 of file DataSampleElement.h.

typedef PublicationLostStatus OpenDDS::DCPS::PublicationReconnectedStatus

Definition at line 182 of file DdsDcpsPublication.idl.

typedef sequence<RepoId> OpenDDS::DCPS::ReaderIdSeq

Definition at line 78 of file DdsDcpsInfoUtils.idl.

typedef Cached_Allocator_With_Overflow<OpenDDS::DCPS::ReceivedDataElementMemoryBlock, ACE_Null_Mutex> OpenDDS::DCPS::ReceivedDataAllocator

Definition at line 72 of file DataReaderImpl.h.

typedef RcHandle<ReceiveListenerSet> OpenDDS::DCPS::ReceiveListenerSet_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file ReceiveListenerSet_rch.h.

typedef Recorder* OpenDDS::DCPS::Recorder_ptr

Definition at line 54 of file Recorder.h.

typedef TAO_Objref_Var_T<Recorder> OpenDDS::DCPS::Recorder_var

Definition at line 55 of file Recorder.h.

typedef RcHandle<RecorderListener> OpenDDS::DCPS::RecorderListener_rch

Definition at line 52 of file Recorder.h.

typedef Replayer* OpenDDS::DCPS::Replayer_ptr

Definition at line 47 of file Replayer.h.

typedef TAO_Objref_Var_T<Replayer> OpenDDS::DCPS::Replayer_var

Definition at line 48 of file Replayer.h.

typedef RcHandle<ReplayerListener> OpenDDS::DCPS::ReplayerListener_rch

Definition at line 43 of file Replayer.h.

typedef GUID_t OpenDDS::DCPS::RepoId

Definition at line 19 of file DdsDcpsInfoUtils.idl.

typedef Dynamic_Cached_Allocator_With_Overflow<ACE_Thread_Mutex> OpenDDS::DCPS::RtpsCustomizedElementAllocator

Definition at line 44 of file RtpsCustomizedElement.h.

typedef RcHandle< RtpsUdpDataLink > OpenDDS::DCPS::RtpsUdpDataLink_rch

Definition at line 18 of file RtpsUdpDataLink_rch.h.

typedef RcHandle< RtpsUdpInst > OpenDDS::DCPS::RtpsUdpInst_rch

Definition at line 50 of file RtpsUdpDataLink.h.

typedef RcHandle<RtpsUdpReceiveStrategy> OpenDDS::DCPS::RtpsUdpReceiveStrategy_rch

Definition at line 18 of file RtpsUdpReceiveStrategy_rch.h.

typedef RcHandle<RtpsUdpSendStrategy> OpenDDS::DCPS::RtpsUdpSendStrategy_rch

Definition at line 18 of file RtpsUdpSendStrategy_rch.h.

typedef RcHandle<RtpsUdpTransport> OpenDDS::DCPS::RtpsUdpTransport_rch

Definition at line 52 of file RtpsUdpDataLink.h.

typedef ACE_Allocator OpenDDS::DCPS::SafetyProfilePool

Definition at line 104 of file SafetyProfilePool.h.

typedef std::pair<SequenceNumber, SequenceNumber> OpenDDS::DCPS::SequenceRange

Definition at line 201 of file SequenceNumber.h.

typedef ACE_Malloc_T<ShmemPool, ACE_Process_Mutex, ACE_PI_Control_Block> OpenDDS::DCPS::ShmemAllocator

Definition at line 56 of file ShmemDataLink.h.

typedef RcHandle<ShmemDataLink> OpenDDS::DCPS::ShmemDataLink_rch

Definition at line 18 of file ShmemDataLink_rch.h.

typedef RcHandle< ShmemInst > OpenDDS::DCPS::ShmemInst_rch

Definition at line 18 of file ShmemInst_rch.h.

typedef ACE_Shared_Memory_Pool OpenDDS::DCPS::ShmemPool

Definition at line 42 of file ShmemDataLink.h.

typedef RcHandle<ShmemReceiveStrategy> OpenDDS::DCPS::ShmemReceiveStrategy_rch

Definition at line 18 of file ShmemReceiveStrategy_rch.h.

typedef RcHandle<ShmemSendStrategy> OpenDDS::DCPS::ShmemSendStrategy_rch

Definition at line 18 of file ShmemSendStrategy_rch.h.

typedef int OpenDDS::DCPS::ShmemSharedSemaphore

Definition at line 52 of file ShmemDataLink.h.

typedef RcHandle<ShmemTransport> OpenDDS::DCPS::ShmemTransport_rch

Definition at line 36 of file ShmemDataLink.h.

typedef RcHandle<StaticDiscovery> OpenDDS::DCPS::StaticDiscovery_rch

Definition at line 32 of file StaticDiscovery.h.

typedef string<256> OpenDDS::DCPS::String256

Definition at line 92 of file DdsDcpsInfoUtils.idl.

typedef DataReaderImpl_T<DDS::SubscriptionBuiltinTopicData> OpenDDS::DCPS::SubscriptionBuiltinTopicDataDataReaderImpl

Definition at line 34 of file DiscoveryBase.h.

typedef SubscriptionLostStatus OpenDDS::DCPS::SubscriptionDisconnectedStatus

Definition at line 26 of file DdsDcpsSubscriptionExt.idl.

typedef RepoId OpenDDS::DCPS::SubscriptionId

Definition at line 23 of file RepoIdTypes.h.

typedef RcHandle<SubscriptionInstance> OpenDDS::DCPS::SubscriptionInstance_rch

Definition at line 93 of file SubscriptionInstance.h.

typedef SubscriptionLostStatus OpenDDS::DCPS::SubscriptionReconnectedStatus

Definition at line 27 of file DdsDcpsSubscriptionExt.idl.

typedef std::pair<OPENDDS_STRING, ACE_Configuration_Section_Key> OpenDDS::DCPS::SubsectionPair

Definition at line 25 of file ConfigUtils.h.

typedef RcHandle<TcpConnection> OpenDDS::DCPS::TcpConnection_rch

Definition at line 18 of file TcpConnection_rch.h.

typedef RcHandle<TcpDataLink> OpenDDS::DCPS::TcpDataLink_rch

Definition at line 19 of file TcpDataLink_rch.h.

typedef RcHandle<TcpInst> OpenDDS::DCPS::TcpInst_rch

Definition at line 18 of file TcpInst_rch.h.

typedef RcHandle<TcpReceiveStrategy> OpenDDS::DCPS::TcpReceiveStrategy_rch

Definition at line 20 of file TcpReceiveStrategy_rch.h.

typedef RcHandle<TcpSendStrategy> OpenDDS::DCPS::TcpSendStrategy_rch

Definition at line 19 of file TcpSendStrategy_rch.h.

typedef RcHandle<TcpTransport> OpenDDS::DCPS::TcpTransport_rch

Definition at line 18 of file TcpTransport_rch.h.

typedef RcHandle<ThreadSynchStrategy> OpenDDS::DCPS::ThreadSynchStrategy_rch

Definition at line 18 of file ThreadSynchStrategy_rch.h.

typedef RcHandle<ThreadSynchWorker> OpenDDS::DCPS::ThreadSynchWorker_rch

Definition at line 53 of file ThreadSynchWorker.h.

typedef DataReaderImpl_T<DDS::TopicBuiltinTopicData> OpenDDS::DCPS::TopicBuiltinTopicDataDataReaderImpl

Definition at line 35 of file DiscoveryBase.h.

typedef DDS::OctetSeq OpenDDS::DCPS::TransportBLOB

Definition at line 21 of file DdsDcpsInfoUtils.idl.

typedef RcHandle< TransportClient > OpenDDS::DCPS::TransportClient_rch

Definition at line 308 of file TransportClient.h.

typedef WeakRcHandle<TransportClient> OpenDDS::DCPS::TransportClient_wrch

Definition at line 43 of file TransportImpl.h.

typedef RcHandle<TransportConfig> OpenDDS::DCPS::TransportConfig_rch

Definition at line 24 of file TransportConfig_rch.h.

typedef Cached_Allocator_With_Overflow<char[RECEIVE_DATA_BUFFER_SIZE], RECEIVE_SYNCH> OpenDDS::DCPS::TransportDataAllocator

Definition at line 220 of file TransportDefs.h.

typedef Cached_Allocator_With_Overflow<ACE_Data_Block, RECEIVE_SYNCH> OpenDDS::DCPS::TransportDataBlockAllocator

Definition at line 216 of file TransportDefs.h.

typedef RcHandle<TransportImpl> OpenDDS::DCPS::TransportImpl_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file TransportImpl_rch.h.

typedef RcHandle< TransportInst > OpenDDS::DCPS::TransportInst_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file TransportInst_rch.h.

typedef sequence<TransportLocator> OpenDDS::DCPS::TransportLocatorSeq

Definition at line 31 of file DdsDcpsInfoUtils.idl.

typedef Cached_Allocator_With_Overflow<ACE_Message_Block, RECEIVE_SYNCH> OpenDDS::DCPS::TransportMessageBlockAllocator

Definition at line 213 of file TransportDefs.h.

typedef RcHandle<TransportReactorTask> OpenDDS::DCPS::TransportReactorTask_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file TransportReactorTask_rch.h.

typedef RcHandle< TransportReceiveListener > OpenDDS::DCPS::TransportReceiveListener_rch

Definition at line 42 of file TransportReceiveListener.h.

typedef WeakRcHandle<TransportReceiveListener> OpenDDS::DCPS::TransportReceiveListener_wrch

Definition at line 24 of file ReceiveListenerSet.h.

typedef RcHandle<TransportReceiveStrategy> OpenDDS::DCPS::TransportReceiveStrategy_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file TransportReceiveStrategy_rch.h.

typedef Cached_Allocator_With_Overflow<TransportSendControlElement, ACE_SYNCH_NULL_MUTEX> OpenDDS::DCPS::TransportSendControlElementAllocator

Definition at line 29 of file TransportSendControlElement.h.

typedef RcHandle<TransportSendListener> OpenDDS::DCPS::TransportSendListener_rch

Definition at line 78 of file TransportSendListener.h.

typedef WeakRcHandle<TransportSendListener> OpenDDS::DCPS::TransportSendListener_wrch

Definition at line 54 of file DataLink.h.

typedef RcHandle<TransportSendStrategy> OpenDDS::DCPS::TransportSendStrategy_rch

The type definition for the smart-pointer to the underlying type.

Definition at line 34 of file TransportSendStrategy_rch.h.

typedef RcHandle<TransportStrategy> OpenDDS::DCPS::TransportStrategy_rch

Definition at line 18 of file TransportStrategy_rch.h.

typedef RcHandle<TransportType> OpenDDS::DCPS::TransportType_rch

Definition at line 23 of file TransportType_rch.h.

typedef RcHandle< UdpDataLink > OpenDDS::DCPS::UdpDataLink_rch

Definition at line 18 of file UdpDataLink_rch.h.

typedef RcHandle<UdpInst> OpenDDS::DCPS::UdpInst_rch

Definition at line 18 of file UdpInst_rch.h.

typedef RcHandle<UdpReceiveStrategy> OpenDDS::DCPS::UdpReceiveStrategy_rch

Definition at line 18 of file UdpReceiveStrategy_rch.h.

typedef RcHandle<UdpSendStrategy> OpenDDS::DCPS::UdpSendStrategy_rch

Definition at line 18 of file UdpSendStrategy_rch.h.

typedef RcHandle<UdpTransport> OpenDDS::DCPS::UdpTransport_rch

Definition at line 31 of file UdpDataLink.h.

typedef sequence<RepoId> OpenDDS::DCPS::WriterIdSeq

Definition at line 76 of file DdsDcpsInfoUtils.idl.

Enumeration Type Documentation

anonymous enum

Controls the maximum size of the iovec array used for a send packet.

Enumerator:

MAX_SEND_BLOCKS

Definition at line 203 of file TransportDefs.h.

00203 { MAX_SEND_BLOCKS = 50 };

anonymous enum

Allocators used for transport receiving logic.

Enumerator:

RECEIVE_DATA_BUFFER_SIZE

Definition at line 210 of file TransportDefs.h.

00210 { RECEIVE_DATA_BUFFER_SIZE = 65536 };

anonymous enum

Default TransportInst settings.

Enumerator:

DEFAULT_CONFIG_QUEUE_MESSAGES_PER_POOL
DEFAULT_CONFIG_QUEUE_INITIAL_POOLS
DEFAULT_CONFIG_MAX_PACKET_SIZE
DEFAULT_CONFIG_MAX_SAMPLES_PER_PACKET
DEFAULT_CONFIG_OPTIMUM_PACKET_SIZE

Definition at line 223 of file TransportDefs.h.

00223      {
00224   DEFAULT_CONFIG_QUEUE_MESSAGES_PER_POOL = 10,
00225   DEFAULT_CONFIG_QUEUE_INITIAL_POOLS     = 5,
00226   DEFAULT_CONFIG_MAX_PACKET_SIZE         = 2147481599,
00227   DEFAULT_CONFIG_MAX_SAMPLES_PER_PACKET  = 10,
00228   DEFAULT_CONFIG_OPTIMUM_PACKET_SIZE     = 4096
00229 };

anonymous enum

Enumerator:

SHMEM_DATA_FREE
SHMEM_DATA_IN_USE
SHMEM_DATA_RECV_DONE
SHMEM_DATA_END_OF_ALLOC

Definition at line 64 of file ShmemDataLink.h.

00064      { // values for ShmemData::status_
00065   SHMEM_DATA_FREE = 0,
00066   SHMEM_DATA_IN_USE = 1,
00067   SHMEM_DATA_RECV_DONE = 2,
00068   SHMEM_DATA_END_OF_ALLOC = -1
00069 };

enum OpenDDS::DCPS::AttachStatus

Return code type for attach_transport() operations.

Enumerator:

ATTACH_BAD_TRANSPORT
ATTACH_ERROR
ATTACH_INCOMPATIBLE_QOS
ATTACH_OK

Definition at line 184 of file TransportDefs.h.

00184                   {
00185   ATTACH_BAD_TRANSPORT,
00186   ATTACH_ERROR,
00187   ATTACH_INCOMPATIBLE_QOS,
00188   ATTACH_OK
00189 };

enum OpenDDS::DCPS::Coherent_State

Enumerator:

NOT_COMPLETED_YET
COMPLETED
REJECTED

Definition at line 63 of file WriterInfo.h.

00063                     {
00064   NOT_COMPLETED_YET,
00065   COMPLETED,
00066   REJECTED
00067 };

enum OpenDDS::DCPS::DataSampleHeaderFlag

Enumerator:

BYTE_ORDER_FLAG
COHERENT_CHANGE_FLAG
HISTORIC_SAMPLE_FLAG
LIFESPAN_DURATION_FLAG
GROUP_COHERENT_FLAG
CONTENT_FILTER_FLAG
SEQUENCE_REPAIR_FLAG
MORE_FRAGMENTS_FLAG

Definition at line 56 of file DataSampleHeader.h.

00056                           {
00057   BYTE_ORDER_FLAG,
00058   COHERENT_CHANGE_FLAG,
00059   HISTORIC_SAMPLE_FLAG,
00060   LIFESPAN_DURATION_FLAG,
00061   GROUP_COHERENT_FLAG,
00062   CONTENT_FILTER_FLAG,
00063   SEQUENCE_REPAIR_FLAG,
00064   MORE_FRAGMENTS_FLAG
00065 };

enum OpenDDS::DCPS::DataSampleHeaderFlag2

Enumerator:

CDR_ENCAP_FLAG
KEY_ONLY_FLAG

Definition at line 67 of file DataSampleHeader.h.

00067                            {
00068   CDR_ENCAP_FLAG,
00069   KEY_ONLY_FLAG
00070 };

enum OpenDDS::DCPS::EntityKind

Summary kinds of entities within the service.

See dds/DdsDcpsGuid.idl for the values these map to.

Enumerator:

KIND_UNKNOWN	Represents ENTITYKIND_USER_UNKNOWN and ENTITYKIND_BUILTIN_UNKNOWN.
KIND_PARTICIPANT	Represents ENTITYKIND_BUILTIN_PARTICIPANT.
KIND_WRITER	Represents ENTITYKIND_USER_WRITER_WITH_KEY and ENTITYKIND_USER_WRITER_NO_KEY.
KIND_READER	Represents ENTITYKIND_USER_READER_WITH_KEY and ENTITYKIND_USER_READER_NO_KEY.
KIND_TOPIC	Represents ENTITYKIND_OPENDDS_TOPIC.
KIND_BUILTIN_WRITER	Represents ENTITYKIND_BUILTIN_WRITER_WITH_KEY and ENTITYKIND_USER_WRITER_NO_KEY.
KIND_BUILTIN_READER	Represents ENTITYKIND_BUILTIN_READER_WITH_KEY and ENTITYKIND_USER_READER_NO_KEY.
KIND_BUILTIN_TOPIC	Represents ENTITYKIND_BUILTIN_TOPIC.
KIND_PUBLISHER	OpenDDS specific Publisher Guid values.
KIND_SUBSCRIBER	OpenDDS specific Subscriber Guid values.
KIND_USER	OpenDDS specific other Guid values.

Definition at line 60 of file GuidUtils.h.

00060                 {     // EntityId_t.entityKind value(s)
00061 
00062   /// Represents ENTITYKIND_USER_UNKNOWN and ENTITYKIND_BUILTIN_UNKNOWN
00063   KIND_UNKNOWN,       // 0x3f & 0x00 (and all other unspecified values)
00064   /// Represents ENTITYKIND_BUILTIN_PARTICIPANT
00065   KIND_PARTICIPANT,   // 0x3f & 0x01
00066 
00067   /// Represents ENTITYKIND_USER_WRITER_WITH_KEY and ENTITYKIND_USER_WRITER_NO_KEY
00068   KIND_WRITER,        // 0x3f & 0x02 | 0x3f & 0x03
00069   /// Represents ENTITYKIND_USER_READER_WITH_KEY and ENTITYKIND_USER_READER_NO_KEY
00070   KIND_READER,        // 0x3f & 0x04 | 0x3f & 0x07
00071   /// Represents ENTITYKIND_OPENDDS_TOPIC
00072   KIND_TOPIC,         // 0x3f & 0x05
00073 
00074   /// Represents ENTITYKIND_BUILTIN_WRITER_WITH_KEY and ENTITYKIND_USER_WRITER_NO_KEY
00075   KIND_BUILTIN_WRITER,
00076   /// Represents ENTITYKIND_BUILTIN_READER_WITH_KEY and ENTITYKIND_USER_READER_NO_KEY
00077   KIND_BUILTIN_READER,
00078   /// Represents ENTITYKIND_BUILTIN_TOPIC
00079   KIND_BUILTIN_TOPIC,
00080 
00081   /// OpenDDS specific Publisher Guid values
00082   KIND_PUBLISHER,
00083   /// OpenDDS specific Subscriber Guid values
00084   KIND_SUBSCRIBER,
00085   /// OpenDDS specific other Guid values
00086   KIND_USER
00087 };

enum OpenDDS::DCPS::MarshalingType

Enumerator:

FULL_MARSHALING
KEY_ONLY_MARSHALING

Definition at line 77 of file DataReaderImpl.h.

00077                     {
00078   FULL_MARSHALING,
00079   KEY_ONLY_MARSHALING
00080 };

enum OpenDDS::DCPS::MessageId

One byte message id (<256).

Enumerator:

SAMPLE_DATA
DATAWRITER_LIVELINESS
INSTANCE_REGISTRATION
UNREGISTER_INSTANCE
DISPOSE_INSTANCE
GRACEFUL_DISCONNECT
REQUEST_ACK
SAMPLE_ACK
END_COHERENT_CHANGES
TRANSPORT_CONTROL
DISPOSE_UNREGISTER_INSTANCE
END_HISTORIC_SAMPLES
MESSAGE_ID_MAX

Definition at line 31 of file DataSampleHeader.h.

00031                {
00032   SAMPLE_DATA,
00033   DATAWRITER_LIVELINESS,
00034   INSTANCE_REGISTRATION,
00035   UNREGISTER_INSTANCE,
00036   DISPOSE_INSTANCE,
00037   GRACEFUL_DISCONNECT,
00038   REQUEST_ACK,
00039   SAMPLE_ACK,
00040   END_COHERENT_CHANGES,
00041   TRANSPORT_CONTROL,
00042   DISPOSE_UNREGISTER_INSTANCE,
00043   END_HISTORIC_SAMPLES,
00044   MESSAGE_ID_MAX // must be the last enumerator
00045 };

enum OpenDDS::DCPS::Operation_t

Enumerator:

DDS_OPERATION_READ
DDS_OPERATION_TAKE

Definition at line 27 of file RakeResults_T.h.

00027 { DDS_OPERATION_READ, DDS_OPERATION_TAKE };

enum OpenDDS::DCPS::ReconnectOpType

Enumerator:

DO_RECONNECT

Definition at line 26 of file TcpReconnectTask.h.

00026                      {
00027   DO_RECONNECT
00028 };

enum OpenDDS::DCPS::RemoveResult

used by DataLink::remove_sample(), TransportSendStrategy, *RemoveVisitor

Enumerator:

REMOVE_ERROR
REMOVE_NOT_FOUND
REMOVE_FOUND
REMOVE_RELEASED

Definition at line 232 of file TransportDefs.h.

00232                   {
00233   REMOVE_ERROR, REMOVE_NOT_FOUND, REMOVE_FOUND, REMOVE_RELEASED
00234 };

enum OpenDDS::DCPS::ReportType

Enumerator:

SERVICE_PARTICIPANT_REPORT_TYPE
DOMAIN_PARTICIPANT_REPORT_TYPE
TOPIC_REPORT_TYPE
PUBLISHER_REPORT_TYPE
SUBSCRIBER_REPORT_TYPE
DATA_WRITER_REPORT_TYPE
DATA_WRITER_PERIODIC_REPORT_TYPE
DATA_READER_REPORT_TYPE
DATA_READER_PERIODIC_REPORT_TYPE
TRANSPORT_REPORT_TYPE

Definition at line 354 of file monitor.idl.

00354                     {
00355       SERVICE_PARTICIPANT_REPORT_TYPE,
00356       DOMAIN_PARTICIPANT_REPORT_TYPE,
00357       TOPIC_REPORT_TYPE,
00358       PUBLISHER_REPORT_TYPE,
00359       SUBSCRIBER_REPORT_TYPE,
00360       DATA_WRITER_REPORT_TYPE,
00361       DATA_WRITER_PERIODIC_REPORT_TYPE,
00362       DATA_READER_REPORT_TYPE,
00363       DATA_READER_PERIODIC_REPORT_TYPE,
00364       TRANSPORT_REPORT_TYPE
00365     };

enum OpenDDS::DCPS::SendControlStatus

Return code type for send_control() operations.

Enumerator:

SEND_CONTROL_ERROR
SEND_CONTROL_OK

Definition at line 178 of file TransportDefs.h.

00178                        {
00179   SEND_CONTROL_ERROR,
00180   SEND_CONTROL_OK
00181 };

enum OpenDDS::DCPS::SendStrategyOpType

Enumerator:

SEND_START
SEND
SEND_STOP
REMOVE_SAMPLE
REMOVE_ALL_CONTROL_SAMPLES

Definition at line 37 of file ThreadPerConnectionSendTask.h.

00037                         {
00038   SEND_START,
00039   SEND,
00040   SEND_STOP,
00041   REMOVE_SAMPLE,
00042   REMOVE_ALL_CONTROL_SAMPLES
00043 };

enum OpenDDS::DCPS::SubMessageId

Enumerator:

SUBMESSAGE_NONE
MULTICAST_SYN
MULTICAST_SYNACK
MULTICAST_NAK
MULTICAST_NAKACK
SUBMESSAGE_ID_MAX

Definition at line 47 of file DataSampleHeader.h.

00047                   {
00048   SUBMESSAGE_NONE,
00049   MULTICAST_SYN,
00050   MULTICAST_SYNACK,
00051   MULTICAST_NAK,
00052   MULTICAST_NAKACK,
00053   SUBMESSAGE_ID_MAX // must be the last enumerator
00054 };

enum OpenDDS::DCPS::TopicStatus

Enumerator:

CREATED
ENABLED
FOUND
NOT_FOUND
REMOVED
CONFLICTING_TYPENAME
PRECONDITION_NOT_MET
INTERNAL_ERROR
TOPIC_DISABLED

Definition at line 47 of file DdsDcpsInfoUtils.idl.

00047                      {
00048       CREATED,
00049       ENABLED,
00050       FOUND,
00051       NOT_FOUND,
00052       REMOVED,
00053       CONFLICTING_TYPENAME,
00054       PRECONDITION_NOT_MET,
00055       INTERNAL_ERROR,
00056       TOPIC_DISABLED
00057     };

enum OpenDDS::DCPS::ValueEnumType

Enumerator:

INTEGER_TYPE
DOUBLE_TYPE
STRING_TYPE
STATISTICS_TYPE
STRING_LIST_TYPE

Definition at line 31 of file monitor.idl.

00031                        { INTEGER_TYPE, DOUBLE_TYPE, STRING_TYPE,
00032                          STATISTICS_TYPE, STRING_LIST_TYPE };

Function Documentation

OpenDDS::DCPS::ACE_FACTORY_DEFINE	(	OpenDDS_Udp	,
		UdpLoader
	)

OpenDDS::DCPS::ACE_FACTORY_DEFINE	(	OpenDDS_Shmem	,
		ShmemLoader
	)

OpenDDS::DCPS::ACE_FACTORY_DEFINE	(	OpenDDS_Rtps_Udp	,
		RtpsUdpLoader
	)

OpenDDS::DCPS::ACE_FACTORY_DEFINE	(	OpenDDS_InfoRepoDiscovery	,
		IRDiscoveryLoader
	)

static size_t OpenDDS::DCPS::arity ( const FilterEvaluator::AstNodeWrapper & node ) [static]

Definition at line 420 of file FilterEvaluator.cpp.

Referenced by OpenDDS::DCPS::FilterEvaluator::walkAst(), and OpenDDS::DCPS::FilterEvaluator::walkOperand().

00421 {
00422   size_t a = 0;
00423   for (AstNode* iter = node->GetFirstChild(); iter; iter = iter->GetSibling()) {
00424     ++a;
00425   }
00426   return a;
00427 }

Here is the caller graph for this function:

void OpenDDS::DCPS::assign	(	DCPS::EntityKey_t &	lhs,
		unsigned int	rhs
	)			`[inline]`

Definition at line 56 of file DiscoveryBase.h.

Referenced by Update::ActorStrt< QosSeq, QosSeq, ACE_CString, BinSeq, ContentSubscriptionBin >::ActorStrt(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_publication_key(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_subscription_key(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_topic_key(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::fill_header(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::MessageReceiver(), Update::ParticipantStrt< QosSeq >::ParticipantStrt(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset(), OpenDDS::DCPS::RtpsUdpDataLink::send_directed_heartbeats(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg(), and Update::TopicStrt< QosSeq, ACE_CString >::TopicStrt().

00057     {
00058       lhs[0] = static_cast<CORBA::Octet>(rhs);
00059       lhs[1] = static_cast<CORBA::Octet>(rhs >> 8);
00060       lhs[2] = static_cast<CORBA::Octet>(rhs >> 16);
00061     }

Here is the caller graph for this function:

template<typename Sequence >

SequenceBackInsertIterator<Sequence> OpenDDS::DCPS::back_inserter ( Sequence & seq ) [inline]

Definition at line 49 of file SequenceIterator.h.

00050   {
00051     return SequenceBackInsertIterator<Sequence>(seq);
00052   }

Here is the caller graph for this function:

template<typename Container , typename FirstType , typename SecondType >

int OpenDDS::DCPS::bind	(	Container &	c,
		const FirstType &	first,
		const SecondType &	second
	)			`[inline]`

Definition at line 18 of file Util.h.

Referenced by OpenDDS::DCPS::ReplayerImpl::association_complete_i(), OpenDDS::DCPS::DataWriterImpl::association_complete_i(), OpenDDS::DCPS::DomainParticipantImpl::create_new_topic(), OpenDDS::DCPS::DataLinkSet::insert_link(), OpenDDS::DCPS::WriteDataContainer::register_instance(), OpenDDS::DCPS::TransportRegistry::register_type(), OpenDDS::DCPS::DataLinkSet::select_links(), OpenDDS::DCPS::DataLinkSet::send_start(), OpenDDS::DCPS::OwnershipManager::set_instance_map(), and OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_instance_data().

00022 {
00023   if (c.find(first) == c.end()) {
00024     typedef typename Container::value_type container_value_type;
00025 
00026     if (c.insert(container_value_type(first, second)).second) {
00027       return 0;
00028     }
00029 
00030     return -1;
00031   }
00032 
00033   return 1;
00034 }

Here is the caller graph for this function:

static FilterEvaluator::AstNodeWrapper OpenDDS::DCPS::child	(	const FilterEvaluator::AstNodeWrapper &	node,
		size_t	idx
	)			`[static]`

Definition at line 429 of file FilterEvaluator.cpp.

Referenced by OpenDDS::DCPS::FilterEvaluator::walkAst(), and OpenDDS::DCPS::FilterEvaluator::walkOperand().

00430 {
00431   AstNode* iter = 0;
00432   for (iter = node->GetFirstChild(); idx != 0; iter = iter->GetSibling(), --idx) {}
00433   return iter;
00434 }

Here is the caller graph for this function:

OpenDDS_Dcps_Export bool OpenDDS::DCPS::compatibleQOS	(	const DDS::DataWriterQos *	writerQos,
		const DDS::DataReaderQos *	readerQos,
		OpenDDS::DCPS::IncompatibleQosStatus *	writerStatus,
		OpenDDS::DCPS::IncompatibleQosStatus *	readerStatus
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::compatibleQOS	(	const DDS::PublisherQos *	pubQos,
		const DDS::SubscriberQos *	subQos,
		OpenDDS::DCPS::IncompatibleQosStatus *	writerStatus,
		OpenDDS::DCPS::IncompatibleQosStatus *	readerStatus
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::compatibleQOS	(	OpenDDS::DCPS::IncompatibleQosStatus *	writerStatus,
		OpenDDS::DCPS::IncompatibleQosStatus *	readerStatus,
		const OpenDDS::DCPS::TransportLocatorSeq &	pubTLS,
		const OpenDDS::DCPS::TransportLocatorSeq &	subTLS,
		DDS::DataWriterQos const *const	writerQos,
		DDS::DataReaderQos const *const	readerQos,
		DDS::PublisherQos const *const	pubQos,
		DDS::SubscriberQos const *const	subQos
	)

Compares whether a publication and subscription are compatible by comparing their constituent parts.

Referenced by OpenDDS::DCPS::EndpointRegistry::match(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::match(), DCPS_IR_Subscription::reevaluate_association(), DCPS_IR_Publication::reevaluate_association(), and DCPS_IR_Topic_Description::try_associate().

Here is the caller graph for this function:

bool OpenDDS::DCPS::compatibleTransports	(	const OpenDDS::DCPS::TransportLocatorSeq &	s1,
		const OpenDDS::DCPS::TransportLocatorSeq &	s2
	)

Definition at line 145 of file DCPS_Utils.cpp.

00147 {
00148   for (CORBA::ULong i = 0; i < s1.length(); ++i) {
00149     for (CORBA::ULong j = 0; j < s2.length(); ++j) {
00150       if (0 == std::strcmp(s1[i].transport_type, s2[j].transport_type)) {
00151         return true;
00152       }
00153     }
00154   }
00155   return false;
00156 }

template<typename T , typename U >

RcHandle<T> OpenDDS::DCPS::const_rchandle_cast ( const RcHandle< U > & h ) [inline]

Definition at line 209 of file RcHandle_T.h.

References OpenDDS::DCPS::RcHandle< T >::in().

00210 {
00211   return RcHandle<T>(const_cast<T*>(h.in()), inc_count());
00212 }

Here is the call graph for this function:

template<typename Sequence >

ConstSequenceIterator<Sequence> OpenDDS::DCPS::const_sequence_begin ( Sequence & seq ) [inline]

Definition at line 268 of file SequenceIterator.h.

References OpenDDS::DCPS::SequenceIteratorBase< ConstSequenceIterator< Sequence >, ConstSequenceIterTraits< Sequence > >::begin().

Referenced by OpenDDS::Security::SSL::SignedDocument::deserialize(), OpenDDS::Security::TokenReader::get_bin_property_value(), OpenDDS::Security::SSL::SignedDocument::get_original(), OpenDDS::Security::TokenReader::get_property_value(), OpenDDS::Security::SSL::SignedDocument::serialize(), and OpenDDS::Security::SSL::Certificate::serialize().

00269   {
00270     return ConstSequenceIterator<Sequence>::Base::begin(seq);
00271   }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Sequence >

ConstSequenceIterator<Sequence> OpenDDS::DCPS::const_sequence_end ( Sequence & seq ) [inline]

Definition at line 274 of file SequenceIterator.h.

References OpenDDS::DCPS::SequenceIteratorBase< ConstSequenceIterator< Sequence >, ConstSequenceIterTraits< Sequence > >::end().

Referenced by OpenDDS::Security::SSL::SignedDocument::deserialize(), OpenDDS::Security::TokenReader::get_bin_property_value(), OpenDDS::Security::SSL::SignedDocument::get_original(), OpenDDS::Security::TokenReader::get_property_value(), OpenDDS::Security::SSL::SignedDocument::serialize(), and OpenDDS::Security::SSL::Certificate::serialize().

00275   {
00276     return ConstSequenceIterator<Sequence>::Base::end(seq);
00277   }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

bool OpenDDS::DCPS::convertToInteger	(	const OPENDDS_STRING &	s,
		T &	value
	)			`[inline]`

Definition at line 30 of file ConfigUtils.h.

Referenced by OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config(), OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), OpenDDS::DCPS::TransportRegistry::load_transport_configuration(), and OpenDDS::DCPS::StaticDiscovery::parse_endpoints().

00031   {
00032 #ifdef OPENDDS_SAFETY_PROFILE
00033     char* end;
00034     const long conv = std::strtol(s.c_str(), &end, 10);
00035     if (end == s.c_str()) return false;
00036     value = static_cast<T>(conv);
00037 #else
00038     std::stringstream istr(s.c_str());
00039     if (!(istr >> value) || (istr.peek() != EOF)) return false;
00040 #endif
00041     return true;
00042   }

Here is the caller graph for this function:

ACE_INLINE ACE_Time_Value OpenDDS::DCPS::duration_to_absolute_time_value	(	const DDS::Duration_t &	t,
		const ACE_Time_Value &	now = `ACE_OS::gettimeofday()`
	)

Definition at line 175 of file Time_Helper.inl.

References ACE_ONE_SECOND_IN_USECS, ACE_Time_Value::max_time, DDS::Duration_t::nanosec, ACE_Time_Value::sec(), DDS::Duration_t::sec, and ACE_Time_Value::usec().

Referenced by OpenDDS::DCPS::DataWriterImpl::AckToken::deadline(), OpenDDS::DCPS::WriteDataContainer::obtain_buffer(), and DDS::WaitSet::wait().

00177 {
00178   CORBA::LongLong sec
00179     = t.sec + now.sec() + (t.nanosec/1000 + now.usec())/ACE_ONE_SECOND_IN_USECS;
00180   CORBA::ULong usec = (t.nanosec/1000 + now.usec()) % ACE_ONE_SECOND_IN_USECS;
00181 
00182   if (sec > ACE_Time_Value::max_time.sec()) {
00183     return ACE_Time_Value::max_time;
00184   }
00185   else {
00186     return ACE_Time_Value(ACE_Utils::truncate_cast<time_t>(sec), usec);
00187   }
00188 }

Here is the call graph for this function:

Here is the caller graph for this function:

ACE_INLINE ACE_Time_Value OpenDDS::DCPS::duration_to_time_value ( const DDS::Duration_t & t )

Definition at line 160 of file Time_Helper.inl.

References ACE_ONE_SECOND_IN_USECS, ACE_Time_Value::max_time, DDS::Duration_t::nanosec, and DDS::Duration_t::sec.

00161 {
00162   CORBA::LongLong sec = t.sec + t.nanosec/1000/ACE_ONE_SECOND_IN_USECS;
00163   CORBA::ULong usec = t.nanosec/1000 % ACE_ONE_SECOND_IN_USECS;
00164 
00165   if (sec > ACE_Time_Value::max_time.sec()) {
00166     return ACE_Time_Value::max_time;
00167   }
00168   else {
00169     return ACE_Time_Value(ACE_Utils::truncate_cast<time_t>(sec), usec);
00170   }
00171 }

Here is the caller graph for this function:

template<typename T , typename U >

RcHandle<T> OpenDDS::DCPS::dynamic_rchandle_cast ( const RcHandle< U > & h ) [inline]

Definition at line 215 of file RcHandle_T.h.

References OpenDDS::DCPS::RcHandle< T >::in().

Referenced by TAO_DDS_DCPSInfo_i::init_transport(), and OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_instance_data().

00216 {
00217   return RcHandle<T>(dynamic_cast<T*>(h.in()), inc_count());
00218 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Container , typename Key >

int OpenDDS::DCPS::find	(	const Container &	c,
		const Key &	key,
		typename Container::mapped_type &	value
	)			`[inline]`

Definition at line 86 of file Util.h.

00090 {
00091   typename Container::const_iterator iter =
00092     c.find(key);
00093 
00094   if (iter == c.end()) {
00095     return -1;
00096   }
00097 
00098   value = iter->second;
00099   return 0;
00100 }

template<typename Container , typename Key >

int OpenDDS::DCPS::find	(	Container &	c,
		const Key &	key,
		typename Container::mapped_type *&	value
	)			`[inline]`

Definition at line 69 of file Util.h.

Referenced by OpenDDS::DCPS::TransportRegistry::create_inst(), OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), OpenDDS::DCPS::WriteDataContainer::dispose(), OpenDDS::DCPS::ReceiveListenerSet::exist(), OpenDDS::DCPS::ReceiveListenerSetMap::find(), OpenDDS::DCPS::WriteDataContainer::get_handle_instance(), OpenDDS::DCPS::OwnershipManager::get_instance_map(), OpenDDS::DCPS::DataDurabilityCache::insert(), OpenDDS::DCPS::DomainParticipantFactoryImpl::lookup_participant(), OpenDDS::DCPS::WriteDataContainer::num_samples(), OpenDDS::DCPS::UdpTransport::passive_connection(), OpenDDS::DCPS::MulticastTransport::passive_connection(), OpenDDS::DCPS::WriteDataContainer::register_instance(), OpenDDS::DCPS::ReceiveListenerSetMap::release_subscriber(), OpenDDS::DCPS::ReceiveListenerSetMap::remove(), OpenDDS::DCPS::WriteDataContainer::unregister(), and OpenDDS::DCPS::OwnershipManager::unregister_reader().

00073 {
00074   typename Container::iterator iter =
00075     c.find(key);
00076 
00077   if (iter == c.end()) {
00078     return -1;
00079   }
00080 
00081   value = &iter->second;
00082   return 0;
00083 }

Here is the caller graph for this function:

ACE_INLINE void OpenDDS::DCPS::find_size_ulong	(	size_t &	size,
		size_t &	padding
	)

Definition at line 1083 of file Serializer.inl.

References ACE_INLINE.

Referenced by gen_find_size().

01084 {
01085   const size_t sz = sizeof(ACE_CDR::ULong);
01086   if ((size + padding) % sz) {
01087     padding += sz - ((size + padding) % sz);
01088   }
01089   size += sz;
01090 }

Here is the caller graph for this function:

void OpenDDS::DCPS::gen_find_size	(	const SequenceNumber &	,
		size_t &	size,
		size_t &	padding
	)			`[inline]`

Definition at line 196 of file SequenceNumber.h.

References find_size_ulong(), and gen_max_marshaled_size().

Referenced by OpenDDS::DCPS::DataSampleHeader::add_cfentries(), OpenDDS::DCPS::RtpsUdpDataLink::add_gap_submsg(), OpenDDS::DCPS::DataWriterImpl::association_complete_i(), OpenDDS::DCPS::DataWriterImpl_T< MessageType >::dds_marshal(), OpenDDS::DCPS::RtpsUdpDataLink::generate_nack_frags(), OpenDDS::DCPS::DataSampleHeader::init(), OpenDDS::DCPS::RtpsUdpDataLink::marshal_gaps(), OpenDDS::RTPS::marshal_key_hash(), OpenDDS::Security::SSL::hash_serialized_impl::operator()(), OpenDDS::DCPS::DataSampleHeader::partial(), OpenDDS::DCPS::RtpsUdpDataLink::send_ack_nacks(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeat_replies().

00196                                                                            {
00197   find_size_ulong(size, padding);
00198   size += gen_max_marshaled_size(CORBA::Long());
00199 }

Here is the call graph for this function:

Here is the caller graph for this function:

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_OutputCDR::from_octet x )

Definition at line 1052 of file Serializer.inl.

References ACE_INLINE.

01053 {
01054   return sizeof(ACE_CDR::Char);
01055 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_OutputCDR::from_wchar x )

Definition at line 1047 of file Serializer.inl.

References ACE_INLINE, and OpenDDS::DCPS::Serializer::WCHAR_SIZE.

01048 {
01049   return Serializer::WCHAR_SIZE + 1; //CDR encoding adds 1 octet for length
01050 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_OutputCDR::from_char x )

Definition at line 1042 of file Serializer.inl.

References ACE_INLINE.

01043 {
01044   return sizeof(ACE_CDR::Char);
01045 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_OutputCDR::from_boolean x )

Definition at line 1037 of file Serializer.inl.

References ACE_INLINE.

01038 {
01039   return sizeof(ACE_CDR::Char);
01040 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::Double & x )

Definition at line 1031 of file Serializer.inl.

References ACE_INLINE.

01032 {
01033   return sizeof(ACE_CDR::Double);
01034 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::Float & x )

Definition at line 1026 of file Serializer.inl.

References ACE_INLINE.

01027 {
01028   return sizeof(ACE_CDR::Float);
01029 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::LongDouble & x )

Definition at line 1021 of file Serializer.inl.

References ACE_INLINE.

01022 {
01023   return sizeof(ACE_CDR::LongDouble);
01024 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::ULongLong & x )

Definition at line 1016 of file Serializer.inl.

References ACE_INLINE.

01017 {
01018   return sizeof(ACE_CDR::ULongLong);
01019 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::LongLong & x )

Definition at line 1011 of file Serializer.inl.

References ACE_INLINE.

01012 {
01013   return sizeof(ACE_CDR::LongLong);
01014 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::ULong & x )

Definition at line 1006 of file Serializer.inl.

References ACE_INLINE.

01007 {
01008   return sizeof(ACE_CDR::ULong);
01009 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::Long & x )

Definition at line 1001 of file Serializer.inl.

References ACE_INLINE.

01002 {
01003   return sizeof(ACE_CDR::Long);
01004 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::UShort & x )

Definition at line 996 of file Serializer.inl.

References ACE_INLINE.

00997 {
00998   return sizeof(ACE_CDR::UShort);
00999 }

ACE_INLINE size_t OpenDDS::DCPS::gen_max_marshaled_size ( const ACE_CDR::Short & x )

Definition at line 991 of file Serializer.inl.

References ACE_INLINE.

00992 {
00993   return sizeof(ACE_CDR::Short);
00994 }

size_t OpenDDS::DCPS::gen_max_marshaled_size ( const GUID_t & ) [inline]

Definition at line 136 of file GuidUtils.h.

Referenced by OpenDDS::DCPS::DataWriterImpl_T< MessageType >::DataWriterImpl_T(), gen_find_size(), OpenDDS::RTPS::marshal_key_hash(), and OpenDDS::DCPS::DataSampleHeader::split().

00137 {
00138   return 16;
00139 }

Here is the caller graph for this function:

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::get_fully_qualified_hostname ( ACE_INET_Addr * addr = 0 )

Helper function to get the fully qualified hostname. It attempts to discover the FQDN by the network interface addresses, however the result is impacted by the network configuration, so it returns name in the order whoever is found first - FQDN, short hostname, name resolved from loopback address. In the case using short hostname or name resolved from loopback, a warning is logged. If there is no any name discovered from network interfaces, an error is logged. If ACE_HAS_IPV6, will give priority to IPV6 interfaces

Referenced by OpenDDS::DCPS::TcpTransport::configure_i(), and OpenDDS::DCPS::UdpDataLink::open().

Here is the caller graph for this function:

OpenDDS_Dcps_Export void OpenDDS::DCPS::get_interface_addrs ( OPENDDS_VECTOR(ACE_INET_Addr)& addrs )

Helper function to get the vector of addresses which should be advertised to peers

Referenced by OpenDDS::DCPS::RtpsUdpInst::populate_locator(), and OpenDDS::RTPS::Sedp::unicast_locators().

Here is the caller graph for this function:

static bool OpenDDS::DCPS::get_remote_reliability ( const TransportImpl::RemoteTransport & remote ) [static]

Definition at line 139 of file MulticastTransport.cpp.

References OpenDDS::DCPS::TransportImpl::RemoteTransport::blob_, and len.

Referenced by OpenDDS::DCPS::MulticastTransport::accept_datalink(), and OpenDDS::DCPS::MulticastTransport::connect_datalink().

00140 {
00141   NetworkAddress network_address;
00142   ACE_CDR::Boolean reliable;
00143 
00144   const size_t len = remote.blob_.length();
00145   const char* buffer = reinterpret_cast<const char*>(remote.blob_.get_buffer());
00146 
00147   ACE_InputCDR cdr(buffer, len);
00148   cdr >> network_address;
00149   cdr >> ACE_InputCDR::to_boolean(reliable);
00150 
00151   return reliable;
00152 }

Here is the caller graph for this function:

template<typename T >

const MetaStruct& OpenDDS::DCPS::getMetaStruct ( ) [inline]

const DDS::InstanceHandle_t OpenDDS::DCPS::HANDLE_UNKNOWN ( 0 )

Referenced by OpenDDS::DCPS::DomainParticipantImpl::id_to_handle().

Here is the caller graph for this function:

OpenDDS_Dcps_Export void OpenDDS::DCPS::increment_incompatibility_count	(	OpenDDS::DCPS::IncompatibleQosStatus *	status,
		DDS::QosPolicyId_t	incompatible_policy
	)

Increments the count of occurances of the incompatible policy for the status

template<typename Container , typename ValueType >

int OpenDDS::DCPS::insert	(	Container &	c,
		const ValueType &	v
	)			`[inline]`

Definition at line 103 of file Util.h.

Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::ReplayerImpl::association_complete_i(), OpenDDS::DCPS::DataWriterImpl::association_complete_i(), OpenDDS::DCPS::DomainParticipantImpl::create_publisher(), OpenDDS::DCPS::DomainParticipantImpl::create_subscriber(), and OpenDDS::DCPS::DataWriterImpl::transport_assoc_done().

00106 {
00107   if (c.find(v) == c.end()) {
00108     if (c.insert(v).second) {
00109       return 0;
00110     }
00111 
00112     return -1;
00113   }
00114 
00115   return 1;
00116 }

Here is the caller graph for this function:

template<class BIT_Reader_var , class BIT_DataSeq >

DDS::ReturnCode_t OpenDDS::DCPS::instance_handle_to_bit_data	(	DomainParticipantImpl *	dp,
		const char *	bit_name,
		const DDS::InstanceHandle_t &	handle,
		BIT_DataSeq &	data
	)			`[inline]`

Definition at line 78 of file BuiltInTopicUtils.h.

References ACE_TEXT(), DDS::ANY_INSTANCE_STATE, DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, DCPS_debug_level, OpenDDS::DCPS::DomainParticipantImpl::get_builtin_subscriber(), ACE_OS::gettimeofday(), DDS::LENGTH_UNLIMITED, LM_DEBUG, LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, DDS::RETCODE_TIMEOUT, ACE_OS::sleep(), and TheServiceParticipant.

00084 00085 00086 00087 00088 00089 00090 00091 00092 00093 00094 00095 00096 00097 00098 00099 00100 00101 00102 00103 00104 00105 00106 00107 00108 00109 00110 00111 00112 00113 00114 00115 00116 00117     } 00118 00119 00120 00121 00122 00123 00124 00125     } 00126 00127 00128 00129 00130 00131 00132 00133 00134       } 00135 00136 00137 00138 00139 00140       } 00141 00142 00143 00144 00145 00146 00147 00148 00149 00150     } 00151   } 00152 }

class="fragment">00083 { DDS::Subscriber_var bit_subscriber = dp->get_builtin_subscriber(); DDS::DataReader_var reader = bit_subscriber->lookup_datareader(bit_name); typedef typename BIT_Reader_var::_obj_type BIT_Reader; BIT_Reader_var bit_reader = BIT_Reader::_narrow(reader.in()); const ACE_Time_Value due = ACE_OS::gettimeofday() + ACE_Time_Value(TheServiceParticipant->bit_lookup_duration_msec() / 1000, (TheServiceParticipant->bit_lookup_duration_msec() % 1000) * 1000); // Look for the data from builtin topic datareader until we get results or // timeout. // This is to resolve the problem of lookup return nothing. This could happen // when the add_association is called before the builtin topic datareader got // the published data. while (true) { DDS::SampleInfoSeq the_info; BIT_DataSeq the_data; const DDS::ReturnCode_t ret = bit_reader->read_instance(the_data, the_info, DDS::LENGTH_UNLIMITED, handle, DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, DDS::ANY_INSTANCE_STATE); if (ret == DDS::RETCODE_OK) { data.length(1); data[0] = the_data[0]; return ret; if (ret != DDS::RETCODE_BAD_PARAMETER && ret != DDS::RETCODE_NO_DATA) { ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: instance_handle_to_repo_id, ") ACE_TEXT("read instance 0x%x returned error %d.\n"), handle, ret), ret); const ACE_Time_Value now = ACE_OS::gettimeofday(); if (now < due) { if (DCPS_debug_level >= 10) { ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) instance_handle_to_repo_id, ") ACE_TEXT("BIT reader read_instance failed - trying again.\n"))); ACE_Time_Value tv = due - now; if (tv > ACE_Time_Value(0, 100000)) { tv = ACE_Time_Value(0, 100000); ACE_OS::sleep(tv); } else { ACE_ERROR_RETURN((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: instance_handle_to_repo_id,") ACE_TEXT(" timeout. \n")), DDS::RETCODE_ERROR); return DDS::RETCODE_TIMEOUT;

Here is the call graph for this function:

bool OpenDDS::DCPS::is_wildcard ( const char * str )

Definition at line 24 of file DCPS_Utils.cpp.

References ACE_OS::strcspn().

00025 {
00026   static const char wild[] = "?*[";
00027 
00028   while (*str) {
00029     size_t i = ACE_OS::strcspn(str, wild);
00030 
00031     if (!str[i]) return false; // no wildcard
00032 
00033     if (i > 0 && str[i-1] == '\\') str += i + 1; // escaped wildcard
00034 
00035     else return true;
00036   }
00037 
00038   return false;
00039 }

Here is the call graph for this function:

template<typename TopicType >

DDS::BuiltinTopicKey_t OpenDDS::DCPS::keyFromSample ( TopicType * sample ) [inline]

Definition at line 212 of file BuiltInTopicUtils.h.

References DDS::BuiltinTopicKey_t::value.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_instance_data().

00213 {
00214   DDS::BuiltinTopicKey_t value;
00215   value.value[0] = value.value[1] = value.value[2] = 0;
00216   return value;
00217 }

Here is the caller graph for this function:

template<>

DDS::BuiltinTopicKey_t OpenDDS::DCPS::keyFromSample< DDS::ParticipantBuiltinTopicData > ( DDS::ParticipantBuiltinTopicData * sample ) [inline]

template<>

DDS::BuiltinTopicKey_t OpenDDS::DCPS::keyFromSample< DDS::PublicationBuiltinTopicData > ( DDS::PublicationBuiltinTopicData * sample ) [inline]

template<>

DDS::BuiltinTopicKey_t OpenDDS::DCPS::keyFromSample< DDS::SubscriptionBuiltinTopicData > ( DDS::SubscriptionBuiltinTopicData * sample ) [inline]

template<>

DDS::BuiltinTopicKey_t OpenDDS::DCPS::keyFromSample< DDS::TopicBuiltinTopicData > ( DDS::TopicBuiltinTopicData * sample ) [inline]

template<class Sample , class Field >

ComparatorBase::Ptr OpenDDS::DCPS::make_field_cmp	(	Field Sample::*	mp,
		ComparatorBase::Ptr	next
	)			`[inline]`

Definition at line 79 of file Comparator_T.h.

00081 {
00082   return make_rch<FieldComparator<Sample, Field> >(mp, next);
00083 }

template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 , typename U6 , typename U7 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2,
		U3 const &	u3,
		U4 const &	u4,
		U5 const &	u5,
		U6 const &	u6,
		U7 const &	u7
	)			`[inline]`

Definition at line 305 of file RcHandle_T.h.

References unwrap_reference().

00306 {
00307   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2), unwrap_reference(u3), unwrap_reference(u4), unwrap_reference(u5), unwrap_reference(u6), unwrap_reference(u7)), keep_count());
00308 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 , typename U6 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2,
		U3 const &	u3,
		U4 const &	u4,
		U5 const &	u5,
		U6 const &	u6
	)			`[inline]`

Definition at line 299 of file RcHandle_T.h.

References unwrap_reference().

00300 {
00301   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2), unwrap_reference(u3), unwrap_reference(u4), unwrap_reference(u5), unwrap_reference(u6)), keep_count());
00302 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 , typename U5 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2,
		U3 const &	u3,
		U4 const &	u4,
		U5 const &	u5
	)			`[inline]`

Definition at line 293 of file RcHandle_T.h.

References unwrap_reference().

00294 {
00295   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2), unwrap_reference(u3), unwrap_reference(u4), unwrap_reference(u5)), keep_count());
00296 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 , typename U2 , typename U3 , typename U4 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2,
		U3 const &	u3,
		U4 const &	u4
	)			`[inline]`

Definition at line 287 of file RcHandle_T.h.

References unwrap_reference().

00288 {
00289   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2), unwrap_reference(u3), unwrap_reference(u4)), keep_count());
00290 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 , typename U2 , typename U3 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2,
		U3 const &	u3
	)			`[inline]`

Definition at line 281 of file RcHandle_T.h.

References unwrap_reference().

00282 {
00283   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2), unwrap_reference(u3)), keep_count());
00284 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 , typename U2 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1,
		U2 const &	u2
	)			`[inline]`

Definition at line 275 of file RcHandle_T.h.

References unwrap_reference().

00276 {
00277   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1), unwrap_reference(u2)), keep_count());
00278 }

Here is the call graph for this function:

template<typename T , typename U0 , typename U1 >

RcHandle<T> OpenDDS::DCPS::make_rch	(	U0 const &	u0,
		U1 const &	u1
	)			`[inline]`

Definition at line 269 of file RcHandle_T.h.

References unwrap_reference().

00270 {
00271   return RcHandle<T>(new T(unwrap_reference(u0), unwrap_reference(u1)), keep_count());
00272 }

Here is the call graph for this function:

template<typename T , typename U >

RcHandle<T> OpenDDS::DCPS::make_rch ( U const & u ) [inline]

Definition at line 263 of file RcHandle_T.h.

References unwrap_reference().

00264 {
00265   return RcHandle<T>(new T(unwrap_reference(u)), keep_count());
00266 }

Here is the call graph for this function:

template<typename T >

RcHandle<T> OpenDDS::DCPS::make_rch ( ) [inline]

Definition at line 257 of file RcHandle_T.h.

00258 {
00259   return RcHandle<T>(new T(), keep_count());
00260 }

template<class Sample , class Field >

ComparatorBase::Ptr OpenDDS::DCPS::make_struct_cmp	(	Field Sample::*	mp,
		ComparatorBase::Ptr	delegate,
		ComparatorBase::Ptr	next
	)			`[inline]`

Definition at line 121 of file Comparator_T.h.

00124 {
00125   return make_rch<StructComparator<Sample, Field> >(mp, delegate, next);
00126 }

bool OpenDDS::DCPS::matches_default ( const DDS::PartitionQosPolicy & qos )

Definition at line 80 of file DCPS_Utils.cpp.

References DDS::PartitionQosPolicy::name.

Referenced by matching_partitions().

00081 {
00082   if (qos.name.length() == 0)
00083     return true; // default
00084 
00085   for (CORBA::ULong i = 0; i < qos.name.length(); ++i) {
00086     if (*qos.name[i] == 0)
00087       return true; // default (empty string)
00088   }
00089 
00090   return false;
00091 }

Here is the caller graph for this function:

bool OpenDDS::DCPS::matches_name	(	const DDS::PartitionQosPolicy &	qos,
		const PartitionName &	name
	)

Definition at line 67 of file DCPS_Utils.cpp.

References OpenDDS::DCPS::PartitionName::matches(), and DDS::PartitionQosPolicy::name.

Referenced by matching_partitions().

00068 {
00069   for (CORBA::ULong i = 0; i < qos.name.length(); ++i) {
00070     PartitionName qos_name(qos.name[i]);
00071 
00072     if (qos_name.matches(name))
00073       return true;
00074   }
00075 
00076   return false;
00077 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool OpenDDS::DCPS::matching_partitions	(	const DDS::PartitionQosPolicy &	pub,
		const DDS::PartitionQosPolicy &	sub
	)

Definition at line 94 of file DCPS_Utils.cpp.

References matches_default(), matches_name(), and DDS::PartitionQosPolicy::name.

00096 {
00097   if (matches_default(pub)) {
00098     if (matches_default(sub))
00099       return true;
00100 
00101     // Zero-length sequences should be treated the same as a
00102     // sequence of length 1 that contains an empty string:
00103     if (pub.name.length() == 0)
00104       return matches_name(sub, "");
00105   }
00106 
00107   for (CORBA::ULong i = 0; i < pub.name.length(); ++i) {
00108     const char* name = pub.name[i];
00109 
00110     if (matches_name(sub, name))
00111       return true;
00112   }
00113 
00114   return false;
00115 }

Here is the call graph for this function:

ACE_INLINE size_t OpenDDS::DCPS::max_marshaled_size_boolean ( )

predefined type max_marshaled_size method explicit disambiguators.

Definition at line 1058 of file Serializer.inl.

References ACE_INLINE.

01059 {
01060   return sizeof(ACE_CDR::Char);
01061 }

ACE_INLINE size_t OpenDDS::DCPS::max_marshaled_size_char ( )

Definition at line 1063 of file Serializer.inl.

References ACE_INLINE.

01064 {
01065   return sizeof(ACE_CDR::Char);
01066 }

ACE_INLINE size_t OpenDDS::DCPS::max_marshaled_size_octet ( )

Definition at line 1073 of file Serializer.inl.

References ACE_INLINE.

01074 {
01075   return sizeof(ACE_CDR::Char);
01076 }

ACE_INLINE size_t OpenDDS::DCPS::max_marshaled_size_ulong ( )

lengths of strings and sequences are ulong

Definition at line 1078 of file Serializer.inl.

References ACE_INLINE.

01079 {
01080   return sizeof(ACE_CDR::ULong);
01081 }

ACE_INLINE size_t OpenDDS::DCPS::max_marshaled_size_wchar ( )

Definition at line 1068 of file Serializer.inl.

References ACE_INLINE, and OpenDDS::DCPS::Serializer::WCHAR_SIZE.

01069 {
01070   return Serializer::WCHAR_SIZE + 1; //CDR encoding adds 1 octet for length
01071 }

template<typename T >

unique_ptr<T>::rv_reference OpenDDS::DCPS::move ( container_supported_unique_ptr< T > & ptr ) [inline]

Definition at line 334 of file unique_ptr.h.

00335 {
00336 # ifndef OPENDDS_SAFETY_PROFILE
00337   assert(ptr->ref_count() == 1);
00338 # endif
00339   return reinterpret_cast<typename unique_ptr<T>::rv_reference>(ptr);
00340 }

template<typename T >

T::rv_reference OpenDDS::DCPS::move ( T & p ) [inline]

Definition at line 142 of file unique_ptr.h.

00143 {
00144   return static_cast<typename T::rv_reference>(p);
00145 }

ACE_INLINE bool OpenDDS::DCPS::non_negative_duration ( const DDS::Duration_t & t )

Check if given duration is either infinite or greater than or equal to zero.

Definition at line 228 of file Time_Helper.inl.

References DDS::DURATION_ZERO_NSEC, DDS::DURATION_ZERO_SEC, DDS::Duration_t::nanosec, DDS::Duration_t::sec, and valid_duration().

Referenced by OpenDDS::DCPS::Qos_Helper::valid(), and DDS::WaitSet::wait().

00229 {
00230   return
00231     (t.sec == DDS::DURATION_ZERO_SEC  // Allow zero duration.
00232      && t.nanosec == DDS::DURATION_ZERO_NSEC)
00233     || valid_duration(t);
00234 }

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS_Dcps_Export bool OpenDDS::DCPS::open_appropriate_socket_type	(	ACE_SOCK_Dgram &	socket,
		const ACE_INET_Addr &	local_address
	)

Helper function to create dual stack socket to support IPV4 and IPV6, for IPV6 builds allows for setting IPV6_V6ONLY socket option to 0 before binding Otherwise defaults to opening a socket based on the type of local_address

Referenced by OpenDDS::DCPS::RtpsUdpTransport::configure_i(), OpenDDS::DCPS::UdpDataLink::open(), and OpenDDS::RTPS::Spdp::SpdpTransport::open_unicast_socket().

Here is the caller graph for this function:

typedef OpenDDS::DCPS::OPENDDS_LIST ( SubsectionPair )

Referenced by OpenDDS::DCPS::TransportReassembly::data_unavailable(), OpenDDS::DCPS::TransportReassembly::get_gaps(), OpenDDS::DCPS::TransportReassembly::insert(), and OpenDDS::DCPS::TransportRegistry::load_transport_configuration().

Here is the caller graph for this function:

typedef OpenDDS::DCPS::OPENDDS_MAP	(	DDS::InstanceHandle_t	,
		PublicationInstance_rch
	)

typedef OpenDDS::DCPS::OPENDDS_MAP	(	DDS::DomainParticipant_ptr	,
		TypeSupportMap
	)

typedef OpenDDS::DCPS::OPENDDS_MAP	(	OPENDDS_STRING	,
		TypeSupport_var
	)

typedef OpenDDS::DCPS::OPENDDS_MAP	(	OPENDDS_STRING	,
		OPENDDS_STRING
	)

Helper types and functions for config file parsing.

Referenced by OpenDDS::DCPS::RakeResults< SampleSeq >::copy_into(), OpenDDS::DCPS::RtpsUdpDataLink::generate_nack_frags(), OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::notify_delivery(), OpenDDS::DCPS::RtpsUdpDataLink::received(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), OpenDDS::DCPS::RtpsUdpDataLink::send_nackfrag_replies(), and OpenDDS::DCPS::PublisherImpl::wait_for_acknowledgments().

Here is the caller graph for this function:

typedef OpenDDS::DCPS::OPENDDS_MAP_CMP	(	RepoId	,
		DataLinkSet_rch	,
		GUID_tKeyLessThan
	)

typedef OpenDDS::DCPS::OPENDDS_MAP_CMP	(	PublicationId	,
		WriterCoherentSample	,
		GUID_tKeyLessThan
	)

typedef OpenDDS::DCPS::OPENDDS_SET_CMP	(	RepoId	,
		GUID_tKeyLessThan
	)

typedef OpenDDS::DCPS::OPENDDS_VECTOR ( HostnameInfo )

typedef OpenDDS::DCPS::OPENDDS_VECTOR ( RawDataSample )

Referenced by OpenDDS::DCPS::ReceiveListenerSet::data_received(), OpenDDS::DCPS::ReliableSession::deliver_held_data(), OpenDDS::DCPS::DataDurabilityCache::init(), OpenDDS::DCPS::DataDurabilityCache::insert(), OpenDDS::DCPS::TransportRegistry::load_transport_configuration(), OpenDDS::DCPS::RtpsUdpInst::populate_locator(), OpenDDS::DCPS::Service_Participant::remap_domains(), OpenDDS::DCPS::SingleSendBuffer::resend_fragments_i(), and OpenDDS::DCPS::Service_Participant::set_repo_domain().

Here is the caller graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator! ( const DDS::Time_t & t )

Definition at line 81 of file Time_Helper.inl.

References DDS::Time_t::nanosec, DDS::Time_t::sec, DDS::TIME_INVALID_NSEC, and DDS::TIME_INVALID_SEC.

00082 {
00083   return t.sec == DDS::TIME_INVALID_SEC
00084          || t.nanosec == DDS::TIME_INVALID_NSEC;
00085 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 95 of file Time_Helper.inl.

00096 {
00097   return !(t1 == t2);
00098 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 28 of file Time_Helper.inl.

00029 {
00030   return !(t1 == t2);
00031 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DomainParticipantFactoryQos &	qos1,
		const DDS::DomainParticipantFactoryQos &	qos2
	)

Definition at line 541 of file Qos_Helper.inl.

00543 {
00544   return !(qos1 == qos2);
00545 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::SubscriberQos &	qos1,
		const DDS::SubscriberQos &	qos2
	)

Definition at line 534 of file Qos_Helper.inl.

00536 {
00537   return !(qos1 == qos2);
00538 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DataReaderQos &	qos1,
		const DDS::DataReaderQos &	qos2
	)

Definition at line 527 of file Qos_Helper.inl.

00529 {
00530   return !(qos1 == qos2);
00531 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::PublisherQos &	qos1,
		const DDS::PublisherQos &	qos2
	)

Definition at line 520 of file Qos_Helper.inl.

00522 {
00523   return !(qos1 == qos2);
00524 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DataWriterQos &	qos1,
		const DDS::DataWriterQos &	qos2
	)

Definition at line 513 of file Qos_Helper.inl.

00515 {
00516   return !(qos1 == qos2);
00517 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::TopicQos &	qos1,
		const DDS::TopicQos &	qos2
	)

Definition at line 506 of file Qos_Helper.inl.

00508 {
00509   return !(qos1 == qos2);
00510 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DomainParticipantQos &	qos1,
		const DDS::DomainParticipantQos &	qos2
	)

Definition at line 499 of file Qos_Helper.inl.

00501 {
00502   return !(qos1 == qos2);
00503 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::PropertyQosPolicy &	qos1,
		const DDS::PropertyQosPolicy &	qos2
	)

Definition at line 492 of file Qos_Helper.inl.

00494 {
00495   return !(qos1 == qos2);
00496 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::ReaderDataLifecycleQosPolicy &	qos1,
		const DDS::ReaderDataLifecycleQosPolicy &	qos2
	)

Definition at line 485 of file Qos_Helper.inl.

00487 {
00488   return !(qos1 == qos2);
00489 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::WriterDataLifecycleQosPolicy &	qos1,
		const DDS::WriterDataLifecycleQosPolicy &	qos2
	)

Definition at line 478 of file Qos_Helper.inl.

00480 {
00481   return !(qos1 == qos2);
00482 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::EntityFactoryQosPolicy &	qos1,
		const DDS::EntityFactoryQosPolicy &	qos2
	)

Definition at line 471 of file Qos_Helper.inl.

00473 {
00474   return !(qos1 == qos2);
00475 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::ResourceLimitsQosPolicy &	qos1,
		const DDS::ResourceLimitsQosPolicy &	qos2
	)

Definition at line 464 of file Qos_Helper.inl.

00466 {
00467   return !(qos1 == qos2);
00468 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::HistoryQosPolicy &	qos1,
		const DDS::HistoryQosPolicy &	qos2
	)

Definition at line 457 of file Qos_Helper.inl.

00459 {
00460   return !(qos1 == qos2);
00461 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DestinationOrderQosPolicy &	qos1,
		const DDS::DestinationOrderQosPolicy &	qos2
	)

Definition at line 450 of file Qos_Helper.inl.

00452 {
00453   return !(qos1 == qos2);
00454 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::ReliabilityQosPolicy &	qos1,
		const DDS::ReliabilityQosPolicy &	qos2
	)

Definition at line 443 of file Qos_Helper.inl.

00445 {
00446   return !(qos1 == qos2);
00447 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::PartitionQosPolicy &	qos1,
		const DDS::PartitionQosPolicy &	qos2
	)

Definition at line 436 of file Qos_Helper.inl.

00438 {
00439   return !(qos1 == qos2);
00440 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::TimeBasedFilterQosPolicy &	qos1,
		const DDS::TimeBasedFilterQosPolicy &	qos2
	)

Definition at line 429 of file Qos_Helper.inl.

00431 {
00432   return !(qos1 == qos2);
00433 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::LivelinessQosPolicy &	qos1,
		const DDS::LivelinessQosPolicy &	qos2
	)

Definition at line 422 of file Qos_Helper.inl.

00424 {
00425   return !(qos1 == qos2);
00426 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::OwnershipStrengthQosPolicy &	qos1,
		const DDS::OwnershipStrengthQosPolicy &	qos2
	)

Definition at line 415 of file Qos_Helper.inl.

00417 {
00418   return !(qos1 == qos2);
00419 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::OwnershipQosPolicy &	qos1,
		const DDS::OwnershipQosPolicy &	qos2
	)

Definition at line 408 of file Qos_Helper.inl.

00410 {
00411   return !(qos1 == qos2);
00412 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::LatencyBudgetQosPolicy &	qos1,
		const DDS::LatencyBudgetQosPolicy &	qos2
	)

Definition at line 401 of file Qos_Helper.inl.

00403 {
00404   return !(qos1 == qos2);
00405 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DeadlineQosPolicy &	qos1,
		const DDS::DeadlineQosPolicy &	qos2
	)

Definition at line 394 of file Qos_Helper.inl.

00396 {
00397   return !(qos1 == qos2);
00398 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::PresentationQosPolicy &	qos1,
		const DDS::PresentationQosPolicy &	qos2
	)

Definition at line 387 of file Qos_Helper.inl.

00389 {
00390   return !(qos1 == qos2);
00391 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DurabilityServiceQosPolicy &	qos1,
		const DDS::DurabilityServiceQosPolicy &	qos2
	)

Definition at line 380 of file Qos_Helper.inl.

00382 {
00383   return !(qos1 == qos2);
00384 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::DurabilityQosPolicy &	qos1,
		const DDS::DurabilityQosPolicy &	qos2
	)

Definition at line 372 of file Qos_Helper.inl.

00374 {
00375   return !(qos1 == qos2);
00376 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::LifespanQosPolicy &	qos1,
		const DDS::LifespanQosPolicy &	qos2
	)

Definition at line 364 of file Qos_Helper.inl.

00366 {
00367   return !(qos1 == qos2);
00368 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::TransportPriorityQosPolicy &	qos1,
		const DDS::TransportPriorityQosPolicy &	qos2
	)

Definition at line 357 of file Qos_Helper.inl.

00359 {
00360   return !(qos1 == qos2);
00361 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::GroupDataQosPolicy &	qos1,
		const DDS::GroupDataQosPolicy &	qos2
	)

Definition at line 350 of file Qos_Helper.inl.

00352 {
00353   return !(qos1 == qos2);
00354 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::TopicDataQosPolicy &	qos1,
		const DDS::TopicDataQosPolicy &	qos2
	)

Definition at line 343 of file Qos_Helper.inl.

00345 {
00346   return !(qos1 == qos2);
00347 }

ACE_INLINE bool OpenDDS::DCPS::operator!=	(	const DDS::UserDataQosPolicy &	qos1,
		const DDS::UserDataQosPolicy &	qos2
	)

Definition at line 336 of file Qos_Helper.inl.

00338 {
00339   return !(qos1 == qos2);
00340 }

bool OpenDDS::DCPS::operator!=	(	const EntityId_t &	lhs,
		const EntityId_t &	rhs
	)			`[inline]`

Definition at line 174 of file GuidUtils.h.

00175 {
00176   return !(lhs == rhs);
00177 }

bool OpenDDS::DCPS::operator!=	(	const GUID_t &	lhs,
		const GUID_t &	rhs
	)			`[inline]`

Definition at line 150 of file GuidUtils.h.

00151 {
00152   return !(lhs == rhs);
00153 }

SequenceNumber OpenDDS::DCPS::operator+	(	int	lhs,
		const SequenceNumber &	rhs
	)			`[inline]`

Definition at line 190 of file SequenceNumber.h.

00191 {
00192   return rhs + lhs;
00193 }

SequenceNumber OpenDDS::DCPS::operator+	(	const SequenceNumber &	lhs,
		int	rhs
	)			`[inline]`

Definition at line 177 of file SequenceNumber.h.

References OpenDDS::DCPS::SequenceNumber::getValue().

00178 {
00179   return SequenceNumber(lhs.getValue() + rhs);
00180 }

Here is the call graph for this function:

SequenceNumber OpenDDS::DCPS::operator+=	(	SequenceNumber &	lhs,
		int	rhs
	)			`[inline]`

Definition at line 183 of file SequenceNumber.h.

References OpenDDS::DCPS::SequenceNumber::getValue(), and OpenDDS::DCPS::SequenceNumber::setValue().

00184 {
00185   lhs.setValue(lhs.getValue() + rhs);
00186   return lhs;
00187 }

Here is the call graph for this function:

ACE_INLINE DDS::Time_t OpenDDS::DCPS::operator-	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 129 of file Time_Helper.inl.

References DDS::Time_t::nanosec, and DDS::Time_t::sec.

00130 {
00131   DDS::Time_t t = { t1.sec - t2.sec, t1.nanosec - t2.nanosec };
00132 
00133   if (t2.nanosec > t1.nanosec)
00134     {
00135       t.nanosec = (t1.nanosec + ACE_ONE_SECOND_IN_NSECS) - t2.nanosec;
00136       t.sec = (t1.sec - 1) - t2.sec;
00137     }
00138 
00139   return t;
00140 }

ACE_INLINE bool OpenDDS::DCPS::operator<	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 102 of file Time_Helper.inl.

References DDS::Time_t::nanosec, and DDS::Time_t::sec.

00103 {
00104   if (!t1 || !t2) return false;
00105 
00106   return t1.sec < t2.sec
00107          || (t1.sec == t2.sec && t1.nanosec < t2.nanosec);
00108 }

ACE_INLINE bool OpenDDS::DCPS::operator<	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 35 of file Time_Helper.inl.

References DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, DDS::Duration_t::nanosec, and DDS::Duration_t::sec.

00036 {
00037   // @note We wouldn't have to handle the case for INFINITY explicitly
00038   //       if both the Duration_t sec and nanosec fields were the
00039   //       maximum values for their corresponding types.
00040   //       Unfortunately, the OMG DDS specification defines the
00041   //       infinite nanosec value to be somewhere in the middle.
00042   DDS::Duration_t const DDS_DURATION_INFINITY = {
00043     DDS::DURATION_INFINITE_SEC,
00044     DDS::DURATION_INFINITE_NSEC
00045   };
00046 
00047   // We assume that either both the DDS::Duration_t::sec and
00048   // DDS::Duration_t::nanosec fields are INFINITY or neither of them
00049   // are.  It doesn't make sense for only one of the fields to be
00050   // INFINITY.
00051   return
00052     t1 != DDS_DURATION_INFINITY
00053     && (t2 == DDS_DURATION_INFINITY
00054         || t1.sec < t2.sec
00055         || (t1.sec == t2.sec && t1.nanosec < t2.nanosec));
00056 }

OpenDDS_Dcps_Export bool OpenDDS::DCPS::operator<<	(	ACE_Message_Block &	buffer,
		const TransportHeader &	value
	)

std::ostream& OpenDDS::DCPS::operator<<	(	std::ostream &	str,
		const DataLink &	value
	)

Definition at line 1033 of file DataLink.cpp.

References OpenDDS::DCPS::DataLink::assoc_by_local_.

01034 {
01035   str << "   There are " << value.assoc_by_local_.size()
01036       << " local entities currently using this link comprising following associations:"
01037       << std::endl;
01038 
01039   for (DataLink::AssocByLocal::const_iterator
01040        localId = value.assoc_by_local_.begin();
01041        localId != value.assoc_by_local_.end();
01042        ++localId) {
01043     for (RepoIdSet::const_iterator
01044          remoteId = localId->second.begin();
01045          remoteId != localId->second.end();
01046          ++remoteId) {
01047       str << GuidConverter(localId->first) << " --> "
01048           << GuidConverter(*remoteId) << "   " << std::endl;
01049     }
01050   }
01051   return str;
01052 }

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_wstring	x
	)

Definition at line 800 of file Serializer.inl.

References ACE_OutputCDR::from_wstring::bound_, OpenDDS::DCPS::Serializer::good_bit(), ACE_OS::strlen(), and ACE_OutputCDR::from_wstring::val_.

00801 {
00802   s << x.val_;
00803   const ACE_CDR::ULong stringlen =
00804     x.bound_ ? static_cast<ACE_CDR::ULong>(ACE_OS::strlen(x.val_)) : 0;
00805   return s.good_bit() && ((x.bound_ == 0) || (stringlen <= x.bound_));
00806 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_string	x
	)

Definition at line 782 of file Serializer.inl.

References ACE_OutputCDR::from_string::bound_, OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), ACE_OS::strlen(), and ACE_OutputCDR::from_string::val_.

00783 {
00784   // Include the null termination in the serialized data.
00785   ACE_CDR::ULong stringlen = 0;
00786 
00787   if (x.val_ != 0) {
00788     stringlen = 1 + static_cast<ACE_CDR::ULong>(ACE_OS::strlen(x.val_));
00789     s << stringlen;
00790     s.buffer_write(reinterpret_cast<char*>(x.val_), stringlen, false);
00791 
00792   } else {
00793     s << ACE_CDR::ULong(0);
00794   }
00795 
00796   return s.good_bit() && ((x.bound_ == 0) || (stringlen - 1 <= x.bound_));
00797 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_octet	x
	)

Definition at line 775 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and ACE_OutputCDR::from_octet::val_.

00776 {
00777   s.buffer_write(reinterpret_cast<char*>(&x.val_), sizeof(ACE_CDR::Octet), false);
00778   return s.good_bit();
00779 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		const std::string &	x
	)

Definition at line 760 of file Serializer.inl.

00761 {
00762   return s << x.c_str();
00763 }

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_wchar	x
	)

Definition at line 739 of file Serializer.inl.

References ACE_TEXT(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::good_bit_, LM_DEBUG, OpenDDS::DCPS::Serializer::SWAP_BE, ACE_OutputCDR::from_wchar::val_, and OpenDDS::DCPS::Serializer::WCHAR_SIZE.

00740 {
00741   // CDR wchar format: 1 octet for # of bytes in wchar, followed by those bytes
00742   static const ACE_CDR::Octet wchar_bytes = Serializer::WCHAR_SIZE;
00743   s.buffer_write(reinterpret_cast<const char*>(&wchar_bytes), 1, false);
00744 #if ACE_SIZEOF_WCHAR == 2
00745   s.buffer_write(reinterpret_cast<char*>(&x.val_), Serializer::WCHAR_SIZE, Serializer::SWAP_BE);
00746 #else
00747   const ACE_UINT16 as_utf16 = static_cast<ACE_UINT16>(x.val_);
00748   if (as_utf16 != x.val_) { // not currently handling surrogates
00749     ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) operator<<(Serializer&, ACE_OutputCDR::from_wchar): failure to convert UTF-32 to UTF-16.\n")));
00750     s.good_bit_ = false;
00751   } else {
00752     s.buffer_write(reinterpret_cast<const char*>(&as_utf16), Serializer::WCHAR_SIZE, Serializer::SWAP_BE);
00753   }
00754 #endif
00755   return s.good_bit();
00756 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_char	x
	)

Definition at line 732 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and ACE_OutputCDR::from_char::val_.

00733 {
00734   s.buffer_write(reinterpret_cast<char*>(&x.val_), sizeof(ACE_CDR::Char), false);
00735   return s.good_bit();
00736 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_OutputCDR::from_boolean	x
	)

Definition at line 725 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::swap_bytes(), and ACE_OutputCDR::from_boolean::val_.

00726 {
00727   s.buffer_write(reinterpret_cast<char*>(&x.val_), sizeof(ACE_CDR::Boolean), s.swap_bytes());
00728   return s.good_bit();
00729 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		const ACE_CDR::WChar *	x
	)

Definition at line 696 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::good_bit_, ACE_OS::strlen(), OpenDDS::DCPS::Serializer::SWAP_BE, OpenDDS::DCPS::Serializer::WCHAR_SIZE, and OpenDDS::DCPS::Serializer::write_array().

00697 {
00698   //NOTE: Serializing wchar/wstring uses UTF-16BE
00699   if (x != 0) {
00700     // Do not include the null terminatator in the serialized data.
00701     const ACE_CDR::ULong length = static_cast<ACE_CDR::ULong>(ACE_OS::strlen(x));
00702     s << ACE_CDR::ULong(length * Serializer::WCHAR_SIZE);
00703 
00704 #if ACE_SIZEOF_WCHAR == 2
00705     s.write_array(reinterpret_cast<const char*>(x), Serializer::WCHAR_SIZE,
00706                   length, Serializer::SWAP_BE);
00707 #else
00708     for (size_t i = 0; i < length && s.good_bit(); ++i) {
00709       const ACE_UINT16 as_utf16 = static_cast<ACE_UINT16>(x[i]);
00710       if (as_utf16 != x[i]) { // not currently handling surrogates
00711         s.good_bit_ = false;
00712         break;
00713       }
00714       s.buffer_write(reinterpret_cast<const char*>(&as_utf16), Serializer::WCHAR_SIZE, Serializer::SWAP_BE);
00715     }
00716 #endif
00717   } else {
00718     s << ACE_CDR::ULong(0);
00719   }
00720 
00721   return s.good_bit();
00722 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		const ACE_CDR::Char *	x
	)

Definition at line 679 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and ACE_OS::strlen().

00680 {
00681   if (x != 0) {
00682     // Include the null termination in the serialized data.
00683     const ACE_CDR::ULong stringlen =
00684       1 + static_cast<ACE_CDR::ULong>(ACE_OS::strlen(x));
00685     s << stringlen;
00686     s.buffer_write(reinterpret_cast<const char*>(x), stringlen, false);
00687 
00688   } else {
00689     s << ACE_CDR::ULong(0);
00690   }
00691 
00692   return s.good_bit();
00693 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::Double	x
	)

Definition at line 671 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00672 {
00673   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::Double));
00674   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Double), s.swap_bytes());
00675   return s.good_bit();
00676 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::Float	x
	)

Definition at line 663 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00664 {
00665   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::Float));
00666   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Float), s.swap_bytes());
00667   return s.good_bit();
00668 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::LongDouble	x
	)

Definition at line 655 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00656 {
00657   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(8);
00658   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::LongDouble), s.swap_bytes());
00659   return s.good_bit();
00660 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::ULongLong	x
	)

Definition at line 647 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00648 {
00649   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::ULongLong));
00650   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::ULongLong), s.swap_bytes());
00651   return s.good_bit();
00652 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::LongLong	x
	)

Definition at line 639 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00640 {
00641   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::LongLong));
00642   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::LongLong), s.swap_bytes());
00643   return s.good_bit();
00644 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::ULong	x
	)

Definition at line 631 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00632 {
00633   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::ULong));
00634   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::ULong), s.swap_bytes());
00635   return s.good_bit();
00636 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::Long	x
	)

Definition at line 623 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00624 {
00625   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::Long));
00626   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Long), s.swap_bytes());
00627   return s.good_bit();
00628 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::UShort	x
	)

Definition at line 615 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00616 {
00617   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::UShort));
00618   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::UShort), s.swap_bytes());
00619   return s.good_bit();
00620 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::Short	x
	)

Definition at line 607 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_w(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00608 {
00609   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_w(sizeof(ACE_CDR::Short));
00610   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Short), s.swap_bytes());
00611   return s.good_bit();
00612 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator<<	(	Serializer &	s,
		ACE_CDR::Char	x
	)

Definition at line 600 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_write(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00601 {
00602   s.buffer_write(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Char), s.swap_bytes());
00603   return s.good_bit();
00604 }

Here is the call graph for this function:

ACE_CDR::Boolean OpenDDS::DCPS::operator<<	(	Serializer &	s,
		const SequenceNumber &	x
	)			`[inline]`

Definition at line 156 of file SequenceNumber.h.

References OpenDDS::DCPS::SequenceNumber::getHigh(), OpenDDS::DCPS::SequenceNumber::getLow(), and OpenDDS::DCPS::Serializer::good_bit().

00156                                                    {
00157   s << x.getHigh();
00158   s << x.getLow();
00159   return s.good_bit();
00160 }

Here is the call graph for this function:

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	os,
		const GUID_t &	rhs
	)

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	os,
		const GuidConverter &	rhs
	)

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	str,
		const DataSampleHeader &	value
	)

Message header insertion onto an ostream.

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	os,
		const SubMessageId	rhs
	)

Sub-Message Id enumeration insertion onto an ostream.

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	str,
		const MessageId	value
	)

Message Id enumeration insertion onto an ostream.

OpenDDS_Dcps_Export bool OpenDDS::DCPS::operator<<	(	ACE_Message_Block &	buffer,
		const DataSampleHeader &	value
	)

Marshal/Insertion into a buffer.

template<typename DatumType >

ACE_INLINE std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	str,
		const DataCollector< DatumType > &	value
	)			`[inline]`

Insert collected data onto an ostream.

Definition at line 16 of file DataCollector_T.inl.

References OpenDDS::DCPS::DataCollector< DatumType >::insert().

00019 {
00020   return value.insert(str);
00021 }

Here is the call graph for this function:

OpenDDS_Dcps_Export std::ostream & OpenDDS::DCPS::operator<<	(	std::ostream &	str,
		const CoherentChangeControl &	value
	)

Message header insertion onto an ostream.

OpenDDS_Dcps_Export ACE_CDR::Boolean OpenDDS::DCPS::operator<<	(	Serializer &	serializer,
		CoherentChangeControl &	value
	)

Marshal/Insertion into a buffer.

ACE_INLINE bool OpenDDS::DCPS::operator<=	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 111 of file Time_Helper.inl.

00112 {
00113   return !(t2 < t1);
00114 }

ACE_INLINE bool OpenDDS::DCPS::operator<=	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 59 of file Time_Helper.inl.

00060 {
00061   // If t2 is *not* less than t1, t1 must be less than
00062   // or equal to t2.
00063   // This is more concise than:
00064   //   t1 < t2 || t1 == t2
00065   return !(t2 < t1);
00066 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 89 of file Time_Helper.inl.

00090 {
00091   return !(t1 < t2) && !(t2 < t1);
00092 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 22 of file Time_Helper.inl.

References DDS::Duration_t::nanosec, and DDS::Duration_t::sec.

00023 {
00024   return t1.sec == t2.sec && t1.nanosec == t2.nanosec;
00025 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::PropertyQosPolicy &	qos1,
		const DDS::PropertyQosPolicy &	qos2
	)

Definition at line 228 of file Qos_Helper.inl.

References DDS::PropertyQosPolicy::binary_value, and DDS::PropertyQosPolicy::value.

00230 {
00231   return qos1.value == qos2.value && qos1.binary_value == qos2.binary_value;
00232 }

template<typename T >

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const TAO::unbounded_value_sequence< T > &	seq1,
		const TAO::unbounded_value_sequence< T > &	seq2
	)			`[inline]`

Definition at line 214 of file Qos_Helper.inl.

00215 {
00216   if (seq1.length() != seq2.length())
00217     return false;
00218 
00219   for (size_t i = 0; i < seq1.length(); ++i)
00220   {
00221     if (seq1[i].name != seq2[i].name || seq1[i].value != seq2[i].value || seq1[i].propagate != seq2[i].propagate)
00222       return false;
00223   }
00224   return true;
00225 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DomainParticipantFactoryQos &	qos1,
		const DDS::DomainParticipantFactoryQos &	qos2
	)

Definition at line 329 of file Qos_Helper.inl.

References DDS::DomainParticipantFactoryQos::entity_factory.

00331 {
00332   return qos1.entity_factory == qos2.entity_factory;
00333 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::SubscriberQos &	qos1,
		const DDS::SubscriberQos &	qos2
	)

Definition at line 318 of file Qos_Helper.inl.

References DDS::SubscriberQos::entity_factory, DDS::SubscriberQos::group_data, DDS::SubscriberQos::partition, and DDS::SubscriberQos::presentation.

00320 {
00321   return
00322     qos1.presentation == qos2.presentation
00323     && qos1.partition == qos2.partition
00324     && qos1.group_data == qos2.group_data
00325     && qos1.entity_factory == qos2.entity_factory;
00326 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DataReaderQos &	qos1,
		const DDS::DataReaderQos &	qos2
	)

Definition at line 300 of file Qos_Helper.inl.

References DDS::DataReaderQos::deadline, DDS::DataReaderQos::destination_order, DDS::DataReaderQos::durability, DDS::DataReaderQos::history, DDS::DataReaderQos::latency_budget, DDS::DataReaderQos::liveliness, DDS::DataReaderQos::reader_data_lifecycle, DDS::DataReaderQos::reliability, DDS::DataReaderQos::resource_limits, DDS::DataReaderQos::time_based_filter, and DDS::DataReaderQos::user_data.

00302 {
00303   return
00304     qos1.durability == qos2.durability
00305     && qos1.deadline == qos2.deadline
00306     && qos1.latency_budget == qos2.latency_budget
00307     && qos1.liveliness == qos2.liveliness
00308     && qos1.reliability == qos2.reliability
00309     && qos1.destination_order == qos2.destination_order
00310     && qos1.history == qos2.history
00311     && qos1.resource_limits == qos2.resource_limits
00312     && qos1.user_data == qos2.user_data
00313     && qos1.time_based_filter == qos2.time_based_filter
00314     && qos1.reader_data_lifecycle == qos2.reader_data_lifecycle;
00315 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::PublisherQos &	qos1,
		const DDS::PublisherQos &	qos2
	)

Definition at line 289 of file Qos_Helper.inl.

References DDS::PublisherQos::entity_factory, DDS::PublisherQos::group_data, DDS::PublisherQos::partition, and DDS::PublisherQos::presentation.

00291 {
00292   return
00293     qos1.presentation == qos2.presentation
00294     && qos1.partition == qos2.partition
00295     && qos1.group_data == qos2.group_data
00296     && qos1.entity_factory == qos2.entity_factory;
00297 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DataWriterQos &	qos1,
		const DDS::DataWriterQos &	qos2
	)

Definition at line 265 of file Qos_Helper.inl.

00267 {
00268   return
00269     qos1.durability == qos2.durability
00270     && qos1.durability_service == qos2.durability_service
00271     && qos1.deadline == qos2.deadline
00272     && qos1.latency_budget == qos2.latency_budget
00273     && qos1.liveliness == qos2.liveliness
00274     && qos1.reliability == qos2.reliability
00275     && qos1.destination_order == qos2.destination_order
00276     && qos1.history == qos2.history
00277     && qos1.resource_limits == qos2.resource_limits
00278     && qos1.transport_priority == qos2.transport_priority
00279     && qos1.lifespan == qos2.lifespan
00280     && qos1.user_data == qos2.user_data
00281     && qos1.ownership == qos2.ownership
00282 #ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
00283     && qos1.ownership_strength == qos2.ownership_strength
00284 #endif
00285     && qos1.writer_data_lifecycle == qos2.writer_data_lifecycle;
00286 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::TopicQos &	qos1,
		const DDS::TopicQos &	qos2
	)

Definition at line 245 of file Qos_Helper.inl.

References DDS::TopicQos::deadline, DDS::TopicQos::destination_order, DDS::TopicQos::durability, DDS::TopicQos::durability_service, DDS::TopicQos::history, DDS::TopicQos::latency_budget, DDS::TopicQos::lifespan, DDS::TopicQos::liveliness, DDS::TopicQos::ownership, DDS::TopicQos::reliability, DDS::TopicQos::resource_limits, DDS::TopicQos::topic_data, and DDS::TopicQos::transport_priority.

00247 {
00248   return
00249     qos1.topic_data == qos2.topic_data
00250     && qos1.durability == qos2.durability
00251     && qos1.durability_service == qos2.durability_service
00252     && qos1.deadline == qos2.deadline
00253     && qos1.latency_budget == qos2.latency_budget
00254     && qos1.liveliness == qos2.liveliness
00255     && qos1.reliability == qos2.reliability
00256     && qos1.destination_order == qos2.destination_order
00257     && qos1.history == qos2.history
00258     && qos1.resource_limits == qos2.resource_limits
00259     && qos1.transport_priority == qos2.transport_priority
00260     && qos1.lifespan == qos2.lifespan
00261     && qos1.ownership == qos2.ownership;
00262 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DomainParticipantQos &	qos1,
		const DDS::DomainParticipantQos &	qos2
	)

Definition at line 235 of file Qos_Helper.inl.

References DDS::DomainParticipantQos::entity_factory, DDS::DomainParticipantQos::property, and DDS::DomainParticipantQos::user_data.

00237 {
00238   return
00239     qos1.user_data == qos2.user_data
00240     && qos1.entity_factory == qos2.entity_factory
00241     && qos1.property == qos2.property;
00242 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::ReaderDataLifecycleQosPolicy &	qos1,
		const DDS::ReaderDataLifecycleQosPolicy &	qos2
	)

Definition at line 203 of file Qos_Helper.inl.

References DDS::ReaderDataLifecycleQosPolicy::autopurge_disposed_samples_delay, and DDS::ReaderDataLifecycleQosPolicy::autopurge_nowriter_samples_delay.

00205 {
00206   return
00207     (qos1.autopurge_nowriter_samples_delay == qos2.autopurge_nowriter_samples_delay)
00208     && (qos1.autopurge_disposed_samples_delay == qos2.autopurge_disposed_samples_delay);
00209 
00210 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::WriterDataLifecycleQosPolicy &	qos1,
		const DDS::WriterDataLifecycleQosPolicy &	qos2
	)

Definition at line 195 of file Qos_Helper.inl.

References DDS::WriterDataLifecycleQosPolicy::autodispose_unregistered_instances.

00197 {
00198   return
00199     qos1.autodispose_unregistered_instances == qos2.autodispose_unregistered_instances;
00200 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::EntityFactoryQosPolicy &	qos1,
		const DDS::EntityFactoryQosPolicy &	qos2
	)

Definition at line 185 of file Qos_Helper.inl.

References DDS::EntityFactoryQosPolicy::autoenable_created_entities.

00187 {
00188   // Marked_Default_Qos for DomainParticipant uses a value that's not 0 or 1
00189   return std::memcmp(&qos1.autoenable_created_entities,
00190                      &qos2.autoenable_created_entities,
00191                      sizeof qos2.autoenable_created_entities) == 0;
00192 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::ResourceLimitsQosPolicy &	qos1,
		const DDS::ResourceLimitsQosPolicy &	qos2
	)

Definition at line 175 of file Qos_Helper.inl.

References DDS::ResourceLimitsQosPolicy::max_instances, DDS::ResourceLimitsQosPolicy::max_samples, and DDS::ResourceLimitsQosPolicy::max_samples_per_instance.

00177 {
00178   return
00179     qos1.max_samples == qos2.max_samples
00180     && qos1.max_instances == qos2.max_instances
00181     && qos1.max_samples_per_instance == qos2.max_samples_per_instance;
00182 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::HistoryQosPolicy &	qos1,
		const DDS::HistoryQosPolicy &	qos2
	)

Definition at line 166 of file Qos_Helper.inl.

References DDS::HistoryQosPolicy::depth, and DDS::HistoryQosPolicy::kind.

00168 {
00169   return
00170     qos1.kind == qos2.kind
00171     && qos1.depth == qos2.depth;
00172 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DestinationOrderQosPolicy &	qos1,
		const DDS::DestinationOrderQosPolicy &	qos2
	)

Definition at line 159 of file Qos_Helper.inl.

References DDS::DestinationOrderQosPolicy::kind.

00161 {
00162   return qos1.kind == qos2.kind;
00163 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::ReliabilityQosPolicy &	qos1,
		const DDS::ReliabilityQosPolicy &	qos2
	)

Definition at line 150 of file Qos_Helper.inl.

References DDS::ReliabilityQosPolicy::kind, and DDS::ReliabilityQosPolicy::max_blocking_time.

00152 {
00153   return
00154     qos1.kind == qos2.kind
00155     && qos1.max_blocking_time == qos2.max_blocking_time;
00156 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::PartitionQosPolicy &	qos1,
		const DDS::PartitionQosPolicy &	qos2
	)

Definition at line 131 of file Qos_Helper.inl.

References len, DDS::PartitionQosPolicy::name, and ACE_OS::strcmp().

00133 {
00134   const CORBA::ULong len = qos1.name.length();
00135 
00136   if (len == qos2.name.length()) {
00137     for (CORBA::ULong i = 0; i < len; ++i) {
00138       if (0 != ACE_OS::strcmp(qos1.name[i], qos2.name[i])) {
00139         return false;
00140       }
00141     }
00142 
00143     return true;
00144   }
00145 
00146   return false;
00147 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::TimeBasedFilterQosPolicy &	qos1,
		const DDS::TimeBasedFilterQosPolicy &	qos2
	)

Definition at line 124 of file Qos_Helper.inl.

References DDS::TimeBasedFilterQosPolicy::minimum_separation.

00126 {
00127   return qos1.minimum_separation == qos2.minimum_separation;
00128 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::LivelinessQosPolicy &	qos1,
		const DDS::LivelinessQosPolicy &	qos2
	)

Definition at line 115 of file Qos_Helper.inl.

References DDS::LivelinessQosPolicy::kind, and DDS::LivelinessQosPolicy::lease_duration.

00117 {
00118   return
00119     qos1.kind == qos2.kind
00120     && qos1.lease_duration == qos2.lease_duration;
00121 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::OwnershipStrengthQosPolicy &	qos1,
		const DDS::OwnershipStrengthQosPolicy &	qos2
	)

Definition at line 108 of file Qos_Helper.inl.

References DDS::OwnershipStrengthQosPolicy::value.

00110 {
00111   return qos1.value == qos2.value;
00112 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::OwnershipQosPolicy &	qos1,
		const DDS::OwnershipQosPolicy &	qos2
	)

Definition at line 101 of file Qos_Helper.inl.

References DDS::OwnershipQosPolicy::kind.

00103 {
00104   return qos1.kind == qos2.kind;
00105 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::LatencyBudgetQosPolicy &	qos1,
		const DDS::LatencyBudgetQosPolicy &	qos2
	)

Definition at line 94 of file Qos_Helper.inl.

References DDS::LatencyBudgetQosPolicy::duration.

00096 {
00097   return qos1.duration == qos2.duration;
00098 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DeadlineQosPolicy &	qos1,
		const DDS::DeadlineQosPolicy &	qos2
	)

Definition at line 87 of file Qos_Helper.inl.

References DDS::DeadlineQosPolicy::period.

00089 {
00090   return qos1.period == qos2.period;
00091 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::PresentationQosPolicy &	qos1,
		const DDS::PresentationQosPolicy &	qos2
	)

Definition at line 77 of file Qos_Helper.inl.

References DDS::PresentationQosPolicy::access_scope, DDS::PresentationQosPolicy::coherent_access, and DDS::PresentationQosPolicy::ordered_access.

00079 {
00080   return
00081     qos1.access_scope == qos2.access_scope
00082     && qos1.coherent_access == qos2.coherent_access
00083     && qos1.ordered_access == qos2.ordered_access;
00084 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DurabilityServiceQosPolicy &	qos1,
		const DDS::DurabilityServiceQosPolicy &	qos2
	)

Definition at line 64 of file Qos_Helper.inl.

References DDS::DurabilityServiceQosPolicy::history_depth, DDS::DurabilityServiceQosPolicy::history_kind, DDS::DurabilityServiceQosPolicy::max_instances, DDS::DurabilityServiceQosPolicy::max_samples, DDS::DurabilityServiceQosPolicy::max_samples_per_instance, and DDS::DurabilityServiceQosPolicy::service_cleanup_delay.

00066 {
00067   return
00068     qos1.service_cleanup_delay == qos2.service_cleanup_delay
00069     && qos1.history_kind == qos2.history_kind
00070     && qos1.history_depth == qos2.history_depth
00071     && qos1.max_samples == qos2.max_samples
00072     && qos1.max_instances == qos2.max_instances
00073     && qos1.max_samples_per_instance == qos2.max_samples_per_instance;
00074 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::DurabilityQosPolicy &	qos1,
		const DDS::DurabilityQosPolicy &	qos2
	)

Definition at line 56 of file Qos_Helper.inl.

References DDS::DurabilityQosPolicy::kind.

00058 {
00059   return qos1.kind == qos2.kind;
00060 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::LifespanQosPolicy &	qos1,
		const DDS::LifespanQosPolicy &	qos2
	)

Definition at line 48 of file Qos_Helper.inl.

References DDS::LifespanQosPolicy::duration.

00050 {
00051   return qos1.duration == qos2.duration;
00052 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::TransportPriorityQosPolicy &	qos1,
		const DDS::TransportPriorityQosPolicy &	qos2
	)

Definition at line 41 of file Qos_Helper.inl.

References DDS::TransportPriorityQosPolicy::value.

00043 {
00044   return qos1.value == qos2.value;
00045 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::GroupDataQosPolicy &	qos1,
		const DDS::GroupDataQosPolicy &	qos2
	)

Definition at line 34 of file Qos_Helper.inl.

References DDS::GroupDataQosPolicy::value.

00036 {
00037   return qos1.value == qos2.value;
00038 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::TopicDataQosPolicy &	qos1,
		const DDS::TopicDataQosPolicy &	qos2
	)

Definition at line 27 of file Qos_Helper.inl.

References DDS::TopicDataQosPolicy::value.

00029 {
00030   return qos1.value == qos2.value;
00031 }

ACE_INLINE bool OpenDDS::DCPS::operator==	(	const DDS::UserDataQosPolicy &	qos1,
		const DDS::UserDataQosPolicy &	qos2
	)

Definition at line 20 of file Qos_Helper.inl.

References DDS::UserDataQosPolicy::value.

00022 {
00023   return qos1.value == qos2.value;
00024 }

bool OpenDDS::DCPS::operator==	(	const EntityId_t &	lhs,
		const EntityId_t &	rhs
	)			`[inline]`

Definition at line 167 of file GuidUtils.h.

References OpenDDS::DCPS::GUID_tKeyLessThan::entity_less().

00168 {
00169   return !GUID_tKeyLessThan::entity_less(lhs, rhs)
00170     && !GUID_tKeyLessThan::entity_less(rhs, lhs);
00171 }

Here is the call graph for this function:

bool OpenDDS::DCPS::operator==	(	const GUID_t &	lhs,
		const GUID_t &	rhs
	)			`[inline]`

Definition at line 143 of file GuidUtils.h.

00144 {
00145   GUID_tKeyLessThan lessThan;
00146   return !lessThan(lhs, rhs) && !lessThan(rhs, lhs);
00147 }

ACE_INLINE bool OpenDDS::DCPS::operator>	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 117 of file Time_Helper.inl.

00118 {
00119   return t2 < t1;
00120 }

ACE_INLINE bool OpenDDS::DCPS::operator>	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 69 of file Time_Helper.inl.

00070 {
00071   return t2 < t1;
00072 }

ACE_INLINE bool OpenDDS::DCPS::operator>=	(	const DDS::Time_t &	t1,
		const DDS::Time_t &	t2
	)

Definition at line 123 of file Time_Helper.inl.

00124 {
00125   return t2 <= t1;
00126 }

ACE_INLINE bool OpenDDS::DCPS::operator>=	(	const DDS::Duration_t &	t1,
		const DDS::Duration_t &	t2
	)

Definition at line 75 of file Time_Helper.inl.

00076 {
00077   return t2 <= t1;
00078 }

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		std::string &	x
	)

Definition at line 967 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::read_string(), and FACE::string_free().

00968 {
00969   char* buf = 0;
00970   const size_t length = s.read_string(buf);
00971   x.assign(buf, length);
00972   CORBA::string_free(buf);
00973   return s.good_bit();
00974 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_wstring	x
	)

Definition at line 958 of file Serializer.inl.

References ACE_InputCDR::to_wstring::bound_, OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::read_string(), and ACE_InputCDR::to_wstring::val_.

00959 {
00960   const size_t length = s.read_string(const_cast<ACE_CDR::WChar*&>(x.val_));
00961   return s.good_bit()
00962          && ((x.bound_ == 0) || (length <= x.bound_));
00963 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_string	x
	)

Definition at line 950 of file Serializer.inl.

References ACE_InputCDR::to_string::bound_, OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::read_string(), and ACE_InputCDR::to_string::val_.

00951 {
00952   const size_t length = s.read_string(const_cast<char*&>(x.val_));
00953   return s.good_bit()
00954          && ((x.bound_ == 0) || (length <= x.bound_));
00955 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_octet	x
	)

Definition at line 943 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and ACE_InputCDR::to_octet::ref_.

00944 {
00945   s.buffer_read(reinterpret_cast<char*>(&x.ref_), sizeof(ACE_CDR::Octet), false);
00946   return s.good_bit();
00947 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_wchar	x
	)

Definition at line 924 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), OpenDDS::DCPS::Serializer::good_bit_, len, ACE_InputCDR::to_wchar::ref_, OpenDDS::DCPS::Serializer::SWAP_BE, and OpenDDS::DCPS::Serializer::WCHAR_SIZE.

00925 {
00926   ACE_CDR::Octet len;
00927   s.buffer_read(reinterpret_cast<char*>(&len), 1, false);
00928   if (len != Serializer::WCHAR_SIZE) {
00929     s.good_bit_ = false;
00930   } else {
00931 #if ACE_SIZEOF_WCHAR == 2
00932     s.buffer_read(reinterpret_cast<char*>(&x.ref_), Serializer::WCHAR_SIZE, Serializer::SWAP_BE);
00933 #else
00934     ACE_UINT16 as_utf16;
00935     s.buffer_read(reinterpret_cast<char*>(&as_utf16), Serializer::WCHAR_SIZE, Serializer::SWAP_BE);
00936     x.ref_ = as_utf16;
00937 #endif
00938   }
00939   return s.good_bit();
00940 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_char	x
	)

Definition at line 917 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), ACE_InputCDR::to_char::ref_, and OpenDDS::DCPS::Serializer::swap_bytes().

00918 {
00919   s.buffer_read(reinterpret_cast<char*>(&x.ref_), sizeof(ACE_CDR::Char), s.swap_bytes());
00920   return s.good_bit();
00921 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_InputCDR::to_boolean	x
	)

Definition at line 910 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), ACE_InputCDR::to_boolean::ref_, and OpenDDS::DCPS::Serializer::swap_bytes().

00911 {
00912   s.buffer_read(reinterpret_cast<char*>(&x.ref_), sizeof(ACE_CDR::Boolean), s.swap_bytes());
00913   return s.good_bit();
00914 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::WChar *&	x
	)

Definition at line 903 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::read_string().

00904 {
00905   s.read_string(x);
00906   return s.good_bit();
00907 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Char *&	x
	)

Definition at line 896 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::read_string().

00897 {
00898   s.read_string(x);
00899   return s.good_bit();
00900 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Double &	x
	)

Definition at line 888 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00889 {
00890   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::Double));
00891   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Double), s.swap_bytes());
00892   return s.good_bit();
00893 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Float &	x
	)

Definition at line 880 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00881 {
00882   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::Float));
00883   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Float), s.swap_bytes());
00884   return s.good_bit();
00885 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::LongDouble &	x
	)

Definition at line 872 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00873 {
00874   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(8);
00875   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::LongDouble), s.swap_bytes());
00876   return s.good_bit();
00877 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::ULongLong &	x
	)

Definition at line 864 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00865 {
00866   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::ULongLong));
00867   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::ULongLong), s.swap_bytes());
00868   return s.good_bit();
00869 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::LongLong &	x
	)

Definition at line 856 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00857 {
00858   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::LongLong));
00859   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::LongLong), s.swap_bytes());
00860   return s.good_bit();
00861 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::ULong &	x
	)

Definition at line 848 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00849 {
00850   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::ULong));
00851   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::ULong), s.swap_bytes());
00852   return s.good_bit();
00853 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Long &	x
	)

Definition at line 840 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00841 {
00842   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::Long));
00843   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Long), s.swap_bytes());
00844   return s.good_bit();
00845 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::UShort &	x
	)

Definition at line 832 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00833 {
00834   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::UShort));
00835   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::UShort), s.swap_bytes());
00836   return s.good_bit();
00837 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Short &	x
	)

Definition at line 824 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::ALIGN_NONE, OpenDDS::DCPS::Serializer::align_r(), OpenDDS::DCPS::Serializer::alignment(), OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00825 {
00826   s.alignment() == Serializer::ALIGN_NONE ? 0 : s.align_r(sizeof(ACE_CDR::Short));
00827   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Short), s.swap_bytes());
00828   return s.good_bit();
00829 }

Here is the call graph for this function:

ACE_INLINE bool OpenDDS::DCPS::operator>>	(	Serializer &	s,
		ACE_CDR::Char &	x
	)

Definition at line 817 of file Serializer.inl.

References OpenDDS::DCPS::Serializer::buffer_read(), OpenDDS::DCPS::Serializer::good_bit(), and OpenDDS::DCPS::Serializer::swap_bytes().

00818 {
00819   s.buffer_read(reinterpret_cast<char*>(&x), sizeof(ACE_CDR::Char), s.swap_bytes());
00820   return s.good_bit();
00821 }

Here is the call graph for this function:

ACE_CDR::Boolean OpenDDS::DCPS::operator>>	(	Serializer &	s,
		SequenceNumber &	x
	)			`[inline]`

Definition at line 163 of file SequenceNumber.h.

00163                                              {
00164   ACE_INT32 high;
00165   ACE_UINT32 low;
00166   if (!(s >> high)) {
00167     return false;
00168   }
00169   if (!(s >> low)) {
00170     return false;
00171   }
00172   x = SequenceNumber(high, low);
00173   return true;
00174 }

OpenDDS_Dcps_Export std::istream & OpenDDS::DCPS::operator>>	(	std::istream &	is,
		GUID_t &	rhs
	)

OpenDDS_Dcps_Export ACE_CDR::Boolean OpenDDS::DCPS::operator>>	(	Serializer &	serializer,
		CoherentChangeControl &	value
	)

OpenDDS_Dcps_Export int OpenDDS::DCPS::processSections	(	ACE_Configuration_Heap &	cf,
		const ACE_Configuration_Section_Key &	key,
		KeyList &	subsections
	)

Function that processes the specified ACE Configuration Section for subsections. If multiple levels of subsections are found, a non-zero value is returned to indicate the error. All valid subsection will be placed into the supplied KeyList (std::pair<> of the subsection number and ACE_Configuration_Section_Key). A return value of zero indicates error-free success.

cf ACE_Configuration_Heap object being processed key ACE_Configuration_Section_Key object that specifies the section of the .ini file to process subsections List of subsections found (list contains a std::pair<> of the subsection number and ACE_Configuration_Section_Key).

Referenced by OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config(), OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), OpenDDS::Security::SecurityRegistry::load_security_configuration(), OpenDDS::DCPS::TransportRegistry::load_transport_configuration(), OpenDDS::DCPS::StaticDiscovery::parse_datareaderqos(), OpenDDS::DCPS::StaticDiscovery::parse_datawriterqos(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), OpenDDS::DCPS::StaticDiscovery::parse_publisherqos(), OpenDDS::DCPS::StaticDiscovery::parse_subscriberqos(), and OpenDDS::DCPS::StaticDiscovery::parse_topics().

Here is the caller graph for this function:

OpenDDS_Dcps_Export int OpenDDS::DCPS::pullValues	(	ACE_Configuration_Heap &	cf,
		const ACE_Configuration_Section_Key &	key,
		ValueMap &	values
	)

Function that pulls all the values from the specified ACE Configuration Section and places them in a value map based on the field name. Returns the number of values found in the section (and added to the value map).

cf ACE_Configuration_Heap object being processed key ACE_Configuration_Section_Key object that specifies the section of the .ini file to process values Map of field names to values (both OPENDDS_STRING) that this function will add to.

Referenced by OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config(), OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::load_domain_configuration(), OpenDDS::Security::SecurityRegistry::load_security_configuration(), OpenDDS::DCPS::TransportRegistry::load_transport_configuration(), OpenDDS::DCPS::StaticDiscovery::parse_datareaderqos(), OpenDDS::DCPS::StaticDiscovery::parse_datawriterqos(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), OpenDDS::DCPS::StaticDiscovery::parse_publisherqos(), OpenDDS::DCPS::StaticDiscovery::parse_subscriberqos(), and OpenDDS::DCPS::StaticDiscovery::parse_topics().

Here is the caller graph for this function:

template<typename Seq >

void OpenDDS::DCPS::push_back	(	Seq &	seq,
		const typename Seq::value_type &	val
	)			`[inline]`

std::vector-style push_back() for CORBA Sequences

Definition at line 136 of file Util.h.

References len.

Referenced by OpenDDS::DCPS::MulticastTransport::accept_datalink(), OpenDDS::DCPS::SubscriberImpl::get_datareaders(), OpenDDS::DCPS::DomainParticipantImpl::get_discovered_participants(), OpenDDS::DCPS::DomainParticipantImpl::get_discovered_topics(), OpenDDS::DCPS::ReceiveListenerSet::get_keys(), OpenDDS::DCPS::DataReaderImpl::remove_associations(), OpenDDS::DCPS::RecorderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::RecorderImpl::remove_publication(), OpenDDS::DCPS::DataReaderImpl::remove_publication(), OpenDDS::DCPS::DataLink::target_intersection(), and OpenDDS::DCPS::DataWriterImpl_T< MessageType >::write_w_timestamp().

00137 {
00138   const CORBA::ULong len = seq.length();
00139   seq.length(len + 1);
00140   seq[len] = val;
00141 }

Here is the caller graph for this function:

template<typename T >

RcHandle<T> OpenDDS::DCPS::rchandle_from ( T * pointer ) [inline]

Definition at line 311 of file RcHandle_T.h.

00312 {
00313 #ifndef OPENDDS_SAFETY_PROFILE
00314   assert(pointer == 0 || pointer->ref_count() > 0);
00315 #endif
00316   return RcHandle<T>(pointer, inc_count());
00317 }

Here is the caller graph for this function:

template<typename T >

reference_wrapper<T> OpenDDS::DCPS::ref ( T & r ) [inline]

Definition at line 238 of file RcHandle_T.h.

Referenced by OpenDDS::DCPS::TcpTransport::accept_datalink(), OpenDDS::DCPS::StaticDiscovery::add_domain_participant(), OpenDDS::RTPS::RtpsDiscovery::add_domain_participant(), OpenDDS::DCPS::TcpTransport::connect_datalink(), OpenDDS::DCPS::TcpTransport::connect_tcp_datalink(), OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::DCPS::UdpTransport::make_datalink(), OpenDDS::DCPS::ShmemTransport::make_datalink(), OpenDDS::DCPS::RtpsUdpTransport::make_datalink(), OpenDDS::DCPS::MulticastTransport::make_datalink(), OpenDDS::DCPS::UdpInst::new_impl(), OpenDDS::DCPS::TcpInst::new_impl(), OpenDDS::DCPS::ShmemInst::new_impl(), OpenDDS::DCPS::RtpsUdpInst::new_impl(), OpenDDS::DCPS::MulticastInst::new_impl(), OpenDDS::DCPS::DataReaderImpl::qos_change(), OpenDDS::DCPS::DataWriterImpl::set_qos(), and OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_instance_data().

00239 {
00240   return reference_wrapper<T>(r);
00241 }

Here is the caller graph for this function:

template<typename Container , typename ValueType >

int OpenDDS::DCPS::remove	(	Container &	c,
		const ValueType &	v
	)			`[inline]`

Definition at line 119 of file Util.h.

References c.

Referenced by OpenDDS::DCPS::ReplayerImpl::association_complete(), OpenDDS::DCPS::DataWriterImpl::association_complete(), OpenDDS::DCPS::WriteDataContainer::data_delivered(), OpenDDS::DCPS::WriteDataContainer::data_dropped(), OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), OpenDDS::DCPS::DomainParticipantImpl::delete_publisher(), OpenDDS::DCPS::DomainParticipantImpl::delete_subscriber(), OpenDDS::DCPS::ReplayerImpl::remove_associations(), OpenDDS::DCPS::DataLink::remove_on_start_callback(), and OpenDDS::DCPS::ContentFilteredTopicImpl::remove_reader().

00122 {
00123   if (c.find(v) != c.end()) {
00124     if (c.erase(v) == 1) {
00125       return 0;
00126     }
00127 
00128     return -1;
00129   }
00130 
00131   return -1;
00132 }

Here is the caller graph for this function:

void OpenDDS::DCPS::reportErrors	(	yard::SimpleTextParser &	parser,
		const char *	input
	)			`[inline]`

called after parsing has failed, throws std::exception with details

Definition at line 27 of file AstNodeWrapper.h.

References OPENDDS_STRING.

Referenced by OpenDDS::DCPS::FilterEvaluator::FilterEvaluator(), and OpenDDS::DCPS::MultiTopicImpl::MultiTopicImpl().

00028 {
00029   AstNode* prev = 0;
00030   for (AstNode* iter = parser.GetAstRoot()->GetFirstChild(); iter;
00031       iter = iter->GetSibling()) {
00032     prev = iter;
00033   }
00034   ptrdiff_t pos = prev ? prev->GetLastToken() - parser.Begin() : 0;
00035   std::ostringstream oss;
00036   oss << pos;
00037   throw std::runtime_error("Invalid expression [" + OPENDDS_STRING(input)
00038     + "] at character " + oss.str());
00039 }

Here is the caller graph for this function:

bool OpenDDS::DCPS::resend_data_expired	(	DataSampleElement const &	element,
		DDS::LifespanQosPolicy const &	lifespan
	)

Todo:: Refactor this code and DataReaderImpl::data_expired() to a common function.

Definition at line 41 of file WriteDataContainer.cpp.

References ACE_TEXT(), DCPS_debug_level, DDS::LifespanQosPolicy::duration, DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, OpenDDS::DCPS::DataSampleElement::get_header(), ACE_OS::gettimeofday(), LM_DEBUG, ACE_Time_Value::sec(), OpenDDS::DCPS::DataSampleHeader::source_timestamp_nanosec_, OpenDDS::DCPS::DataSampleHeader::source_timestamp_sec_, time_to_time_value(), and ACE_Time_Value::usec().

Referenced by OpenDDS::DCPS::WriteDataContainer::copy_and_prepend().

00043 {
00044   if (lifespan.duration.sec != DDS::DURATION_INFINITE_SEC
00045       || lifespan.duration.nanosec != DDS::DURATION_INFINITE_NSEC) {
00046     // Finite lifespan.  Check if data has expired.
00047 
00048     DDS::Time_t const tmp = {
00049       element.get_header().source_timestamp_sec_ + lifespan.duration.sec,
00050       element.get_header().source_timestamp_nanosec_ + lifespan.duration.nanosec
00051     };
00052 
00053     ACE_Time_Value const now(ACE_OS::gettimeofday());
00054     ACE_Time_Value const expiration_time(time_to_time_value(tmp));
00055 
00056     if (now >= expiration_time) {
00057       if (DCPS_debug_level >= 8) {
00058         ACE_Time_Value const diff(now - expiration_time);
00059         ACE_DEBUG((LM_DEBUG,
00060                    ACE_TEXT("OpenDDS (%P|%t) Data to be sent ")
00061                    ACE_TEXT("expired by %d seconds, %d microseconds.\n"),
00062                    diff.sec(),
00063                    diff.usec()));
00064       }
00065 
00066       return true;  // Data expired.
00067     }
00068   }
00069 
00070   return false;
00071 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename Sequence >

SequenceIterator<Sequence> OpenDDS::DCPS::sequence_begin ( Sequence & seq ) [inline]

Definition at line 256 of file SequenceIterator.h.

References OpenDDS::DCPS::SequenceIteratorBase< SequenceIterator< Sequence >, SequenceIterTraits< Sequence > >::begin().

00257   {
00258     return SequenceIterator<Sequence>::Base::begin(seq);
00259   }

Here is the call graph for this function:

template<typename Sequence >

SequenceIterator<Sequence> OpenDDS::DCPS::sequence_end ( Sequence & seq ) [inline]

Definition at line 262 of file SequenceIterator.h.

References OpenDDS::DCPS::SequenceIteratorBase< SequenceIterator< Sequence >, SequenceIterTraits< Sequence > >::end().

00263   {
00264     return SequenceIterator<Sequence>::Base::end(seq);
00265   }

Here is the call graph for this function:

void OpenDDS_Dcps_Export OpenDDS::DCPS::set_DCPS_debug_level ( unsigned int lvl )

The proper way to set the DCPS_debug_level. This function allows for possible side-effects of setting the level.

Referenced by OpenDDS::DCPS::Service_Participant::parse_args().

Here is the caller graph for this function:

OpenDDS_Dcps_Export bool OpenDDS::DCPS::set_socket_multicast_ttl	(	const ACE_SOCK_Dgram &	socket,
		const unsigned char &	ttl
	)

Helper function to set the ttl on a socket appropriately given whether it is IPV4 or IPV6

Referenced by OpenDDS::DCPS::MulticastDataLink::join(), OpenDDS::DCPS::RtpsUdpDataLink::open(), and OpenDDS::RTPS::Spdp::SpdpTransport::open_unicast_socket().

Here is the caller graph for this function:

template<typename Seq >

void OpenDDS::DCPS::set_to_seq	(	const RepoIdSet &	rids,
		Seq &	seq
	)			`[inline]`

Definition at line 340 of file DataLink.cpp.

Referenced by OpenDDS::DCPS::DataLink::clear_associations(), OpenDDS::DCPS::DataLink::notify(), and OpenDDS::DCPS::DataLink::peer_ids().

00341 {
00342   seq.length(static_cast<CORBA::ULong>(rids.size()));
00343   CORBA::ULong i = 0;
00344   for (RepoIdSet::const_iterator iter = rids.begin(); iter != rids.end(); ++iter) {
00345     seq[i++] = *iter;
00346   }
00347 }

Here is the caller graph for this function:

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::DomainParticipantQos &	,
		const DDS::DomainParticipantQos &
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::TopicQos &	,
		const DDS::TopicQos &
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::PublisherQos &	qos1,
		const DDS::PublisherQos &	qos2
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::SubscriberQos &	qos1,
		const DDS::SubscriberQos &	qos2
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::DataWriterQos &	qos1,
		const DDS::DataWriterQos &	qos2
	)

OpenDDS_Dcps_Export bool OpenDDS::DCPS::should_check_association_upon_change	(	const DDS::DataReaderQos &	qos1,
		const DDS::DataReaderQos &	qos2
	)

Referenced by DCPS_IR_Subscription::set_qos(), and DCPS_IR_Publication::set_qos().

Here is the caller graph for this function:

template<typename T , typename U >

RcHandle<T> OpenDDS::DCPS::static_rchandle_cast ( const RcHandle< U > & h ) [inline]

Definition at line 203 of file RcHandle_T.h.

References OpenDDS::DCPS::RcHandle< T >::in().

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::bit_config(), InfoRepo::init(), OpenDDS::RTPS::Sedp::local_address(), OpenDDS::RTPS::Sedp::multicast_group(), OpenDDS::DCPS::UdpTransport::passive_connection(), OpenDDS::DCPS::MulticastTransport::passive_connection(), OpenDDS::DCPS::TcpDataLink::receive_strategy(), OpenDDS::Federator::ManagerImpl::repository(), OpenDDS::DCPS::TcpDataLink::send_strategy(), and OpenDDS::RTPS::Sedp::unicast_locators().

00204 {
00205   return RcHandle<T>(static_cast<T*>(h.in()), inc_count());
00206 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

void OpenDDS::DCPS::swap	(	container_supported_unique_ptr< T > &	lhs,
		container_supported_unique_ptr< T > &	rhs
	)			`[inline]`

Definition at line 299 of file unique_ptr.h.

References OpenDDS::DCPS::container_supported_unique_ptr< T >::swap().

00300 {
00301   lhs.swap(rhs);
00302 }

Here is the call graph for this function:

template<typename T , typename Deleter >

void OpenDDS::DCPS::swap	(	unique_ptr< T, Deleter > &	a,
		unique_ptr< T, Deleter > &	b
	)			`[inline]`

Definition at line 149 of file unique_ptr.h.

References OpenDDS::DCPS::unique_ptr< T, Deleter >::swap().

00150 {
00151   return a.swap(b);
00152 }

Here is the call graph for this function:

ACE_INLINE void OpenDDS::DCPS::swap	(	ReceivedDataSample &	a,
		ReceivedDataSample &	b
	)

Definition at line 47 of file ReceivedDataSample.inl.

References OpenDDS::DCPS::ReceivedDataSample::header_, OpenDDS::DCPS::ReceivedDataSample::sample_, and swap().

00048 {
00049   using std::swap;
00050   swap(a.header_, b.header_);
00051   swap(a.sample_, b.sample_);
00052 }

Here is the call graph for this function:

template<typename T >

void OpenDDS::DCPS::swap	(	RcHandle< T > &	lhs,
		RcHandle< T > &	rhs
	)			`[inline]`

Definition at line 197 of file RcHandle_T.h.

References OpenDDS::DCPS::RcHandle< T >::swap().

00198 {
00199   lhs.swap(rhs);
00200 }

Here is the call graph for this function:

void OpenDDS::DCPS::swap	(	RawDataSample &	lhs,
		RawDataSample &	rhs
	)

Referenced by OpenDDS::DCPS::DataWriterImpl_T< MessageType >::dds_marshal(), OpenDDS::SafetyProfile::StringEltPolicy< CharT >::move_n(), OpenDDS::DCPS::TopicDescriptionPtr< ContentFilteredTopicImpl >::operator=(), OpenDDS::DCPS::ReceivedDataSample::operator=(), OpenDDS::DCPS::WeakRcHandle< DataReaderImpl_T< MessageType > >::operator=(), OpenDDS::DCPS::RawDataSample::operator=(), OpenDDS::DCPS::DataDurabilityCache::sample_data_type::operator=(), OpenDDS::DCPS::TransportReassembly::reassemble_i(), OpenDDS::DCPS::RemoveAssociationSweeper< T >::remove_info(), OpenDDS::DCPS::ContentFilteredTopicImpl::set_expression_parameters(), OpenDDS::SafetyProfile::Sequence< T, Bounds, Elts >::swap(), OpenDDS::SafetyProfile::AllocPolicy< T, Sequence, Unbounded >::swap(), and swap().

Here is the caller graph for this function:

ACE_INLINE DDS::Duration_t OpenDDS::DCPS::time_to_duration ( const DDS::Time_t & t )

Definition at line 201 of file Time_Helper.inl.

References DDS::Time_t::nanosec, and DDS::Time_t::sec.

00202 {
00203   DDS::Duration_t d = { t.sec, t.nanosec };
00204   return d;
00205 }

ACE_INLINE ACE_Time_Value OpenDDS::DCPS::time_to_time_value ( const DDS::Time_t & t )

Definition at line 143 of file Time_Helper.inl.

References DDS::Time_t::nanosec, and DDS::Time_t::sec.

Referenced by OpenDDS::DCPS::DataReaderImpl::filter_sample(), and resend_data_expired().

00144 {
00145   ACE_Time_Value tv(t.sec, t.nanosec / 1000);
00146   return tv;
00147 }

Here is the caller graph for this function:

ACE_INLINE DDS::Duration_t OpenDDS::DCPS::time_value_to_duration ( const ACE_Time_Value & tv )

Definition at line 192 of file Time_Helper.inl.

References DDS::Duration_t::nanosec, ACE_Time_Value::sec(), DDS::Duration_t::sec, ACE_Utils::truncate_cast(), and ACE_Time_Value::usec().

Referenced by OpenDDS::DCPS::DataReaderImpl::process_latency(), and OpenDDS::DCPS::DataReaderImpl::time_based_filter_instance().

00193 {
00194   DDS::Duration_t t;
00195   t.sec = ACE_Utils::truncate_cast<CORBA::Long>(tv.sec());
00196   t.nanosec = tv.usec() * 1000;
00197   return t;
00198 }

Here is the call graph for this function:

Here is the caller graph for this function:

ACE_INLINE DDS::Time_t OpenDDS::DCPS::time_value_to_time ( const ACE_Time_Value & tv )

Definition at line 150 of file Time_Helper.inl.

References DDS::Time_t::nanosec, ACE_Time_Value::sec(), DDS::Time_t::sec, ACE_Utils::truncate_cast(), and ACE_Time_Value::usec().

00151 {
00152   DDS::Time_t t;
00153   t.sec = ACE_Utils::truncate_cast<CORBA::Long>(tv.sec());
00154   t.nanosec = tv.usec() * 1000;
00155   return t;
00156 }

Here is the call graph for this function:

Here is the caller graph for this function:

template<typename T >

OPENDDS_STRING OpenDDS::DCPS::to_dds_string ( const T * to_convert ) [inline]

Definition at line 32 of file SafetyProfileStreams.h.

References OPENDDS_STRING, and ACE_OS::snprintf().

00033 {
00034   const char* fmt = "%p";
00035   const int buff_size = 20 + 1; // note +1 for null terminator
00036   char buf[buff_size];
00037   ACE_OS::snprintf(&buf[0], buff_size, fmt, to_convert);
00038   return OPENDDS_STRING(buf);
00039 }

Here is the call graph for this function:

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string	(	unsigned long	to_convert,
		bool	as_hex
	)

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string	(	unsigned long long	to_convert,
		bool	as_hex
	)

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string ( long long to_convert )

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string ( long to_convert )

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string	(	unsigned int	to_convert,
		bool	as_hex
	)

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string ( int to_convert )

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_dds_string ( ::CORBA::UShort to_convert )

Referenced by OpenDDS::DCPS::MultiTopicDataReaderBase::data_available(), OpenDDS::DCPS::TransportInst::dump_to_str(), OpenDDS::DCPS::RtpsUdpInst::dump_to_str(), OpenDDS::DCPS::WriterInfo::get_state_str(), OpenDDS::DCPS::DataDurabilityCache::insert(), OpenDDS::DCPS::InstanceState::instance_state_string(), OpenDDS::DCPS::UdpInst::local_address(), OpenDDS::DCPS::TcpInst::local_address(), OpenDDS::DCPS::RtpsUdpInst::local_address(), OpenDDS::DCPS::DataReaderImpl::notify_liveliness_change(), OpenDDS::DCPS::GuidConverter::operator OPENDDS_STRING(), OpenDDS::DCPS::RtpsSampleHeader::process_iqos(), and OpenDDS::DCPS::TcpConnection::reconnect_state_string().

Here is the caller graph for this function:

OpenDDS_Dcps_Export OPENDDS_STRING OpenDDS::DCPS::to_string ( const GUID_t & guid )

OPENDDS_STRING OpenDDS::DCPS::to_string ( const DataSampleHeader & value )

const char * OpenDDS::DCPS::to_string ( const SubMessageId value )

const char * OpenDDS::DCPS::to_string ( const MessageId value )

Referenced by OpenDDS::DCPS::DataWriterImpl::create_control_message(), OpenDDS::DCPS::DataWriterImpl::create_sample_data_message(), OpenDDS::DCPS::RecorderImpl::data_received(), OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::DataLink::data_received_i(), and OpenDDS::DCPS::GuidConverter::operator OPENDDS_STRING().

Here is the caller graph for this function:

bool OpenDDS::DCPS::topicIsBIT	(	const char *	name,
		const char *	type
	)			`[inline]`

Returns true if the topic name and type pair matches one of the built-in topic name and type pairs.

Definition at line 40 of file BuiltInTopicUtils.h.

References BUILT_IN_PARTICIPANT_TOPIC, BUILT_IN_PARTICIPANT_TOPIC_TYPE, BUILT_IN_PUBLICATION_TOPIC, BUILT_IN_PUBLICATION_TOPIC_TYPE, BUILT_IN_SUBSCRIPTION_TOPIC, BUILT_IN_SUBSCRIPTION_TOPIC_TYPE, BUILT_IN_TOPIC_TOPIC, BUILT_IN_TOPIC_TOPIC_TYPE, and ACE_OS::strcmp().

Referenced by DCPS_IR_Domain::add_topic(), DCPS_IR_Domain::force_add_topic(), OpenDDS::DCPS::ReplayerImpl::init(), OpenDDS::DCPS::RecorderImpl::init(), OpenDDS::DCPS::DataWriterImpl::init(), DCPS_IR_Domain::publish_subscription_bit(), and DCPS_IR_Domain::publish_topic_bit().

00041 {
00042     return (
00043       !ACE_OS::strcmp(name, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC) &&
00044       !ACE_OS::strcmp(type, OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE)
00045     ) || (
00046       !ACE_OS::strcmp(name, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC) &&
00047       !ACE_OS::strcmp(type, OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE)
00048     ) || (
00049       !ACE_OS::strcmp(name, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC) &&
00050       !ACE_OS::strcmp(type, OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE)
00051     ) || (
00052       !ACE_OS::strcmp(name, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC) &&
00053       !ACE_OS::strcmp(type, OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE)
00054     );
00055 }

Here is the call graph for this function:

Here is the caller graph for this function:

OPENDDS_STRING OpenDDS::DCPS::toString ( yard::TreeBuildingParser< char >::Node * iter ) [inline]

Definition at line 42 of file AstNodeWrapper.h.

References OPENDDS_STRING.

Referenced by OpenDDS::DCPS::FilterEvaluator::FilterEvaluator(), OpenDDS::Security::Permissions::load(), OpenDDS::DCPS::MultiTopicImpl::MultiTopicImpl(), and OpenDDS::DCPS::FilterEvaluator::walkOperand().

00043 {
00044   return iter ? OPENDDS_STRING(iter->GetFirstToken(), iter->GetLastToken()) : "";
00045 }

Here is the caller graph for this function:

static const ACE_UINT32 OpenDDS::DCPS::TRANSPORT_HDR_SERIALIZED_SZ ( 28 ) [static]

template<typename Container >

int OpenDDS::DCPS::unbind	(	Container &	c,
		const typename Container::key_type &	k
	)			`[inline]`

Definition at line 60 of file Util.h.

References unbind().

00063 {
00064   typename Container::mapped_type v;
00065   return unbind(c, k, v);
00066 }

Here is the call graph for this function:

template<typename Container >

int OpenDDS::DCPS::unbind	(	Container &	c,
		const typename Container::key_type &	k,
		typename Container::mapped_type &	v
	)			`[inline]`

Definition at line 38 of file Util.h.

Referenced by OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), OpenDDS::DCPS::ReceiveListenerSetMap::release_subscriber(), OpenDDS::DCPS::ReceiveListenerSetMap::remove(), OpenDDS::DCPS::ReceiveListenerSet::remove(), OpenDDS::DCPS::ReceiveListenerSet::remove_all(), OpenDDS::DCPS::DataLinkSet::remove_link(), OpenDDS::DCPS::ReceiveListenerSetMap::remove_set(), unbind(), OpenDDS::DCPS::WriteDataContainer::unregister_all(), and OpenDDS::DCPS::OwnershipManager::unregister_reader().

00042 {
00043   typename Container::const_iterator iter = c.find(k);
00044 
00045   if (iter != c.end()) {
00046     v = iter->second;
00047 
00048     if (c.erase(k) == 1) {
00049       return 0;
00050     }
00051 
00052     return -1;
00053   }
00054 
00055   return -1;
00056 }

Here is the caller graph for this function:

template<typename T >

T& OpenDDS::DCPS::unwrap_reference ( reference_wrapper< T > const & t ) [inline]

Definition at line 250 of file RcHandle_T.h.

References OpenDDS::DCPS::reference_wrapper< T >::get().

00251 {
00252   return t.get();
00253 }

Here is the call graph for this function:

template<typename T >

T const& OpenDDS::DCPS::unwrap_reference ( T const & t ) [inline]

Definition at line 244 of file RcHandle_T.h.

Referenced by make_rch().

00245 {
00246   return t;
00247 }

Here is the caller graph for this function:

ACE_INLINE bool OpenDDS::DCPS::valid_duration ( DDS::Duration_t const & t )

Validate DDS::Duration_t value (infinite or positive and non-zero).

Definition at line 208 of file Time_Helper.inl.

References DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, DDS::Duration_t::nanosec, and DDS::Duration_t::sec.

Referenced by non_negative_duration(), and OpenDDS::DCPS::Qos_Helper::valid().

00209 {
00210   DDS::Duration_t const DDS_DURATION_INFINITY = {
00211     DDS::DURATION_INFINITE_SEC,
00212     DDS::DURATION_INFINITE_NSEC
00213   };
00214 
00215   // Only accept infinite or positive finite durations.  (Zero
00216   // excluded).
00217   //
00218   // Note that it doesn't make much sense for users to set
00219   // durations less than 10 milliseconds since the underlying
00220   // timer resolution is generally no better than that.
00221   return
00222     t == DDS_DURATION_INFINITY
00223     || t.sec > 0
00224     || (t.sec >= 0 && t.nanosec > 0);
00225 }

Here is the caller graph for this function:

Variable Documentation

const DDS::StatusMask OpenDDS::DCPS::ALL_STATUS_MASK = 0xffffffff

Definition at line 319 of file DdsDcpsInfrastructure.idl.

Referenced by OpenDDS::DCPS::MultiTopicDataReaderBase::init().

const int OpenDDS::DCPS::BIT_LOOKUP_DURATION_MSEC = 2000

Definition at line 106 of file Service_Participant.cpp.

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC = "DCPSParticipant"

Definition at line 16 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::LocalParticipant< Sedp >::bit_key_to_repo_id(), OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::DomainParticipantImpl::get_discovered_participant_data(), OpenDDS::DCPS::DataReaderImpl::init(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), OpenDDS::RTPS::Spdp::part_bit(), OpenDDS::DCPS::LocalParticipant< Sedp >::part_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC_TYPE = "PARTICIPANT_BUILT_IN_TOPIC_TYPE"

Definition at line 17 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), DCPS_IR_Domain::publish_publication_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC = "DCPSPublication"

Definition at line 25 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::bit_key_to_repo_id(), OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::DataReaderImpl::get_matched_publication_data(), OpenDDS::DCPS::DataReaderImpl::init(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), OpenDDS::DCPS::BitPubListenerImpl::on_data_available(), OpenDDS::DCPS::DomainParticipantImpl::ownership_manager(), OpenDDS::DCPS::StaticEndpointManager::pub_bit(), OpenDDS::RTPS::Sedp::pub_bit(), OpenDDS::DCPS::RecorderImpl::repoid_to_bit_key(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC_TYPE = "PUBLICATION_BUILT_IN_TOPIC_TYPE"

Definition at line 26 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), DCPS_IR_Domain::publish_publication_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC = "DCPSSubscription"

Definition at line 22 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::bit_key_to_repo_id(), OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::DataWriterImpl::get_matched_subscription_data(), OpenDDS::DCPS::DataReaderImpl::init(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), OpenDDS::DCPS::StaticEndpointManager::sub_bit(), OpenDDS::RTPS::Sedp::sub_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC_TYPE = "SUBSCRIPTION_BUILT_IN_TOPIC_TYPE"

Definition at line 23 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), DCPS_IR_Domain::publish_publication_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC = "DCPSTopic"

Definition at line 19 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::DomainParticipantImpl::get_discovered_topic_data(), OpenDDS::DCPS::DataReaderImpl::init(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), OpenDDS::RTPS::Sedp::topic_bit(), and topicIsBIT().

OpenDDS_Dcps_Export const char *const OpenDDS::DCPS::BUILT_IN_TOPIC_TOPIC_TYPE = "TOPIC_BUILT_IN_TOPIC_TYPE"

Definition at line 20 of file BuiltInTopicUtils.cpp.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), DCPS_IR_Domain::publish_publication_bit(), and topicIsBIT().

const ACE_TCHAR OpenDDS::DCPS::COMMON_SECTION_NAME[] = ACE_TEXT("common") [static]

Definition at line 114 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration().

ACE_TString OpenDDS::DCPS::config_fname(ACE_TEXT("")) [static]

Referenced by OpenDDS::DCPS::Service_Participant::get_domain_participant_factory(), OpenDDS::DCPS::Service_Participant::load_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

const ACE_TCHAR OpenDDS::DCPS::CONFIG_SECTION_NAME[] = ACE_TEXT("config") [static]

Definition at line 172 of file TransportDefs.h.

Referenced by OpenDDS::DCPS::TransportRegistry::load_transport_configuration().

const string OpenDDS::DCPS::DATA_READER_MONITOR_TOPIC = "Data Reader Monitor"

Definition at line 19 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const string OpenDDS::DCPS::DATA_READER_PERIODIC_MONITOR_TOPIC = "Data Reader Periodic Monitor"

Definition at line 20 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const string OpenDDS::DCPS::DATA_WRITER_MONITOR_TOPIC = "Data Writer Monitor"

Definition at line 17 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const string OpenDDS::DCPS::DATA_WRITER_PERIODIC_MONITOR_TOPIC = "Data Writer Periodic Monitor"

Definition at line 18 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS_Dcps_Export unsigned int OpenDDS::DCPS::DCPS_debug_level = 0

Logging verbosity level. set by Service_Participant value guidelines: 1 - logs that should happen once per process or are warnings 2 - logs that should happen once per DDS entity 4 - logs that are related to administrative interfaces 6 - logs that should happen every Nth sample write/read 8 - logs that should happen once per sample write/read 10 - logs that may happen more than once per sample write/read

Definition at line 14 of file debug.cpp.

const size_t OpenDDS::DCPS::DEFAULT_CHUNK_MULTIPLIER = 10

Definition at line 99 of file Service_Participant.cpp.

const int OpenDDS::DCPS::DEFAULT_FEDERATION_BACKOFF_MULTIPLIER = 2

Definition at line 103 of file Service_Participant.cpp.

const int OpenDDS::DCPS::DEFAULT_FEDERATION_INITIAL_BACKOFF_SECONDS = 1

Definition at line 102 of file Service_Participant.cpp.

const int OpenDDS::DCPS::DEFAULT_FEDERATION_LIVELINESS = 60

Definition at line 104 of file Service_Participant.cpp.

const int OpenDDS::DCPS::DEFAULT_FEDERATION_RECOVERY_DURATION = 900

Definition at line 101 of file Service_Participant.cpp.

const size_t OpenDDS::DCPS::DEFAULT_NUM_CHUNKS = 20

Definition at line 97 of file Service_Participant.cpp.

const char OpenDDS::DCPS::DEFAULT_ORB_NAME[] = "OpenDDS_DCPS"

Definition at line 47 of file Service_Participant.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info().

const ACE_CString OpenDDS::DCPS::DEFAULT_PERSISTENT_DATA_DIR = "OpenDDS-durable-data-dir" [static]

Definition at line 112 of file Service_Participant.cpp.

const ACE_TCHAR OpenDDS::DCPS::DEFAULT_REPO_IOR[] = ACE_TEXT("file://repo.ior") [static]

Definition at line 110 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::get_discovery().

const DDS::StatusMask OpenDDS::DCPS::DEFAULT_STATUS_MASK = ALL_STATUS_MASK

Definition at line 321 of file DdsDcpsInfrastructure.idl.

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics(), OpenDDS::DCPS::MonitorFactoryImpl::create_data_writer(), OpenDDS::DCPS::DomainParticipantImpl::find_topic(), OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::DCPS::PeerDiscovery< Spdp >::init_bit(), DCPS_IR_Domain::init_built_in_topics_topics(), DCPS_IR_Domain::init_built_in_topics_transport(), OpenDDS::DCPS::MonitorFactoryImpl::initialize(), and OpenDDS::Federator::ManagerImpl::initialize().

const string OpenDDS::DCPS::DOMAIN_PARTICIPANT_MONITOR_TOPIC = "Domain Participant Monitor"

Definition at line 13 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const ACE_TCHAR OpenDDS::DCPS::DOMAIN_SECTION_NAME[] = ACE_TEXT("domain") [static]

Definition at line 115 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_domain_configuration().

const EntityId_t OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_READER = { {0x00,0x02,0x00}, 0xc7}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 49 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Sedp::Task::svc_i().

const EntityId_t OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER = { {0x00,0x02,0x00}, 0xc2}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 48 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), and OpenDDS::RTPS::Sedp::disassociate().

const EntityId_t OpenDDS::DCPS::ENTITYID_PARTICIPANT = { {0x00,0x00,0x01}, 0xc1}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 39 of file GuidUtils.h.

Referenced by OpenDDS::DCPS::StaticDiscovery::add_domain_participant(), OpenDDS::RTPS::RtpsDiscovery::add_domain_participant(), OpenDDS::DCPS::LocalParticipant< Sedp >::bit_key_to_repo_id(), OpenDDS::RTPS::Sedp::data_received(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::RtpsDiscovery::generate_participant_guid(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::RTPS::Spdp::handle_participant_data(), OpenDDS::RTPS::Sedp::is_opendds(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::match(), OpenDDS::DCPS::RepoIdGenerator::next(), and OpenDDS::RTPS::Sedp::Task::svc_i().

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_READER = { {0x00,0x00,0x03}, 0xc7}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 43 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Sedp::Task::svc_i().

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER = { {0x00,0x00,0x03}, 0xc2}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 42 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), and OpenDDS::RTPS::Sedp::disassociate().

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_READER = { {0x00,0x00,0x04}, 0xc7}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 45 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Sedp::Task::svc_i().

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER = { {0x00,0x00,0x04}, 0xc2}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 44 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), and OpenDDS::RTPS::Sedp::disassociate().

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_TOPIC_READER = { {0x00,0x00,0x02}, 0xc7}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 41 of file GuidUtils.h.

const EntityId_t OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_TOPIC_WRITER = { {0x00,0x00,0x02}, 0xc2}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 40 of file GuidUtils.h.

const EntityId_t OpenDDS::DCPS::ENTITYID_SPDP_BUILTIN_PARTICIPANT_READER = { {0x00,0x01,0x00}, 0xc7}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 47 of file GuidUtils.h.

const EntityId_t OpenDDS::DCPS::ENTITYID_SPDP_BUILTIN_PARTICIPANT_WRITER = { {0x00,0x01,0x00}, 0xc2}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 46 of file GuidUtils.h.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), and OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport().

const EntityId_t OpenDDS::DCPS::ENTITYID_UNKNOWN = { {0x00,0x00,0x00}, 0x00}

Entity Id values specified in Version 2.1 of RTPS specification.

Definition at line 38 of file GuidUtils.h.

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_PARTICIPANT = 0xc1

Definition at line 31 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_READER_NO_KEY = 0xc4

Definition at line 34 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_READER_WITH_KEY = 0xc7

Definition at line 35 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), and OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_TOPIC = 0xc5

Definition at line 36 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), and OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_UNKNOWN = 0xc0

Definition at line 30 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_WRITER_NO_KEY = 0xc3

Definition at line 33 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_BUILTIN_WRITER_WITH_KEY = 0xc2

Definition at line 32 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), and OpenDDS::DCPS::GuidConverter::isBuiltinDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_OPENDDS_NIL_WRITER = 0x4e

Definition at line 52 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::DataReaderImpl::accept_sample_processing(), and OpenDDS::DCPS::GuidConverter::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_OPENDDS_PUBLISHER = 0x42

Definition at line 46 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidBuilder::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_OPENDDS_SUBSCRIBER = 0x41

Definition at line 45 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidBuilder::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_OPENDDS_TOPIC = 0x45

Definition at line 48 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), OpenDDS::DCPS::GuidConverter::isUserDomainEntity(), and OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::make_topic_guid().

const octet OpenDDS::DCPS::ENTITYKIND_OPENDDS_USER = 0x4a

Definition at line 49 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidBuilder::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_USER_READER_NO_KEY = 0x04

Definition at line 41 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_subscription_key(), OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidConverter::isUserDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_USER_READER_WITH_KEY = 0x07

Definition at line 42 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::StaticEndpointManager::assign_subscription_key(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_subscription_key(), OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), OpenDDS::DCPS::GuidConverter::isUserDomainEntity(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), and OpenDDS::DCPS::StaticDiscovery::pre_reader().

const octet OpenDDS::DCPS::ENTITYKIND_USER_UNKNOWN = 0x00

Definition at line 38 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidBuilder::entityKind().

const octet OpenDDS::DCPS::ENTITYKIND_USER_WRITER_NO_KEY = 0x03

Definition at line 40 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_publication_key(), OpenDDS::DCPS::GuidConverter::entityKind(), and OpenDDS::DCPS::GuidConverter::isUserDomainEntity().

const octet OpenDDS::DCPS::ENTITYKIND_USER_WRITER_WITH_KEY = 0x02

Definition at line 39 of file DdsDcpsGuid.idl.

Referenced by OpenDDS::DCPS::StaticEndpointManager::assign_publication_key(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::assign_publication_key(), OpenDDS::DCPS::GuidConverter::entityKind(), OpenDDS::DCPS::GuidBuilder::entityKind(), OpenDDS::DCPS::GuidConverter::isUserDomainEntity(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), and OpenDDS::DCPS::StaticDiscovery::pre_writer().

bool OpenDDS::DCPS::got_bidir_giop = false [static]

Definition at line 152 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_bit_flag = false [static]

Definition at line 129 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_bit_lookup_duration_msec = false [static]

Definition at line 127 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::bit_lookup_duration_msec(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_bit_transport_ip = false [static]

Definition at line 126 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_bit_transport_port = false [static]

Definition at line 125 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::bit_transport_port(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_chunk_association_multiplier = false [static]

Definition at line 123 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::association_chunk_multiplier(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_chunks = false [static]

Definition at line 122 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), OpenDDS::DCPS::Service_Participant::n_chunks(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_debug_level = false [static]

Definition at line 119 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_default_address = false [static]

Definition at line 151 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_default_discovery = false [static]

Definition at line 141 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_global_transport_config = false [static]

Definition at line 128 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_info = false [static]

Definition at line 121 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), OpenDDS::DCPS::Service_Participant::parse_args(), and OpenDDS::DCPS::Service_Participant::set_repo_ior().

bool OpenDDS::DCPS::got_liveliness_factor = false [static]

Definition at line 124 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::liveliness_factor(), OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_log_fname = false [static]

Definition at line 149 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_log_verbose = false [static]

Definition at line 150 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_monitor = false [static]

Definition at line 153 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_pending_timeout = false [static]

Definition at line 137 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_persistent_data_dir = false [static]

Definition at line 139 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_publisher_content_filter = false [static]

Definition at line 135 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_transport_debug_level = false [static]

Definition at line 136 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

bool OpenDDS::DCPS::got_use_rti_serialization = false [static]

Definition at line 120 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::Service_Participant::load_common_configuration(), and OpenDDS::DCPS::Service_Participant::parse_args().

const GUID_t OpenDDS::DCPS::GUID_UNKNOWN = { { 0 }, { { 0 }, 0 } }

Nil value for GUID.

Definition at line 53 of file GuidUtils.h.

const GuidPrefix_t OpenDDS::DCPS::GUIDPREFIX_UNKNOWN = { 0 }

Nil value for the GUID prefix (participant identifier).

Definition at line 34 of file GuidUtils.h.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages().

InfoRepoDiscovery::StaticInitializer OpenDDS::DCPS::initialize_inforepodisco [static]

Definition at line 287 of file InfoRepoDiscovery.h.

int const OpenDDS::DCPS::INVALID_ENUM_VALUE = 999

Definition at line 17 of file Marked_Default_Qos.cpp.

Referenced by OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataReader_Use_TopicQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataReaderQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataWriter_Use_TopicQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_DataWriterQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_PublisherQos(), OpenDDS::DCPS::Marked_Default_Qos::marked_default_SubscriberQos(), and OpenDDS::DCPS::Marked_Default_Qos::marked_default_TopicQos().

const CORBA::ULong OpenDDS::DCPS::MAX_READERS_PER_ELEM = 5

Definition at line 25 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::DataSampleElement::DataSampleElement().

const int OpenDDS::DCPS::MAX_READERS_TO_RESEND = 5

Definition at line 29 of file SendStateDataSampleList.h.

const long OpenDDS::DCPS::MONITOR_DOMAIN_ID = -999

Definition at line 10 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::create_dp_monitor(), and OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const long OpenDDS::DCPS::MONITOR_TRANSPORT_ID = 999

Definition at line 11 of file monitor.idl.

MulticastInitializer OpenDDS::DCPS::multicast_init [static]

Definition at line 24 of file Multicast.h.

const DDS::StatusMask OpenDDS::DCPS::NO_STATUS_MASK = 0x00000000

Definition at line 320 of file DdsDcpsInfrastructure.idl.

Referenced by OpenDDS::DCPS::DataWriterImpl::cleanup(), and OpenDDS::DCPS::DataReaderImpl::cleanup().

int OpenDDS::DCPS::OpenDDS_Requires_MonitorFactory_Initializer [static]

Initial value:

  MonitorFactory::service_initialize()

Definition at line 94 of file MonitorFactory.h.

int OpenDDS::DCPS::OpenDDS_Requires_MonitorFactoryImpl_Initializer [static]

Initial value:

  MonitorFactoryImpl::service_initialize()

Definition at line 94 of file MonitorFactoryImpl.h.

const string OpenDDS::DCPS::PUBLISHER_MONITOR_TOPIC = "Publisher Monitor"

Definition at line 15 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const ACE_TCHAR OpenDDS::DCPS::REPO_SECTION_NAME[] = ACE_TEXT("repository") [static]

Definition at line 116 of file Service_Participant.cpp.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::load_configuration(), and OpenDDS::DCPS::Service_Participant::set_repo_ior().

const ACE_TCHAR OpenDDS::DCPS::RTPS_SECTION_NAME[] = ACE_TEXT("rtps_discovery") [static]

Definition at line 117 of file Service_Participant.cpp.

Referenced by OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config(), OpenDDS::DCPS::Service_Participant::get_discovery(), and OpenDDS::DCPS::Service_Participant::load_configuration().

RtpsUdpInitializer OpenDDS::DCPS::rtps_udp_init [static]

Definition at line 24 of file RtpsUdp.h.

const string OpenDDS::DCPS::SERVICE_PARTICIPANT_MONITOR_TOPIC = "Service Participant Monitor"

Definition at line 12 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

ShmemInitializer OpenDDS::DCPS::shmem_init [static]

Definition at line 24 of file Shmem.h.

const string OpenDDS::DCPS::SUBSCRIBER_MONITOR_TOPIC = "Subscriber Monitor"

Definition at line 16 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

Tcp_Initializer OpenDDS::DCPS::tcp_initializer [static]

Definition at line 33 of file Tcp.h.

const string OpenDDS::DCPS::TOPIC_MONITOR_TOPIC = "Topic Monitor"

Definition at line 14 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

OpenDDS_Dcps_Export unsigned int OpenDDS::DCPS::Transport_debug_level = 0

Transport Logging verbosity level.

Definition at line 12 of file TransportDebug.cpp.

const string OpenDDS::DCPS::TRANSPORT_MONITOR_TOPIC = "Transport Monitor"

Definition at line 21 of file monitor.idl.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::initialize().

const ACE_TCHAR OpenDDS::DCPS::TRANSPORT_SECTION_NAME[] = ACE_TEXT("transport") [static]

Definition at line 171 of file TransportDefs.h.

Referenced by OpenDDS::DCPS::TransportRegistry::load_transport_configuration().

UdpInitializer OpenDDS::DCPS::udp_init [static]

Definition at line 24 of file Udp.h.

const GuidVendorId_t OpenDDS::DCPS::VENDORID_OCI = { 0x01, 0x03 }

Vendor Id value specified for OCI is used for OpenDDS.

Definition at line 31 of file GuidUtils.h.

Referenced by OpenDDS::DCPS::EndpointRegistry::build_id(), OpenDDS::DCPS::GuidBuilder::create(), OpenDDS::RTPS::Spdp::is_opendds(), OpenDDS::DCPS::EndpointManager< Security::SPDPdiscoveredParticipantData >::is_opendds(), and OpenDDS::RTPS::GuidGenerator::populate().

OpenDDS::DCPS Namespace Reference

Namespaces

Classes

Typedefs

Enumerations

Functions

Variables

Typedef Documentation

Enumeration Type Documentation

Function Documentation

Variable Documentation