OpenDDS  Snapshot(2023/04/28-20:55)
QOS_XML_Loader.cpp
Go to the documentation of this file.
1 #include "QOS_XML_Loader.h"
2 #include "XML_File_Intf.h"
3 #include "ace/Tokenizer_T.h"
4 #include "dds/DCPS/debug.h"
5 
6 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
7 
8 namespace OpenDDS {
9 namespace DCPS {
10 
11  QOS_XML_Loader::QOS_XML_Loader(XML::XML_Error_Handler* error_handler)
12  : xml_file_ (error_handler)
13  {
14  }
15 
16  QOS_XML_Loader::~QOS_XML_Loader()
17  {
18  }
19 
20  ACE_TString
21  QOS_XML_Loader::get_xml_file_name(const ACE_TCHAR* qos_profile)
22  {
23  if (qos_profile)
24  {
25  ACE_TCHAR* buf = ACE_OS::strdup(qos_profile);
26  ACE_Tokenizer_T<ACE_TCHAR> tok(buf);
27  tok.delimiter_replace('#', 0);
28  const ACE_TCHAR * file_name = tok.next();
29 
30  if (file_name == 0)
31  {
32  ACE_OS::free(buf);
33  if (DCPS_debug_level > 5)
34  {
35  ACE_ERROR((LM_ERROR,
36  "get_xml_file_name <%s> - "
37  "Error: malformed qos_profile. Expected format: "
38  "<xml_file_base_name>#<profile_name>\n",
39  qos_profile));
40  }
41  return ACE_TString();
42  }
43 
44  ACE_TString ret(file_name);
45  ret += ACE_TEXT(".xml");
46  ACE_OS::free(buf);
47  return ret;
48  }
49 
50  return ACE_TString();
51  }
52 
53  ACE_TString
54  QOS_XML_Loader::get_profile_name(const ACE_TCHAR* qos_profile)
55  {
56  if (qos_profile)
57  {
58  ACE_TCHAR* buf = ACE_OS::strdup(qos_profile);
59  ACE_Tokenizer_T<ACE_TCHAR> tok(buf);
60  tok.delimiter_replace('#', 0);
61  const ACE_TCHAR * lib_name = tok.next();
62  const ACE_TCHAR * prof_name = tok.next();
63 
64  if (lib_name == 0 || prof_name == 0 || tok.next() != 0)
65  {
66  ACE_OS::free(buf);
67  if (DCPS_debug_level > 5)
68  {
69  ACE_ERROR((LM_ERROR,
70  "get_profile_name <%s> - "
71  "Error: malformed qos_profile. Expected format: "
72  "<xml_file_base_name>#<profile_name>\n",
73  qos_profile));
74  }
75  return ACE_TString();
76  }
77 
78  ACE_TString ret(prof_name);
79  ACE_OS::free(buf);
80  return ret;
81  }
82 
83  return ACE_TString();
84  }
85 
86 
87  DDS::ReturnCode_t
88  QOS_XML_Loader::init(const ACE_TCHAR* qos_profile)
89  {
90  if (!qos_profile)
91  {
92  if (DCPS_debug_level > 5)
93  {
94  ACE_ERROR((LM_ERROR,
95  ACE_TEXT("QOS_XML_Loader::init - ")
96  ACE_TEXT("Passed an empty qos_profile, returning.\n")));
97  }
98  return ::DDS::RETCODE_BAD_PARAMETER;
99  }
100 
101  const ACE_TString filename = get_xml_file_name(qos_profile);
102 
103  if (filename.empty())
104  {
105  if (DCPS_debug_level > 5)
106  {
107  ACE_ERROR((LM_ERROR,
108  ACE_TEXT("QOS_XML_Loader::init - ")
109  ACE_TEXT("Unable to extract a file name from <%s>, returning.\n"),
110  qos_profile));
111  }
112  return ::DDS::RETCODE_BAD_PARAMETER;
113  }
114 
115  xml_file_.add_search_path(
116  ACE_TEXT("DDS_ROOT"),
117  ACE_TEXT("/docs/schema/"));
118 
119  DDS::ReturnCode_t const retcode = xml_file_.init(filename.c_str());
120 
121  return retcode;
122  }
123 
124  DDS::ReturnCode_t
125  QOS_XML_Loader::get_datawriter_qos(
126  ::DDS::DataWriterQos& dw_qos,
127  const ACE_TCHAR * qos_profile,
128  const ACE_TCHAR * topic_name)
129  {
130  if (!qos_profile)
131  {
132  if (DCPS_debug_level > 9)
133  {
134  ACE_DEBUG((LM_DEBUG,
135  ACE_TEXT("QOS_XML_Loader::get_datawriter_qos - ")
136  ACE_TEXT("No QOS profile provided. Can't do anything, ")
137  ACE_TEXT("returning\n")));
138  }
139 
140  return DDS::RETCODE_OK;
141  }
142 
143  const ACE_TString profile_name = get_profile_name(qos_profile);
144 
145  if (profile_name.empty())
146  {
147  if (DCPS_debug_level > 5)
148  {
149  ACE_ERROR((LM_ERROR,
150  ACE_TEXT("QOS_XML_Loader::get_datawriter_qos - ")
151  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
152  qos_profile));
153  }
154  return ::DDS::RETCODE_BAD_PARAMETER;
155  }
156 
157  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
158 
159  try
160  {
161  retcode = xml_file_.get_datawriter_qos(dw_qos,
162  profile_name.c_str(),
163  topic_name);
164  }
165  catch (...)
166  {
167  if (DCPS_debug_level > 5)
168  {
169  ACE_ERROR((LM_ERROR,
170  ACE_TEXT("QOS_XML_Loader::get_datawriter_qos - ")
171  ACE_TEXT("Caught unexpected exception.\n")));
172  }
173  retcode = DDS::RETCODE_ERROR;
174  }
175 
176  return retcode;
177  }
178 
179  DDS::ReturnCode_t
180  QOS_XML_Loader::get_datareader_qos(
181  DDS::DataReaderQos& dr_qos,
182  const ACE_TCHAR * qos_profile,
183  const ACE_TCHAR * topic_name)
184  {
185  if (!qos_profile)
186  {
187  if (DCPS_debug_level > 9)
188  {
189  ACE_DEBUG((LM_DEBUG,
190  ACE_TEXT("QOS_XML_Loader::get_datareader_qos - ")
191  ACE_TEXT("No QOS profile provided. Can't do anything, ")
192  ACE_TEXT("returning\n")));
193  }
194 
195  return DDS::RETCODE_OK;
196  }
197 
198  const ACE_TString profile_name = get_profile_name(qos_profile);
199 
200  if (profile_name.empty())
201  {
202  if (DCPS_debug_level > 5)
203  {
204  ACE_ERROR((LM_ERROR,
205  ACE_TEXT("QOS_XML_Loader::get_datareader_qos - ")
206  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
207  qos_profile));
208  }
209  return ::DDS::RETCODE_BAD_PARAMETER;
210  }
211 
212  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
213 
214  try
215  {
216  retcode = xml_file_.get_datareader_qos(dr_qos,
217  profile_name.c_str(),
218  topic_name);
219  }
220  catch (...)
221  {
222  if (DCPS_debug_level > 5)
223  {
224  ACE_ERROR((LM_ERROR,
225  ACE_TEXT("QOS_XML_Loader::get_datareader_qos - ")
226  ACE_TEXT("Caught unexpected exception.\n")));
227  }
228  retcode = ::DDS::RETCODE_ERROR;
229  }
230 
231  return retcode;
232  }
233 
234  DDS::ReturnCode_t
235  QOS_XML_Loader::get_publisher_qos(
236  DDS::PublisherQos& pub_qos,
237  const ACE_TCHAR * qos_profile)
238  {
239  if (!qos_profile)
240  {
241  if (DCPS_debug_level > 9)
242  {
243  ACE_DEBUG((LM_DEBUG,
244  ACE_TEXT("QOS_XML_Loader::get_publisher_qos - ")
245  ACE_TEXT("No QOS profile provided. Can't do anything, ")
246  ACE_TEXT("returning\n")));
247  }
248 
249  return DDS::RETCODE_OK;
250  }
251 
252  const ACE_TString profile_name = get_profile_name(qos_profile);
253 
254  if (profile_name.empty())
255  {
256  if (DCPS_debug_level > 5)
257  {
258  ACE_ERROR((LM_ERROR,
259  ACE_TEXT("QOS_XML_Loader::get_publisher_qos - ")
260  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
261  qos_profile));
262  }
263  return ::DDS::RETCODE_BAD_PARAMETER;
264  }
265 
266  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
267 
268  try
269  {
270  retcode = xml_file_.get_publisher_qos(pub_qos, profile_name.c_str());
271  }
272  catch (...)
273  {
274  if (DCPS_debug_level > 5)
275  {
276  ACE_ERROR((LM_ERROR,
277  ACE_TEXT("QOS_XML_Loader::get_publisher_qos - ")
278  ACE_TEXT("Caught unexpected exception.\n")));
279  }
280  retcode = DDS::RETCODE_ERROR;
281  }
282 
283  return retcode;
284  }
285 
286  DDS::ReturnCode_t
287  QOS_XML_Loader::get_subscriber_qos(
288  DDS::SubscriberQos& sub_qos,
289  const ACE_TCHAR * qos_profile)
290  {
291  if (!qos_profile)
292  {
293  if (DCPS_debug_level > 9)
294  {
295  ACE_DEBUG((LM_DEBUG,
296  ACE_TEXT("QOS_XML_Loader::get_subscriber_qos - ")
297  ACE_TEXT("No QOS profile provided. Can't do anything, ")
298  ACE_TEXT("returning\n")));
299  }
300 
301  return DDS::RETCODE_OK;
302  }
303 
304  const ACE_TString profile_name = get_profile_name(qos_profile);
305 
306  if (profile_name.empty())
307  {
308  if (DCPS_debug_level > 5)
309  {
310  ACE_ERROR((LM_ERROR,
311  ACE_TEXT("QOS_XML_Loader::get_subscriber_qos - ")
312  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
313  qos_profile));
314  }
315  return ::DDS::RETCODE_BAD_PARAMETER;
316  }
317 
318  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
319 
320  try
321  {
322  retcode = xml_file_.get_subscriber_qos(sub_qos, profile_name.c_str());
323  }
324  catch (...)
325  {
326  if (DCPS_debug_level > 5)
327  {
328  ACE_ERROR((LM_ERROR,
329  ACE_TEXT("QOS_XML_Loader::get_subscriber_qos - ")
330  ACE_TEXT("Caught unexpected exception.\n")));
331  }
332  retcode = DDS::RETCODE_ERROR;
333  }
334 
335  return retcode;
336  }
337 
338  DDS::ReturnCode_t
339  QOS_XML_Loader::get_topic_qos(
340  DDS::TopicQos& topic_qos,
341  const ACE_TCHAR * qos_profile,
342  const ACE_TCHAR * topic_name)
343  {
344  if (!qos_profile)
345  {
346  if (DCPS_debug_level > 9)
347  {
348  ACE_DEBUG((LM_DEBUG,
349  ACE_TEXT("QOS_XML_Loader::get_topic_qos - ")
350  ACE_TEXT("No QOS profile provided. Can't do anything, ")
351  ACE_TEXT("returning\n")));
352  }
353 
354  return DDS::RETCODE_OK;
355  }
356 
357  const ACE_TString profile_name = get_profile_name(qos_profile);
358 
359  if (profile_name.empty())
360  {
361  if (DCPS_debug_level > 5)
362  {
363  ACE_ERROR((LM_ERROR,
364  ACE_TEXT("QOS_XML_Loader::get_topic_qos - ")
365  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
366  qos_profile));
367  }
368  return ::DDS::RETCODE_BAD_PARAMETER;
369  }
370 
371  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
372 
373  try
374  {
375  retcode = xml_file_.get_topic_qos(topic_qos,
376  profile_name.c_str(),
377  topic_name);
378  }
379  catch (...)
380  {
381  if (DCPS_debug_level > 5)
382  {
383  ACE_ERROR((LM_ERROR,
384  ACE_TEXT("QOS_XML_Loader::get_topic_qos - ")
385  ACE_TEXT("Caught unexpected exception.\n")));
386  }
387  retcode = DDS::RETCODE_ERROR;
388  }
389 
390  return retcode;
391  }
392 
393  DDS::ReturnCode_t
394  QOS_XML_Loader::get_participant_qos(
395  DDS::DomainParticipantQos& part_qos,
396  const ACE_TCHAR * qos_profile)
397  {
398  if (!qos_profile)
399  {
400  if (DCPS_debug_level > 9)
401  {
402  ACE_DEBUG((LM_DEBUG,
403  ACE_TEXT("QOS_XML_Loader::get_participant_qos - ")
404  ACE_TEXT("No QOS profile provided. Can't do anything, ")
405  ACE_TEXT("returning\n")));
406  }
407 
408  return DDS::RETCODE_OK;
409  }
410 
411  const ACE_TString profile_name = get_profile_name(qos_profile);
412 
413  if (profile_name.empty())
414  {
415  if (DCPS_debug_level > 5)
416  {
417  ACE_ERROR((LM_ERROR,
418  ACE_TEXT("QOS_XML_Loader::get_participant_qos - ")
419  ACE_TEXT("Error parsing profile string <%s>, returning.\n"),
420  qos_profile));
421  }
422  return ::DDS::RETCODE_BAD_PARAMETER;
423  }
424 
425  DDS::ReturnCode_t retcode = DDS::RETCODE_OK;
426 
427  try
428  {
429  retcode = xml_file_.get_participant_qos(part_qos, profile_name.c_str());
430  }
431  catch (...)
432  {
433  if (DCPS_debug_level > 5)
434  {
435  ACE_ERROR((LM_ERROR,
436  ACE_TEXT("QOS_XML_Loader::get_participant_qos - ")
437  ACE_TEXT("Caught unexpected exception.\n")));
438  }
439  retcode = DDS::RETCODE_ERROR;
440  }
441 
442  return retcode;
443  }
444 }
445 }
446 
447 OPENDDS_END_VERSIONED_NAMESPACE_DECL
ACE_DEBUG
#define ACE_DEBUG(X)
OpenDDS::DCPS::QOS_XML_Handler::get_participant_qos
DDS::ReturnCode_t get_participant_qos(::DDS::DomainParticipantQos &sub_qos, const ACE_TCHAR *profile_name)
Definition: XML_Intf.cpp:354
ACE_ERROR
#define ACE_ERROR(X)
ACE_String_Base< char >::c_str
const char * c_str(void) const
OpenDDS::DCPS::QOS_XML_Handler::get_datareader_qos
DDS::ReturnCode_t get_datareader_qos(::DDS::DataReaderQos &dr_qos, const ACE_TCHAR *profile_name, const ACE_TCHAR *topic_name)
Definition: XML_Intf.cpp:208
ACE_OS::free
void free(void *)
OpenDDS::DCPS::QOS_XML_Loader::get_datareader_qos
DDS::ReturnCode_t get_datareader_qos(DDS::DataReaderQos &dr_qos, const ACE_TCHAR *qos_profile, const ACE_TCHAR *topic_name)
Definition: QOS_XML_Loader.cpp:180
OpenDDS::DCPS::QOS_XML_Loader::QOS_XML_Loader
QOS_XML_Loader(XML::XML_Error_Handler *error_handler=0)
Definition: QOS_XML_Loader.cpp:11
ACE_Tokenizer_T::delimiter_replace
int delimiter_replace(ACE_CHAR_T d, ACE_CHAR_T replacement)
OpenDDS::DCPS::QOS_XML_Handler::get_publisher_qos
DDS::ReturnCode_t get_publisher_qos(::DDS::PublisherQos &pub_qos, const ACE_TCHAR *profile_name)
Definition: XML_Intf.cpp:284
OpenDDS::DCPS::QOS_XML_Loader::get_datawriter_qos
DDS::ReturnCode_t get_datawriter_qos(DDS::DataWriterQos &dw_qos, const ACE_TCHAR *qos_profile, const ACE_TCHAR *topic_name)
Definition: QOS_XML_Loader.cpp:125
OpenDDS::DCPS::QOS_XML_Loader::get_publisher_qos
DDS::ReturnCode_t get_publisher_qos(DDS::PublisherQos &pub_qos, const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:235
OpenDDS::DCPS::QOS_XML_Handler::get_topic_qos
DDS::ReturnCode_t get_topic_qos(::DDS::TopicQos &tp_qos, const ACE_TCHAR *profile_name, const ACE_TCHAR *topic_name)
Definition: XML_Intf.cpp:246
OpenDDS::DCPS::QOS_XML_Handler::get_datawriter_qos
DDS::ReturnCode_t get_datawriter_qos(::DDS::DataWriterQos &dw_qos, const ACE_TCHAR *profile_name, const ACE_TCHAR *topic_name)
Definition: XML_Intf.cpp:170
LM_DEBUG
LM_DEBUG
OpenDDS::DCPS::QOS_XML_Loader::xml_file_
QOS_XML_File_Handler xml_file_
Definition: QOS_XML_Loader.h:86
OpenDDS::DCPS::QOS_XML_Loader::get_topic_qos
DDS::ReturnCode_t get_topic_qos(DDS::TopicQos &topic_qos, const ACE_TCHAR *qos_profile, const ACE_TCHAR *topic_name)
Definition: QOS_XML_Loader.cpp:339
ACE_TCHAR
char ACE_TCHAR
OpenDDS::DCPS::QOS_XML_Loader::get_subscriber_qos
DDS::ReturnCode_t get_subscriber_qos(DDS::SubscriberQos &sub_qos, const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:287
OpenDDS::DCPS::QOS_XML_File_Handler::add_search_path
void add_search_path(const ACE_TCHAR *environment, const ACE_TCHAR *relpath)
Definition: XML_File_Intf.cpp:97
OpenDDS::DCPS::QOS_XML_Loader::get_participant_qos
DDS::ReturnCode_t get_participant_qos(DDS::DomainParticipantQos &part_qos, const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:394
OpenDDS::DCPS::QOS_XML_Loader::get_xml_file_name
ACE_TString get_xml_file_name(const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:21
OpenDDS::DCPS::QOS_XML_Handler::get_subscriber_qos
DDS::ReturnCode_t get_subscriber_qos(::DDS::SubscriberQos &sub_qos, const ACE_TCHAR *profile_name)
Definition: XML_Intf.cpp:319
ACE_String_Base< char >::empty
bool empty(void) const
OpenDDS::DCPS::QOS_XML_Loader::init
DDS::ReturnCode_t init(const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:88
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::DCPS::DCPS_debug_level
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
Definition: debug.cpp:30
OpenDDS::DCPS::QOS_XML_File_Handler::init
DDS::ReturnCode_t init(const ACE_TCHAR *file)
Definition: XML_File_Intf.cpp:27
DDS::RETCODE_ERROR
const ReturnCode_t RETCODE_ERROR
Definition: DdsDcpsInfrastructure.idl:55
OPENDDS_END_VERSIONED_NAMESPACE_DECL
#define OPENDDS_END_VERSIONED_NAMESPACE_DECL
Definition: Versioned_Namespace.h:48
ACE_OS::strdup
char * strdup(const char *s)
DDS::RETCODE_OK
const ReturnCode_t RETCODE_OK
Definition: DdsDcpsInfrastructure.idl:54
ACE_Tokenizer_T::next
ACE_CHAR_T * next(void)
OpenDDS::DCPS::QOS_XML_Loader::get_profile_name
ACE_TString get_profile_name(const ACE_TCHAR *qos_profile)
Definition: QOS_XML_Loader.cpp:54
LM_ERROR
LM_ERROR
OpenDDS
The Internal API and Implementation of OpenDDS.
Definition: AddressCache.h:28
DDS::RETCODE_BAD_PARAMETER
const ReturnCode_t RETCODE_BAD_PARAMETER
Definition: DdsDcpsInfrastructure.idl:57
Generated by   doxygen 1.8.13