DataWriterQos_Handler.cpp

Go to the documentation of this file.

#include "DataWriterQos_Handler.h"
#include "QOS_DataWriter_T.h"
#include "dds/DCPS/debug.h"

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

bool
DataWriterQos_Handler::get_datawriter_qos(DDS::DataWriterQos& dw_qos,
                                          dds::qosProfile * profile,
                                          const ACE_TCHAR * name)
{
  if (name)
    {
//       // find the correct datawriter_qos
//       for (dds::qosProfile::datawriter_qos_iterator dw_it = profile->begin_datawriter_qos();
//           dw_it != profile->end_datawriter_qos();
//           ++dw_it)
//         {
//           if (ACE_OS::strcmp(dw_name.c_str(), name) == 0)
//             {
//               return get_datawriter_qos(dw_qos, *dw_it->get());
//             }
//         }
    }
  else
    {
      if (profile->count_datawriter_qos() == 0)
        {
          if (OpenDDS::DCPS::DCPS_debug_level > 7)
            {
              ACE_DEBUG((LM_TRACE,
                ACE_TEXT("DataWriterQos_Handler::get_datawriter_qos - ")
                ACE_TEXT("No DataWriter QOS available in profile <%s>\n"),
                profile->name().c_str()));
            }
          return true;
        }
      // get the first datawriter in the XML
      dds::qosProfile::datawriter_qos_iterator dw_it = profile->begin_datawriter_qos();
      return DataWriterQos_Handler::get_datawriter_qos(dw_qos, dw_it->get());
    }

  ACE_ERROR((LM_ERROR,
    ACE_TEXT("(%P|%t) ERROR: DataWriterQos_Handler::get_datawriter_qos - ")
    ACE_TEXT("Unable to find DataWriterQos <%s>\n"),
    name));
  return false;
}

bool
DataWriterQos_Handler::get_datawriter_qos(DDS::DataWriterQos& dw_qos,
                                          dds::datawriterQos * dw)
{
  typedef QOS_DataWriter_T<dds::datawriterQos*, DDS::DataWriterQos> dw_type;
  dw_type datawriter_qos_handler;
  datawriter_qos_handler.read_qos(dw_qos, dw);

  return true;
}

OPENDDS_END_VERSIONED_NAMESPACE_DECL