QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE > Class Template Reference

#include <QOS_DataReader_T.h>

Inheritance diagram for QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >:

[legend]

Collaboration diagram for QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >:

[legend]

List of all members.

Public Member Functions
	QOS_DataReader_T (void)
	~QOS_DataReader_T (void)
void	read_qos (DDS_QOS_TYPE &, const XML_QOS_TYPE)
Private Types
typedef QOS_DwDrTp_Base_T < XML_QOS_TYPE, DDS_QOS_TYPE >	DwDrTpBase

---

Detailed Description

template<typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
class QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >

Author:

Marcel Smit (msmit@remedy.nl)

Starting point for parsing the DataReader QOS settings.

Definition at line 15 of file QOS_DataReader_T.h.

---

Member Typedef Documentation

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

typedef QOS_DwDrTp_Base_T<XML_QOS_TYPE, DDS_QOS_TYPE> QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >::DwDrTpBase [private]

Definition at line 25 of file QOS_DataReader_T.h.

---

Constructor & Destructor Documentation

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >::QOS_DataReader_T

(

void

)

[inline]

Definition at line 8 of file QOS_DataReader_T.cpp.

{
}

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >::~QOS_DataReader_T

(

void

)

[inline]

Definition at line 13 of file QOS_DataReader_T.cpp.

{
}

---

Member Function Documentation

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
	)			[inline]

Reimplemented from QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >.

Definition at line 19 of file QOS_DataReader_T.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, QosCommon::get_duration(), LM_TRACE, and QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  // First start parsing the QOS settings which the DataWriter, the DataReader,
  // and the Topic have in common

  DwDrTpBase::read_qos (dds_qos, xml_qos);

  // Now parse the topic-only QOS settings.

//  if (xml_qos->user_data ())
//    {
      // TODO: Have a good look at this.

//       const std::string value = *xml_qos->user_data ()->value ();
//
//       ACE_DEBUG ((LM_TRACE,
//         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 ());

          if (OpenDDS::DCPS::DCPS_debug_level > 9)
            {
              ACE_DEBUG ((LM_TRACE,
                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 ());

          if (OpenDDS::DCPS::DCPS_debug_level > 9)
            {
              ACE_DEBUG ((LM_TRACE,
                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 ());

          if (OpenDDS::DCPS::DCPS_debug_level > 9)
            {
              ACE_DEBUG ((LM_TRACE,
                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));
            }
        }
    }
}

Here is the call graph for this function:

---

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

• QOS_DataReader_T.h
• QOS_DataReader_T.cpp