RTI Connext C++ API  Version 5.1.0
DDSKeyedOctetsDataReader Class Reference

<<interface>> Instantiates DataReader < DDS_KeyedOctets >. More...

Inheritance diagram for DDSKeyedOctetsDataReader:
DDSDataReader DDSDomainEntity DDSEntity

Public Member Functions

virtual DDS_ReturnCode_t read (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t take (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data-samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t read_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples, DDSReadCondition *condition)
 Accesses via DDSKeyedOctetsDataReader::read the samples that match the criteria specified in the DDSReadCondition.
 
virtual DDS_ReturnCode_t take_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples, DDSReadCondition *condition)
 Analogous to DDSKeyedOctetsDataReader::read_w_condition except it accesses samples via the DDSKeyedOctetsDataReader::take operation.
 
virtual DDS_ReturnCode_t read_next_sample (DDS_KeyedOctets &received_data, DDS_SampleInfo &sample_info)
 Copies the next not-previously-accessed data value from the DDSDataReader.
 
virtual DDS_ReturnCode_t take_next_sample (DDS_KeyedOctets &received_data, DDS_SampleInfo &sample_info)
 Copies the next not-previously-accessed data value from the DDSDataReader.
 
virtual DDS_ReturnCode_t read_instance (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &a_handle=DDS_HANDLE_NIL, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t take_instance (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &a_handle=DDS_HANDLE_NIL, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t read_instance_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &a_handle=DDS_HANDLE_NIL, DDSReadCondition *condition=NULL)
 Accesses via DDSKeyedOctetsDataReader::read_instance the samples that match the criteria specified in the DDSReadCondition.
 
virtual DDS_ReturnCode_t take_instance_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &a_handle=DDS_HANDLE_NIL, DDSReadCondition *condition=NULL)
 Accesses via DDSKeyedOctetsDataReader::take_instance the samples that match the criteria specified in the DDSReadCondition.
 
virtual DDS_ReturnCode_t read_next_instance (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &previous_handle=DDS_HANDLE_NIL, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t take_next_instance (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &previous_handle=DDS_HANDLE_NIL, DDS_SampleStateMask sample_states=DDS_ANY_SAMPLE_STATE, DDS_ViewStateMask view_states=DDS_ANY_VIEW_STATE, DDS_InstanceStateMask instance_states=DDS_ANY_INSTANCE_STATE)
 Access a collection of data samples from the DDSDataReader.
 
virtual DDS_ReturnCode_t read_next_instance_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &previous_handle=DDS_HANDLE_NIL, DDSReadCondition *condition=NULL)
 Accesses via DDSKeyedOctetsDataReader::read_next_instance the samples that match the criteria specified in the DDSReadCondition.
 
virtual DDS_ReturnCode_t take_next_instance_w_condition (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq, DDS_Long max_samples=DDS_LENGTH_UNLIMITED, const DDS_InstanceHandle_t &previous_handle=DDS_HANDLE_NIL, DDSReadCondition *condition=NULL)
 Accesses via DDSKeyedOctetsDataReader::take_next_instance the samples that match the criteria specified in the DDSReadCondition.
 
virtual DDS_ReturnCode_t return_loan (DDS_KeyedOctetsSeq &received_data, DDS_SampleInfoSeq &info_seq)
 Indicates to the DDSDataReader that the application is done accessing the collection of received_data and info_seq obtained by some earlier invocation of read or take on the DDSDataReader.
 
virtual DDS_ReturnCode_t get_key_value (DDS_KeyedOctets &key_holder, const DDS_InstanceHandle_t &handle)
 Retrieve the instance key that corresponds to an instance handle.
 
virtual DDS_ReturnCode_t get_key_value (char *key, const DDS_InstanceHandle_t &handle)
 <<eXtension>> Retrieve the instance key that corresponds to an instance handle.
 
virtual DDS_InstanceHandle_t lookup_instance (const DDS_KeyedOctets &key_holder)
 Retrieve the instance handle that corresponds to an instance key_holder.
 
