#include <XML_Intf.h>

Inheritance diagram for OpenDDS::DCPS::QOS_XML_Handler:

Public Member Functions
	QOS_XML_Handler ()

	~QOS_XML_Handler ()

::dds::qosProfile_seq	profiles_

DDS::ReturnCode_t	get_datawriter_qos (::DDS::DataWriterQos &dw_qos, const ACE_TCHAR profile_name, const ACE_TCHAR topic_name)

DDS::ReturnCode_t	get_datareader_qos (::DDS::DataReaderQos &dr_qos, const ACE_TCHAR profile_name, const ACE_TCHAR topic_name)

DDS::ReturnCode_t	get_topic_qos (::DDS::TopicQos &tp_qos, const ACE_TCHAR profile_name, const ACE_TCHAR topic_name)

DDS::ReturnCode_t	get_publisher_qos (::DDS::PublisherQos &pub_qos, const ACE_TCHAR *profile_name)

DDS::ReturnCode_t	get_subscriber_qos (::DDS::SubscriberQos &sub_qos, const ACE_TCHAR *profile_name)

DDS::ReturnCode_t	get_participant_qos (::DDS::DomainParticipantQos &sub_qos, const ACE_TCHAR *profile_name)

DDS::ReturnCode_t	addQoSProfile (const dds::qosProfile &profile)

DDS::ReturnCode_t	addQoSProfileSeq (const dds::qosProfile_seq &profiles)

DDS::ReturnCode_t	delQoSProfile (const ACE_TCHAR *profileName)

size_t	length () const

::dds::qosProfile	getProfile (const ACE_TCHAR *profileName)

const ::dds::qosProfile_seq &	get ()

::dds::qosProfile *	get_profile (const ACE_TCHAR *profile_name)

Detailed Description

Definition at line 27 of file XML_Intf.h.

Constructor & Destructor Documentation

◆ QOS_XML_Handler()

OpenDDS::DCPS::QOS_XML_Handler::QOS_XML_Handler ( )

Definition at line 20 of file XML_Intf.cpp.

21 {

22 }

◆ ~QOS_XML_Handler()

OpenDDS::DCPS::QOS_XML_Handler::~QOS_XML_Handler ( )

Definition at line 24 of file XML_Intf.cpp.

25 {

26 }

Member Function Documentation

◆ addQoSProfile()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::addQoSProfile ( const dds::qosProfile & profile )

Add qos profile to sequence

Definition at line 72 of file XML_Intf.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, profiles_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, ACE_OS::strcmp(), and ACE_OS::strlen().

Referenced by addQoSProfileSeq().

   {
     // get profile name  and check if it exists
 
     const ACE_TCHAR* profileName = profile.name().c_str();
     if (ACE_OS::strlen(profileName) == 0) {
       if (DCPS_debug_level > 7)
       {
          ACE_ERROR((LM_ERROR,
            ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::addQoSProfile - ")
            ACE_TEXT("No profile name specified\n")));
       return DDS::RETCODE_ERROR;
       }
     }
 
     // check if this profile name is already in the list
     dds::qosProfile_seq::qos_profile_const_iterator it;
     for (it = profiles_.begin_qos_profile();
          it != profiles_.end_qos_profile();
          ++it)
     {
       if (ACE_OS::strcmp((*it)->name().c_str(), profileName) == 0) {
         if (DCPS_debug_level > 7)
         {
           ACE_ERROR((LM_ERROR,
             ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::addQoSProfile - ")
             ACE_TEXT("Profile exists or profile name <%C> in use.\n"),
             profileName));
         }
         return DDS::RETCODE_ERROR;
       }
     }
 
     // append qos profile to list
     dds::qosProfile_seq::qos_profile_value_type t(new dds::qosProfile(profile));
     profiles_.add_qos_profile(t);
     return DDS::RETCODE_OK;
   }

◆ addQoSProfileSeq()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::addQoSProfileSeq ( const dds::qosProfile_seq & profiles )

Add qos profiles to sequence

Definition at line 112 of file XML_Intf.cpp.

References addQoSProfile(), and DDS::RETCODE_OK.

   {
 
     dds::qosProfile_seq::qos_profile_const_iterator it;
     for (it = profiles.begin_qos_profile();
          it != profiles.end_qos_profile();
          ++it)
     {
       dds::qosProfile qos(*(it->get()));
       addQoSProfile(qos);
     }
 
     return DDS::RETCODE_OK;
 
   }

