QOS_PubSub_T< XML_QOS_TYPE, DDS_QOS_TYPE > Class Template Reference

#include <QOS_PubSub_T.h>

Public Member Functions
	QOS_PubSub_T ()
	~QOS_PubSub_T ()
void	read_qos (DDS_QOS_TYPE &, const XML_QOS_TYPE)

Detailed Description

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

Author

Marcel Smit (msmit.nosp@m.@rem.nosp@m.edy.n.nosp@m.l)

This template contains the parsing of all QOS XML setting which the Publisher and the Subscriber have in common.

The DDS_QOS_TYPE template attribute can either contain an DDS::PublisherQos or an DDS::SubscriberQos. These are the IDL representatives.

The XML_QOS_TYPE can either contain an ::dds::publisherQos or an ::dds::subscriberQos. These are the XML representatives.

Definition at line 22 of file QOS_PubSub_T.h.

Constructor & Destructor Documentation

QOS_PubSub_T()

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL QOS_PubSub_T< XML_QOS_TYPE, DDS_QOS_TYPE >::QOS_PubSub_T

(

)

Definition at line 9 of file QOS_PubSub_T.cpp.

{
}

~QOS_PubSub_T()

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

QOS_PubSub_T< XML_QOS_TYPE, DDS_QOS_TYPE >::~QOS_PubSub_T

(

)

Definition at line 14 of file QOS_PubSub_T.cpp.

{
}

Member Function Documentation

read_qos()

template<typename XML_QOS_TYPE , typename DDS_QOS_TYPE >

void QOS_PubSub_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos	(	DDS_QOS_TYPE &	dds_qos,
		const XML_QOS_TYPE	xml_qos
	)

Definition at line 20 of file QOS_PubSub_T.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, OpenDDS::DCPS::DCPS_debug_level, DDS::GROUP_PRESENTATION_QOS, DDS::INSTANCE_PRESENTATION_QOS, LM_ERROR, LM_TRACE, OPENDDS_END_VERSIONED_NAMESPACE_DECL, FACE::string_dup(), and DDS::TOPIC_PRESENTATION_QOS.

Referenced by PublisherQos_Handler::get_publisher_qos(), and SubscriberQos_Handler::get_subscriber_qos().

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

//       const std::string value = *xml_qos->group_data()->value();
//
//       ACE_DEBUG((LM_TRACE,
//         ACE_TEXT("QOS_DataReader_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
//         ACE_TEXT("Set group_data to <%C>\n"),
//         value.c_str()));
//
//       dds_qos.group_data.value =
//         *xml_qos->group_data()->value();
//     }

    if (xml_qos->presentation_p())
      {
        if (xml_qos->presentation().access_scope_p())
          {
            switch (xml_qos->presentation().access_scope().integral())
              {
              case ::dds::presentationAccessScopeKind::INSTANCE_PRESENTATION_QOS_l:
                dds_qos.presentation.access_scope = ::DDS::INSTANCE_PRESENTATION_QOS;
                break;
              case ::dds::presentationAccessScopeKind::TOPIC_PRESENTATION_QOS_l:
                dds_qos.presentation.access_scope = ::DDS::TOPIC_PRESENTATION_QOS;
                break;
              case ::dds::presentationAccessScopeKind::GROUP_PRESENTATION_QOS_l:
                dds_qos.presentation.access_scope = ::DDS::GROUP_PRESENTATION_QOS;
                break;
              default:
                ACE_ERROR((LM_ERROR,
                  ACE_TEXT("(%P|%t) ERROR: QOS_PubSub_T::read_qos - ")
                  ACE_TEXT("Unknown presentation access scope found <%d>; setting it to INSTANCE_PRESENTATION_QOS\n"),
                  xml_qos->presentation().access_scope().integral()));
                dds_qos.presentation.access_scope = ::DDS::INSTANCE_PRESENTATION_QOS;
                break;
              }
            if (OpenDDS::DCPS::DCPS_debug_level > 9)
              {
                ACE_DEBUG((LM_TRACE,
                  ACE_TEXT("QOS_PubSub_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
                  ACE_TEXT("Set presentation access scope to <%d>\n"),
                  dds_qos.presentation.access_scope));
              }
          }
        if (xml_qos->presentation().coherent_access_p())
          {
            dds_qos.presentation.coherent_access =
              xml_qos->presentation().coherent_access();

            if (OpenDDS::DCPS::DCPS_debug_level > 9)
              {
                ACE_DEBUG((LM_TRACE,
                  ACE_TEXT("QOS_PubSub_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
                  ACE_TEXT("Set presentation coherent_access to <%d>\n"),
                  dds_qos.presentation.coherent_access));
              }
          }
        if (xml_qos->presentation().ordered_access_p())
          {
            dds_qos.presentation.ordered_access =
              xml_qos->presentation().ordered_access();

            if (OpenDDS::DCPS::DCPS_debug_level > 9)
              {
                ACE_DEBUG((LM_TRACE,
                  ACE_TEXT("QOS_PubSub_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
                  ACE_TEXT("Set presentation ordered_access to <%d>\n"),
                  dds_qos.presentation.ordered_access));
              }
          }
      }

  if (xml_qos->partition_p())
    {
      if (xml_qos->partition().name_p())
        {
          dds_qos.partition.name.length(static_cast<CORBA::ULong>(xml_qos->partition().name().count_element()));
          CORBA::ULong pos = 0;
          for (::dds::stringSeq::element_const_iterator it = xml_qos->partition().name().begin_element();
               it != xml_qos->partition().name().end_element();
               ++it, ++pos)
            {
              dds_qos.partition.name[pos] = ::CORBA::string_dup(ACE_TEXT_ALWAYS_CHAR(it->get()->c_str()));

              if (OpenDDS::DCPS::DCPS_debug_level > 9)
                {
                  ACE_DEBUG((LM_TRACE,
                    ACE_TEXT("QOS_PubSub_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
                    ACE_TEXT("New name <%s> inserted in partition at position <%u>\n"),
                    dds_qos.partition.name[pos].in(), pos));
                }
            }
        }
    }

  if (xml_qos->entity_factory_p())
    {
      if (xml_qos->entity_factory().autoenable_created_entities_p())
        {
          dds_qos.entity_factory.autoenable_created_entities =
            xml_qos->entity_factory().autoenable_created_entities();

          if (OpenDDS::DCPS::DCPS_debug_level > 9)
            {
              ACE_DEBUG((LM_TRACE,
                ACE_TEXT("QOS_PubSub_T<XML_QOS_TYPE, DDS_QOS_TYPE>::read_qos - ")
                ACE_TEXT("Set entity_factory autoenable_created_entities to <%d>\n"),
                dds_qos.entity_factory.autoenable_created_entities));
            }
        }
    }
}

---

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

• QOS_PubSub_T.h
• QOS_PubSub_T.cpp