virtual DDS_InstanceHandle_t lookup_instance (const char *key)
 <<eXtension>> Retrieve the instance handle that corresponds to an instance key.
 
- Public Member Functions inherited from DDSDataReader
virtual DDSReadConditioncreate_readcondition (DDS_SampleStateMask sample_states, DDS_ViewStateMask view_states, DDS_InstanceStateMask instance_states)
 Creates a DDSReadCondition.
 
virtual DDSQueryConditioncreate_querycondition (DDS_SampleStateMask sample_states, DDS_ViewStateMask view_states, DDS_InstanceStateMask instance_states, const char *query_expression, const struct DDS_StringSeq &query_parameters)
 Creates a DDSQueryCondition.
 
virtual DDS_ReturnCode_t delete_readcondition (DDSReadCondition *condition)
 Deletes a DDSReadCondition or DDSQueryCondition attached to the DDSDataReader.
 
virtual DDS_ReturnCode_t delete_contained_entities ()
 Deletes all the entities that were created by means of the "create" operations on the DDSDataReader.
 
virtual DDS_ReturnCode_t wait_for_historical_data (const DDS_Duration_t &max_wait)
 Waits until all "historical" data is received for DDSDataReader entities that have a non-VOLATILE Durability Qos kind.
 
virtual DDS_ReturnCode_t acknowledge_sample (const DDS_SampleInfo &sample_info)
 Acknowledge a single sample explicitly.
 
virtual DDS_ReturnCode_t acknowledge_all ()
 Acknowledge all previously accessed samples.
 
virtual DDS_ReturnCode_t acknowledge_sample (const DDS_SampleInfo &sample_info, const DDS_AckResponseData_t &response_data)
 [Not supported.] Acknowledge a single sample explicitly
 
virtual DDS_ReturnCode_t acknowledge_all (const DDS_AckResponseData_t &response_data)
 [Not supported.] Acknowledge all previously accessed samples
 
virtual DDS_ReturnCode_t get_matched_publications (DDS_InstanceHandleSeq &publication_handles)
 Retrieve the list of publications currently "associated" with this DDSDataReader.
 
virtual DDS_ReturnCode_t get_matched_publication_data (DDS_PublicationBuiltinTopicData &publication_data, const DDS_InstanceHandle_t &publication_handle)
 This operation retrieves the information on a publication that is currently "associated" with the DDSDataReader.
 
virtual DDS_ReturnCode_t get_matched_publication_participant_data (DDS_ParticipantBuiltinTopicData &participant_data, const DDS_InstanceHandle_t &publication_handle)
 This operation retrieves the information on the discovered DDSDomainParticipant associated with the publication that is currently matching with the DDSDataReader.
 
virtual DDSTopicDescriptionget_topicdescription ()
 Returns the DDSTopicDescription associated with the DDSDataReader.
 
virtual DDSSubscriberget_subscriber ()
 Returns the DDSSubscriber to which the DDSDataReader belongs.
 
virtual DDS_ReturnCode_t get_sample_rejected_status (DDS_SampleRejectedStatus &status)
 Accesses the DDS_SAMPLE_REJECTED_STATUS communication status.
 
virtual DDS_ReturnCode_t get_liveliness_changed_status (DDS_LivelinessChangedStatus &status)
 Accesses the DDS_LIVELINESS_CHANGED_STATUS communication status.
 
virtual DDS_ReturnCode_t get_requested_deadline_missed_status (DDS_RequestedDeadlineMissedStatus &status)
 Accesses the DDS_REQUESTED_DEADLINE_MISSED_STATUS communication status.
 
virtual DDS_ReturnCode_t get_requested_incompatible_qos_status (DDS_RequestedIncompatibleQosStatus &status)
 Accesses the DDS_REQUESTED_INCOMPATIBLE_QOS_STATUS communication status.
 
virtual DDS_ReturnCode_t get_sample_lost_status (DDS_SampleLostStatus &status)
 Accesses the DDS_SAMPLE_LOST_STATUS communication status.
 
