XML_Intf.cpp

Go to the documentation of this file.

#include "XML_Intf.h"
#include "ace/XML_Utils/XML_Helper.h"
#include "ace/XML_Utils/XMLSchema/id_map.hpp"

#include "DataReaderQos_Handler.h"
#include "DataWriterQos_Handler.h"
#include "TopicQos_Handler.h"
#include "PublisherQos_Handler.h"
#include "SubscriberQos_Handler.h"
#include "ParticipantQos_Handler.h"

#include "dds/DCPS/debug.h"

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

namespace OpenDDS {
namespace DCPS {

  QOS_XML_Handler::QOS_XML_Handler()
  {
  }

  QOS_XML_Handler::~QOS_XML_Handler()
  {
  }

  ::dds::qosProfile *
  QOS_XML_Handler::get_profile(const ACE_TCHAR * profile_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::addQoSProfile(const dds::qosProfile & profile)
  {
    // 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;
  }

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

    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;

  }

  DDS::ReturnCode_t
  QOS_XML_Handler::delQoSProfile(const ACE_TCHAR * profileName)
  {

    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;
  }

  size_t QOS_XML_Handler::length() const
  {
     return profiles_.count_qos_profile();
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_datawriter_qos(::DDS::DataWriterQos& dw_qos,
                                      const ACE_TCHAR * profile_name,
                                      const ACE_TCHAR * topic_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_datareader_qos(::DDS::DataReaderQos& dr_qos,
                                      const ACE_TCHAR * profile_name,
                                      const ACE_TCHAR * topic_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_topic_qos(::DDS::TopicQos& tp_qos,
                                 const ACE_TCHAR * profile_name,
                                 const ACE_TCHAR * topic_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_publisher_qos(::DDS::PublisherQos& pub_qos,
                                     const ACE_TCHAR * profile_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_subscriber_qos(::DDS::SubscriberQos& sub_qos,
                                      const ACE_TCHAR * profile_name)
  {
    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;
  }

  DDS::ReturnCode_t
  QOS_XML_Handler::get_participant_qos(::DDS::DomainParticipantQos& sub_qos,
                                       const ACE_TCHAR * profile_name)
  {
    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;
  }

}
}

OPENDDS_END_VERSIONED_NAMESPACE_DECL