◆ delQoSProfile()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::delQoSProfile ( const ACE_TCHAR * profileName )

Remove qos profile to sequence

Definition at line 129 of file XML_Intf.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, profiles_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, ACE_OS::strcmp(), and ACE_OS::strlen().

   {
 
     if (ACE_OS::strlen(profileName) == 0)
     {
       if (DCPS_debug_level > 7)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::delQoSProfile - ")
           ACE_TEXT("No profile specified\n")));
         return DDS::RETCODE_ERROR;
       }
     }
 
     dds::qosProfile_seq::qos_profile_const_iterator it;
     for (it = profiles_.begin_qos_profile();
          it != profiles_.end_qos_profile();
          ++it)
     {
       if (ACE_OS::strcmp((*it)->name().c_str(), profileName) == 0) {
         profiles_.del_qos_profile(*it);
         return DDS::RETCODE_OK;
       }
 
     }
 
     if (DCPS_debug_level > 7)
     {
       ACE_ERROR((LM_ERROR,
         ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::delQoSProfile - ")
         ACE_TEXT("Profile doesn't exists or wrong profile name.\n")));
     }
     return DDS::RETCODE_ERROR;
   }

◆ get()

const ::dds::qosProfile_seq& OpenDDS::DCPS::QOS_XML_Handler::get ( void )

inline

get profiles sequence

Definition at line 111 of file XML_Intf.h.

                                    {
       return profiles_;
     }

◆ get_datareader_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_datareader_qos	(	::DDS::DataReaderQos &	dr_qos,
		const ACE_TCHAR *	profile_name,
		const ACE_TCHAR *	topic_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 208 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), DataReaderQos_Handler::get_datareader_qos(), get_profile(), LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_datareader_qos().

   {
     ACE_UNUSED_ARG(topic_name);
 
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             DataReaderQos_Handler::get_datareader_qos(dr_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_datareader_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_datareader_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ get_datawriter_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_datawriter_qos	(	::DDS::DataWriterQos &	dw_qos,
		const ACE_TCHAR *	profile_name,
		const ACE_TCHAR *	topic_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 170 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), DataWriterQos_Handler::get_datawriter_qos(), get_profile(), LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_datawriter_qos().

   {
     ACE_UNUSED_ARG(topic_name);
 
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             DataWriterQos_Handler::get_datawriter_qos(dw_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_datawriter_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_datawriter_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ get_participant_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_participant_qos	(	::DDS::DomainParticipantQos &	sub_qos,
		const ACE_TCHAR *	profile_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 354 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), ParticipantQos_Handler::get_participant_qos(), get_profile(), LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_participant_qos().

   {
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             ParticipantQos_Handler::get_participant_qos(sub_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_participant_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_participant_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ get_profile()

dds::qosProfile * OpenDDS::DCPS::QOS_XML_Handler::get_profile ( const ACE_TCHAR * profile_name )

protected

Searches for the profile in the XML file, using the given profile name.

Definition at line 29 of file XML_Intf.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, profiles_, ACE_OS::strcmp(), and ACE_OS::strlen().

Referenced by get_datareader_qos(), get_datawriter_qos(), get_participant_qos(), get_publisher_qos(), get_subscriber_qos(), and get_topic_qos().

   {
     if (ACE_OS::strlen(profile_name) == 0)
     {
       if (DCPS_debug_level > 7)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::get_profile - ")
           ACE_TEXT("No profile specified\n")));
         return 0;
       }
     }
 
     dds::qosProfile_seq::qos_profile_const_iterator it;
     for (it = profiles_.begin_qos_profile();
         it != profiles_.end_qos_profile();
         ++it)
       {
         if (ACE_OS::strcmp((*it)->name().c_str(), profile_name) == 0)
           {
             if (DCPS_debug_level > 7)
               {
                 ACE_ERROR((LM_ERROR,
                   ACE_TEXT("QOS_XML_Handler::get_profile - ")
                   ACE_TEXT("Found profile <%s>\n"),
                   (*it)->name().c_str()));
               }
             return it->get();
           }
       }
 
     if (OpenDDS::DCPS::DCPS_debug_level > 7)
       {
         ACE_ERROR ((LM_ERROR,
           ACE_TEXT("(%P|%t) ERROR: QOS_XML_Handler::get_profile - ")
           ACE_TEXT("Did not find profile <%s>\n"),
           profile_name));
       }
 
     return 0;
   }

◆ get_publisher_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_publisher_qos	(	::DDS::PublisherQos &	pub_qos,
		const ACE_TCHAR *	profile_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 284 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), get_profile(), PublisherQos_Handler::get_publisher_qos(), LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_publisher_qos().

   {
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             PublisherQos_Handler::get_publisher_qos(pub_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_publisher_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_publisher_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ get_subscriber_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_subscriber_qos	(	::DDS::SubscriberQos &	sub_qos,
		const ACE_TCHAR *	profile_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 319 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), get_profile(), SubscriberQos_Handler::get_subscriber_qos(), LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_subscriber_qos().

   {
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             SubscriberQos_Handler::get_subscriber_qos(sub_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_subscriber_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_subscriber_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ get_topic_qos()

DDS::ReturnCode_t OpenDDS::DCPS::QOS_XML_Handler::get_topic_qos	(	::DDS::TopicQos &	tp_qos,
		const ACE_TCHAR *	profile_name,
		const ACE_TCHAR *	topic_name
	)

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 246 of file XML_Intf.cpp.

References CORBA::Exception::_info(), ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), get_profile(), TopicQos_Handler::get_topic_qos(), LM_ERROR, DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::QOS_XML_Loader::get_topic_qos().

   {
     ACE_UNUSED_ARG(topic_name);
 
     DDS::ReturnCode_t retcode = DDS::RETCODE_ERROR;
     try
       {
         ::dds::qosProfile * profile = this->get_profile(profile_name);
         if (profile != 0)
           {
             TopicQos_Handler::get_topic_qos(tp_qos, profile);
             retcode = ::DDS::RETCODE_OK;
           }
         else
           retcode = DDS::RETCODE_BAD_PARAMETER;
       }
     catch (const CORBA::Exception &ex)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_topic_qos - ")
           ACE_TEXT("Caught CORBA exception whilst parsing XML into IDL: %C\n"),
           ex._info().c_str()));
         retcode = DDS::RETCODE_ERROR;
       }
     catch (...)
       {
         ACE_ERROR((LM_ERROR,
           ACE_TEXT("QOS_XML_Handler::get_topic_qos - ")
           ACE_TEXT("Unexpected exception whilst parsing XML into IDL.\n")));
         retcode = DDS::RETCODE_ERROR;
       }
 
     return retcode;
   }

◆ getProfile()

::dds::qosProfile OpenDDS::DCPS::QOS_XML_Handler::getProfile ( const ACE_TCHAR * profileName )

inline

Get profile by name

Definition at line 99 of file XML_Intf.h.

References ACE_TEXT().

                                                             {
       ::dds::qosProfile* profile = get_profile (profileName);
       if (profile) {
         return *profile;
       } else {
         return ::dds::qosProfile(ACE_TEXT(""));
       }
     }

◆ length()

size_t OpenDDS::DCPS::QOS_XML_Handler::length ( void ) const

Get number of profiles in sequence

Definition at line 164 of file XML_Intf.cpp.

References profiles_.

   {
      return profiles_.count_qos_profile();
   }

Member Data Documentation

◆ profiles_

::dds::qosProfile_seq OpenDDS::DCPS::QOS_XML_Handler::profiles_

protected

These methods will search for the profileQos in profiles_, using the given profile_name. If found, these methods will invoke the corresponding method on the corresponding Handler class. These classes are available in the xxxQos_Handler.h files.

Definition at line 116 of file XML_Intf.h.

Referenced by addQoSProfile(), delQoSProfile(), get_profile(), OpenDDS::DCPS::QOS_XML_File_Handler::init(), OpenDDS::DCPS::QOS_XML_String_Handler::init(), and length().

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

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ QOS_XML_Handler()

◆ ~QOS_XML_Handler()

Member Function Documentation

◆ addQoSProfile()

◆ addQoSProfileSeq()

◆ delQoSProfile()

◆ get()

◆ get_datareader_qos()

◆ get_datawriter_qos()

◆ get_participant_qos()

◆ get_profile()

◆ get_publisher_qos()

◆ get_subscriber_qos()

◆ get_topic_qos()

◆ getProfile()

◆ length()

Member Data Documentation

◆ profiles_