virtual DDS_ReturnCode_t get_subscription_matched_status (DDS_SubscriptionMatchedStatus &status)
 Accesses the DDS_SUBSCRIPTION_MATCHED_STATUS communication status.
 
virtual DDS_ReturnCode_t get_datareader_cache_status (DDS_DataReaderCacheStatus &status)
 <<eXtension>> Get the datareader cache status for this reader.
 
virtual DDS_ReturnCode_t get_datareader_protocol_status (DDS_DataReaderProtocolStatus &status)
 <<eXtension>> Get the datareader protocol status for this reader.
 
virtual DDS_ReturnCode_t get_matched_publication_datareader_protocol_status (DDS_DataReaderProtocolStatus &status, const DDS_InstanceHandle_t &publication_handle)
 <<eXtension>> Get the datareader protocol status for this reader, per matched publication identified by the publication_handle.
 
virtual DDS_ReturnCode_t set_qos (const DDS_DataReaderQos &qos)
 Sets the reader QoS.
 
virtual DDS_ReturnCode_t get_qos (DDS_DataReaderQos &qos)
 Gets the reader QoS.
 
virtual DDS_ReturnCode_t set_qos_with_profile (const char *library_name, const char *profile_name)
 <<eXtension>> Change the QoS of this reader using the input XML QoS profile.
 
virtual DDS_ReturnCode_t set_listener (DDSDataReaderListener *l, DDS_StatusMask mask=DDS_STATUS_MASK_ALL)
 Sets the reader listener.
 
virtual DDSDataReaderListenerget_listener ()
 Get the reader listener.
 
virtual DDS_ReturnCode_t enable ()
 Enables the DDSEntity.
 
virtual DDSStatusConditionget_statuscondition ()
 Allows access to the DDSStatusCondition associated with the DDSEntity.
 
virtual DDS_StatusMask get_status_changes ()
 Retrieves the list of communication statuses in the DDSEntity that are triggered.
 
virtual DDS_InstanceHandle_t get_instance_handle ()
 Allows access to the DDS_InstanceHandle_t associated with the DDSEntity.
 

Static Public Member Functions

static DDSKeyedOctetsDataReadernarrow (DDSDataReader *reader)
 Narrow the given DDSDataReader pointer to a DDSKeyedOctetsDataReader pointer.
 

Detailed Description

<<interface>> Instantiates DataReader < DDS_KeyedOctets >.

When reading or taking data with this reader, if you request a copy of the samples instead of a loan, and a string or byte array in a destination data sample is NULL, the middleware will allocate a new string or array for you of sufficient length to hold the received data. New strings will be allocated with DDS_String_alloc; new arrays will be allocated with DDS_OctetBuffer_alloc. The sample's destructor will delete them.

A non- NULL string or array is assumed to be allocated to sufficient length to store the incoming data. It will not be reallocated.

See Also
FooDataReader
DDSDataReader

Member Function Documentation

virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data samples from the DDSDataReader.

See Also
FooDataReader::read
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data-samples from the DDSDataReader.

See Also
FooDataReader::take
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples,
DDSReadCondition condition 
)
virtual

Accesses via DDSKeyedOctetsDataReader::read the samples that match the criteria specified in the DDSReadCondition.

See Also
FooDataReader::read_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples,
DDSReadCondition condition 
)
virtual

Analogous to DDSKeyedOctetsDataReader::read_w_condition except it accesses samples via the DDSKeyedOctetsDataReader::take operation.

See Also
FooDataReader::take_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_next_sample ( DDS_KeyedOctets received_data,
DDS_SampleInfo sample_info 
)
virtual

Copies the next not-previously-accessed data value from the DDSDataReader.

See Also
FooDataReader::read_next_sample
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_next_sample ( DDS_KeyedOctets received_data,
DDS_SampleInfo sample_info 
)
virtual

Copies the next not-previously-accessed data value from the DDSDataReader.

