|
| DDS_State_Connector_T (void) |
|
virtual | ~DDS_State_Connector_T (void) |
|
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) |
|
|
|
virtual
CCM_TYPE::observable_traits::data_type::_ptr_type | get_observable_data (void) |
|
virtual
CCM_TYPE::observable_traits::dds_entity_type::_ptr_type | get_observable_dds_entity (void) |
|
|
|
virtual
CCM_TYPE::passive_observer_traits::data_type::_ptr_type | get_passive_observer_data (void) |
|
virtual
CCM_TYPE::passive_observer_traits::dds_entity_type::_ptr_type | get_passive_observer_dds_entity (void) |
|
virtual
CCM_TYPE::passive_observer_traits::filter_config_type::_ptr_type | get_passive_observer_filter_config (void) |
|
virtual ::CCM_DDS::QueryFilter * | passive_observer_filter (void) |
|
virtual void | passive_observer_filter (const ::CCM_DDS::QueryFilter &filter) |
|
|
|
virtual
CCM_TYPE::pull_observer_traits::data_type::_ptr_type | get_pull_observer_data (void) |
|
virtual
CCM_TYPE::pull_observer_traits::fresh_data_type::_ptr_type | get_pull_observer_fresh_data (void) |
|
virtual
CCM_TYPE::pull_observer_traits::dds_entity_type::_ptr_type | get_pull_observer_dds_entity (void) |
|
virtual
CCM_TYPE::pull_observer_traits::filter_config_type::_ptr_type | get_pull_observer_filter_config (void) |
|
virtual ::CCM_DDS::QueryFilter * | pull_observer_filter (void) |
|
virtual void | pull_observer_filter (const ::CCM_DDS::QueryFilter &filter) |
|
|
|
virtual
CCM_TYPE::push_observer_traits::data_type::_ptr_type | get_push_observer_data (void) |
|
virtual
CCM_TYPE::push_observer_traits::data_control_type::_ptr_type | get_push_observer_data_control (void) |
|
virtual
CCM_TYPE::push_observer_traits::dds_entity_type::_ptr_type | get_push_observer_dds_entity (void) |
|
virtual
CCM_TYPE::push_observer_traits::filter_config_type::_ptr_type | get_push_observer_filter_config (void) |
|
virtual ::CCM_DDS::QueryFilter * | push_observer_filter (void) |
|
virtual void | push_observer_filter (const ::CCM_DDS::QueryFilter &filter) |
|
|
DDS_StateListen operations
|
virtual
CCM_TYPE::push_state_observer_traits::data_type::_ptr_type | get_push_state_observer_data (void) |
|
virtual
CCM_TYPE::push_state_observer_traits::data_control_type::_ptr_type | get_push_state_observer_data_control (void) |
|
virtual
CCM_TYPE::push_state_observer_traits::dds_entity_type::_ptr_type | get_push_state_observer_dds_entity (void) |
|
virtual
CCM_TYPE::push_state_observer_traits::filter_config_type::_ptr_type | get_push_state_observer_filter_config (void) |
|
virtual ::CCM_DDS::QueryFilter * | push_state_observer_filter (void) |
|
virtual void | push_state_observer_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) |
|
virtual TAO::ObjectKey * | _key (void) |
|
virtual CORBA::ULong | _hash (CORBA::ULong maximum) |
|
virtual CORBA::Boolean | _is_equivalent (CORBA::Object_ptr other_obj) |
|
virtual CORBA::Boolean | _non_existent (void) |
|
virtual InterfaceDef_ptr | _get_interface (void) |
|
virtual CORBA::Object_ptr | _get_component (void) |
|
virtual char * | _repository_id (void) |
|
virtual void | _create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags) |
|
virtual void | _create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exclist, CORBA::ContextList_ptr ctxtlist, CORBA::Request_ptr &request, CORBA::Flags req_flags) |
|
virtual CORBA::Request_ptr | _request (const char *operation) |
|
virtual CORBA::ORB_ptr | _get_orb (void) |
|
|
bool | observable_obtained_ |
|
bool | passive_observer_obtained_ |
|
bool | pull_observer_obtained_ |
|
bool | push_observer_obtained_ |
|
bool | push_state_observer_obtained_ |
|
|
DDS_Update_T< typename
CCM_TYPE::observable_traits,
typename
DDS_TYPE::typed_writer_type,
typename DDS_TYPE::value_type,
SEQ_TYPE > | observable_ |
|
|
DDS_Read_T< typename
CCM_TYPE::passive_observer_traits,
typename
DDS_TYPE::typed_reader_type,
typename DDS_TYPE::value_type,
SEQ_TYPE > | passive_observer_ |
|
|
DDS_Get_T< typename
CCM_TYPE::pull_observer_traits,
typename
DDS_TYPE::typed_reader_type,
typename DDS_TYPE::value_type,
SEQ_TYPE, FIXED > | pull_observer_ |
|
|
DDS_Listen_T< typename
CCM_TYPE::push_observer_traits,
typename
DDS_TYPE::typed_reader_type,
typename DDS_TYPE::value_type,
SEQ_TYPE,
CIAO::DDS4CCM::DDS4CCM_READ > | push_observer_ |
|
|
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::DDS4CCM_READ > | push_state_observer_ |
|
|
typedef DDS_Base_Connector_T
< CCM_TYPE > | BaseConnector |
|
bool | late_binding (void) |
|
void | late_binding (bool late_binding) |
|
bool | late_binded (const char *topic_name) |
|
bool | stop_dds (const char *topic_name) |
|
ACE_Reactor * | reactor (void) |
| Get the reactor associated with this component. More...
|
|
void | init_domain (::DDS::DomainParticipant_ptr &participant) |
|
void | init_topic (::DDS::DomainParticipant_ptr participant,::DDS::Topic_ptr &topic, const char *topic_name, const char *type_name) |
|
void | init_publisher (::DDS::DomainParticipant_ptr participant,::DDS::Publisher_ptr &publisher) |
|
void | init_subscriber (::DDS::DomainParticipant_ptr participant,::DDS::Subscriber_ptr &subscriber) |
|
void | activate_topic (ACE_Reactor *reactor,::DDS::Topic_ptr topic,::DDS::TopicListener_ptr &listener) |
|
void | activate_publisher (ACE_Reactor *reactor,::DDS::Publisher_ptr publisher,::DDS::PublisherListener_ptr &publisher_listener) |
|
void | activate_subscriber (ACE_Reactor *reactor,::DDS::Subscriber_ptr subscriber,::DDS::SubscriberListener_ptr &subscriber_listener) |
|
void | passivate_topic (::DDS::Topic_ptr topic,::DDS::TopicListener_ptr topic_listener) |
|
void | passivate_publisher (::DDS::Publisher_ptr publisher,::DDS::PublisherListener_ptr publisher_listener) |
|
void | passivate_subscriber (::DDS::Subscriber_ptr subscriber,::DDS::SubscriberListener_ptr subscriber_listener) |
|
void | remove_topic (::DDS::DomainParticipant_ptr participant,::DDS::Topic_ptr topic) |
|
void | remove_publisher (::DDS::DomainParticipant_ptr participant,::DDS::Publisher_ptr publisher) |
|
void | remove_subscriber (::DDS::DomainParticipant_ptr participant,::DDS::Subscriber_ptr subscriber) |
|
void | remove_domain (::DDS::DomainParticipant_ptr participant) |
|
CORBA::String_var | topic_name_ |
|
CORBA::String_var | type_name_ |
|
DDS::StringSeq | key_fields_ |
|
::DDS::Topic_var | topic_ |
|
::DDS::TopicListener_var | topiclistener_ |
|
::DDS::Publisher_var | publisher_ |
|
::DDS::PublisherListener_var | publisher_listener_ |
|
::DDS::Subscriber_var | subscriber_ |
|
::DDS::SubscriberListener_var | subscriber_listener_ |
|
bool | init_subscriber_ |
|
bool | init_publisher_ |
|
::DDS::DomainId_t | domain_id_ |
|
::CORBA::String_var | qos_profile_ |
|
bool | configuration_complete_ |
|
::CIAO::DDS4CCM::Logger_Service * | dlf_ |
|
::DDS::DomainParticipant_var | domain_participant_ |
|
CCM_TYPE::context_type::_var_type | context_ |
|
::DDS::DomainParticipantFactory_var | participant_factory_ |
|
DDS_XML_QOS_PARSER_TYPE * | qos_xml_ |
|
template<typename CCM_TYPE, typename DDS_TYPE, bool FIXED, typename SEQ_TYPE>
class DDS_State_Connector_T< CCM_TYPE, DDS_TYPE, FIXED, SEQ_TYPE >
- Author
- Johnny Willemsen jwill.nosp@m.emse.nosp@m.n@rem.nosp@m.edy..nosp@m.nl
$Id$
DDS State Connector implementation