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
|
// $Id$
#include "dds4ccm/impl/logger/Log_Macros.h"
#include "dds/DdsDcpsInfrastructureC.h"
#include "QOS_Common.h"
template <typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::QOS_DataReader_T (void)
{
}
template <typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::~QOS_DataReader_T (void)
{
}
template <typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
void
QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos (DDS_QOS_TYPE& dds_qos, const XML_QOS_TYPE xml_qos)
{
DwDrTpBase::read_qos (dds_qos, xml_qos);
// if (xml_qos->user_data ())
// {
// TODO: Have a good look at this.
// const std::string value = *xml_qos->user_data ()->value ();
//
// DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_DDS_STATUS, (LM_TRACE, DDS4CCM_INFO
// ACE_TEXT ("QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
// ACE_TEXT ("Set user_data to <%C>\n"),
// value.c_str ()));
//
// dds_qos.user_data.value =
// *xml_qos->user_data ()->value ();
// }
if (xml_qos->time_based_filter_p ())
{
if (xml_qos->time_based_filter ().minimum_separation_p ())
{
const std::string nsec = xml_qos->time_based_filter ().minimum_separation ().nanosec ();
const std::string sec = xml_qos->time_based_filter ().minimum_separation ().sec ();
QosCommon::get_duration (dds_qos.time_based_filter.minimum_separation,
sec.c_str (),
nsec.c_str ());
DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_DDS_STATUS, (LM_TRACE, DDS4CCM_INFO
ACE_TEXT ("QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
ACE_TEXT ("Set time_based_filter minimum_separation to <%d:%u>\n"),
dds_qos.time_based_filter.minimum_separation.sec,
dds_qos.time_based_filter.minimum_separation.nanosec));
}
}
if (xml_qos->reader_data_lifecycle_p ())
{
if (xml_qos->reader_data_lifecycle ().autopurge_nowriter_samples_delay_p ())
{
const std::string nsec = xml_qos->reader_data_lifecycle ().autopurge_nowriter_samples_delay ().nanosec ();
const std::string sec = xml_qos->reader_data_lifecycle ().autopurge_nowriter_samples_delay ().sec ();
QosCommon::get_duration (dds_qos.reader_data_lifecycle.autopurge_nowriter_samples_delay,
sec.c_str (),
nsec.c_str ());
DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_DDS_STATUS, (LM_TRACE, DDS4CCM_INFO
ACE_TEXT ("QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
ACE_TEXT ("Set reader_data_lifecycle autopurge_nowriter_samples_delay to <%d:%u>\n"),
dds_qos.reader_data_lifecycle.autopurge_nowriter_samples_delay.sec,
dds_qos.reader_data_lifecycle.autopurge_nowriter_samples_delay.nanosec));
}
if (xml_qos->reader_data_lifecycle ().autopurge_disposed_samples_delay_p ())
{
const std::string nsec = xml_qos->reader_data_lifecycle ().autopurge_disposed_samples_delay ().nanosec ();
const std::string sec = xml_qos->reader_data_lifecycle ().autopurge_disposed_samples_delay ().sec ();
QosCommon::get_duration (dds_qos.reader_data_lifecycle.autopurge_disposed_samples_delay,
sec.c_str (),
nsec.c_str ());
DDS4CCM_DEBUG (DDS4CCM_LOG_LEVEL_DDS_STATUS, (LM_TRACE, DDS4CCM_INFO
ACE_TEXT ("QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
ACE_TEXT ("Set reader_data_lifecycle autopurge_disposed_samples_delay to <%d:%u>\n"),
dds_qos.reader_data_lifecycle.autopurge_disposed_samples_delay.sec,
dds_qos.reader_data_lifecycle.autopurge_disposed_samples_delay.nanosec));
}
}
}
|