See Also
FooDataReader::take_next_sample
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_instance ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t a_handle = DDS_HANDLE_NIL,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data samples from the DDSDataReader.

See Also
FooDataReader::read_instance
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_instance ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t a_handle = DDS_HANDLE_NIL,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data samples from the DDSDataReader.

See Also
FooDataReader::take_instance
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_instance_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t a_handle = DDS_HANDLE_NIL,
DDSReadCondition condition = NULL 
)
virtual

Accesses via DDSKeyedOctetsDataReader::read_instance the samples that match the criteria specified in the DDSReadCondition.

See Also
FooDataReader::read_instance_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_instance_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t a_handle = DDS_HANDLE_NIL,
DDSReadCondition condition = NULL 
)
virtual

Accesses via DDSKeyedOctetsDataReader::take_instance the samples that match the criteria specified in the DDSReadCondition.

See Also
FooDataReader::take_instance_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_next_instance ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t previous_handle = DDS_HANDLE_NIL,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data samples from the DDSDataReader.

See Also
FooDataReader::read_next_instance
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_next_instance ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t previous_handle = DDS_HANDLE_NIL,
DDS_SampleStateMask  sample_states = DDS_ANY_SAMPLE_STATE,
DDS_ViewStateMask  view_states = DDS_ANY_VIEW_STATE,
DDS_InstanceStateMask  instance_states = DDS_ANY_INSTANCE_STATE 
)
virtual

Access a collection of data samples from the DDSDataReader.

See Also
FooDataReader::take_next_instance
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::read_next_instance_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t previous_handle = DDS_HANDLE_NIL,
DDSReadCondition condition = NULL 
)
virtual

Accesses via DDSKeyedOctetsDataReader::read_next_instance the samples that match the criteria specified in the DDSReadCondition.

See Also
FooDataReader::read_next_instance_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::take_next_instance_w_condition ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq,
DDS_Long  max_samples = DDS_LENGTH_UNLIMITED,
const DDS_InstanceHandle_t previous_handle = DDS_HANDLE_NIL,
DDSReadCondition condition = NULL 
)
virtual

Accesses via DDSKeyedOctetsDataReader::take_next_instance the samples that match the criteria specified in the DDSReadCondition.

See Also
FooDataReader::take_next_instance_w_condition
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::return_loan ( DDS_KeyedOctetsSeq received_data,
DDS_SampleInfoSeq info_seq 
)
virtual

Indicates to the DDSDataReader that the application is done accessing the collection of received_data and info_seq obtained by some earlier invocation of read or take on the DDSDataReader.

See Also
FooDataReader::return_loan
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::get_key_value ( DDS_KeyedOctets key_holder,
const DDS_InstanceHandle_t handle 
)
virtual

Retrieve the instance key that corresponds to an instance handle.

See Also
FooDataReader::get_key_value
virtual DDS_ReturnCode_t DDSKeyedOctetsDataReader::get_key_value ( char *  key,
const DDS_InstanceHandle_t handle 
)
virtual

<<eXtension>> Retrieve the instance key that corresponds to an instance handle.

See Also
FooDataReader::get_key_value
virtual DDS_InstanceHandle_t DDSKeyedOctetsDataReader::lookup_instance ( const DDS_KeyedOctets key_holder)
virtual

Retrieve the instance handle that corresponds to an instance key_holder.

See Also
FooDataReader::lookup_instance
virtual DDS_InstanceHandle_t DDSKeyedOctetsDataReader::lookup_instance ( const char *  key)
virtual

<<eXtension>> Retrieve the instance handle that corresponds to an instance key.

See Also
FooDataReader::lookup_instance
static DDSKeyedOctetsDataReader* DDSKeyedOctetsDataReader::narrow ( DDSDataReader reader)
static

Narrow the given DDSDataReader pointer to a DDSKeyedOctetsDataReader pointer.

See Also
FooDataReader::narrow

RTI Connext C++ API Version 5.1.0 Copyright © Mon Feb 3 2014 Real-Time Innovations, Inc