RTI Connext Modern C++ API Version 7.2.0
|
<<extension>> Extensions to dds::pub More...
Classes | |
class | AcknowledgmentInfo |
<<extension>> <<value-type>> Information about an application-acknowledged sample More... | |
class | FlowController |
<<extension>> <<reference-type>> A flow controller is the object responsible for shaping the network traffic by determining when attached asynchronous dds::pub::DataWriter instances are allowed to write data. More... | |
class | FlowControllerProperty |
<<extension>> <<value-type>> Configures a FlowController More... | |
struct | FlowControllerSchedulingPolicy_def |
<<extension>> Kinds of flow controller shceduling policy More... | |
class | FlowControllerTokenBucketProperty |
<<extension>> <<value-type>> Configures a FlowController based on a tocken-bucket mechanism More... | |
class | WriteParams |
<<extension>> <<value-type>> Advanced parameters for writing with a DataWriter More... | |
Typedefs | |
typedef dds::core::safe_enum< FlowControllerSchedulingPolicy_def > | FlowControllerSchedulingPolicy |
<<extension>> The safe enumeration for FlowControllerSchedulingPolicy_def::type More... | |
Functions | |
template<typename T > | |
dds::topic::ParticipantBuiltinTopicData | matched_subscription_participant_data (const dds::pub::DataWriter< T > &writer, const dds::core::InstanceHandle &handle) |
<<extension>> This operation retrieves the information on the discovered dds::domain::DomainParticipant associated with the subscription that is currently matching with the dds::pub::DataWriter. More... | |
template<typename T > | |
rti::core::LocatorSeq | matched_subscriptions_locators (const dds::pub::DataWriter< T > &writer) |
<<extension>> Retrieve the list of locators for subscriptions currently associated with this DataWriter. More... | |
template<typename T > | |
bool | is_matched_subscription_active (const dds::pub::DataWriter< T > &writer, const dds::core::InstanceHandle &handle) |
<<extension>> Check if a matched subscription is active. More... | |
template<typename T > | |
std::vector< dds::topic::SubscriptionBuiltinTopicData > | matched_subscription_data (const dds::pub::DataWriter< T > &writer) |
<<extension>> Obtain the SubscriptionBuiltinTopicData for all of the subscriptions matched with a DataWriter. More... | |
template<typename PublisherForwardIterator > | |
uint32_t | find_publishers (const dds::domain::DomainParticipant participant, PublisherForwardIterator begin, uint32_t max_size) |
<<extension>> Retrieve all of the dds::pub::Publisher created from this dds::domain::DomainParticipant More... | |
template<typename PublisherBackInsertIterator > | |
uint32_t | find_publishers (const dds::domain::DomainParticipant participant, PublisherBackInsertIterator begin) |
Retrieve all the dds::pub::Publisher created from this dds::domain::DomainParticipant. More... | |
dds::pub::Publisher | find_publisher (const dds::domain::DomainParticipant participant, const std::string &publisher_name) |
<<extension>> Looks up a dds::pub::Publisher by its entity name within the dds::domain::DomainParticipant. More... | |
template<typename AnyDataWriterBackInsertIterator > | |
uint32_t | find_datawriters (dds::pub::Publisher publisher, AnyDataWriterBackInsertIterator begin) |
Retrieve all the dds::pub::DataWriter created from this dds::pub::Publisher. More... | |
template<typename AnyDataWriterForwardIterator > | |
uint32_t | find_datawriters (dds::pub::Publisher publisher, AnyDataWriterForwardIterator begin, uint32_t max_size) |
Retrieve all the dds::pub::DataWriter created from this dds::pub::Publisher. More... | |
template<typename Writer > | |
Writer | find_datawriter_by_topic_name (dds::pub::Publisher publisher, const std::string &topic_name) |
<<extension>> Retrieves a dds::pub::DataWriter with the given name within the dds::pub::Publisher More... | |
template<typename Writer > | |
Writer | find_datawriter_by_name (dds::pub::Publisher publisher, const std::string &datawriter_name) |
<<extension>> Retrieves a dds::pub::DataWriter with the given name within the dds::pub::Publisher More... | |
template<typename Writer > | |
Writer | find_datawriter_by_name (dds::domain::DomainParticipant participant, const std::string &datawriter_name) |
<<extension>> Retrieves a dds::pub::DataWriter within the dds::domain::DomainParticipant with the given name More... | |
dds::pub::Publisher | implicit_publisher (const dds::domain::DomainParticipant &dp) |
<<extension>> Get the implicit dds::pub::Publisher for a given dds::domain::DomainParticipant. More... | |
FlowController | find_flow_controller (dds::domain::DomainParticipant participant, const std::string &name) |
Retrieves an existing FlowController. More... | |
<<extension>> Extensions to dds::pub
dds::topic::ParticipantBuiltinTopicData rti::pub::matched_subscription_participant_data | ( | const dds::pub::DataWriter< T > & | writer, |
const dds::core::InstanceHandle & | handle | ||
) |
<<extension>> This operation retrieves the information on the discovered dds::domain::DomainParticipant associated with the subscription that is currently matching with the dds::pub::DataWriter.
The subscription_handle
must correspond to a subscription currently associated with the dds::pub::DataWriter. Otherwise, the operation will fail with dds::core::InvalidArgumentError. The operation may also fail with dds::core::PreconditionNotMetError if the subscription corresponds to the same dds::domain::DomainParticipant that the DataWriter belongs to. Use dds::pub::matched_subscriptions() to find the subscriptions that are currently matched with the dds::pub::DataWriter.
One | of the Standard Exceptions, or dds::core::NotEnabledError |
T | The topic-type that the DataWriter subscribes to |
writer | The writer to lookup the matched participant data of |
handle | The InstanceHandle to a specific subscription. Must correspond to a subscription currently associated with the DataWriter. |
rti::core::LocatorSeq rti::pub::matched_subscriptions_locators | ( | const dds::pub::DataWriter< T > & | writer | ) |
<<extension>> Retrieve the list of locators for subscriptions currently associated with this DataWriter.
The locators returned are the ones that are used by the DDS implementation to communicate with the corresponding matched DataReaders.
T | The topic-type that the DataWriter publishes. |
writer | The DataWriter. |
bool rti::pub::is_matched_subscription_active | ( | const dds::pub::DataWriter< T > & | writer, |
const dds::core::InstanceHandle & | handle | ||
) |
<<extension>> Check if a matched subscription is active.
T | The topic-type that the DataWriter publishes. |
writer | The DataWriter. |
handle | The dds::core::InstanceHandle of the matched subscription. |
This API is used for querying the endpoint liveliness of a matched subscription. A matched subscription will be marked as inactive when it becomes nonprogessing (e.g., not responding to a DataWriter's heartbeats, or letting its internal queue fill up without taking the available data). Note that if the participant associated with the matched subscription loses liveliness, the dds::core::InstanceHandle will become invalid and this function will fail with dds::core::InvalidArgumentError.
std::vector< dds::topic::SubscriptionBuiltinTopicData > rti::pub::matched_subscription_data | ( | const dds::pub::DataWriter< T > & | writer | ) |
<<extension>> Obtain the SubscriptionBuiltinTopicData for all of the subscriptions matched with a DataWriter.
This API retrieves the matched publication data from all of the subscriptions currently matched a DataWriter.
T | The topic-type that the DataWriter publishes. |
writer | The DataWriter. |
uint32_t rti::pub::find_publishers | ( | const dds::domain::DomainParticipant | participant, |
PublisherForwardIterator | begin, | ||
uint32_t | max_size | ||
) |
<<extension>> Retrieve all of the dds::pub::Publisher created from this dds::domain::DomainParticipant
PublisherForwardIterator | A forward iterator whose value type is dds::pub::Publisher |
participant | The dds::domain::DomainParticipant the Publishers belong to |
begin | A forward iterator to the position in the destination container to insert the found Publishers into |
max_size | The maximum number of Publishers to add |
uint32_t rti::pub::find_publishers | ( | const dds::domain::DomainParticipant | participant, |
PublisherBackInsertIterator | begin | ||
) |
Retrieve all the dds::pub::Publisher created from this dds::domain::DomainParticipant.
PublisherBackInsertIterator | A back-inserting iterator whose value type is dds::pub::Publisher |
participant | The dds::domain::DomainParticipant the Publishers belong to |
begin | A back-inserting iterator to the position in the destination container to insert the found Publishers in |
dds::pub::Publisher rti::pub::find_publisher | ( | const dds::domain::DomainParticipant | participant, |
const std::string & | publisher_name | ||
) |
<<extension>> Looks up a dds::pub::Publisher by its entity name within the dds::domain::DomainParticipant.
Every dds::pub::Publisher in the system has an entity name which is configured and stored in the EntityName policy, ENTITY_NAME.
This operation retrieves a dds::pub::Publisher within the dds::domain::DomainParticipant given the entity's name. If there are several dds::pub::Publisher with the same name within the dds::domain::DomainParticipant, this function returns the first matching occurrence.
participant | The dds::domain::DomainParticipant to look for the dds::pub::Publisher in. |
publisher_name | Entity name of the Publisher |
uint32_t rti::pub::find_datawriters | ( | dds::pub::Publisher | publisher, |
AnyDataWriterBackInsertIterator | begin | ||
) |
Retrieve all the dds::pub::DataWriter created from this dds::pub::Publisher.
rti::pub
AnyDataWriterBackInsertIterator | An iterator whose value_type is dds::pub::AnyDataWriter |
publisher | The dds::pub::Publisher the DataWriters belong to |
begin | A back-inserting iterator to the position in the destination container to insert the found DataWriters into |
uint32_t rti::pub::find_datawriters | ( | dds::pub::Publisher | publisher, |
AnyDataWriterForwardIterator | begin, | ||
uint32_t | max_size | ||
) |
Retrieve all the dds::pub::DataWriter created from this dds::pub::Publisher.
AnyDataWriterForwardIterator | An iterator whose value_type is dds::pub::AnyDataWriter |
publisher | The dds::pub::Publisher the DataWriters belong to |
begin | A forward iterator to the first position in the destination container to copy the found DataWriters into |
max_size | The maximum number of DataWriters to return |
Writer rti::pub::find_datawriter_by_topic_name | ( | dds::pub::Publisher | publisher, |
const std::string & | topic_name | ||
) |
<<extension>> Retrieves a dds::pub::DataWriter with the given name within the dds::pub::Publisher
Every dds::pub::DataWriter in the system has an entity name which is configured and stored in the <<extension>> EntityName policy, ENTITY_NAME.
This operation retrieves the dds::pub::DataWriter within the dds::pub::Publisher whose name matches the one specified. If there are several dds::pub::DataWriter with the same name within the dds::pub::Publisher, the operation returns the first matching occurrence.
Writer | The type of the writer. It can be dds::pub::AnyDataWriter, or an instantiation of dds::pub::DataWriter<T> (if T is not the correct type, this function throws dds::core::InvalidDowncastError) |
publisher | The dds::pub::Publisher that created the DataWriter to find |
topic_name | Entity name of the DataWriter to find |
Writer rti::pub::find_datawriter_by_name | ( | dds::pub::Publisher | publisher, |
const std::string & | datawriter_name | ||
) |
<<extension>> Retrieves a dds::pub::DataWriter with the given name within the dds::pub::Publisher
Every dds::pub::DataWriter in the system has an entity name which is configured and stored in the <<extension>> EntityName policy, ENTITY_NAME.
This operation retrieves the dds::pub::DataWriter within the dds::pub::Publisher whose name matches the one specified. If there are several dds::pub::DataWriter with the same name within the dds::pub::Publisher, the operation returns the first matching occurrence.
Writer | The type of the writer. It can be dds::pub::AnyDataWriter, or an instantiation of dds::pub::DataWriter<T> (if T is not the correct type, this function throws dds::core::InvalidDowncastError) |
publisher | The dds::pub::Publisher that created the DataWriter to find |
datawriter_name | Entity name of the DataWriter to find |
Writer rti::pub::find_datawriter_by_name | ( | dds::domain::DomainParticipant | participant, |
const std::string & | datawriter_name | ||
) |
<<extension>> Retrieves a dds::pub::DataWriter within the dds::domain::DomainParticipant with the given name
Every dds::pub::DataWriter in the system has an entity name which is configured and stored in the EntityName policy, ENTITY_NAME.
Every dds::pub::Publisher in the system has an entity name which is also configured and stored in the EntityName policy.
This operation retrieves a dds::pub::DataWriter within a dds::pub::Publisher given the specified name which encodes both to the dds::pub::DataWriter and the dds::pub::Publisher name.
If there are several dds::pub::DataWriter with the same name within the corresponding dds::pub::Publisher this function returns the first matching occurrence.
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 dds::pub::Publisher to which the dds::pub::DataWriter belongs and the entity name of of the dds::pub::DataWriter itself, separated by a double colon "::". For example: MyPublisherName::MyDataWriterName
The plain name contains the dds::pub::DataWriter name only. In this situation it is implied that the dds::pub::DataWriter belongs to the implicit dds::pub::Publisher so the use of a plain name is equivalent to specifying a fully qualified name with the dds::pub::Publisher name part being "implicit". For example: the plain name "MyDataWriterName" is equivalent to specifiying the fully qualified name "implicit::MyDataWriterName"
The dds::pub::DataWriter is only looked up within the dds::pub::Publisher specified in the fully qualified name, or within the implicit dds::pub::Publisher if the name was not fully qualified.
Writer | The type of the writer. It can be dds::pub::AnyDataWriter, or an instantiation of dds::pub::DataWriter<T> (if T is not the correct type, this function throws dds::core::InvalidDowncastError) |
participant | The dds::domain::DomainParticipant within which the dds::pub::DataWriter exists |
datawriter_name | EntityName of the DataWriter to find |
dds::pub::Publisher rti::pub::implicit_publisher | ( | const dds::domain::DomainParticipant & | dp | ) |
<<extension>> Get the implicit dds::pub::Publisher for a given dds::domain::DomainParticipant.
If an implicit Publisher does not already exist, this creates one.
The implicit Publisher is created with default dds::pub::qos::PublisherQos and no listener. When a DomainParticipant is deleted, if there are no attached dds::pub::DataWriter that belong to the implicit Publisher, the implicit Publisher will be implicitly deleted.
dp | The DomainParticipant that the implicit publisher belongs to |
FlowController find_flow_controller | ( | dds::domain::DomainParticipant | participant, |
const std::string & | name | ||
) |
Retrieves an existing FlowController.
participant | The DomainParticipant associated to the FlowController |
name | The name used to create the FlowController or the name of one of the built-in FlowControllers (FlowController::DEFAULT_NAME, FlowController::FIXED_RATE_NAME, FlowController::ON_DEMAND_NAME) |