DDS4CCM 1.0.4
|
#include <DDS_Subscriber_Base_T.h>
Public Member Functions | |
DDS_Subscriber_Base_T (void) | |
~DDS_Subscriber_Base_T (void) | |
void | set_component (::CORBA::Object_ptr component) |
void | configuration_complete (::DDS::Topic_ptr topic,::DDS::Subscriber_ptr subscriber, const char *qos_profile) |
void | activate (::CCM_DDS::PortStatusListener_ptr listener, ACE_Reactor *reactor) |
void | passivate (void) |
void | remove (::DDS::Subscriber_ptr subscriber) |
DDS_Read | |
DDS_Subscriber_Base_T operations | |
CCM_TYPE::data_type::_ptr_type | get_data (void) |
CCM_TYPE::dds_entity_type::_ptr_type | get_dds_entity (void) |
CCM_TYPE::filter_config_type::_ptr_type | get_filter_config (void) |
::CCM_DDS::QueryFilter * | filter (void) |
void | filter (const ::CCM_DDS::QueryFilter &filter) |
Protected Types | |
typedef ::CIAO::DDS4CCM::Reader_T < typename CCM_TYPE::data_type, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE > | Reader_type |
typedef ::CIAO::DDS4CCM::CCM_DDS_ContentFilterSetting_i | ContentFilterSetting_type |
Protected Attributes | |
::CIAO::DDS4CCM::ConditionManager | condition_manager_ |
::DDS::DataReaderListener_var | listener_ |
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T < ContentFilterSetting_type > | cft_setting_ |
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T < Reader_type > | dds_read_ |
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T < ::CIAO::DDS4CCM::CCM_DataReader > | ccm_data_reader_ |
bool | configuration_complete_ |
Base class for all ports, containing a reader
typedef ::CIAO::DDS4CCM::CCM_DDS_ContentFilterSetting_i DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::ContentFilterSetting_type [protected] |
typedef ::CIAO::DDS4CCM::Reader_T< typename CCM_TYPE::data_type, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE> DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::Reader_type [protected] |
DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::DDS_Subscriber_Base_T | ( | void | ) |
DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::~DDS_Subscriber_Base_T | ( | void | ) |
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::activate | ( | ::CCM_DDS::PortStatusListener_ptr | listener, |
ACE_Reactor * | reactor | ||
) |
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::configuration_complete | ( | ::DDS::Topic_ptr | topic, |
::DDS::Subscriber_ptr | subscriber, | ||
const char * | qos_profile | ||
) |
Reimplemented in DDS_Get_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, FIXED >, DDS_Get_T< typename CCM_TYPE::pull_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, and DDS_Get_T< typename CCM_TYPE::pull_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >.
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::filter | ( | const ::CCM_DDS::QueryFilter & | filter | ) |
CCM_DDS::QueryFilter * DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::filter | ( | void | ) |
CCM_TYPE::data_type::_ptr_type DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::get_data | ( | void | ) |
CCM_TYPE::dds_entity_type::_ptr_type DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::get_dds_entity | ( | void | ) |
CCM_TYPE::filter_config_type::_ptr_type DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::get_filter_config | ( | void | ) |
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::passivate | ( | void | ) |
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::remove | ( | ::DDS::Subscriber_ptr | subscriber | ) |
Reimplemented in DDS_Get_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, FIXED >, DDS_Listen_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >, DDS_StateListen_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >, DDS_Get_T< typename CCM_TYPE::pull_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, DDS_Get_T< typename CCM_TYPE::pull_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, DDS_Listen_T< typename CCM_TYPE::push_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >, DDS_Listen_T< typename CCM_TYPE::push_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >, and DDS_StateListen_T< typename CCM_TYPE::push_state_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >.
void DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::set_component | ( | ::CORBA::Object_ptr | component | ) |
Reimplemented in DDS_Get_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, FIXED >, DDS_Listen_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >, DDS_StateListen_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >, DDS_Get_T< typename CCM_TYPE::pull_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, DDS_Get_T< typename CCM_TYPE::pull_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, DDS_Listen_T< typename CCM_TYPE::push_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >, DDS_Listen_T< typename CCM_TYPE::push_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >, and DDS_StateListen_T< typename CCM_TYPE::push_state_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE >.
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T< ::CIAO::DDS4CCM::CCM_DataReader > DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::ccm_data_reader_ [protected] |
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T<ContentFilterSetting_type> DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::cft_setting_ [protected] |
::CIAO::DDS4CCM::ConditionManager DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::condition_manager_ [protected] |
bool DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::configuration_complete_ [protected] |
::CIAO::DDS4CCM::LocalObject_Auto_Ptr_T<Reader_type> DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::dds_read_ [protected] |
::DDS::DataReaderListener_var DDS_Subscriber_Base_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE >::listener_ [protected] |
Reimplemented in DDS_Get_T< CCM_TYPE, TYPED_DDS_READER, VALUE_TYPE, SEQ_VALUE_TYPE, FIXED >, DDS_Get_T< typename CCM_TYPE::pull_observer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >, and DDS_Get_T< typename CCM_TYPE::pull_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED >.