#include <DataReader_T.h>
Public Member Functions | |
DataReader_T (DDSDataReader *dr=0) | |
Constructor. | |
virtual | ~DataReader_T (void) |
Destructor. | |
void | read_wo_instance (typename DDS_TYPE::dds_seq_type &data, typename DDS_TYPE::sampleinfo_seq_type &sample_info, DDSQueryCondition *qc) |
void | read_w_instance (typename DDS_TYPE::dds_seq_type &data, const ::DDS_InstanceHandle_t &lookup_hnd, typename DDS_TYPE::sampleinfo_seq_type &sample_info) |
DDS_ReturnCode_t | get (typename DDS_TYPE::dds_seq_type &data, typename DDS_TYPE::sampleinfo_seq_type &sample_info, const DDS_Long &max_samples, DDSQueryCondition *qc) |
DDS_ReturnCode_t | get (typename DDS_TYPE::dds_seq_type &data, typename DDS_TYPE::sampleinfo_seq_type &sample_info, const DDS_Long &max_samples, DDSReadCondition *rd) |
DDS_ReturnCode_t | take (typename DDS_TYPE::dds_seq_type &data, typename DDS_TYPE::sampleinfo_seq_type &sample_info, const DDS_Long &max_samples, DDSQueryCondition *qc) |
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, typename DDS_TYPE::sampleinfo_seq_type &sample_info) |
void | delete_datareader (::DDS::Subscriber_ptr subscriber) |
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) |
void | set_impl (::DDS::DataReader_ptr dr) |
::DDS::StatusMask | get_mask (void) |
virtual DDSDataReader * | get_impl (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::datareader_type * | impl (void) |
void | log_query_condition (DDSQueryCondition *qc) |
Private Attributes | |
DDS_TYPE::datareader_type * | impl_ |
::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 = 0 ) |
[explicit] |
Constructor.
CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::~DataReader_T | ( | void | ) | [virtual] |
Destructor.
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 | ||
) |
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 | ||
) |
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 | ||
) |
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 | ||
) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_contained_entities | ( | void | ) |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_datareader | ( | ::DDS::Subscriber_ptr | subscriber ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_readcondition | ( | ::DDS::ReadCondition_ptr | a_condition ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::enable | ( | void | ) |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get | ( | typename DDS_TYPE::dds_seq_type & | data, |
typename DDS_TYPE::sampleinfo_seq_type & | sample_info, | ||
const DDS_Long & | max_samples, | ||
DDSReadCondition * | rd | ||
) |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get | ( | typename DDS_TYPE::dds_seq_type & | data, |
typename DDS_TYPE::sampleinfo_seq_type & | sample_info, | ||
const DDS_Long & | max_samples, | ||
DDSQueryCondition * | qc | ||
) |
DDSDataReader * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_impl | ( | void | ) | [virtual] |
Implements CIAO::DDS4CCM::CCM_DDS_DataReader_Base.
DDS_INSTANCE_HANDLE_T_RETN CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_instance_handle | ( | void | ) | [virtual] |
DDS::DataReaderListener_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_listener | ( | void | ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_liveliness_changed_status | ( | ::DDS::LivelinessChangedStatus & | status ) |
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_mask | ( | void | ) |
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 | ||
) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_matched_publications | ( | ::DDS::InstanceHandleSeq & | publication_handles ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_qos | ( | ::DDS::DataReaderQos & | qos ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_deadline_missed_status | ( | ::DDS::RequestedDeadlineMissedStatus & | status ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_incompatible_qos_status | ( | ::DDS::RequestedIncompatibleQosStatus & | status ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_lost_status | ( | ::DDS::SampleLostStatus & | status ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_rejected_status | ( | ::DDS::SampleRejectedStatus & | status ) |
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_status_changes | ( | void | ) |
DDS::StatusCondition_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_statuscondition | ( | void | ) |
DDS::Subscriber_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscriber | ( | void | ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscription_matched_status | ( | ::DDS::SubscriptionMatchedStatus & | status ) |
DDS::TopicDescription_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_topicdescription | ( | void | ) |
DDS_TYPE::datareader_type * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::impl | ( | void | ) | [private] |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::log_query_condition | ( | DDSQueryCondition * | qc ) | [private] |
DDS_InstanceHandle_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::lookup_instance | ( | const typename DDS_TYPE::value_type & | an_instance ) |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::passivate | ( | void | ) |
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, | ||
typename DDS_TYPE::sampleinfo_seq_type & | sample_info | ||
) |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::read_wo_instance | ( | typename DDS_TYPE::dds_seq_type & | data, |
typename DDS_TYPE::sampleinfo_seq_type & | sample_info, | ||
DDSQueryCondition * | qc | ||
) |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::return_loan | ( | typename DDS_TYPE::dds_seq_type & | data, |
typename DDS_TYPE::sampleinfo_seq_type & | sample_info | ||
) |
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_impl | ( | ::DDS::DataReader_ptr | dr ) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_listener | ( | ::DDS::DataReaderListener_ptr | a_listener, |
::DDS::StatusMask | mask | ||
) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_qos | ( | const ::DDS::DataReaderQos & | qos ) |
DDS_ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::take | ( | typename DDS_TYPE::dds_seq_type & | data, |
typename DDS_TYPE::sampleinfo_seq_type & | sample_info, | ||
const DDS_Long & | max_samples, | ||
DDSQueryCondition * | qc | ||
) |
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::wait_for_historical_data | ( | const ::DDS::Duration_t & | max_wait ) |
DDS_TYPE::datareader_type* 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] |