|
| DataReader_T (::DDSDataReader *dr,::DDS::DomainParticipant_ptr dp,::DDS::Subscriber_ptr sub) |
| Constructor. More...
|
|
virtual | ~DataReader_T (void) |
| Destructor. More...
|
|
virtual ::DDS::ReturnCode_t | read (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | take (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | read_w_condition (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples,::DDS::ReadCondition_ptr a_condition) |
|
virtual ::DDS::ReturnCode_t | take_w_condition (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples,::DDS::ReadCondition_ptr a_condition) |
|
virtual ::DDS::ReturnCode_t | read_next_sample (VALUE_TYPE &data_values,::DDS::SampleInfo &sample_info) |
|
virtual ::DDS::ReturnCode_t | take_next_sample (VALUE_TYPE &data_values,::DDS::SampleInfo &sample_info) |
|
virtual ::DDS::ReturnCode_t | read_instance (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &a_handle,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | take_instance (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &a_handle,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | read_next_instance (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &previous_handle,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | take_next_instance (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &previous_handle,::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::ReturnCode_t | read_next_instance_w_condition (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &previous_handle,::DDS::ReadCondition_ptr a_condition) |
|
virtual ::DDS::ReturnCode_t | take_next_instance_w_condition (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos,::CORBA::Long max_samples, const ::DDS::InstanceHandle_t &previous_handle,::DDS::ReadCondition_ptr a_condition) |
|
virtual ::DDS::ReturnCode_t | return_loan (SEQ_TYPE &data_values,::DDS::SampleInfoSeq &sample_infos) |
|
virtual ::DDS::ReturnCode_t | get_key_value (VALUE_TYPE &key_holder, const ::DDS::InstanceHandle_t &handle) |
|
virtual ::DDS::InstanceHandle_t | lookup_instance (const VALUE_TYPE &an_instance) |
|
virtual ::DDS::ReturnCode_t | enable (void) |
|
virtual ::DDS::StatusCondition_ptr | get_statuscondition (void) |
|
virtual ::DDS::StatusMask | get_status_changes (void) |
|
virtual DDS_INSTANCE_HANDLE_T_RETN | get_instance_handle (void) |
|
virtual ::DDS::ReadCondition_ptr | create_readcondition (::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states) |
|
virtual ::DDS::QueryCondition_ptr | create_querycondition (::DDS::SampleStateMask sample_states,::DDS::ViewStateMask view_states,::DDS::InstanceStateMask instance_states, const char *query_expression, const ::DDS::StringSeq &query_parameters) |
|
virtual ::DDS::ReturnCode_t | delete_readcondition (::DDS::ReadCondition_ptr a_condition) |
|
virtual ::DDS::ReturnCode_t | delete_contained_entities (void) |
|
virtual ::DDS::ReturnCode_t | set_qos (const ::DDS::DataReaderQos &qos) |
|
virtual ::DDS::ReturnCode_t | get_qos (::DDS::DataReaderQos &qos) |
|
virtual ::DDS::ReturnCode_t | set_listener (::DDS::DataReaderListener_ptr a_listener,::DDS::StatusMask mask) |
|
virtual
::DDS::DataReaderListener_ptr | get_listener (void) |
|
virtual ::DDS::TopicDescription_ptr | get_topicdescription (void) |
|
virtual ::DDS::Subscriber_ptr | get_subscriber (void) |
|
virtual ::DDS::ReturnCode_t | get_sample_rejected_status (::DDS::SampleRejectedStatus &status) |
|
virtual ::DDS::ReturnCode_t | get_liveliness_changed_status (::DDS::LivelinessChangedStatus &status) |
|
virtual ::DDS::ReturnCode_t | get_requested_deadline_missed_status (::DDS::RequestedDeadlineMissedStatus &status) |
|
virtual ::DDS::ReturnCode_t | get_requested_incompatible_qos_status (::DDS::RequestedIncompatibleQosStatus &status) |
|
virtual ::DDS::ReturnCode_t | get_subscription_matched_status (::DDS::SubscriptionMatchedStatus &status) |
|
virtual ::DDS::ReturnCode_t | get_sample_lost_status (::DDS::SampleLostStatus &status) |
|
virtual ::DDS::ReturnCode_t | wait_for_historical_data (const ::DDS::Duration_t &max_wait) |
|
virtual ::DDS::ReturnCode_t | get_matched_publications (::DDS::InstanceHandleSeq &publication_handles) |
|
virtual ::DDS::ReturnCode_t | get_matched_publication_data (::DDS::PublicationBuiltinTopicData &publication_data, DDS_INSTANCE_HANDLE_T_IN publication_handle) |
|
virtual void | set_rti_entity (::DDSDataReader *dr,::DDS::DomainParticipant_ptr dp) |
|
::DDSDataReader * | get_rti_entity (void) |
|
virtual | ~DDS_DataReader_Base (void) |
|
ReadCondition | create_readcondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states) |
|
QueryCondition | create_querycondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states, in string query_expression, in StringSeq query_parameters) |
|
ReturnCode_t | delete_readcondition (in ReadCondition a_condition) |
|
ReturnCode_t | set_qos (in DataReaderQos qos) |
|
ReturnCode_t | get_qos (inout DataReaderQos qos) |
|
ReturnCode_t | set_listener (in DataReaderListener a_listener, in StatusMask mask) |
|
ReturnCode_t | get_sample_rejected_status (inout SampleRejectedStatus status) |
|
ReturnCode_t | get_liveliness_changed_status (inout LivelinessChangedStatus status) |
|
ReturnCode_t | get_requested_deadline_missed_status (inout RequestedDeadlineMissedStatus status) |
|
ReturnCode_t | get_requested_incompatible_qos_status (inout RequestedIncompatibleQosStatus status) |
|
ReturnCode_t | get_subscription_matched_status (inout SubscriptionMatchedStatus status) |
|
ReturnCode_t | get_sample_lost_status (inout SampleLostStatus status) |
|
ReturnCode_t | wait_for_historical_data (in Duration_t max_wait) |
|
ReturnCode_t | get_matched_publications (inout InstanceHandleSeq publication_handles) |
|
ReturnCode_t | get_matched_publication_data (inout PublicationBuiltinTopicData publication_data, in InstanceHandle_t publication_handle) |
|