DDS4CCM
1.1.8
|
#include <DDS_Event_Connector_T.h>
Public Member Functions | |
DDS_Event_Connector_T (void) | |
virtual | ~DDS_Event_Connector_T (void) |
virtual void | topic_name (const char *topic_name) |
virtual char * | topic_name (void) |
virtual void | configuration_complete (void) |
virtual void | ccm_activate (void) |
virtual void | ccm_passivate (void) |
virtual void | ccm_remove (void) |
DDS_Write | |
DDS_Write operations | |
virtual CCM_TYPE::supplier_traits::data_type::_ptr_type | get_supplier_data (void) |
virtual CCM_TYPE::supplier_traits::dds_entity_type::_ptr_type | get_supplier_dds_entity (void) |
DDS_Get | |
DDS_Get operations | |
virtual CCM_TYPE::pull_consumer_traits::data_type::_ptr_type | get_pull_consumer_data (void) |
virtual CCM_TYPE::pull_consumer_traits::fresh_data_type::_ptr_type | get_pull_consumer_fresh_data (void) |
virtual ::DDS::CCM_DataReader_ptr | get_pull_consumer_dds_entity (void) |
virtual ::CCM_DDS::CCM_ContentFilterSetting_ptr | get_pull_consumer_filter_config (void) |
virtual ::CCM_DDS::QueryFilter * | pull_consumer_filter (void) |
virtual void | pull_consumer_filter (const ::CCM_DDS::QueryFilter &filter) |
DDS_Listen | |
DDS_Listen operations | |
virtual CCM_TYPE::push_consumer_traits::data_type::_ptr_type | get_push_consumer_data (void) |
virtual ::CCM_DDS::CCM_DataListenerControl_ptr | get_push_consumer_data_control (void) |
virtual ::DDS::CCM_DataReader_ptr | get_push_consumer_dds_entity (void) |
virtual ::CCM_DDS::CCM_ContentFilterSetting_ptr | get_push_consumer_filter_config (void) |
virtual ::CCM_DDS::QueryFilter * | push_consumer_filter (void) |
virtual void | push_consumer_filter (const ::CCM_DDS::QueryFilter &filter) |
![]() | |
DDS_TopicBase_Connector_T (void) | |
virtual | ~DDS_TopicBase_Connector_T (void) |
virtual ::DDS::StringSeq * | key_fields (void) |
virtual void | type_name (const char *type_name) |
virtual char * | type_name (void) |
virtual void | key_fields (const ::DDS::StringSeq &key_fields) |
virtual void | register_type (::DDS::DomainParticipant_ptr participant, const char *typesupport_name) |
virtual void | unregister_type (::DDS::DomainParticipant_ptr participant, const char *typesupport_name) |
![]() | |
DDS_Base_Connector_T (void) | |
virtual | ~DDS_Base_Connector_T (void) |
virtual void | set_session_context (::Components::SessionContext_ptr ctx) |
virtual ::DDS::DomainId_t | domain_id (void) |
virtual void | domain_id (::DDS::DomainId_t domain_id) |
virtual char * | qos_profile (void) |
virtual void | qos_profile (const char *qos_profile) |
Private Types | |
typedef DDS_TopicBase_Connector_T < CCM_TYPE, DDS_TYPE, SEQ_TYPE > | TopicBaseConnector |
Private Member Functions | |
void | do_configuration_complete (void) |
void | do_ccm_activate (void) |
void | do_ccm_remove (void) |
Private Attributes | |
bool | supplier_obtained_ |
bool | push_consumer_obtained_ |
bool | pull_consumer_obtained_ |
DDS_Write_T< typename CCM_TYPE::supplier_traits, typename DDS_TYPE::typed_writer_type, typename DDS_TYPE::value_type, SEQ_TYPE > | supplier_ |
DDS_Listen_T< typename CCM_TYPE::push_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE > | push_consumer_ |
DDS_Get_T< typename CCM_TYPE::pull_consumer_traits, typename DDS_TYPE::typed_reader_type, typename DDS_TYPE::value_type, SEQ_TYPE, FIXED > | pull_consumer_ |
DDS Event Connector implementation
|
private |
DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::DDS_Event_Connector_T | ( | void | ) |
|
virtual |
|
virtual |
Interface methods for the Deployment and Configuration Framework
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
virtual |
Interface methods for the Deployment and Configuration Framework
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
virtual |
Interface methods for the Deployment and Configuration Framework
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
virtual |
Interface methods for the Deployment and Configuration Framework
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
private |
|
private |
|
private |
|
virtual |
DDS::CCM_DataReader_ptr DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::get_pull_consumer_dds_entity | ( | void | ) |
CCM_DDS::CCM_ContentFilterSetting_ptr DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::get_pull_consumer_filter_config | ( | void | ) |
|
virtual |
|
virtual |
CCM_DDS::CCM_DataListenerControl_ptr DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::get_push_consumer_data_control | ( | void | ) |
DDS::CCM_DataReader_ptr DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::get_push_consumer_dds_entity | ( | void | ) |
CCM_DDS::CCM_ContentFilterSetting_ptr DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::get_push_consumer_filter_config | ( | void | ) |
|
virtual |
|
virtual |
CCM_DDS::QueryFilter * DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::pull_consumer_filter | ( | void | ) |
|
virtual |
CCM_DDS::QueryFilter * DDS_Event_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >::push_consumer_filter | ( | void | ) |
|
virtual |
|
virtual |
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
virtual |
Reimplemented from DDS_TopicBase_Connector_T< CCM_TYPE, DDS_TYPE, SEQ_TYPE >.
|
private |
DDS_Get pull_consumer
|
private |
|
private |
DDS_Listen push_consumer
|
private |
|
private |
DDS_Write supplier
|
private |