QOS_DataReader_T.cpp

Go to the documentation of this file.

#include "dds/DdsDcpsInfrastructureC.h"
#include "QOS_Common.h"
#include "ace/ace_wchar.h"

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

template <typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::QOS_DataReader_T()
{
}

template <typename XML_QOS_TYPE, typename DDS_QOS_TYPE>
QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::~QOS_DataReader_T()
{
}

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)
{
  // 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 ACE_TString sec(xml_qos->time_based_filter().minimum_separation().sec().c_str());
          const ACE_TString nsec(xml_qos->time_based_filter().minimum_separation().nanosec().c_str());

          QosCommon::get_duration(dds_qos.time_based_filter.minimum_separation,
                                  sec.fast_rep(),
                                  nsec.fast_rep());

          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 ACE_TString sec(xml_qos->reader_data_lifecycle().autopurge_nowriter_samples_delay().sec().c_str());
          const ACE_TString nsec(xml_qos->reader_data_lifecycle().autopurge_nowriter_samples_delay().nanosec().c_str());

          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 ACE_TString sec(xml_qos->reader_data_lifecycle().autopurge_disposed_samples_delay().sec().c_str());
          const ACE_TString nsec(xml_qos->reader_data_lifecycle().autopurge_disposed_samples_delay().nanosec().c_str());

          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));
            }
        }
    }
  if (xml_qos->type_consistency_p())
    {
      if (xml_qos->type_consistency().kind_p())
        {
          QosCommon::get_type_consistency_kind(xml_qos->type_consistency().kind(),
                                               dds_qos.type_consistency.kind);

          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 type_consistency kind to <%d>\n"),
                dds_qos.type_consistency.kind));
            }
        }
      if (xml_qos->type_consistency().ignore_sequence_bounds_p())
        {
          dds_qos.type_consistency.ignore_sequence_bounds =
            xml_qos->type_consistency().ignore_sequence_bounds();

          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 ignore_sequence_bounds to <%d>\n"),
                dds_qos.type_consistency.ignore_sequence_bounds));
            }
        }
      if (xml_qos->type_consistency().ignore_string_bounds_p())
        {
          dds_qos.type_consistency.ignore_string_bounds =
            xml_qos->type_consistency().ignore_string_bounds();

          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 ignore_string_bounds to <%d>\n"),
                dds_qos.type_consistency.ignore_string_bounds));
            }
        }
      if (xml_qos->type_consistency().ignore_member_names_p())
        {
          dds_qos.type_consistency.ignore_member_names =
            xml_qos->type_consistency().ignore_member_names();

          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 ignore_member_names to <%d>\n"),
                dds_qos.type_consistency.ignore_member_names));
            }
        }
      if (xml_qos->type_consistency().prevent_type_widening_p())
        {
          dds_qos.type_consistency.prevent_type_widening =
            xml_qos->type_consistency().prevent_type_widening();

          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 prevent_type_widening to <%d>\n"),
                dds_qos.type_consistency.prevent_type_widening));
            }
        }
      if (xml_qos->type_consistency().force_type_validation_p())
        {
          dds_qos.type_consistency.force_type_validation =
            xml_qos->type_consistency().force_type_validation();

          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 force_type_validation to <%d>\n"),
                dds_qos.type_consistency.force_type_validation));
            }
        }
    }
}

OPENDDS_END_VERSIONED_NAMESPACE_DECL