#include <DDS_Base_Connector_T.h>

Inheritance diagram for DDS_Base_Connector_T:

Collaboration diagram for DDS_Base_Connector_T:

Public Member Functions
	DDS_Base_Connector_T (void)
virtual	~DDS_Base_Connector_T (void)
virtual void	set_session_context (::Components::SessionContext_ptr ctx)
domain_id
Accessors for domain_id
virtual ::DDS::DomainId_t	domain_id (void)
virtual void	domain_id (::DDS::DomainId_t domain_id)
qos_profile
Accessors for qos_profile
virtual char *	qos_profile (void)
virtual void	qos_profile (const char *qos_profile)

virtual void	configuration_complete (void)
virtual void	ccm_remove (void)
virtual void	ccm_activate (void)
virtual void	ccm_passivate (void)
Protected Member Functions
ACE_Reactor *	reactor (void)
	Get the reactor associated with this component.

void	init_domain (::DDS::DomainParticipant_ptr &participant)
virtual void	register_type (::DDS::DomainParticipant_ptr participant, const char *typesupport_name)=0
void	init_topic (::DDS::DomainParticipant_ptr participant,::DDS::Topic_ptr &topic, const char topic_name, const char typesupport_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)
virtual void	unregister_type (::DDS::DomainParticipant_ptr participant, const char *typesupport_name)=0
Protected Attributes

::DDS::DomainId_t	domain_id_
::CORBA::String_var	qos_profile_
configuration_complete_
Indicates whether configuration_complete has been invoked. Once invoked, changing a connectors attribute is not allowed anymore. If the user still wants to set an attribute, a NonChangeable exception is thrown.
bool	configuration_complete_
::CIAO::DDS4CCM::Logger_Service *	dlf_
::DDS::DomainParticipant_var	domain_participant_
CCM_TYPE::context_type::_var_type	context_
DomainParticipantFactory	participant_factory_

Detailed Description

Author:: Johnny Willemsen <jwillemsen@remedy.nl>

Id:: DDS_Base_Connector_T.h 94378 2011-08-09 14:57:33Z johnnyw

Constructor & Destructor Documentation

DDS_Base_Connector_T::DDS_Base_Connector_T ( void )

virtual DDS_Base_Connector_T::~DDS_Base_Connector_T ( void ) [virtual]

Member Function Documentation

void DDS_Base_Connector_T::activate_publisher	(	ACE_Reactor *	reactor,
		::DDS::Publisher_ptr	publisher,
		::DDS::PublisherListener_ptr &	publisher_listener
	)		`[protected]`

Activation of a connector.

Helper methods to create the DDS listeners and attach them to the DDS Entities. This will activate the DDS Entities.

void DDS_Base_Connector_T::activate_subscriber	(	ACE_Reactor *	reactor,
		::DDS::Subscriber_ptr	subscriber,
		::DDS::SubscriberListener_ptr &	subscriber_listener
	)		`[protected]`

Activation of a connector.

Helper methods to create the DDS listeners and attach them to the DDS Entities. This will activate the DDS Entities.

void DDS_Base_Connector_T::activate_topic	(	ACE_Reactor *	reactor,
		::DDS::Topic_ptr	topic,
		::DDS::TopicListener_ptr &	listener
	)		`[protected]`

Activation of a connector.

Helper methods to create the DDS listeners and attach them to the DDS Entities. This will activate the DDS Entities.

virtual void DDS_Base_Connector_T::ccm_activate ( void ) [virtual]

Interface methods for the Deployment and Configuration Framework

Reimplemented in DDS_TopicBase_Connector_T.

virtual void DDS_Base_Connector_T::ccm_passivate ( void ) [virtual]

Interface methods for the Deployment and Configuration Framework

Reimplemented in DDS_TopicBase_Connector_T.

virtual void DDS_Base_Connector_T::ccm_remove ( void ) [virtual]

Interface methods for the Deployment and Configuration Framework

Reimplemented in DDS_TopicBase_Connector_T.

virtual void DDS_Base_Connector_T::configuration_complete ( void ) [virtual]

Interface methods for the Deployment and Configuration Framework

Reimplemented in DDS_TopicBase_Connector_T.

virtual ::DDS::DomainId_t DDS_Base_Connector_T::domain_id ( void )

virtual void DDS_Base_Connector_T::domain_id ( ::DDS::DomainId_t domain_id ) [virtual]

void DDS_Base_Connector_T::init_domain ( ::DDS::DomainParticipant_ptr & participant ) [protected]

Initialization of a connector.

When one wants to use his own DDS::DomainParticipant, DDS::Topic, DDS::Subscriber and/or DDS::Publisher, these helper methods allows to create these, independent of the DDS vendor.

See $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to use these methods.

These methods will create the DDS4CCM Entities (and therefor the DDS entities in DDS itself), like DomainParticipant, Topic, Subscriber and Publisher

void DDS_Base_Connector_T::init_publisher	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Publisher_ptr &	publisher
	)		`[protected]`

Initialization of a connector.

When one wants to use his own DDS::DomainParticipant, DDS::Topic, DDS::Subscriber and/or DDS::Publisher, these helper methods allows to create these, independent of the DDS vendor.

See $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to use these methods.

These methods will create the DDS4CCM Entities (and therefor the DDS entities in DDS itself), like DomainParticipant, Topic, Subscriber and Publisher

void DDS_Base_Connector_T::init_subscriber	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Subscriber_ptr &	subscriber
	)		`[protected]`

Initialization of a connector.

When one wants to use his own DDS::DomainParticipant, DDS::Topic, DDS::Subscriber and/or DDS::Publisher, these helper methods allows to create these, independent of the DDS vendor.

See $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to use these methods.

These methods will create the DDS4CCM Entities (and therefor the DDS entities in DDS itself), like DomainParticipant, Topic, Subscriber and Publisher

void DDS_Base_Connector_T::init_topic	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Topic_ptr &	topic,
		const char *	topic_name,
		const char *	typesupport_name
	)		`[protected]`

Initialization of a connector.

When one wants to use his own DDS::DomainParticipant, DDS::Topic, DDS::Subscriber and/or DDS::Publisher, these helper methods allows to create these, independent of the DDS vendor.

See $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to use these methods.

These methods will create the DDS4CCM Entities (and therefor the DDS entities in DDS itself), like DomainParticipant, Topic, Subscriber and Publisher

void DDS_Base_Connector_T::passivate_publisher	(	::DDS::Publisher_ptr	publisher,
		::DDS::PublisherListener_ptr	publisher_listener
	)		`[protected]`

Passivation of a connector.

Helper methods to detach the DDS listeners from the DDS Entities. This'll passivate the DDS Entities.

In order to allow a thread safe and memory leak free passivation, one should use a temporary _var variable and assign this by using _retn () in the calling methods.

For example:

DDS::TopicListener_var tmp = this->topic_listener_._retn (); if (!CORBA::is_nil (tmp.in ())) this->passivate_topi (this->topic_.in (), tmp.in ());

Where topic_listener_ and topic_ are _var class members of a derived, user defined class.

Again, see $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to passivate a connector.

void DDS_Base_Connector_T::passivate_subscriber	(	::DDS::Subscriber_ptr	subscriber,
		::DDS::SubscriberListener_ptr	subscriber_listener
	)		`[protected]`

Passivation of a connector.

Helper methods to detach the DDS listeners from the DDS Entities. This'll passivate the DDS Entities.

In order to allow a thread safe and memory leak free passivation, one should use a temporary _var variable and assign this by using _retn () in the calling methods.

For example:

DDS::TopicListener_var tmp = this->topic_listener_._retn (); if (!CORBA::is_nil (tmp.in ())) this->passivate_topi (this->topic_.in (), tmp.in ());

Where topic_listener_ and topic_ are _var class members of a derived, user defined class.

Again, see $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to passivate a connector.

void DDS_Base_Connector_T::passivate_topic	(	::DDS::Topic_ptr	topic,
		::DDS::TopicListener_ptr	topic_listener
	)		`[protected]`

Passivation of a connector.

Helper methods to detach the DDS listeners from the DDS Entities. This'll passivate the DDS Entities.

In order to allow a thread safe and memory leak free passivation, one should use a temporary _var variable and assign this by using _retn () in the calling methods.

For example:

DDS::TopicListener_var tmp = this->topic_listener_._retn (); if (!CORBA::is_nil (tmp.in ())) this->passivate_topi (this->topic_.in (), tmp.in ());

Where topic_listener_ and topic_ are _var class members of a derived, user defined class.

Again, see $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to passivate a connector.

virtual char* DDS_Base_Connector_T::qos_profile ( void ) [virtual]

virtual void DDS_Base_Connector_T::qos_profile ( const char * qos_profile ) [virtual]

ACE_Reactor* DDS_Base_Connector_T::reactor ( void ) [protected]

Get the reactor associated with this component.

virtual void DDS_Base_Connector_T::register_type	(	::DDS::DomainParticipant_ptr	participant,
		const char *	typesupport_name
	)		`[protected, pure virtual]`

Initialization of a connector.

When one wants to use his own DDS::DomainParticipant, DDS::Topic, DDS::Subscriber and/or DDS::Publisher, these helper methods allows to create these, independent of the DDS vendor.

See $CIAO_ROOT/connectors/dds4ccm/tests/MultiTopic/Connector/MultiTopic_Connector_T.cpp on how to use these methods.

These methods will create the DDS4CCM Entities (and therefor the DDS entities in DDS itself), like DomainParticipant, Topic, Subscriber and Publisher

Implemented in DDS_TopicBase_Connector_T.

void DDS_Base_Connector_T::remove_domain ( ::DDS::DomainParticipant_ptr participant ) [protected]

Removal of a connector.

Helper methods to remove the DDS Entities from memory.

Again, one should use a temporary _var variable and _retn () in order to remove the DDS Entities in a thread safe and memory leak free manner. See 'Passivation of a connector' in this file.

void DDS_Base_Connector_T::remove_publisher	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Publisher_ptr	publisher
	)		`[protected]`

Removal of a connector.

Helper methods to remove the DDS Entities from memory.

Again, one should use a temporary _var variable and _retn () in order to remove the DDS Entities in a thread safe and memory leak free manner. See 'Passivation of a connector' in this file.

void DDS_Base_Connector_T::remove_subscriber	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Subscriber_ptr	subscriber
	)		`[protected]`

Removal of a connector.

Helper methods to remove the DDS Entities from memory.

Again, one should use a temporary _var variable and _retn () in order to remove the DDS Entities in a thread safe and memory leak free manner. See 'Passivation of a connector' in this file.

void DDS_Base_Connector_T::remove_topic	(	::DDS::DomainParticipant_ptr	participant,
		::DDS::Topic_ptr	topic
	)		`[protected]`

Removal of a connector.

Helper methods to remove the DDS Entities from memory.

Again, one should use a temporary _var variable and _retn () in order to remove the DDS Entities in a thread safe and memory leak free manner. See 'Passivation of a connector' in this file.

virtual void DDS_Base_Connector_T::set_session_context ( ::Components::SessionContext_ptr ctx ) [virtual]

virtual void DDS_Base_Connector_T::unregister_type	(	::DDS::DomainParticipant_ptr	participant,
		const char *	typesupport_name
	)		`[protected, pure virtual]`

Removal of a connector.

Helper methods to remove the DDS Entities from memory.

Again, one should use a temporary _var variable and _retn () in order to remove the DDS Entities in a thread safe and memory leak free manner. See 'Passivation of a connector' in this file.

Implemented in DDS_TopicBase_Connector_T.

Member Data Documentation

bool DDS_Base_Connector_T::configuration_complete_ [protected]

Context of the connector. Used to make connection to the user component like the interface to the data listeners.

CCM_TYPE::context_type::_var_type DDS_Base_Connector_T::context_ [protected]

Context of the connector. Used to make connection to the user component like the interface to the data listeners.

::CIAO::DDS4CCM::Logger_Service* DDS_Base_Connector_T::dlf_ [protected]

Context of the connector. Used to make connection to the user component like the interface to the data listeners.

::DDS::DomainId_t DDS_Base_Connector_T::domain_id_ [protected]

Attribute of DDS4CCM Base

::DDS::DomainParticipant_var DDS_Base_Connector_T::domain_participant_ [protected]

Context of the connector. Used to make connection to the user component like the interface to the data listeners.

DomainParticipantFactory DDS_Base_Connector_T::participant_factory_ [protected]

DomainParticipantFactory. Administration of Domain Participants

::CORBA::String_var DDS_Base_Connector_T::qos_profile_ [protected]

Attribute of DDS4CCM Base

The documentation for this class was generated from the following file:

DDS_Base_Connector_T.h

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation