1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
|
/**
* @author Johnny Willemsen <jwillemsen@remedy.nl>
*/
#ifndef DDS_BASE_CONNECTOR_T_H_
#define DDS_BASE_CONNECTOR_T_H_
#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
#include "dds4ccm/impl/logger/Logger_Service.h"
#include "dds4ccm/impl/dds4ccm_conf.h"
#include "ace/Copy_Disabled.h"
#if (CIAO_DDS4CCM_NDDS==1)
# include "dds4ccm/impl/ndds/DomainParticipantFactory.h"
#elif (CIAO_DDS4CCM_OPENDDS==1)
# include "dds/DCPS/Service_Participant.h"
# include "dds/DCPS/QOS_XML_Handler/QOS_XML_Loader.h"
#endif
template <typename CCM_TYPE>
class DDS_Base_Connector_T
: public virtual CCM_TYPE::base_type,
public virtual ::CORBA::LocalObject,
private virtual ACE_Copy_Disabled
{
public:
DDS_Base_Connector_T (void);
virtual ~DDS_Base_Connector_T (void);
/**
* @name domain_id
* Accessors for domain_id
*/
//@{
virtual ::DDS::DomainId_t domain_id (void);
virtual void domain_id (::DDS::DomainId_t domain_id);
//@}
/**
* @name qos_profile
* Accessors for qos_profile
*/
//@{
virtual char *qos_profile (void);
virtual void qos_profile (const char * qos_profile);
//@}
virtual void set_session_context (::Components::SessionContext_ptr ctx);
/**
*
* Interface methods for the Deployment and Configuration Framework
*/
//@{
virtual void configuration_complete (void);
virtual void ccm_remove (void);
virtual void ccm_activate (void);
virtual void ccm_passivate (void);
//@}
private:
/**
* Initialization of the domain participant factory.
*/
void create_dds_participant_factory (void);
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 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 * type_name);
void init_publisher (::DDS::DomainParticipant_ptr participant,
::DDS::Publisher_ptr & publisher);
void init_subscriber (::DDS::DomainParticipant_ptr participant,
::DDS::Subscriber_ptr & subscriber);
//@}
/**
* 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 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);
//@}
/**
* 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 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);
//@}
/**
* 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 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;
//@}
/// Get the reactor associated with this component
ACE_Reactor * reactor (void);
/**
* Attribute of DDS4CCM Base
*/
//@{
::DDS::DomainId_t domain_id_;
::CORBA::String_var qos_profile_;
//@}
/**
* @name 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_;
/**
* Context of the connector. Used to make connection to the user component
* like the interface to the data listeners.
*/
typename CCM_TYPE::context_type::_var_type context_;
/**
* DomainParticipantFactory. Administration of Domain Participants
*/
::DDS::DomainParticipantFactory_var participant_factory_;
#if (CIAO_DDS4CCM_OPENDDS==1)
OpenDDS::DCPS::TransportImpl_rch transport_impl_;
#endif
DDS_XML_QOS_PARSER_TYPE* qos_xml_;
};
#include "dds4ccm/impl/DDS_Base_Connector_T.cpp"
#endif /* DDS_BASE_CONNECTOR_T_H_ */
|
