<<interface>> Container for all DDSDomainEntity objects. More...

Inheritance diagram for DDSDomainParticipant:

Public Member Functions
virtual DDS_ReturnCode_t	get_default_datawriter_qos (DDS_DataWriterQos &qos)=0
	<<eXtension>> Copy the default DDS_DataWriterQos values into the provided DDS_DataWriterQos instance.

virtual DDS_ReturnCode_t	set_default_datawriter_qos (const DDS_DataWriterQos &qos)=0
	<<eXtension>> Set the default DataWriterQos values for this DomainParticipant.

virtual DDS_ReturnCode_t	set_default_datawriter_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Set the default DDS_DataWriterQos values for this domain participant based on the input XML QoS profile.

virtual DDS_ReturnCode_t	get_default_datareader_qos (DDS_DataReaderQos &qos)=0
	<<eXtension>> Copy the default DDS_DataReaderQos values into the provided DDS_DataReaderQos instance.

virtual DDS_ReturnCode_t	set_default_datareader_qos (const DDS_DataReaderQos &qos)=0
	<<eXtension>> Set the default DDS_DataReaderQos values for this domain participant.

virtual DDS_ReturnCode_t	set_default_datareader_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Set the default DDS_DataReaderQos values for this DomainParticipant based on the input XML QoS profile.

virtual DDS_ReturnCode_t	get_default_flowcontroller_property (DDS_FlowControllerProperty_t &prop)=0
	<<eXtension>> Copies the default DDS_FlowControllerProperty_t values for this domain participant into the given DDS_FlowControllerProperty_t instance.

virtual DDS_ReturnCode_t	set_default_flowcontroller_property (const DDS_FlowControllerProperty_t &prop)=0
	<<eXtension>> Set the default DDS_FlowControllerProperty_t values for this domain participant.

virtual DDS_ReturnCode_t	register_contentfilter (const char filter_name, const DDSContentFilter contentfilter)=0
	<<eXtension>> Register a content filter which can be used to create a DDSContentFilteredTopic.

virtual DDSContentFilter *	lookup_contentfilter (const char *filter_name)=0
	<<eXtension>> Lookup a content filter previously registered with DDSDomainParticipant::register_contentfilter.

virtual DDS_ReturnCode_t	unregister_contentfilter (const char *filter_name)=0
	<<eXtension>> Unregister a content filter previously registered with DDSDomainParticipant::register_contentfilter.

virtual const char *	get_default_library ()=0
	<<eXtension>> Gets the default XML library associated with a DDSDomainParticipant.

virtual const char *	get_default_profile ()=0
	<<eXtension>> Gets the default XML profile associated with a DDSDomainParticipant.

virtual const char *	get_default_profile_library ()=0
	<<eXtension>> Gets the library where the default XML QoS profile is contained for a DDSDomainParticipant.

virtual DDS_ReturnCode_t	set_default_library (const char *library_name)=0
	<<eXtension>> Sets the default XML library for a DDSDomainParticipant.

virtual DDS_ReturnCode_t	set_default_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Sets the default XML profile for a DDSDomainParticipant.

virtual DDS_ReturnCode_t	get_default_topic_qos (DDS_TopicQos &qos)=0
	Copies the default DDS_TopicQos values for this domain participant into the given DDS_TopicQos instance.

virtual DDS_ReturnCode_t	set_default_topic_qos (const DDS_TopicQos &qos)=0
	Set the default DDS_TopicQos values for this domain participant.

virtual DDS_ReturnCode_t	set_default_topic_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Set the default DDS_TopicQos values for this domain participant based on the input XML QoS profile.

virtual DDS_ReturnCode_t	get_default_publisher_qos (DDS_PublisherQos &qos)=0
	Copy the default DDS_PublisherQos values into the provided DDS_PublisherQos instance.

virtual DDS_ReturnCode_t	set_default_publisher_qos (const DDS_PublisherQos &qos)=0
	Set the default DDS_PublisherQos values for this DomainParticipant.

virtual DDS_ReturnCode_t	set_default_publisher_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Set the default DDS_PublisherQos values for this DomainParticipant based on the input XML QoS profile.

virtual DDS_ReturnCode_t	get_default_subscriber_qos (DDS_SubscriberQos &qos)=0
	Copy the default DDS_SubscriberQos values into the provided DDS_SubscriberQos instance.

virtual DDS_ReturnCode_t	set_default_subscriber_qos (const DDS_SubscriberQos &qos)=0
	Set the default DDS_SubscriberQos values for this Domain{articipant.

virtual DDS_ReturnCode_t	set_default_subscriber_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Set the default DDS_SubscriberQos values for this DomainParticipant based on the input XML QoS profile.

virtual DDSPublisher *	create_publisher (const DDS_PublisherQos &qos, DDSPublisherListener *listener, DDS_StatusMask mask)=0
	Creates a DDSPublisher with the desired QoS policies and attaches to it the specified DDSPublisherListener.

virtual DDSPublisher *	create_publisher_with_profile (const char library_name, const char profile_name, DDSPublisherListener *listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a new DDSPublisher object using the DDS_PublisherQos associated with the input XML QoS profile.

virtual DDS_ReturnCode_t	delete_publisher (DDSPublisher *p)=0
	Deletes an existing DDSPublisher.

virtual DDSSubscriber *	create_subscriber (const DDS_SubscriberQos &qos, DDSSubscriberListener *listener, DDS_StatusMask mask)=0
	Creates a DDSSubscriber with the desired QoS policies and attaches to it the specified DDSSubscriberListener.

virtual DDSSubscriber *	create_subscriber_with_profile (const char library_name, const char profile_name, DDSSubscriberListener *listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a new DDSSubscriber object using the DDS_PublisherQos associated with the input XML QoS profile.

virtual DDS_ReturnCode_t	delete_subscriber (DDSSubscriber *s)=0
	Deletes an existing DDSSubscriber.

virtual DDS_ReturnCode_t	get_publishers (DDSPublisherSeq &publishers)=0
	<<eXtension>> Allows the application to access all the publishers the participant has.

virtual DDS_ReturnCode_t	get_subscribers (DDSSubscriberSeq &subscribers)=0
	<<eXtension>> Allows the application to access all the subscribers the participant has.

virtual DDSTopic *	create_topic (const char topic_name, const char type_name, const DDS_TopicQos &qos, DDSTopicListener *listener, DDS_StatusMask mask)=0
	Creates a DDSTopic with the desired QoS policies and attaches to it the specified DDSTopicListener.

virtual DDSTopic *	create_topic_with_profile (const char topic_name, const char type_name, const char library_name, const char profile_name, DDSTopicListener *listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a new DDSTopic object using the DDS_PublisherQos associated with the input XML QoS profile.

virtual DDS_ReturnCode_t	delete_topic (DDSTopic *topic)=0
	Deletes a DDSTopic.

virtual DDSContentFilteredTopic *	create_contentfilteredtopic (const char name, DDSTopic related_topic, const char *filter_expression, const DDS_StringSeq &expression_parameters)=0
	Creates a DDSContentFilteredTopic, that can be used to do content-based subscriptions.

virtual DDSContentFilteredTopic *	create_contentfilteredtopic_with_filter (const char name, DDSTopic related_topic, const char filter_expression, const DDS_StringSeq &expression_parameters, const char filter_name=DDS_SQLFILTER_NAME)=0
	<<eXtension>> Creates a DDSContentFilteredTopic using the specified filter to do content-based subscriptions.

virtual DDS_ReturnCode_t	delete_contentfilteredtopic (DDSContentFilteredTopic *a_contentfilteredtopic)=0
	Deletes a DDSContentFilteredTopic.

virtual DDSMultiTopic *	create_multitopic (const char name, const char type_name, const char *subscription_expression, const DDS_StringSeq &expression_parameters)=0
	[Not supported (optional)] Creates a MultiTopic that can be used to subscribe to multiple topics and combine/filter the received data into a resulting type.

virtual DDS_ReturnCode_t	delete_multitopic (DDSMultiTopic *a_multitopic)=0
	[Not supported (optional)] Deletes a DDSMultiTopic.

virtual DDSTopic *	find_topic (const char *topic_name, const DDS_Duration_t &timeout)=0
	Finds an existing (or ready to exist) DDSTopic, based on its name.

virtual DDSTopicDescription *	lookup_topicdescription (const char *topic_name)=0
	Looks up an existing, locally created DDSTopicDescription, based on its name.

virtual DDSFlowController *	create_flowcontroller (const char *name, const DDS_FlowControllerProperty_t &prop)=0
	<<eXtension>> Creates a DDSFlowController with the desired property.

virtual DDS_ReturnCode_t	delete_flowcontroller (DDSFlowController *fc)=0
	<<eXtension>> Deletes an existing DDSFlowController.

virtual DDSFlowController *	lookup_flowcontroller (const char *name)=0
	<<eXtension>> Looks up an existing locally-created DDSFlowController, based on its name.

virtual DDSSubscriber *	get_builtin_subscriber ()=0
	Accesses the built-in DDSSubscriber.

virtual DDS_ReturnCode_t	ignore_participant (const DDS_InstanceHandle_t &handle)=0
	Instructs RTI Connext to locally ignore a remote DDSDomainParticipant.

virtual DDS_ReturnCode_t	ignore_topic (const DDS_InstanceHandle_t &handle)=0
	Instructs RTI Connext to locally ignore a DDSTopic.

virtual DDS_ReturnCode_t	ignore_publication (const DDS_InstanceHandle_t &handle)=0
	Instructs RTI Connext to locally ignore a publication.

virtual DDS_ReturnCode_t	ignore_subscription (const DDS_InstanceHandle_t &handle)=0
	Instructs RTI Connext to locally ignore a subscription.

virtual DDS_DomainId_t	get_domain_id ()=0
	Get the unique domain identifier.

virtual DDS_ReturnCode_t	get_current_time (DDS_Time_t &current_time)=0
	Returns the current value of the time.

virtual DDS_ReturnCode_t	register_durable_subscription (DDS_EndpointGroup_t &group, const char *topic_name)=0
	Registers a Durable Subscription on the specified DDSTopic on all Persistence Services.

virtual DDS_ReturnCode_t	delete_durable_subscription (DDS_EndpointGroup_t &group)=0
	Deletes an existing Durable Subscription on all Persistence Services.

virtual DDS_ReturnCode_t	assert_liveliness ()=0
	Manually asserts the liveliness of this DDSDomainParticipant.

virtual DDS_ReturnCode_t	delete_contained_entities ()=0
	Delete all the entities that were created by means of the "create" operations on the DDSDomainParticipant.

virtual DDS_ReturnCode_t	get_discovered_participants (DDS_InstanceHandleSeq &participant_handles)=0
	Returns a list of discovered DDSDomainParticipant entities.

virtual DDS_ReturnCode_t	get_discovered_participant_data (struct DDS_ParticipantBuiltinTopicData &participant_data, const DDS_InstanceHandle_t &participant_handle)=0
	Returns DDS_ParticipantBuiltinTopicData for the specified DDSDomainParticipant.

virtual DDS_ReturnCode_t	get_discovered_topics (DDS_InstanceHandleSeq &topic_handles)=0
	Returns list of discovered DDSTopic objects.

virtual DDS_ReturnCode_t	get_discovered_topic_data (struct DDS_TopicBuiltinTopicData &topic_data, const DDS_InstanceHandle_t &topic_handle)=0
	Returns DDS_TopicBuiltinTopicData for the specified DDSTopic.

virtual DDS_Boolean	contains_entity (const DDS_InstanceHandle_t &a_handle)=0
	Completes successfully with DDS_BOOLEAN_TRUE if the referenced DDSEntity is contained by the DDSDomainParticipant.

virtual DDS_ReturnCode_t	set_qos (const DDS_DomainParticipantQos &qos)=0
	Change the QoS of this DomainParticipant.

virtual DDS_ReturnCode_t	set_qos_with_profile (const char library_name, const char profile_name)=0
	<<eXtension>> Change the QoS of this domain participant using the input XML QoS profile.

virtual DDS_ReturnCode_t	get_qos (DDS_DomainParticipantQos &qos)=0
	Get the participant QoS.

virtual DDS_ReturnCode_t	add_peer (const char *peer_desc_string)=0
	<<eXtension>> Attempt to contact one or more additional peer participants.

virtual DDS_ReturnCode_t	remove_peer (const char *peer_desc_string)=0
	<<eXtension>> Remove one or more peer participants from the list of peers with which this DDSDomainParticipant will try to communicate.

virtual DDS_ReturnCode_t	set_listener (DDSDomainParticipantListener *l, DDS_StatusMask mask=DDS_STATUS_MASK_ALL)=0
	Sets the participant listener.

virtual DDSDomainParticipantListener *	get_listener ()=0
	Get the participant listener.

virtual DDSPublisher *	get_implicit_publisher ()=0
	<<eXtension>> Returns the implicit DDSPublisher. If an implicit Publisher does not already exist, this creates one.

virtual DDSSubscriber *	get_implicit_subscriber ()=0
	<<eXtension>> Returns the implicit DDSSubscriber. If an implicit Subscriber does not already exist, this creates one.

virtual DDSDataWriter *	create_datawriter (DDSTopic topic, const DDS_DataWriterQos &qos, DDSDataWriterListener listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a DDSDataWriter that will be attached and belong to the implicit DDSPublisher.

virtual DDSDataWriter *	create_datawriter_with_profile (DDSTopic topic, const char library_name, const char profile_name, DDSDataWriterListener listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a DDSDataWriter using a XML QoS profile that will be attached and belong to the implicit DDSPublisher.

virtual DDS_ReturnCode_t	delete_datawriter (DDSDataWriter *a_datawriter)=0
	<<eXtension>> Deletes a DDSDataWriter that belongs to the implicit DDSPublisher.

virtual DDSDataReader *	create_datareader (DDSTopicDescription topic, const DDS_DataReaderQos &qos, DDSDataReaderListener listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a DDSDataReader that will be attached and belong to the implicit DDSSubscriber.

virtual DDSDataReader *	create_datareader_with_profile (DDSTopicDescription topic, const char library_name, const char profile_name, DDSDataReaderListener listener, DDS_StatusMask mask)=0
	<<eXtension>> Creates a DDSDataReader using a XML QoS profile that will be attached and belong to the implicit DDSSubscriber.

virtual DDS_ReturnCode_t	delete_datareader (DDSDataReader *a_datareader)=0
	<<eXtension>> Deletes a DDSDataReader that belongs to the implicit DDSSubscriber.

virtual DDSPublisher *	lookup_publisher_by_name (const char *publisher_name)=0
	st_ext Looks up a DDSPublisher by its entity name within this DDSDomainParticipant.

virtual DDSSubscriber *	lookup_subscriber_by_name (const char *subscriber_name)=0
	<<eXtension>> Retrieves a DDSSubscriber by its entity name within this DDSDomainParticipant.

virtual DDSDataWriter *	lookup_datawriter_by_name (const char *datawriter_full_name)=0
	<<eXtension>> Looks up a DDSDataWriter by its entity name within this DDSDomainParticipant.

virtual DDSDataReader *	lookup_datareader_by_name (const char *datareader_full_name)=0
	st_ext Retrieves up a DDSDataReader by its entity name in this DDSDomainParticipant.

Public Member Functions inherited from DDSEntity
virtual DDS_ReturnCode_t	enable ()=0
	Enables the DDSEntity.

virtual DDSStatusCondition *	get_statuscondition ()=0
	Allows access to the DDSStatusCondition associated with the DDSEntity.

virtual DDS_StatusMask	get_status_changes ()=0
	Retrieves the list of communication statuses in the DDSEntity that are triggered.

virtual DDS_InstanceHandle_t	get_instance_handle ()=0
	Allows access to the DDS_InstanceHandle_t associated with the DDSEntity.

Detailed Description

<<interface>> Container for all DDSDomainEntity objects.

The DomainParticipant object plays several roles:

- It acts as a container for all other DDSEntity objects.

- It acts as factory for the DDSPublisher, DDSSubscriber, DDSTopic and DDSMultiTopic DDSEntity objects.

- It represents the participation of the application on a communication plane that isolates applications running on the same set of physical computers from each other. A domain establishes a virtual network linking all applications that share the same domainId and isolating them from applications running on different domains. In this way, several independent distributed applications can coexist in the same physical network without interfering, or even being aware of each other.

- It provides administration services in the domain, offering operations that allow the application to ignore locally any information about a given participant (ignore_participant()), publication (ignore_publication()), subscription (ignore_subscription()) or topic (ignore_topic()).

The following operations may be called even if the DDSDomainParticipant is not enabled. (Operations NOT in this list will fail with the value DDS_RETCODE_NOT_ENABLED if called on a disabled DomainParticipant).

Operations defined at the base-class level: set_qos(), set_qos_with_profile(), get_qos(), set_listener(), get_listener(), enable();

Factory operations: create_flowcontroller(), create_topic(), create_topic_with_profile(), create_publisher(), create_publisher_with_profile(), create_subscriber(), create_subscriber_with_profile(), delete_flowcontroller(), delete_topic(), delete_publisher(), delete_subscriber(), set_default_flowcontroller_property(), get_default_flowcontroller_property(), set_default_topic_qos(), set_default_topic_qos_with_profile(), get_default_topic_qos(), set_default_publisher_qos(), set_default_publisher_qos_with_profile(), get_default_publisher_qos(), set_default_subscriber_qos(), set_default_subscriber_qos_with_profile(), get_default_subscriber_qos(), delete_contained_entities(), set_default_datareader_qos(), set_default_datareader_qos_with_profile(), get_default_datareader_qos(), set_default_datawriter_qos(), set_default_datawriter_qos_with_profile(), get_default_datawriter_qos(), set_default_library(), set_default_profile();

Operations for looking up topics: lookup_topicdescription();

Operations that access status: get_statuscondition(), get_status_changes().

QoS:: DDS_DomainParticipantQos

Status:: Status Kinds

Listener:: DDSDomainParticipantListener

See Also: Operations Allowed in Listener Callbacks

Examples:: HelloWorld_publisher.cxx.

Member Function Documentation

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_datawriter_qos ( DDS_DataWriterQos & qos )

pure virtual

<<eXtension>> Copy the default DDS_DataWriterQos values into the provided DDS_DataWriterQos instance.

The retrieved qos will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_datawriter_qos, or DDSDomainParticipant::set_default_datawriter_qos_with_profile, or else, if the call was never made, the default values listed in DDS_DataWriterQos.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

MT Safety:: UNSAFE. It is not safe to retrieve the default DataWriter QoS from a DomainPartipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datawriter_qos.

Parameters

qos	<<inout>> Qos to be filled up.

Returns: One of the Standard Return Codes

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_datawriter_qos ( const DDS_DataWriterQos & qos )

pure virtual

<<eXtension>> Set the default DataWriterQos values for this DomainParticipant.

This set of default values will be inherited for a newly created DDSPublisher.

Precondition: The specified QoS policies must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default DataWriter QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datawriter_qos or DDSDomainParticipant::get_default_datawriter_qos.

Parameters

qos	<<in>> Default qos to be set. The special value DDS_DATAWRITER_QOS_DEFAULT may be passed as `qos` to indicate that the default QoS should be reset back to the initial values the factory would used if DDSDomainParticipant::set_default_datawriter_qos had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_datawriter_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Set the default DDS_DataWriterQos values for this domain participant based on the input XML QoS profile.

This set of default values will be inherited for a newly created DDSPublisher.

Precondition: The DDS_DataWriterQos contained in the specified XML QoS profile must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default DataWriter QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datawriter_qos or DDSDomainParticipant::get_default_datawriter_qos

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).

If the input profile cannot be found, the method fails with DDS_RETCODE_ERROR.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_datareader_qos ( DDS_DataReaderQos & qos )

pure virtual

<<eXtension>> Copy the default DDS_DataReaderQos values into the provided DDS_DataReaderQos instance.

The retrieved qos will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_datareader_qos, or DDSDomainParticipant::set_default_datareader_qos_with_profile, or else, if the call was never made, the default values listed in DDS_DataReaderQos.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

MT Safety:: UNSAFE. It is not safe to retrieve the default DataReader QoS from a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datareader_qos.

Parameters

qos	<<inout>> Qos to be filled up.

Returns: One of the Standard Return Codes

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_datareader_qos ( const DDS_DataReaderQos & qos )

pure virtual

<<eXtension>> Set the default DDS_DataReaderQos values for this domain participant.

This set of default values will be inherited for a newly created DDSSubscriber.

Precondition: The specified QoS policies must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default DataReader QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datareader_qos or DDSDomainParticipant::get_default_datareader_qos.

Parameters

qos	<<in>> Default qos to be set. The special value DDS_DATAREADER_QOS_DEFAULT may be passed as `qos` to indicate that the default QoS should be reset back to the initial values the factory would used if DDSDomainParticipant::set_default_datareader_qos had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_datareader_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Set the default DDS_DataReaderQos values for this DomainParticipant based on the input XML QoS profile.

This set of default values will be inherited for a newly created DDSSubscriber.

Precondition: The DDS_DataReaderQos contained in the specified XML QoS profile must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default DataReader QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_datareader_qos or DDSDomainParticipant::get_default_datareader_qos.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).

If the input profile cannot be found, the method fails with DDS_RETCODE_ERROR.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_flowcontroller_property ( DDS_FlowControllerProperty_t & prop )

pure virtual

<<eXtension>> Copies the default DDS_FlowControllerProperty_t values for this domain participant into the given DDS_FlowControllerProperty_t instance.

The retrieved property will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_flowcontroller_property, or else, if the call was never made, the default values listed in DDS_FlowControllerProperty_t.

MT Safety:: UNSAFE. It is not safe to retrieve the default flow controller properties from a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_flowcontroller_property

Parameters

prop	<<in>> Default property to be retrieved.

Returns: One of the Standard Return Codes

See Also: DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT; DDSDomainParticipant::create_flowcontroller

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_flowcontroller_property ( const DDS_FlowControllerProperty_t & prop )

pure virtual

<<eXtension>> Set the default DDS_FlowControllerProperty_t values for this domain participant.

This default value will be used for newly created DDSFlowController if DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT is specified as the property parameter when DDSDomainParticipant::create_flowcontroller is called.

Precondition: The specified property values must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default flow controller properties for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_flowcontroller_property , DDSDomainParticipant::get_default_flowcontroller_property or calling DDSDomainParticipant::create_flowcontroller with DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT as the qos parameter.

Parameters

prop <<in>> Default property to be set. The special value DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT may be passed as property to indicate that the default property should be reset to the default values the factory would use if DDSDomainParticipant::set_default_flowcontroller_property had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT; DDSDomainParticipant::create_flowcontroller

virtual DDS_ReturnCode_t DDSDomainParticipant::register_contentfilter	(	const char *	filter_name,
		const DDSContentFilter *	contentfilter
	)

pure virtual

<<eXtension>> Register a content filter which can be used to create a DDSContentFilteredTopic.

DDS specifies a SQL-like content filter for use by content filtered topics. If this filter does not meet your filtering requirements, you can register a custom filter.

To use a custom filter, it must be registered in the following places:

In any application that uses the custom filter to create a DDSContentFilteredTopic and the corresponding DDSDataReader.
In each application that writes the data to the applications mentioned above.

For example, suppose Application A on the subscription side creates a Topic named X and a ContentFilteredTopic named filteredX (and a corresponding DataReader), using a previously registered content filter, myFilter. With only that, you will have filtering at the subscription side. If you also want to perform filtering in any application that publishes Topic X, then you also need to register the same definition of the ContentFilter myFilter in that application.

Each filter_name can only be used to registered a content filter once with a DDSDomainParticipant.

Parameters

filter_name	<<in>> Name of the filter. The name must be unique within the DDSDomainParticipant and must not exceed 255 characters. Cannot be NULL.
contentfilter	<<in>> Content filter to be registered. Cannot be NULL.

Returns: One of the Standard Return Codes

See Also: DDSDomainParticipant::unregister_contentfilter

virtual DDSContentFilter* DDSDomainParticipant::lookup_contentfilter ( const char * filter_name )

pure virtual

<<eXtension>> Lookup a content filter previously registered with DDSDomainParticipant::register_contentfilter.

Parameters

filter_name <<in>> Name of the filter. Cannot be NULL.

Returns: NULL if the given filter_name has not been previously registered to the DDSDomainParticipant with DDSDomainParticipant::register_contentfilter. Otherwise, return the DDSContentFilter that has been previosuly registered with the given filter_name.

See Also: DDSDomainParticipant::register_contentfilter

virtual DDS_ReturnCode_t DDSDomainParticipant::unregister_contentfilter ( const char * filter_name )

pure virtual

<<eXtension>> Unregister a content filter previously registered with DDSDomainParticipant::register_contentfilter.

A filter_name can be unregistered only if it has been previously registered to the DDSDomainParticipant with DDSDomainParticipant::register_contentfilter.

The unregistration of filter is not allowed if there are any existing DDSContentFilteredTopic objects that are using the filter. If the operation is called on a filter with existing DDSContentFilteredTopic objects attached to it, this operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

If there are still existing discovered DDSDataReader s with the same filter_name and the filter's compile method of the filter have previously been called on the discovered DDSDataReader s, finalize method of the filter will be called on those discovered DDSDataReader s before the content filter is unregistered. This means filtering will now be performed on the application that is creating the DDSDataReader.

Parameters

filter_name <<in>> Name of the filter. Cannot be NULL.

Returns: One of the Standard Return Codes or DDS_RETCODE_PRECONDITION_NOT_MET

See Also: DDSDomainParticipant::register_contentfilter

virtual const char* DDSDomainParticipant::get_default_library ( )

pure virtual

<<eXtension>> Gets the default XML library associated with a DDSDomainParticipant.

Returns: The default library or null if the default library was not set.

See Also: DDSDomainParticipant::set_default_library

virtual const char* DDSDomainParticipant::get_default_profile ( )

pure virtual

<<eXtension>> Gets the default XML profile associated with a DDSDomainParticipant.

Returns: The default profile or null if the default profile was not set.

See Also: DDSDomainParticipant::set_default_profile

virtual const char* DDSDomainParticipant::get_default_profile_library ( )

pure virtual

<<eXtension>> Gets the library where the default XML QoS profile is contained for a DDSDomainParticipant.

The default profile library is automatically set when DDSDomainParticipant::set_default_profile is called.

This library can be different than the DDSDomainParticipant default library (see DDSDomainParticipant::get_default_library).

Returns: The default profile library or null if the default profile was not set.

See Also: DDSDomainParticipant::set_default_profile

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_library ( const char * library_name )

pure virtual

<<eXtension>> Sets the default XML library for a DDSDomainParticipant.

This method specifies the library that will be used as the default the next time a default library is needed during a call to one of this DomainParticipant's operations.

Any API requiring a library_name as a parameter can use null to refer to the default library.

If the default library is not set, the DDSDomainParticipant inherits the default from the DDSDomainParticipantFactory (see DDSDomainParticipantFactory::set_default_library).

Parameters

library_name <<in>> Library name. If library_name is null any previous default is unset.

Returns: One of the Standard Return Codes

See Also: DDSDomainParticipant::get_default_library

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Sets the default XML profile for a DDSDomainParticipant.

This method specifies the profile that will be used as the default the next time a default DomainParticipant profile is needed during a call to one of this DomainParticipant's operations. When calling a DDSDomainParticipant method that requires a profile_name parameter, you can use NULL to refer to the default profile. (This same information applies to setting a default library.)

If the default profile is not set, the DDSDomainParticipant inherits the default from the DDSDomainParticipantFactory (see DDSDomainParticipantFactory::set_default_profile).

This method does not set the default QoS for entities created by the DDSDomainParticipant; for this functionality, use the methods set_default_<entity>_qos_with_profile (you may pass in NULL after having called set_default_profile()).

This method does not set the default QoS for newly created DomainParticipants; for this functionality, use DDSDomainParticipantFactory::set_default_participant_qos_with_profile.

Parameters

library_name	<<in>> The library name containing the profile.
profile_name	<<in>> The profile name. If profile_name is null any previous default is unset.

Returns: One of the Standard Return Codes

See Also: DDSDomainParticipant::get_default_profile; DDSDomainParticipant::get_default_profile_library

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_topic_qos ( DDS_TopicQos & qos )

pure virtual

Copies the default DDS_TopicQos values for this domain participant into the given DDS_TopicQos instance.

The retrieved qos will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_topic_qos, or else, if the call was never made, the default values listed in DDS_TopicQos.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

MT Safety:: UNSAFE. It is not safe to retrieve the default Topic QoS from a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_topic_qos

Parameters

qos	<<in>> Default qos to be retrieved.

Returns: One of the Standard Return Codes

See Also: DDS_TOPIC_QOS_DEFAULT; DDSDomainParticipant::create_topic

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_topic_qos ( const DDS_TopicQos & qos )

pure virtual

Set the default DDS_TopicQos values for this domain participant.

This default value will be used for newly created DDSTopic if DDS_TOPIC_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_topic is called.

Precondition: The specified QoS policies must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default topic QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_topic_qos, DDSDomainParticipant::get_default_topic_qos or calling DDSDomainParticipant::create_topic with DDS_TOPIC_QOS_DEFAULT as the qos parameter.

Parameters

qos	<<in>> Default qos to be set. The special value DDS_TOPIC_QOS_DEFAULT may be passed as `qos` to indicate that the default QoS should be reset back to the initial values the factory would used if DDSDomainParticipant::set_default_topic_qos had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_TOPIC_QOS_DEFAULT; DDSDomainParticipant::create_topic

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_topic_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Set the default DDS_TopicQos values for this domain participant based on the input XML QoS profile.

This default value will be used for newly created DDSTopic if DDS_TOPIC_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_topic is called.

Precondition: The DDS_TopicQos contained in the specified XML QoS profile must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default topic QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_topic_qos, DDSDomainParticipant::get_default_topic_qos or calling DDSDomainParticipant::create_topic with DDS_TOPIC_QOS_DEFAULT as the qos parameter.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).

If the input profile cannot be found the method fails with DDS_RETCODE_ERROR.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_TOPIC_QOS_DEFAULT; DDSDomainParticipant::create_topic_with_profile

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_publisher_qos ( DDS_PublisherQos & qos )

pure virtual

Copy the default DDS_PublisherQos values into the provided DDS_PublisherQos instance.

The retrieved qos will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_publisher_qos, or DDSDomainParticipant::set_default_publisher_qos_with_profile, or else, if the call was never made, the default values listed in DDS_PublisherQos.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

If DDS_PUBLISHER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_topic is called, the default value of the QoS set in the factory, equivalent to the value obtained by calling DDSDomainParticipant::get_default_publisher_qos, will be used to create the DDSPublisher.

MT Safety:: UNSAFE. It is not safe to retrieve the default publisher QoS from a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_publisher_qos

Parameters

qos	<<inout>> Qos to be filled up.

Returns: One of the Standard Return Codes

See Also: DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_publisher

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_publisher_qos ( const DDS_PublisherQos & qos )

pure virtual

Set the default DDS_PublisherQos values for this DomainParticipant.

This set of default values will be used for a newly created DDSPublisher if DDS_PUBLISHER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_publisher is called.

Precondition: The specified QoS policies must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default publisher QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_publisher_qos, DDSDomainParticipant::get_default_publisher_qos or calling DDSDomainParticipant::create_publisher with DDS_PUBLISHER_QOS_DEFAULT as the qos parameter.

Parameters

qos	<<in>> Default qos to be set. The special value DDS_PUBLISHER_QOS_DEFAULT may be passed as `qos` to indicate that the default QoS should be reset back to the initial values the factory would used if DDSDomainParticipant::set_default_publisher_qos had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_publisher

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_publisher_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Set the default DDS_PublisherQos values for this DomainParticipant based on the input XML QoS profile.

This set of default values will be used for a newly created DDSPublisher if DDS_PUBLISHER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_publisher is called.

Precondition: The DDS_PublisherQos contained in the specified XML QoS profile must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default publisher QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_publisher_qos, DDSDomainParticipant::get_default_publisher_qos or calling DDSDomainParticipant::create_publisher with DDS_PUBLISHER_QOS_DEFAULT as the qos parameter.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).

If the input profile cannot be found, the method fails with DDS_RETCODE_ERROR.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_publisher_with_profile

virtual DDS_ReturnCode_t DDSDomainParticipant::get_default_subscriber_qos ( DDS_SubscriberQos & qos )

pure virtual

Copy the default DDS_SubscriberQos values into the provided DDS_SubscriberQos instance.

The retrieved qos will match the set of values specified on the last successful call to DDSDomainParticipant::set_default_subscriber_qos, or DDSDomainParticipant::set_default_subscriber_qos_with_profile, or else, if the call was never made, the default values listed in DDS_SubscriberQos.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

If DDS_SUBSCRIBER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_subscriber is called, the default value of the QoS set in the factory, equivalent to the value obtained by calling DDSDomainParticipant::get_default_subscriber_qos, will be used to create the DDSSubscriber.

MT Safety:: UNSAFE. It is not safe to retrieve the default Subscriber QoS from a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_subscriber_qos.

Parameters

qos	<<inout>> Qos to be filled up.

Returns: One of the Standard Return Codes

See Also: DDS_SUBSCRIBER_QOS_DEFAULT; DDSDomainParticipant::create_subscriber

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_subscriber_qos ( const DDS_SubscriberQos & qos )

pure virtual

Set the default DDS_SubscriberQos values for this Domain{articipant.

This set of default values will be used for a newly created DDSSubscriber if DDS_SUBSCRIBER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_subscriber is called.

Precondition: The specified QoS policies must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default Subscriber QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_subscriber_qos, DDSDomainParticipant::get_default_subscriber_qos or calling DDSDomainParticipant::create_subscriber with DDS_SUBSCRIBER_QOS_DEFAULT as the qos parameter.

Parameters

qos	<<in>> Default qos to be set. The special value DDS_SUBSCRIBER_QOS_DEFAULT may be passed as `qos` to indicate that the default QoS should be reset back to the initial values the factory would used if DDSDomainParticipant::set_default_subscriber_qos had never been called.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

virtual DDS_ReturnCode_t DDSDomainParticipant::set_default_subscriber_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Set the default DDS_SubscriberQos values for this DomainParticipant based on the input XML QoS profile.

This set of default values will be used for a newly created DDSSubscriber if DDS_SUBSCRIBER_QOS_DEFAULT is specified as the qos parameter when DDSDomainParticipant::create_subscriber is called.

Precondition: The DDS_SubscriberQos contained in the specified XML QoS profile must be consistent, or else the operation will have no effect and fail with DDS_RETCODE_INCONSISTENT_POLICY

MT Safety:: UNSAFE. It is not safe to set the default Subscriber QoS for a DomainParticipant while another thread may be simultaneously calling DDSDomainParticipant::set_default_subscriber_qos, DDSDomainParticipant::get_default_subscriber_qos or calling DDSDomainParticipant::create_subscriber with DDS_SUBSCRIBER_QOS_DEFAULT as the qos parameter.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).

If the input profile cannot be found, the method fails with DDS_RETCODE_ERROR.

Returns: One of the Standard Return Codes, or DDS_RETCODE_INCONSISTENT_POLICY

See Also: DDS_SUBSCRIBER_QOS_DEFAULT; DDSDomainParticipant::create_subscriber_with_profile

virtual DDSPublisher* DDSDomainParticipant::create_publisher	(	const DDS_PublisherQos &	qos,
		DDSPublisherListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

Creates a DDSPublisher with the desired QoS policies and attaches to it the specified DDSPublisherListener.

Precondition: The specified QoS policies must be consistent, or the operation will fail and no DDSPublisher will be created.

MT Safety:: UNSAFE. If DDS_PUBLISHER_QOS_DEFAULT is used for qos, it is not safe to create the publisher while another thread may be simultaneously calling DDSDomainParticipant::set_default_publisher_qos.

Parameters

qos	<<in>> QoS to be used for creating the new DDSPublisher. The special value DDS_PUBLISHER_QOS_DEFAULT can be used to indicate that the DDSPublisher should be created with the default DDS_PublisherQos set in the DDSDomainParticipant.
listener	<<in>>. Listener to be attached to the newly created DDSPublisher.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created publisher object or NULL on failure.

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_PublisherQos for rules on consistency among QoS; DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_publisher_with_profile; DDSDomainParticipant::get_default_publisher_qos; DDSPublisher::set_listener

Examples:: HelloWorld_publisher.cxx.

virtual DDSPublisher* DDSDomainParticipant::create_publisher_with_profile	(	const char *	library_name,
		const char *	profile_name,
		DDSPublisherListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a new DDSPublisher object using the DDS_PublisherQos associated with the input XML QoS profile.

Precondition: The DDS_PublisherQos in the input profile must be consistent, or the operation will fail and no DDSPublisher will be created.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).
listener	<<in>>. Listener to be attached to the newly created DDSPublisher.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created publisher object or NULL on failure.

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_PublisherQos for rules on consistency among QoS; DDSDomainParticipant::create_publisher; DDSDomainParticipant::get_default_publisher_qos; DDSPublisher::set_listener

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_publisher ( DDSPublisher * p )

pure virtual

Deletes an existing DDSPublisher.

Precondition: The DDSPublisher must not have any attached DDSDataWriter objects. If there are existing DDSDataWriter objects, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.; DDSPublisher must have been created by this DDSDomainParticipant, or else it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: Listener installed on the DDSPublisher will not be called after this method completes successfully.

Parameters

p	<<in>> DDSPublisher to be deleted.

Returns: One of the Standard Return Codes, or DDS_RETCODE_PRECONDITION_NOT_MET.

virtual DDSSubscriber* DDSDomainParticipant::create_subscriber	(	const DDS_SubscriberQos &	qos,
		DDSSubscriberListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

Creates a DDSSubscriber with the desired QoS policies and attaches to it the specified DDSSubscriberListener.

Precondition: The specified QoS policies must be consistent, or the operation will fail and no DDSSubscriber will be created.

MT Safety:: UNSAFE. If DDS_SUBSCRIBER_QOS_DEFAULT is used for qos, it is not safe to create the subscriber while another thread may be simultaneously calling DDSDomainParticipant::set_default_subscriber_qos.

Parameters

qos	<<in>> QoS to be used for creating the new DDSSubscriber. The special value DDS_SUBSCRIBER_QOS_DEFAULT can be used to indicate that the DDSSubscriber should be created with the default DDS_SubscriberQos set in the DDSDomainParticipant.
listener	<<in>>. Listener to be attached to the newly created DDSSubscriber.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created subscriber object or NULL on failure.

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_SubscriberQos for rules on consistency among QoS; DDS_SUBSCRIBER_QOS_DEFAULT; DDSDomainParticipant::create_subscriber_with_profile; DDSDomainParticipant::get_default_subscriber_qos; DDSSubscriber::set_listener

virtual DDSSubscriber* DDSDomainParticipant::create_subscriber_with_profile	(	const char *	library_name,
		const char *	profile_name,
		DDSSubscriberListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a new DDSSubscriber object using the DDS_PublisherQos associated with the input XML QoS profile.

Precondition: The DDS_SubscriberQos in the input profile must be consistent, or the operation will fail and no DDSSubscriber will be created.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).
listener	<<in>>. Listener to be attached to the newly created DDSSubscriber.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created subscriber object or NULL on failure.

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_SubscriberQos for rules on consistency among QoS; DDSDomainParticipant::create_subscriber; DDSDomainParticipant::get_default_subscriber_qos; DDSSubscriber::set_listener

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_subscriber ( DDSSubscriber * s )

pure virtual

Deletes an existing DDSSubscriber.

Precondition: The DDSSubscriber must not have any attached DDSDataReader objects. If there are existing DDSDataReader objects, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET; The DDSSubscriber must have been created by this DDSDomainParticipant, or else it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: A Listener installed on the DDSSubscriber will not be called after this method completes successfully.

Parameters

s	<<in>> DDSSubscriber to be deleted.

Returns: One of the Standard Return Codes, or DDS_RETCODE_PRECONDITION_NOT_MET.

virtual DDS_ReturnCode_t DDSDomainParticipant::get_publishers ( DDSPublisherSeq & publishers )

pure virtual

<<eXtension>> Allows the application to access all the publishers the participant has.

If the sequence doesn't own its buffer, and its maximum is less than the total number of publishers, it will be filled up to its maximum, and fail with DDS_RETCODE_OUT_OF_RESOURCES.

MT Safety:: Safe.

Parameters

publishers <<inout>> a PublisherSeq object where the set or list of publishers will be returned

Returns: One of the Standard Return Codes or DDS_RETCODE_OUT_OF_RESOURCES

virtual DDS_ReturnCode_t DDSDomainParticipant::get_subscribers ( DDSSubscriberSeq & subscribers )

pure virtual

<<eXtension>> Allows the application to access all the subscribers the participant has.

If the sequence doesn't own its buffer, and its maximum is less than the total number of subscribers, it will be filled up to its maximum, and fail with DDS_RETCODE_OUT_OF_RESOURCES.

MT Safety:: Safe.

Parameters

subscribers <<inout>> a SubscriberSeq object where the set or list of subscribers will be returned

Returns: One of the Standard Return Codes or DDS_RETCODE_OUT_OF_RESOURCES

virtual DDSTopic* DDSDomainParticipant::create_topic	(	const char *	topic_name,
		const char *	type_name,
		const DDS_TopicQos &	qos,
		DDSTopicListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

Creates a DDSTopic with the desired QoS policies and attaches to it the specified DDSTopicListener.

Precondition: The application is not allowed to create two DDSTopic objects with the same topic_name attached to the same DDSDomainParticipant. If the application attempts this, this method will fail and return a NULL topic.; The specified QoS policies must be consistent, or the operation will fail and no DDSTopic will be created.; Prior to creating a DDSTopic, the type must have been registered with RTI Connext. This is done using the FooTypeSupport::register_type operation on a derived class of the DDSTypeSupport interface.

MT Safety:: UNSAFE. It is not safe to create a topic while another thread is trying to lookup that topic description with DDSDomainParticipant::lookup_topicdescription.

MT Safety:: UNSAFE. If DDS_TOPIC_QOS_DEFAULT is used for qos, it is not safe to create the topic while another thread may be simultaneously calling DDSDomainParticipant::set_default_topic_qos.

Parameters

topic_name	<<in>> Name for the new topic, must not exceed 255 characters. Cannot be NULL.
type_name	<<in>> The type to which the new DDSTopic will be bound. Cannot be NULL.
qos	<<in>> QoS to be used for creating the new DDSTopic. The special value DDS_TOPIC_QOS_DEFAULT can be used to indicate that the DDSTopic should be created with the default DDS_TopicQos set in the DDSDomainParticipant.
listener	<<in>>. Listener to be attached to the newly created DDSTopic.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created topic, or NULL on failure

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_TopicQos for rules on consistency among QoS; DDS_TOPIC_QOS_DEFAULT; DDSDomainParticipant::create_topic_with_profile; DDSDomainParticipant::get_default_topic_qos; DDSTopic::set_listener

Examples:: HelloWorld_publisher.cxx.

virtual DDSTopic* DDSDomainParticipant::create_topic_with_profile	(	const char *	topic_name,
		const char *	type_name,
		const char *	library_name,
		const char *	profile_name,
		DDSTopicListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a new DDSTopic object using the DDS_PublisherQos associated with the input XML QoS profile.

Precondition: The application is not allowed to create two DDSTopicDescription objects with the same topic_name attached to the same DDSDomainParticipant. If the application attempts this, this method will fail and return a NULL topic.; The DDS_TopicQos in the input profile must be consistent, or the operation will fail and no DDSTopic will be created.; Prior to creating a DDSTopic, the type must have been registered with RTI Connext. This is done using the FooTypeSupport::register_type operation on a derived class of the DDSTypeSupport interface.

MT Safety:: UNSAFE. It is not safe to create a topic while another thread is trying to lookup that topic description with DDSDomainParticipant::lookup_topicdescription.

Parameters

topic_name	<<in>> Name for the new topic, must not exceed 255 characters. Cannot be NULL.
type_name	<<in>> The type to which the new DDSTopic will be bound. Cannot be NULL.
library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).
listener	<<in>>. Listener to be attached to the newly created DDSTopic.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: newly created topic, or NULL on failure

See Also: Specifying QoS on entities for information on setting QoS before entity creation; DDS_TopicQos for rules on consistency among QoS; DDSDomainParticipant::create_topic; DDSDomainParticipant::get_default_topic_qos; DDSTopic::set_listener

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_topic ( DDSTopic * topic )

pure virtual

Deletes a DDSTopic.

Precondition: If the DDSTopic does not belong to the application's DDSDomainParticipant, this operation fails with DDS_RETCODE_PRECONDITION_NOT_MET.; Make sure no objects are using the topic. More specifically, there must be no existing DDSDataReader, DDSDataWriter, DDSContentFilteredTopic, or DDSMultiTopic objects belonging to the same DDSDomainParticipant that are using the DDSTopic. If delete_topic is called on a DDSTopic with any of these existing objects attached to it, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: Listener installed on the DDSTopic will not be called after this method completes successfully.

Parameters

topic <<in>> DDSTopic to be deleted.

Returns: One of the Standard Return Codes, or DDS_RETCODE_PRECONDITION_NOT_MET

virtual DDSContentFilteredTopic* DDSDomainParticipant::create_contentfilteredtopic	(	const char *	name,
		DDSTopic *	related_topic,
		const char *	filter_expression,
		const DDS_StringSeq &	expression_parameters
	)

pure virtual

Creates a DDSContentFilteredTopic, that can be used to do content-based subscriptions.

The DDSContentFilteredTopic only relates to samples published under that DDSTopic, filtered according to their content. The filtering is done by means of evaluating a logical expression that involves the values of some of the data-fields in the sample. The logical expression derived from the filter_expression and expression_parameters arguments.

Queries and Filters Syntax describes the syntax of filter_expression and expression_parameters.

Precondition: The application is not allowed to create two DDSContentFilteredTopic objects with the same topic_name attached to the same DDSDomainParticipant. If the application attempts this, this method will fail and returns NULL.; If related_topic does not belong to this DDSDomainParticipant, this operation returns NULL.; This function will create a content filter using the builtin SQL filter which implements a superset of the DDS specification. This filter requires that all IDL types have been compiled with typecodes. If this precondition is not met, this operation returns NULL. Do not use rtiddsgen's -notypecode option if you want to use the builtin SQL filter.

Parameters

name	<<in>> Name for the new content filtered topic, must not exceed 255 characters. Cannot be NULL.
related_topic	<<in>> DDSTopic to be filtered. Cannot be NULL.
filter_expression	<<in>> Cannot be NULL
expression_parameters	<<in>> An empty sequence must be used if the filter expression does not contain any parameters. Length of sequence cannot be greater than 100.

Returns: newly created DDSContentFilteredTopic, or NULL on failure

virtual DDSContentFilteredTopic* DDSDomainParticipant::create_contentfilteredtopic_with_filter	(	const char *	name,
		DDSTopic *	related_topic,
		const char *	filter_expression,
		const DDS_StringSeq &	expression_parameters,
		const char *	filter_name = `DDS_SQLFILTER_NAME`
	)

pure virtual

<<eXtension>> Creates a DDSContentFilteredTopic using the specified filter to do content-based subscriptions.

Parameters

name	<<in>> Name for the new content filtered topic. Cannot exceed 255 characters. Cannot be NULL.
related_topic	<<in>> DDSTopic to be filtered. Cannot be NULL.
filter_expression	<<in>> Cannot be NULL.
expression_parameters	<<in>> . An empty sequence must be used if the filter expression does not contain any parameters. Length of the sequence cannot be greater than 100.
filter_name	<<in>> Name of content filter to use. Must previously have been registered with DDSDomainParticipant::register_contentfilter on the same DDSDomainParticipant. Cannot be NULL.

Builtin filter names are DDS_SQLFILTER_NAME and DDS_STRINGMATCHFILTER_NAME

Returns: newly created DDSContentFilteredTopic, or NULL on failure

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_contentfilteredtopic ( DDSContentFilteredTopic * a_contentfilteredtopic )

pure virtual

Deletes a DDSContentFilteredTopic.

Precondition: The deletion of a DDSContentFilteredTopic is not allowed if there are any existing DDSDataReader objects that are using the DDSContentFilteredTopic. If the operation is called on a DDSContentFilteredTopic with existing DDSDataReader objects attached to it, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.; The DDSContentFilteredTopic must be created by this DDSDomainParticipant, or else this operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Parameters

a_contentfilteredtopic <<in>>

Returns: One of the Standard Return Codes or DDS_RETCODE_PRECONDITION_NOT_MET

virtual DDSMultiTopic* DDSDomainParticipant::create_multitopic	(	const char *	name,
		const char *	type_name,
		const char *	subscription_expression,
		const DDS_StringSeq &	expression_parameters
	)

pure virtual

[Not supported (optional)] Creates a MultiTopic that can be used to subscribe to multiple topics and combine/filter the received data into a resulting type.

The resulting type is specified by the type_name argument. The list of topics and the logic used to combine, filter, and rearrange the information from each DDSTopic are specified using the subscription_expression and expression_parameters arguments.

Queries and Filters Syntax describes the syntax of subscription_expression and expression_parameters.

Precondition: The application is not allowed to create two DDSTopicDescription objects with the same name attached to the same DDSDomainParticipant. If the application attempts this, this method will fail and return NULL.; Prior to creating a DDSMultiTopic, the type must have been registered with RTI Connext. This is done using the FooTypeSupport::register_type operation on a derived class of the DDSTypeSupport interface. Otherwise, this method will return NULL.

Parameters

name	<<in>> Name of the newly create DDSMultiTopic. Cannot be NULL.
type_name	<<in>> Cannot be NULL.
subscription_expression	<<in>> Cannot be NULL.
expression_parameters	<<in>>

Returns: NULL

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_multitopic ( DDSMultiTopic * a_multitopic )

pure virtual

[Not supported (optional)] Deletes a DDSMultiTopic.

Precondition: The deletion of a DDSMultiTopic is not allowed if there are any existing DDSDataReader objects that are using the DDSMultiTopic. If the delete_multitopic operation is called on a DDSMultiTopic with existing DDSDataReader objects attached to it, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.; The DDSMultiTopic must be created by this DDSDomainParticipant, or else this operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Parameters

a_multitopic <<in>>

Returns: DDS_RETCODE_UNSUPPORTED

virtual DDSTopic* DDSDomainParticipant::find_topic	(	const char *	topic_name,
		const DDS_Duration_t &	timeout
	)

pure virtual

Finds an existing (or ready to exist) DDSTopic, based on its name.

This call can be used to block for a specified duration to wait for the DDSTopic to be created.

If the requested DDSTopic already exists, it is returned. Otherwise, find_topic() waits until another thread creates it or else returns when the specified timeout occurs.

find_topic() is useful when multiple threads are concurrently creating and looking up topics. In that case, one thread can call find_topic() and, if another thread has not yet created the topic being looked up, it can wait for some period of time for it to do so. In almost all other cases, it is more straightforward to call DDSDomainParticipant::lookup_topicdescription.

The DDSDomainParticipant must already be enabled.

Note: Each DDSTopic obtained by DDSDomainParticipant::find_topic must also be deleted by means of DDSDomainParticipant::delete_topic. If DDSTopic is obtained multiple times by means of DDSDomainParticipant::find_topic or DDSDomainParticipant::create_topic, it must also be deleted that same number of times using DDSDomainParticipant::delete_topic.

Parameters

topic_name	<<in>> Name of the DDSTopic to search for. Cannot be NULL.
timeout	<<in>> The time to wait if the DDSTopic does not exist already.

Returns: the topic, if it exists, or NULL

virtual DDSTopicDescription* DDSDomainParticipant::lookup_topicdescription ( const char * topic_name )

pure virtual

Looks up an existing, locally created DDSTopicDescription, based on its name.

DDSTopicDescription is the base class for DDSTopic, DDSMultiTopic and DDSContentFilteredTopic. So you can narrow the DDSTopicDescription returned from this operation to a DDSTopic or DDSContentFilteredTopic as appropriate.

Unlike DDSDomainParticipant::find_topic, which logically returns a new DDSTopic object that must be independently deleted, this operation returns a reference to the original local object.

The DDSDomainParticipant does not have to be enabled when you call lookup_topicdescription().

The returned topic may be either enabled or disabled.

MT Safety:: UNSAFE. It is not safe to lookup a topic description while another thread is creating that topic.

Parameters

topic_name <<in>> Name of DDSTopicDescription to search for. This string must be no more than 255 characters; it cannot be NULL.

Returns: The topic description, if it has already been created locally, otherwise it returns NULL.

virtual DDSFlowController* DDSDomainParticipant::create_flowcontroller	(	const char *	name,
		const DDS_FlowControllerProperty_t &	prop
	)

pure virtual

<<eXtension>> Creates a DDSFlowController with the desired property.

The created DDSFlowController is associated with a DDSDataWriter via DDS_PublishModeQosPolicy::flow_controller_name. A single DDSFlowController may service multiple DDSDataWriter instances, even if they belong to a different DDSPublisher. The property determines how the DDSFlowController shapes the network traffic.

Precondition: The specified property must be consistent, or the operation will fail and no DDSFlowController will be created.

MT Safety:: UNSAFE. If DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT is used for property, it is not safe to create the flow controller while another thread may be simultaneously calling DDSDomainParticipant::set_default_flowcontroller_property or trying to lookup that flow controller with DDSDomainParticipant::lookup_flowcontroller.

Parameters

name	<<in>> name of the DDSFlowController to create. A DDSDataWriter is associated with a DDSFlowController by name. Limited to 255 characters.
prop	<<in>> property to be used for creating the new DDSFlowController. The special value DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT can be used to indicate that the DDSFlowController should be created with the default DDS_FlowControllerProperty_t set in the DDSDomainParticipant.

Returns: Newly created flow controller object or NULL on failure.

See Also: DDS_FlowControllerProperty_t for rules on consistency among property; DDS_FLOW_CONTROLLER_PROPERTY_DEFAULT; DDSDomainParticipant::get_default_flowcontroller_property

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_flowcontroller ( DDSFlowController * fc )

pure virtual

<<eXtension>> Deletes an existing DDSFlowController.

Precondition: The DDSFlowController must not have any attached DDSDataWriter objects. If there are any attached DDSDataWriter objects, it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.; The DDSFlowController must have been created by this DDSDomainParticipant, or else it will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: The DDSFlowController is deleted if this method completes successfully.

Parameters

fc	<<in>> The DDSFlowController to be deleted.

Returns: One of the Standard Return Codes, or DDS_RETCODE_PRECONDITION_NOT_MET.

virtual DDSFlowController* DDSDomainParticipant::lookup_flowcontroller ( const char * name )

pure virtual

<<eXtension>> Looks up an existing locally-created DDSFlowController, based on its name.

Looks up a previously created DDSFlowController, including the built-in ones. Once a DDSFlowController has been deleted, subsequent lookups will fail.

MT Safety:: UNSAFE. It is not safe to lookup a flow controller description while another thread is creating that flow controller.

Parameters

name	<<in>> Name of DDSFlowController to search for. Limited to 255 characters. Cannot be NULL.

Returns: The flow controller if it has already been created locally, or NULL otherwise.

virtual DDSSubscriber* DDSDomainParticipant::get_builtin_subscriber ( )

pure virtual

Accesses the built-in DDSSubscriber.

Each DDSDomainParticipant contains several built-in DDSTopic objects as well as corresponding DDSDataReader objects to access them. All of these DDSDataReader objects belong to a single built-in DDSSubscriber.

The built-in Topics are used to communicate information about other DDSDomainParticipant, DDSTopic, DDSDataReader, and DDSDataWriter objects.

The built-in subscriber is created when this operation is called for the first time. The built-in subscriber is deleted automatically when the DDSDomainParticipant is deleted.

Returns: The built-in DDSSubscriber singleton.

See Also: DDS_SubscriptionBuiltinTopicData; DDS_PublicationBuiltinTopicData; DDS_ParticipantBuiltinTopicData; DDS_TopicBuiltinTopicData

virtual DDS_ReturnCode_t DDSDomainParticipant::ignore_participant ( const DDS_InstanceHandle_t & handle )

pure virtual

Instructs RTI Connext to locally ignore a remote DDSDomainParticipant.

From the time of this call onwards, RTI Connext will locally behave as if the remote participant did not exist. This means it will ignore any topic, publication, or subscription that originates on that DDSDomainParticipant.

There is no way to reverse this operation.

This operation can be used in conjunction with the discovery of remote participants offered by means of the DDS_ParticipantBuiltinTopicData to provide access control.

Application data can be associated with a DDSDomainParticipant by means of the USER_DATA policy. This application data is propagated as a field in the built-in topic and can be used by an application to implement its own access control policy.

The DDSDomainParticipant to ignore is identified by the handle argument. This handle is the one that appears in the DDS_SampleInfo retrieved when reading the data-samples available for the built-in DDSDataReader to the DDSDomainParticipant topic. The built-in DDSDataReader is read with the same FooDataReader::read and FooDataReader::take operations used for any DDSDataReader.

Parameters

handle <<in>> DDS_InstanceHandle_t of the DDSDomainParticipant to be ignored.

Returns: One of the Standard Return Codes, DDS_RETCODE_OUT_OF_RESOURCES, DDS_RETCODE_NOT_ENABLED

See Also: DDS_ParticipantBuiltinTopicData; DDS_PARTICIPANT_TOPIC_NAME; DDSDomainParticipant::get_builtin_subscriber

virtual DDS_ReturnCode_t DDSDomainParticipant::ignore_topic ( const DDS_InstanceHandle_t & handle )

pure virtual

Instructs RTI Connext to locally ignore a DDSTopic.

This means it will locally ignore any publication, or subscription to the DDSTopic.

There is no way to reverse this operation.

This operation can be used to save local resources when the application knows that it will never publish or subscribe to data under certain topics.

The DDSTopic to ignore is identified by the handle argument. This is the handle of a DDSTopic that appears in the DDS_SampleInfo retrieved when reading data samples from the built-in DDSDataReader for the DDSTopic.

Parameters

handle <<in>> Handle of the DDSTopic to be ignored.

Returns: One of the Standard Return Codes, DDS_RETCODE_OUT_OF_RESOURCES or DDS_RETCODE_NOT_ENABLED

See Also: DDS_TopicBuiltinTopicData; DDS_TOPIC_TOPIC_NAME; DDSDomainParticipant::get_builtin_subscriber

virtual DDS_ReturnCode_t DDSDomainParticipant::ignore_publication ( const DDS_InstanceHandle_t & handle )

pure virtual

Instructs RTI Connext to locally ignore a publication.

A publication is defined by the association of a topic name, user data, and partition set on the DDSPublisher (see DDS_PublicationBuiltinTopicData). After this call, any data written by that publication's DDSDataWriter will be ignored.

This operation can be used to ignore local and remote DataWriters.

The publication (DataWriter) to ignore is identified by the handle argument.

To ignore a remote DataWriter, the handle can be obtained from the DDS_SampleInfo retrieved when reading data samples from the built-in DDSDataReader for the publication topic.

To ignore a local DataWriter, the handle can be obtained by calling DDSEntity::get_instance_handle for the local DataWriter.

There is no way to reverse this operation.

Parameters

handle <<in>> Handle of the DDSDataWriter to be ignored.

Returns: One of the Standard Return Codes, DDS_RETCODE_OUT_OF_RESOURCES or DDS_RETCODE_NOT_ENABLED

See Also: DDS_PublicationBuiltinTopicData; DDS_PUBLICATION_TOPIC_NAME; DDSDomainParticipant::get_builtin_subscriber

virtual DDS_ReturnCode_t DDSDomainParticipant::ignore_subscription ( const DDS_InstanceHandle_t & handle )

pure virtual

Instructs RTI Connext to locally ignore a subscription.

A subscription is defined by the association of a topic name, user data, and partition set on the DDSSubscriber (see DDS_SubscriptionBuiltinTopicData). After this call, any data received related to that subscription's DDSDataReader will be ignored.

This operation can be used to ignore local and remote DataReaders.

The subscription to ignore is identified by the handle argument.

To ignore a remote DataReader, the handle can be obtained from the DDS_SampleInfo retrieved when reading data samples from the built-in DDSDataReader for the subscription topic.

To ignore a local DataReader, the handle can be obtained by calling DDSEntity::get_instance_handle for the local DataReader.

There is no way to reverse this operation.

Parameters

handle <<in>> Handle of the DDSDataReader to be ignored.

Returns: One of the Standard Return Codes, DDS_RETCODE_OUT_OF_RESOURCES or DDS_RETCODE_NOT_ENABLED

See Also: DDS_SubscriptionBuiltinTopicData; DDS_SUBSCRIPTION_TOPIC_NAME; DDSDomainParticipant::get_builtin_subscriber

virtual DDS_DomainId_t DDSDomainParticipant::get_domain_id ( )

pure virtual

Get the unique domain identifier.

This operation retrieves the domain_id used to create the DDSDomainParticipant. The domain_id identifies the DDS domain to which the DDSDomainParticipant belongs. Each DDS domain represents a separate data 'communication plane' isolated from other domains.

Returns: the unique domainId that was used to create the domain

See Also: DDSDomainParticipantFactory::create_participant; DDSDomainParticipantFactory::create_participant_with_profile

virtual DDS_ReturnCode_t DDSDomainParticipant::get_current_time ( DDS_Time_t & current_time )

pure virtual

Returns the current value of the time.

The current value of the time that RTI Connext uses to time-stamp DDSDataWriter and to set the reception-timestamp for the data updates that it receives.

Parameters

current_time <<inout>> Current time to be filled up.

Returns: One of the Standard Return Codes

virtual DDS_ReturnCode_t DDSDomainParticipant::register_durable_subscription	(	DDS_EndpointGroup_t &	group,
		const char *	topic_name
	)

pure virtual

Registers a Durable Subscription on the specified DDSTopic on all Persistence Services.

If you need to receive all samples published on a DDSTopic, including the ones published while a DDSDataReader is inactive or before it may be created, create a Durable Subscription using this method.

In this way, the Persistence Service will ensure that all the samples on that DDSTopic are retained until they are acknowledged by at least N DataReaders belonging to the Durable Subscription where N is the quorum count.

If the same Durable Subscription is created on a different DDSTopic, the Persistence Service will implicitly delete the previous Durable Subscription and create a new one on the new DDSTopic.

Parameters

group	<<in>> DDS_EndpointGroup_t The Durable Subscription name and quorum.
topic_name	<<in>> The topic name for which the Durable Subscription is created.

Returns: One of the Standard Return Codes

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_durable_subscription ( DDS_EndpointGroup_t & group )

pure virtual

Deletes an existing Durable Subscription on all Persistence Services.

The Persistence Service will delete the Durable Subscription and the quorum of the existing samples will be considered satisfied.

Parameters

group <<in>> DDS_EndpointGroup_t specifying the Durable Subscription name. Quorum is not required for this operation.

Returns: One of the Standard Return Codes

virtual DDS_ReturnCode_t DDSDomainParticipant::assert_liveliness ( )

pure virtual

Manually asserts the liveliness of this DDSDomainParticipant.

This is used in combination with the DDS_LivelinessQosPolicy to indicate to RTI Connext that the entity remains active.

You need to use this operation if the DDSDomainParticipant conatins DDSDataWriter entities with the DDS_LivelinessQosPolicy::kind set to DDS_MANUAL_BY_PARTICIPANT_LIVELINESS_QOS and it only affects the liveliness of those DDSDataWriter entities. Otherwise, it has no effect.

Note: writing data via the FooDataWriter::write or FooDataWriter::write_w_timestamp operation asserts liveliness on the DDSDataWriter itself and its DDSDomainParticipant. Consequently the use of assert_liveliness() is only needed if the application is not writing data regularly.

Returns: One of the Standard Return Codes, or DDS_RETCODE_NOT_ENABLED

See Also: DDS_LivelinessQosPolicy

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_contained_entities ( )

pure virtual

Delete all the entities that were created by means of the "create" operations on the DDSDomainParticipant.

This operation deletes all contained DDSPublisher (including an implicit Publisher, if one exists), DDSSubscriber (including implicit subscriber), DDSTopic, DDSContentFilteredTopic, and DDSMultiTopic objects.

Prior to deleting each contained entity, this operation will recursively call the corresponding delete_contained_entities operation on each contained entity (if applicable). This pattern is applied recursively. In this manner the operation delete_contained_entities() on the DDSDomainParticipant will end up deleting all the entities recursively contained in the DDSDomainParticipant, that is also the DDSDataWriter, DDSDataReader, as well as the DDSQueryCondition and DDSReadCondition objects belonging to the contained DDSDataReader.

The operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET if any of the contained entities is in a state where it cannot be deleted.

If delete_contained_entities() completes successfully, the application may delete the DDSDomainParticipant knowing that it has no contained entities.

Returns: One of the Standard Return Codes, or DDS_RETCODE_PRECONDITION_NOT_MET.

Examples:: HelloWorld_publisher.cxx.

virtual DDS_ReturnCode_t DDSDomainParticipant::get_discovered_participants ( DDS_InstanceHandleSeq & participant_handles )

pure virtual

Returns a list of discovered DDSDomainParticipant entities.

This operation retrieves the list of DDSDomainParticipant entities that have been discovered in the domain and that the application has not indicated should be "ignored" by means of the DDSDomainParticipant::ignore_participant operation.

Parameters

participant_handles <<inout>> ::DDSInstanceHandleSeq to be filled with handles of the discovered DDSDomainParticipant entities.

Returns: One of the Standard Return Codes or DDS_RETCODE_NOT_ENABLED

virtual DDS_ReturnCode_t DDSDomainParticipant::get_discovered_participant_data	(	struct DDS_ParticipantBuiltinTopicData &	participant_data,
		const DDS_InstanceHandle_t &	participant_handle
	)

pure virtual

Returns DDS_ParticipantBuiltinTopicData for the specified DDSDomainParticipant.

This operation retrieves information on a DDSDomainParticipant that has been discovered on the network. The participant must be in the same domain as the participant on which this operation is invoked and must not have been "ignored" by means of the DDSDomainParticipant::ignore_participant operation.

The participant_handle must correspond to such a DomainParticipant. Otherwise, the operation will fail with PRECONDITION_NOT_MET.

Use the operation DDSDomainParticipant::get_discovered_participants to find the DDSDomainParticipant entities that are currently discovered.

Note: This operation does not retrieve the DDS_ParticipantBuiltinTopicData::property. This information is available through DDSDataReaderListener::on_data_available() (if a reader listener is installed on the DDSParticipantBuiltinTopicDataDataReader).

MT Safety:: Unsafe. It is not safe to call this operation from multiple threads at the same time.

Parameters

participant_data	<<inout>> DDS_ParticipantBuiltinTopicData to be filled in with the data for the specified DDSDomainParticipant.
participant_handle	<<in>> DDS_InstanceHandle_t of DDSDomainParticipant.

Returns: One of the Standard Return Codes, DDS_RETCODE_PRECONDITION_NOT_MET or DDS_RETCODE_NOT_ENABLED

See Also: DDS_ParticipantBuiltinTopicData; DDSDomainParticipant::get_discovered_participants

virtual DDS_ReturnCode_t DDSDomainParticipant::get_discovered_topics ( DDS_InstanceHandleSeq & topic_handles )

pure virtual

Returns list of discovered DDSTopic objects.

This operation retrieves the list of DDSTopic s that have been discovered in the domain and that the application has not indicated should be "ignored" by means of the DDSDomainParticipant::ignore_topic operation.

Parameters

topic_handles <<inout>> ::DDSInstanceHandleSeq to be filled with handles of the discovered DDSTopic objects

Returns: One of the Standard Return Codes or DDS_RETCODE_NOT_ENABLED

virtual DDS_ReturnCode_t DDSDomainParticipant::get_discovered_topic_data	(	struct DDS_TopicBuiltinTopicData &	topic_data,
		const DDS_InstanceHandle_t &	topic_handle
	)

pure virtual

Returns DDS_TopicBuiltinTopicData for the specified DDSTopic.

This operation retrieves information on a DDSTopic that has been discovered by the local Participant and must not have been "ignored" by means of the DDSDomainParticipant::ignore_topic operation.

The topic_handle must correspond to such a topic. Otherwise, the operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

This call is not supported for remote topics. If a remote topic_handle is used, the operation will fail with DDS_RETCODE_UNSUPPORTED.

Use the operation DDSDomainParticipant::get_discovered_topics to find the topics that are currently discovered.

Parameters

topic_data	<<inout>> DDS_TopicBuiltinTopicData to be filled with the specified DDSTopic's data.
topic_handle	<<in>> DDS_InstanceHandle_t of DDSTopic.

Returns: One of the Standard Return Codes, DDS_RETCODE_PRECONDITION_NOT_MET or DDS_RETCODE_NOT_ENABLED

See Also: DDS_TopicBuiltinTopicData; DDSDomainParticipant::get_discovered_topics

virtual DDS_Boolean DDSDomainParticipant::contains_entity ( const DDS_InstanceHandle_t & a_handle )

pure virtual

Completes successfully with DDS_BOOLEAN_TRUE if the referenced DDSEntity is contained by the DDSDomainParticipant.

This operation checks whether or not the given a_handle represents an DDSEntity that was created from the DDSDomainParticipant. The containment applies recursively. That is, it applies both to entities (DDSTopicDescription, DDSPublisher, or DDSSubscriber) created directly using the DDSDomainParticipant as well as entities created using a contained DDSPublisher, or DDSSubscriber as the factory, and so forth.

The instance handle for an DDSEntity may be obtained from built-in topic data, from various statuses, or from the operation DDSEntity::get_instance_handle.

Parameters

a_handle <<in>> DDS_InstanceHandle_t of the DDSEntity to be checked.

Returns: DDS_BOOLEAN_TRUE if DDSEntity is contained by the DDSDomainParticipant, or DDS_BOOLEAN_FALSE otherwise.

virtual DDS_ReturnCode_t DDSDomainParticipant::set_qos ( const DDS_DomainParticipantQos & qos )

pure virtual

Change the QoS of this DomainParticipant.

The DDS_DomainParticipantQos::user_data and DDS_DomainParticipantQos::entity_factory can be changed. The other policies are immutable.

Parameters

qos <<in>> Set of policies to be applied to DDSDomainParticipant. Policies must be consistent. Immutable policies cannot be changed after DDSDomainParticipant is enabled. The special value DDS_PARTICIPANT_QOS_DEFAULT can be used to indicate that the QoS of the DDSDomainParticipant should be changed to match the current default DDS_DomainParticipantQos set in the DDSDomainParticipantFactory.

Returns: One of the Standard Return Codes, DDS_RETCODE_IMMUTABLE_POLICY if immutable policy is changed, or DDS_RETCODE_INCONSISTENT_POLICY if policies are inconsistent

See Also: DDS_DomainParticipantQos for rules on consistency among QoS; set_qos (abstract)

virtual DDS_ReturnCode_t DDSDomainParticipant::set_qos_with_profile	(	const char *	library_name,
		const char *	profile_name
	)

pure virtual

<<eXtension>> Change the QoS of this domain participant using the input XML QoS profile.

The DDS_DomainParticipantQos::user_data and DDS_DomainParticipantQos::entity_factory can be changed. The other policies are immutable.

Parameters

library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipantFactory::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipantFactory::set_default_profile).

Returns: One of the Standard Return Codes, DDS_RETCODE_IMMUTABLE_POLICY if immutable policy is changed, or DDS_RETCODE_INCONSISTENT_POLICY if policies are inconsistent

See Also: DDS_DomainParticipantQos for rules on consistency among QoS

virtual DDS_ReturnCode_t DDSDomainParticipant::get_qos ( DDS_DomainParticipantQos & qos )

pure virtual

Get the participant QoS.

This method may potentially allocate memory depending on the sequences contained in some QoS policies.

Parameters

qos	<<inout>> QoS to be filled up.

Returns: One of the Standard Return Codes

See Also: get_qos (abstract)

virtual DDS_ReturnCode_t DDSDomainParticipant::add_peer ( const char * peer_desc_string )

pure virtual

<<eXtension>> Attempt to contact one or more additional peer participants.

Add the given peer description to the list of peers with which this DDSDomainParticipant will try to communicate.

This method may be called at any time after this DDSDomainParticipant has been created (before or after it has been enabled).

If this method is called after DDSEntity::enable, an attempt will be made to contact the new peer(s) immediately.

If this method is called before the DomainParticipant is enabled, the peer description will simply be added to the list that was populated by DDS_DiscoveryQosPolicy::initial_peers; the first attempted contact will take place after this DDSDomainParticipant is enabled.

Adding a peer description with this method does not guarantee that any peer(s) discovered as a result will exactly correspond to those described:

This DDSDomainParticipant will attempt to discover peer participants at the given locations but may not succeed if no such participants are available. In this case, this method will not wait for contact attempt(s) to be made and it will not report an error.

If remote participants described by the given peer description are discovered, the distributed application is configured with asymmetric peer lists, and DDS_DiscoveryQosPolicy::accept_unknown_peers is set to DDS_BOOLEAN_TRUE. Thus, this DDSDomainParticipant may actually discover more peers than are described in the given peer description.

To be informed of the exact remote participants that are discovered, regardless of which peers this DDSDomainParticipant attempts to discover, use the built-in participant topic: DDS_PARTICIPANT_TOPIC_NAME.

To remove specific peer locators, you may use DDSDomainParticipant::remove_peer. If a peer is removed, the add_peer operation will add it back to the list of peers.

To stop communicating with a peer DDSDomainParticipant that has been discovered, use DDSDomainParticipant::ignore_participant.

Adding a peer description with this method has no effect on the DDS_DiscoveryQosPolicy::initial_peers that may be subsequently retrieved with DDSDomainParticipant::get_qos() (because DDS_DiscoveryQosPolicy is immutable).

Parameters

peer_desc_string <<in>> New peer descriptor to be added. The format is specified in Peer Descriptor Format.

Returns: One of the Standard Return Codes

See Also: Peer Descriptor Format; DDS_DiscoveryQosPolicy::initial_peers; DDS_PARTICIPANT_TOPIC_NAME; DDSDomainParticipant::get_builtin_subscriber

virtual DDS_ReturnCode_t DDSDomainParticipant::remove_peer ( const char * peer_desc_string )

pure virtual

<<eXtension>> Remove one or more peer participants from the list of peers with which this DDSDomainParticipant will try to communicate.

This method may be called any time after this DDSDomainParticipant has been enabled

Calling this method has the following effects:

If a DDSDomainParticipant was already discovered, it will be locally removed along with all its entities.
Any further requests coming from a DDSDomainParticipant located on any of the removed peers will be ignored.
All the locators contained in the peer description will be removed from the peer list. The local DDSDomainParticipant will stop sending announcement to those locators.

If remote participants located on a peer that was previously removed are discovered, they will be ignored untill the related peer is added back by using DDSDomainParticipant::add_peer.

Removing a peer description with this method has no effect on the DDS_DiscoveryQosPolicy::initial_peers that may be subsequently retrieved with DDSDomainParticipant::get_qos() (because DDS_DiscoveryQosPolicy is immutable).

Parameters

peer_desc_string <<in>> Peer descriptor to be removed. The format is specified in Peer Descriptor Format.

Returns: One of the Standard Return Codes

See Also: Peer Descriptor Format; DDS_DiscoveryQosPolicy::initial_peers; DDSDomainParticipant::add_peer

virtual DDS_ReturnCode_t DDSDomainParticipant::set_listener	(	DDSDomainParticipantListener *	l,
		DDS_StatusMask	mask = `DDS_STATUS_MASK_ALL`
	)

pure virtual

Sets the participant listener.

Parameters

l	<<in>> Listener to be installed on entity.
mask	<<in>> Changes of communication status to be invoked on the listener. See DDS_StatusMask.

MT Safety:: Unsafe. This method is not synchronized with the listener callbacks, so it is possible to set a new listener on a participant when the old listener is in a callback.

Care should therefore be taken not to delete any listener that has been set on an enabled participant unless some application-specific means are available of ensuring that the old listener cannot still be in use.

Returns: One of the Standard Return Codes

See Also: set_listener (abstract)

virtual DDSDomainParticipantListener* DDSDomainParticipant::get_listener ( )

pure virtual

Get the participant listener.

Returns: Existing listener attached to the DDSDomainParticipant.

See Also: get_listener (abstract)

virtual DDSPublisher* DDSDomainParticipant::get_implicit_publisher ( )

pure virtual

<<eXtension>> Returns the implicit DDSPublisher. If an implicit Publisher does not already exist, this creates one.

There can only be one implicit Publisher per DomainParticipant.

The implicit Publisher is created with DDS_PUBLISHER_QOS_DEFAULT and no Listener.

This implicit Publisher will be deleted automatically when the following methods are called: DDSDomainParticipant::delete_contained_entities, or DDSDomainParticipant::delete_publisher with the implicit publisher as a parameter. Additionally, when a DomainParticipant is deleted, if there are no attached DataWriters that belong to the implicit Publisher, the implicit Publisher will be implicitly deleted.

MT Safety:: UNSAFE. It is not safe to create an implicit Publisher while another thread may be simultaneously calling DDSDomainParticipant::set_default_publisher_qos.

Returns: The implicit publisher

See Also: DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_publisher

virtual DDSSubscriber* DDSDomainParticipant::get_implicit_subscriber ( )

pure virtual

<<eXtension>> Returns the implicit DDSSubscriber. If an implicit Subscriber does not already exist, this creates one.

There can only be one implicit Subscriber per DomainParticipant.

The implicit Subscriber is created with DDS_SUBSCRIBER_QOS_DEFAULT and no Listener.

This implicit Subscriber will be deleted automatically when the following methods are called: DDSDomainParticipant::delete_contained_entities, or DDSDomainParticipant::delete_subscriber with the subscriber as a parameter. Additionally, when a DomainParticipant is deleted, if there are no attached DataReaders that belong to the implicit Subscriber, the implicit Subscriber will be implicitly deleted.

MT Safety:: UNSAFE. it is not safe to create the implicit subscriber while another thread may be simultaneously calling DDSDomainParticipant::set_default_subscriber_qos.

Returns: The implicit subscriber

See Also: DDS_PUBLISHER_QOS_DEFAULT; DDSDomainParticipant::create_subscriber

virtual DDSDataWriter* DDSDomainParticipant::create_datawriter	(	DDSTopic *	topic,
		const DDS_DataWriterQos &	qos,
		DDSDataWriterListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a DDSDataWriter that will be attached and belong to the implicit DDSPublisher.

Precondition: The given DDSTopic must have been created from the same DomainParticipant as the implicit Publisher. If it was created from a different DomainParticipant, this method will fail.

The DDSDataWriter created using this method will be associated with the implicit Publisher. This Publisher is automatically created (if it does not exist) using DDS_PUBLISHER_QOS_DEFAULT when the following methods are called: DDSDomainParticipant::create_datawriter, DDSDomainParticipant::create_datawriter_with_profile, or DDSDomainParticipant::get_implicit_publisher.

MT Safety:: UNSAFE. If DDS_DATAWRITER_QOS_DEFAULT is used for the qos parameter, it is not safe to create the DataWriter while another thread may be simultaneously calling DDSDomainParticipant::set_default_datawriter_qos.

Parameters

topic	<<in>> The DDSTopic that the DDSDataWriter will be associated with.
qos	<<in>> QoS to be used for creating the new DDSDataWriter. The special value DDS_DATAWRITER_QOS_DEFAULT can be used to indicate that the DDSDataWriter should be created with the default DDS_DataWriterQos set in the implicit DDSPublisher. The special value DDS_DATAWRITER_QOS_USE_TOPIC_QOS can be used to indicate that the DDSDataWriter should be created with the combination of the default DDS_DataWriterQos set on the DDSPublisher and the DDS_TopicQos of the DDSTopic.
listener	<<in>> The listener of the DDSDataWriter.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: A DDSDataWriter of a derived class specific to the data type associated with the DDSTopic or NULL if an error occurred.

See Also: FooDataWriter; Specifying QoS on entities for information on setting QoS before entity creation; DDS_DataWriterQos for rules on consistency among QoS; DDS_DATAWRITER_QOS_DEFAULT; DDS_DATAWRITER_QOS_USE_TOPIC_QOS; DDSDomainParticipant::create_datawriter_with_profile; DDSDomainParticipant::get_default_datawriter_qos; DDSDomainParticipant::get_implicit_publisher; DDSTopic::set_qos; DDSDataWriter::set_listener

virtual DDSDataWriter* DDSDomainParticipant::create_datawriter_with_profile	(	DDSTopic *	topic,
		const char *	library_name,
		const char *	profile_name,
		DDSDataWriterListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a DDSDataWriter using a XML QoS profile that will be attached and belong to the implicit DDSPublisher.

Precondition: The given DDSTopic must have been created from the same DomainParticipant as the implicit Publisher. If it was created from a different DomainParticipant, this method will return NULL.

The DDSDataWriter created using this method will be associated with the implicit Publisher. This Publisher is automatically created (if it does not exist) using DDS_PUBLISHER_QOS_DEFAULT when the following methods are called: DDSDomainParticipant::create_datawriter, DDSDomainParticipant::create_datawriter_with_profile, or DDSDomainParticipant::get_implicit_publisher

Parameters

topic	<<in>> The DDSTopic that the DDSDataWriter will be associated with.
library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).
listener	<<in>> The listener of the DDSDataWriter.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: A DDSDataWriter of a derived class specific to the data type associated with the DDSTopic or NULL if an error occurred.

See Also: FooDataWriter; Specifying QoS on entities for information on setting QoS before entity creation; DDS_DataWriterQos for rules on consistency among QoS; DDSDomainParticipant::create_datawriter; DDSDomainParticipant::get_default_datawriter_qos; DDSDomainParticipant::get_implicit_publisher; DDSTopic::set_qos; DDSDataWriter::set_listener

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_datawriter ( DDSDataWriter * a_datawriter )

pure virtual

<<eXtension>> Deletes a DDSDataWriter that belongs to the implicit DDSPublisher.

The deletion of the DDSDataWriter will automatically unregister all instances. Depending on the settings of the WRITER_DATA_LIFECYCLE QosPolicy, the deletion of the DDSDataWriter may also dispose all instances.

Special Instructions if Using 'Timestamp' APIs and BY_SOURCE_TIMESTAMP Destination Ordering:

If the DataWriter's DDS_DestinationOrderQosPolicy::kind is DDS_BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS, calls to delete_datawriter() may fail if your application has previously used the 'with timestamp' APIs (write_w_timestamp(), register_instance_w_timestamp(), unregister_instance_w_timestamp(), or dispose_w_timestamp()) with a timestamp larger (later) than the time at which delete_datawriter() is called. To prevent delete_datawriter() from failing in this situation, either:

Change the WRITER_DATA_LIFECYCLE QosPolicy so that RTI Connext will not autodispose unregistered instances (set DDS_WriterDataLifecycleQosPolicy::autodispose_unregistered_instances to DDS_BOOLEAN_FALSE.) or
Explicitly call unregister_instance_w_timestamp() for all instances modified with the *_w_timestamp() APIs before calling delete_datawriter().

Precondition: If the DDSDataWriter does not belong to the implicit DDSPublisher, the operation will fail with DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: Listener installed on the DDSDataWriter will not be called after this method completes successfully.

Parameters

a_datawriter <<in>> The DDSDataWriter to be deleted.

Returns: One of the Standard Return Codes or DDS_RETCODE_PRECONDITION_NOT_MET.

See Also: DDSDomainParticipant::get_implicit_publisher

virtual DDSDataReader* DDSDomainParticipant::create_datareader	(	DDSTopicDescription *	topic,
		const DDS_DataReaderQos &	qos,
		DDSDataReaderListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a DDSDataReader that will be attached and belong to the implicit DDSSubscriber.

Precondition: The given DDSTopicDescription must have been created from the same DomainParticipant as the implicit Subscriber. If it was created from a different DomainParticipant, this method will return NULL.

The DDSDataReader created using this method will be associated with the implicit Subscriber. This Subscriber is automatically created (if it does not exist) using DDS_SUBSCRIBER_QOS_DEFAULT when the following methods are called: DDSDomainParticipant::create_datareader, DDSDomainParticipant::create_datareader_with_profile, or DDSDomainParticipant::get_implicit_subscriber.

MT Safety:: UNSAFE. If DDS_DATAREADER_QOS_DEFAULT is used for the qos parameter, it is not safe to create the datareader while another thread may be simultaneously calling DDSDomainParticipant::set_default_datareader_qos.

Parameters

topic	<<in>> The DDSTopicDescription that the DDSDataReader will be associated with.
qos	<<in>> The qos of the DDSDataReader. The special value DDS_DATAREADER_QOS_DEFAULT can be used to indicate that the DDSDataReader should be created with the default DDS_DataReaderQos set in the implicit DDSSubscriber. If DDSTopicDescription is of type DDSTopic or DDSContentFilteredTopic, the special value DDS_DATAREADER_QOS_USE_TOPIC_QOS can be used to indicate that the DDSDataReader should be created with the combination of the default DDS_DataReaderQos set on the implicit DDSSubscriber and the DDS_TopicQos (in the case of a DDSContentFilteredTopic, the DDS_TopicQos of the related DDSTopic). if DDS_DATAREADER_QOS_USE_TOPIC_QOS is used, `topic` cannot be a DDSMultiTopic.
listener	<<in>> The listener of the DDSDataReader.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: A DDSDataReader of a derived class specific to the data-type associated with the DDSTopic or NULL if an error occurred.

See Also: FooDataReader; Specifying QoS on entities for information on setting QoS before entity creation; DDS_DataReaderQos for rules on consistency among QoS; DDSDomainParticipant::create_datareader_with_profile; DDSDomainParticipant::get_default_datareader_qos; DDSDomainParticipant::get_implicit_subscriber; DDSTopic::set_qos; DDSDataReader::set_listener

virtual DDSDataReader* DDSDomainParticipant::create_datareader_with_profile	(	DDSTopicDescription *	topic,
		const char *	library_name,
		const char *	profile_name,
		DDSDataReaderListener *	listener,
		DDS_StatusMask	mask
	)

pure virtual

<<eXtension>> Creates a DDSDataReader using a XML QoS profile that will be attached and belong to the implicit DDSSubscriber.

Precondition: The given DDSTopicDescription must have been created from the same DomainParticipant as the implicit subscriber. If it was created from a different DomainParticipant, this method will return NULL.

The DDSDataReader created using this method will be associated with the implicit Subscriber. This Subscriber is automatically created (if it does not exist) using DDS_SUBSCRIBER_QOS_DEFAULT when the following methods are called: DDSDomainParticipant::create_datareader, DDSDomainParticipant::create_datareader_with_profile, or DDSDomainParticipant::get_implicit_subscriber

Parameters

topic	<<in>> The DDSTopicDescription that the DDSDataReader will be associated with.
library_name	<<in>> Library name containing the XML QoS profile. If library_name is null RTI Connext will use the default library (see DDSDomainParticipant::set_default_library).
profile_name	<<in>> XML QoS Profile name. If profile_name is null RTI Connext will use the default profile (see DDSDomainParticipant::set_default_profile).
listener	<<in>> The listener of the DDSDataReader.
mask	<<in>>. Changes of communication status to be invoked on the listener. See DDS_StatusMask.

Returns: A DDSDataReader of a derived class specific to the data-type associated with the DDSTopic or NULL if an error occurred.

See Also: FooDataReader; Specifying QoS on entities for information on setting QoS before entity creation; DDS_DataReaderQos for rules on consistency among QoS; DDSDomainParticipant::create_datareader; DDSDomainParticipant::get_default_datareader_qos; DDSDomainParticipant::get_implicit_subscriber; DDSTopic::set_qos; DDSDataReader::set_listener

virtual DDS_ReturnCode_t DDSDomainParticipant::delete_datareader ( DDSDataReader * a_datareader )

pure virtual

<<eXtension>> Deletes a DDSDataReader that belongs to the implicit DDSSubscriber.

Precondition: If the DDSDataReader does not belong to the implicit DDSSubscriber, or if ther are any existing DDSReadCondition or DDSQueryCondition objects that are attached to the DDSDataReader, or if there are outstanding loans on samples (as a result of a call to read(), take(), or one of the variants thereof), the operation fails with the error DDS_RETCODE_PRECONDITION_NOT_MET.

Postcondition: Listener installed on the DDSDataReader will not be called after this method completes successfully.

Parameters

a_datareader <<in>> The DDSDataReader to be deleted.

Returns: One of the Standard Return Codes or DDS_RETCODE_PRECONDITION_NOT_MET.

See Also: DDSDomainParticipant::get_implicit_subscriber

virtual DDSPublisher* DDSDomainParticipant::lookup_publisher_by_name ( const char * publisher_name )

pure virtual

st_ext Looks up a DDSPublisher by its entity name within this DDSDomainParticipant.

Every DDSPublisher in the system has an entity name which is configured and stored in the GROUP_DATA policy. The use of the GROUP_DATA to store the entity name is a temporary situation while the feature is in experimental state.

This operation retrieves a DDSPublisher within the DDSDomainParticipant given the entity's name. If there are several DDSPublisher with the same name within the DDSDomainParticipant, this function returns the first matching occurrence.

Parameters

publisher_name <<in>> Entity name of the DDSPublisher.

Returns: The first DDSPublisher found with the specified name or NULL if it is not found.

See Also: DDSDomainParticipant::lookup_datawriter_by_name

virtual DDSSubscriber* DDSDomainParticipant::lookup_subscriber_by_name ( const char * subscriber_name )

pure virtual

<<eXtension>> Retrieves a DDSSubscriber by its entity name within this DDSDomainParticipant.

Every DDSSubscriber in the system has an entity name which is configured and stored in the GROUP_DATA policy. The use of the GROUP_DATA to store the entity name is a temporary situation while the function is in experimental state.

This operation retrieves a DDSSubscriber within the DDSDomainParticipant given the entity's name. If there are several DDSSubscriber with the same name within the DDSDomainParticipant, this function returns the first matching occurrence.

Parameters

subscriber_name <<in>> Entity name of the DDSSubscriber.

Returns: The first DDSSubscriber found with the specified name or NULL if it is not found.

See Also: DDSDomainParticipant::lookup_datareader_by_name

virtual DDSDataWriter* DDSDomainParticipant::lookup_datawriter_by_name ( const char * datawriter_full_name )

pure virtual

<<eXtension>> Looks up a DDSDataWriter by its entity name within this DDSDomainParticipant.

Every DDSDataWriter in the system has an entity name which is configured and stored in the EntityName policy, ENTITY_NAME.

Every DDSPublisher in the system has an entity name which is configured and stored in the <<eXtension>> GROUP_DATA policy. This is a temporary situation situation while the function is in experimental state.

This operation retrieves a DDSDataWriter within a DDSPublisher given the specified name which encodes both to the DDSDataWriter and the DDSPublisher name.

The specified name might be given as a fully-qualified entity name or as a plain name.

The fully qualified entity name is a concatenation of the DDSPublisher to which the DDSDataWriter belongs and the entity name of of the DDSDataWriter itself, separated by a double colon "::". For example: MyPublisherName::MyDataWriterName

The plain name contains the DDSDataWriter name only. In this situation it is implied that the DDSDataWriter belongs to the implicit DDSPublisher so the use of a plain name is equivalent to specifying a fully qualified name with the DDSPublisher name part being "implicit". For example: the plain name "MyDataWriterName" is equivalent to specifiying the fully qualified name "implicit::MyDataWriterName"

The DDSDataWriter is only looked up within the DDSPublisher specified in the fully qualified name, or within the implicit DDSPublisher if the name was not fully qualified.

If there are several DDSDataWriter with the same name within the corresponding DDSPublisher this function returns the first matching occurrence.

Parameters

datawriter_full_name <<in>> Entity name or fully-qualified entity name of the DDSDataWriter.

Returns: The first DDSDataWriter found with the specified name or NULL if it is not found.

See Also: DDSPublisher::lookup_datawriter_by_name; DDSDomainParticipant::lookup_publisher_by_name

virtual DDSDataReader* DDSDomainParticipant::lookup_datareader_by_name ( const char * datareader_full_name )

pure virtual

st_ext Retrieves up a DDSDataReader by its entity name in this DDSDomainParticipant.

Every DDSDataReader in the system has an entity name which is configured and stored in the EntityName policy, ENTITY_NAME.

Every DDSSubscriber in the system has an entity name which is configured and stored in the <<eXtension>> GROUP_DATA policy. This is a temporary situation situation while the function is in experimental state.

This operation retrieves a DDSDataReader within a DDSSubscriber given the specified name which encodes both to the DDSDataReader and the DDSSubscriber name.

The specified name might be given as a fully-qualified entity name or as a plain name.

The fully qualified entity name is a concatenation of the DDSSubscriber to which the DDSDataReader belongs and the entity name of of the DDSDataReader itself, separated by a double colon "::". For example: MySubscriberName::MyDataReaderName

The plain name contains the DDSDataReader name only. In this situation it is implied that the DDSDataReader belongs to the implicit DDSSubscriber so the use of a plain name is equivalent to specifying a fully qualified name with the DDSSubscriber name part being "implicit". For example: the plain name "MyDataReaderName" is equivalent to specifiying the fully qualified name "implicit::MyDataReaderName"

The DDSDataReader is only looked up within the DDSSubscriber specified in the fully qualified name, or within the implicit DDSSubscriber if the name was not fully qualified.

If there are several DDSDataReader with the same name within the corresponding DDSSubscriber this function returns the first matching occurrence.

Parameters

datareader_full_name <<in>> Full entity name of the DDSDataReader.

Returns: The first DDSDataReader found with the specified name or NULL if it is not found.

See Also: DDSSubscriber::lookup_datareader_by_name; DDSDomainParticipant::lookup_subscriber_by_name

Public Member Functions

Detailed Description

Member Function Documentation

Special Instructions if Using 'Timestamp' APIs and BY_SOURCE_TIMESTAMP Destination Ordering: