#include <DataReader_T.h>
Public Member Functions | |
DataReader_T (DDSDataReader *dr) | |
Constructor. | |
virtual | ~DataReader_T (void) |
Destructor. | |
void | read_w_instance (typename DDS_TYPE::dds_seq_type &data, const ::DDS_InstanceHandle_t &lookup_hnd,::DDS_SampleInfoSeq &sample_info) |
void | read_wo_instance (typename DDS_TYPE::dds_seq_type &data,::DDS_SampleInfoSeq &sample_info) |
DDS_ReturnCode_t | read_w_condition (typename DDS_TYPE::dds_seq_type &data,::DDS_SampleInfoSeq &sample_info,::DDS_Long max_samples) |
DDS_ReturnCode_t | take (typename DDS_TYPE::dds_seq_type &data,::DDS_SampleInfoSeq &sample_info,::DDS_Long max_samples) |
DDS_InstanceHandle_t | lookup_instance (const typename DDS_TYPE::value_type &an_instance) |
DDS_ReturnCode_t | return_loan (typename DDS_TYPE::dds_seq_type &data,::DDS_SampleInfoSeq &sample_info) |
void | delete_datareader (::DDS::Subscriber_ptr subscriber) |
::CCM_DDS::QueryFilter * | query (void) |
void | query (const ::CCM_DDS::QueryFilter &filter) |
void | set_filter (const ::CCM_DDS::QueryFilter &filter, DDSQueryCondition *qc) |
void | remove_condition (DDSQueryCondition *qc, const char *type) |
void | remove_conditions (void) |
DDSReadCondition * | get_readcondition (void) |
void | create_readcondition (void) |
DDSQueryCondition * | get_querycondition (void) |
void | attach_querycondition (void) |
bool | wait (DDSConditionSeq &active_conditions, DDS_Duration_t &time_out) |
void | passivate (void) |
void | create_datareader (::DDS::ContentFilteredTopic_ptr topic,::DDS::Subscriber_ptr subscriber, const char *library_name, const char *profile_name) |
void | create_datareader (::DDS::Topic_ptr topic,::DDS::Subscriber_ptr subscriber, const char *library_name, const char *profile_name) |
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) |
DDS_TYPE::data_reader * | get_impl (void) |
void | set_impl (::DDS::DataReader_ptr dr) |
::DDS::StatusMask | get_mask (void) |
Private Types | |
typedef ::CIAO::DDS4CCM::CCM_DDS_DataReaderListener_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | DataReaderListener_type |
typedef CCM_DDS_Topic_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | Topic_type |
typedef CCM_DDS_ReadCondition_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | ReadCondition_type |
typedef CCM_DDS_QueryCondition_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | QueryCondition_type |
typedef CCM_DDS_ContentFilteredTopic_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | ContentFilteredTopic_type |
typedef CCM_DDS_Subscriber_T < DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | Subscriber_type |
typedef DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE > | DataReader_type |
Private Member Functions | |
DDS_TYPE::data_reader * | impl (void) |
Private Attributes | |
DDS_TYPE::data_reader * | impl_ |
::DDSReadCondition * | rd_condition_ |
::DDSWaitSet * | ws_ |
DDSQueryCondition * | qc_reader_ |
DDSQueryCondition * | qc_getter_ |
DDSQueryCondition * | qc_listener_ |
::DDS::StatusMask | lst_mask_ |
typedef CCM_DDS_ContentFilteredTopic_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::ContentFilteredTopic_type [private] |
typedef DataReader_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::DataReader_type [private] |
typedef ::CIAO::DDS4CCM::CCM_DDS_DataReaderListener_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::DataReaderListener_type [private] |
typedef CCM_DDS_QueryCondition_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::QueryCondition_type [private] |
typedef CCM_DDS_ReadCondition_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::ReadCondition_type [private] |
typedef CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::Subscriber_type [private] |
typedef CCM_DDS_Topic_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::Topic_type [private] |
CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::DataReader_T | ( | DDSDataReader * | dr | ) | [inline] |
Constructor.
CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::~DataReader_T | ( | void | ) | [inline, virtual] |
Destructor.
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::attach_querycondition | ( | void | ) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::create_datareader | ( | ::DDS::Topic_ptr | topic, | |
::DDS::Subscriber_ptr | subscriber, | |||
const char * | library_name, | |||
const char * | profile_name | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::create_datareader | ( | ::DDS::ContentFilteredTopic_ptr | topic, | |
::DDS::Subscriber_ptr | subscriber, | |||
const char * | library_name, | |||
const char * | profile_name | |||
) | [inline] |
DDS::QueryCondition_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::create_querycondition | ( | ::DDS::SampleStateMask | sample_states, | |
::DDS::ViewStateMask | view_states, | |||
::DDS::InstanceStateMask | instance_states, | |||
const char * | query_expression, | |||
const ::DDS::StringSeq & | query_parameters | |||
) | [inline] |
DDS::ReadCondition_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::create_readcondition | ( | ::DDS::SampleStateMask | sample_states, | |
::DDS::ViewStateMask | view_states, | |||
::DDS::InstanceStateMask | instance_states | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::create_readcondition | ( | void | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_contained_entities | ( | void | ) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_datareader | ( | ::DDS::Subscriber_ptr | subscriber | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_readcondition | ( | ::DDS::ReadCondition_ptr | a_condition | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::enable | ( | void | ) | [inline] |
DDS_TYPE::data_reader * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_impl | ( | void | ) | [inline] |
DDS_INSTANCE_HANDLE_T_RETN CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_instance_handle | ( | void | ) | [inline, virtual] |
DDS::DataReaderListener_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_listener | ( | void | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_liveliness_changed_status | ( | ::DDS::LivelinessChangedStatus & | status | ) | [inline] |
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_mask | ( | void | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_matched_publication_data | ( | ::DDS::PublicationBuiltinTopicData & | publication_data, | |
DDS_INSTANCE_HANDLE_T_IN | publication_handle | |||
) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_matched_publications | ( | ::DDS::InstanceHandleSeq & | publication_handles | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_qos | ( | ::DDS::DataReaderQos & | qos | ) | [inline] |
DDSQueryCondition * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_querycondition | ( | void | ) | [inline] |
DDSReadCondition * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_readcondition | ( | void | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_deadline_missed_status | ( | ::DDS::RequestedDeadlineMissedStatus & | status | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_incompatible_qos_status | ( | ::DDS::RequestedIncompatibleQosStatus & | status | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_lost_status | ( | ::DDS::SampleLostStatus & | status | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_rejected_status | ( | ::DDS::SampleRejectedStatus & | status | ) | [inline] |
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_status_changes | ( | void | ) | [inline] |
DDS::StatusCondition_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_statuscondition | ( | void | ) | [inline] |
DDS::Subscriber_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscriber | ( | void | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscription_matched_status | ( | ::DDS::SubscriptionMatchedStatus & | status | ) | [inline] |
DDS::TopicDescription_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_topicdescription | ( | void | ) | [inline] |
DDS_TYPE::data_reader * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::impl | ( | void | ) | [inline, private] |
DDS_InstanceHandle_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::lookup_instance | ( | const typename DDS_TYPE::value_type & | an_instance | ) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::passivate | ( | void | ) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::query | ( | const ::CCM_DDS::QueryFilter & | filter | ) | [inline] |
CCM_DDS::QueryFilter * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::query | ( | void | ) | [inline] |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::read_w_condition | ( | typename DDS_TYPE::dds_seq_type & | data, | |
::DDS_SampleInfoSeq & | sample_info, | |||
::DDS_Long | max_samples | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::read_w_instance | ( | typename DDS_TYPE::dds_seq_type & | data, | |
const ::DDS_InstanceHandle_t & | lookup_hnd, | |||
::DDS_SampleInfoSeq & | sample_info | |||
) |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::read_wo_instance | ( | typename DDS_TYPE::dds_seq_type & | data, | |
::DDS_SampleInfoSeq & | sample_info | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::remove_condition | ( | DDSQueryCondition * | qc, | |
const char * | type | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::remove_conditions | ( | void | ) | [inline] |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::return_loan | ( | typename DDS_TYPE::dds_seq_type & | data, | |
::DDS_SampleInfoSeq & | sample_info | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_filter | ( | const ::CCM_DDS::QueryFilter & | filter, | |
DDSQueryCondition * | qc | |||
) | [inline] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_impl | ( | ::DDS::DataReader_ptr | dr | ) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_listener | ( | ::DDS::DataReaderListener_ptr | a_listener, | |
::DDS::StatusMask | mask | |||
) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_qos | ( | const ::DDS::DataReaderQos & | qos | ) | [inline] |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::take | ( | typename DDS_TYPE::dds_seq_type & | data, | |
::DDS_SampleInfoSeq & | sample_info, | |||
::DDS_Long | max_samples | |||
) | [inline] |
bool CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::wait | ( | DDSConditionSeq & | active_conditions, | |
DDS_Duration_t & | time_out | |||
) | [inline] |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::wait_for_historical_data | ( | const ::DDS::Duration_t & | max_wait | ) | [inline] |
DDS_TYPE::data_reader* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::impl_ [private] |
::DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::lst_mask_ [private] |
DDSQueryCondition* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::qc_getter_ [private] |
DDSQueryCondition* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::qc_listener_ [private] |
DDSQueryCondition* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::qc_reader_ [private] |
::DDSReadCondition* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::rd_condition_ [private] |
::DDSWaitSet* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::ws_ [private] |