Public Member Functions | Private Types | Private Member Functions | Private Attributes

CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE > Class Template Reference

#include <DataReader_T.h>

Inheritance diagram for CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >:
Inheritance graph
[legend]
Collaboration diagram for CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >:
Collaboration graph
[legend]

List of all members.

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_

template<typename DDS_TYPE, typename CCM_TYPE, DDS4CCM_Vendor VENDOR_TYPE>
class CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >


Member Typedef Documentation

template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef CCM_DDS_ContentFilteredTopic_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::ContentFilteredTopic_type [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef DataReader_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::DataReader_type [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef CCM_DDS_QueryCondition_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::QueryCondition_type [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef CCM_DDS_ReadCondition_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::ReadCondition_type [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef CCM_DDS_Subscriber_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::Subscriber_type [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
typedef CCM_DDS_Topic_T<DDS_TYPE, CCM_TYPE, VENDOR_TYPE> CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::Topic_type [private]

Constructor & Destructor Documentation

template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::DataReader_T ( DDSDataReader *  dr = 0 ) [explicit]

Constructor.

template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::~DataReader_T ( void   ) [virtual]

Destructor.


Member Function Documentation

template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_contained_entities ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_datareader ( ::DDS::Subscriber_ptr  subscriber )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::delete_readcondition ( ::DDS::ReadCondition_ptr  a_condition )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::enable ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDSDataReader * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_impl ( void   ) [virtual]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS_INSTANCE_HANDLE_T_RETN CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_instance_handle ( void   ) [virtual]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::DataReaderListener_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_listener ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_liveliness_changed_status ( ::DDS::LivelinessChangedStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_mask ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_matched_publications ( ::DDS::InstanceHandleSeq publication_handles )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_qos ( ::DDS::DataReaderQos qos )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_deadline_missed_status ( ::DDS::RequestedDeadlineMissedStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_requested_incompatible_qos_status ( ::DDS::RequestedIncompatibleQosStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_lost_status ( ::DDS::SampleLostStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_sample_rejected_status ( ::DDS::SampleRejectedStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_status_changes ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::StatusCondition_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_statuscondition ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::Subscriber_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscriber ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_subscription_matched_status ( ::DDS::SubscriptionMatchedStatus status )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::TopicDescription_ptr CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::get_topicdescription ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS_TYPE::datareader_type * CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::impl ( void   ) [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::log_query_condition ( DDSQueryCondition *  qc ) [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS_InstanceHandle_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::lookup_instance ( const typename DDS_TYPE::value_type &  an_instance )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::passivate ( void   )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
void CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_impl ( ::DDS::DataReader_ptr  dr )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_listener ( ::DDS::DataReaderListener_ptr  a_listener,
::DDS::StatusMask  mask 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::set_qos ( const ::DDS::DataReaderQos qos )
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
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 
)
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS::ReturnCode_t CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::wait_for_historical_data ( const ::DDS::Duration_t max_wait )

Member Data Documentation

template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
DDS_TYPE::datareader_type* CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::impl_ [private]
template<typename DDS_TYPE , typename CCM_TYPE , DDS4CCM_Vendor VENDOR_TYPE>
::DDS::StatusMask CIAO::DDS4CCM::DataReader_T< DDS_TYPE, CCM_TYPE, VENDOR_TYPE >::lst_mask_ [private]

The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines