QosCommon Class Reference

#include <QOS_Common.h>

Static Public Member Functions
static void	get_duration (::DDS::Duration_t &duration, const ACE_TCHAR *sec, const ACE_TCHAR *nsec)
::CORBA::Long	get_qos_long (const ACE_TCHAR *value)
static void	get_durability_kind (const ::dds::durabilityKind kind, ::DDS::DurabilityQosPolicyKind &dds_kind)
static void	get_history_kind (const ::dds::historyKind kind, ::DDS::HistoryQosPolicyKind &dds_kind)
static void	get_liveliness_kind (const ::dds::livelinessKind kind, ::DDS::LivelinessQosPolicyKind &dds_kind)
static void	get_realiability_kind (const dds::reliabilityKind kind, ::DDS::ReliabilityQosPolicyKind &dds_kind)
static void	get_destination_order_kind (const ::dds::destinationOrderKind kind, ::DDS::DestinationOrderQosPolicyKind &dds_kind)
static void	get_ownership_kind (::dds::ownershipKind kind, ::DDS::OwnershipQosPolicyKind &dds_kind)
static void	get_type_consistency_kind (::dds::typeConsistencyKind kind, ::DDS::TypeConsistencyEnforcementQosPolicyKind_t &dds_kind)
static void	get_data_presentation_id_kind (::dds::dataRepresentationIdKind kind, ::DDS::DataRepresentationId_t &dds_kind)

Detailed Description

Author

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

Converting most common QOS XML settings to IDL QOS.

Definition at line 22 of file QOS_Common.h.

Member Function Documentation

get_data_presentation_id_kind()

void QosCommon::get_data_presentation_id_kind ( ::dds::dataRepresentationIdKind  kind, ::DDS::DataRepresentationId_t &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 203 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::UNALIGNED_CDR_DATA_REPRESENTATION, DDS::XCDR2_DATA_REPRESENTATION, DDS::XCDR_DATA_REPRESENTATION, and DDS::XML_DATA_REPRESENTATION.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::dataRepresentationIdKind::XCDR_DATA_REPRESENTATION_l:
      dds_kind = ::DDS::XCDR_DATA_REPRESENTATION;
      break;
    case ::dds::dataRepresentationIdKind::XML_DATA_REPRESENTATION_l:
      dds_kind = ::DDS::XML_DATA_REPRESENTATION;
      break;
    case ::dds::dataRepresentationIdKind::XCDR2_DATA_REPRESENTATION_l:
      dds_kind = ::DDS::XCDR2_DATA_REPRESENTATION;
      break;
    case ::dds::dataRepresentationIdKind::UNALIGNED_CDR_DATA_REPRESENTATION_l:
      dds_kind = ::OpenDDS::DCPS::UNALIGNED_CDR_DATA_REPRESENTATION;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_data_presentation_id_kind - ")
        ACE_TEXT("Unknown data presentation kind found <%d>; returning XCDR2_DATA_REPRESENTATION\n"),
        kind.integral()));
      dds_kind = ::DDS::XCDR2_DATA_REPRESENTATION;
      break;
    }
}

get_destination_order_kind()

void QosCommon::get_destination_order_kind ( const ::dds::destinationOrderKind  kind, ::DDS::DestinationOrderQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 137 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS, DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS, and LM_ERROR.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::destinationOrderKind::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS_l:
      dds_kind = ::DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS;
      break;
    case ::dds::destinationOrderKind::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS_l:
      dds_kind = ::DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_destination_order_kind - ")
        ACE_TEXT("Unknown destination order kind found <%d>; returning BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS;
      break;
    }
}

get_durability_kind()

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL void QosCommon::get_durability_kind ( const ::dds::durabilityKind  kind, ::DDS::DurabilityQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 6 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), LM_ERROR, DDS::PERSISTENT_DURABILITY_QOS, DDS::TRANSIENT_DURABILITY_QOS, DDS::TRANSIENT_LOCAL_DURABILITY_QOS, and DDS::VOLATILE_DURABILITY_QOS.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::durabilityKind::VOLATILE_DURABILITY_QOS_l:
      dds_kind = ::DDS::VOLATILE_DURABILITY_QOS;
      break;
    case ::dds::durabilityKind::TRANSIENT_LOCAL_DURABILITY_QOS_l:
      dds_kind = ::DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
      break;
    case ::dds::durabilityKind::TRANSIENT_DURABILITY_QOS_l:
      dds_kind = ::DDS::TRANSIENT_DURABILITY_QOS;
      break;
    case ::dds::durabilityKind::PERSISTENT_DURABILITY_QOS_l:
      dds_kind = ::DDS::PERSISTENT_DURABILITY_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_durability_kind - ")
        ACE_TEXT("Unknown durability kind found <%d>; returning VOLATILE_DURABILITY_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::VOLATILE_DURABILITY_QOS;
      break;
    }
}

get_duration()

void QosCommon::get_duration ( ::DDS::Duration_t &  duration, const ACE_TCHAR *  sec, const ACE_TCHAR *  nsec  )

static

get_duration

The QOS XML seconds and nano seconds tags may contain text (DURATION_INFINITY, DURATION_INFINITY_SEC, DURATION_INFINITY_NSEC). These values need to be converted to a numeric value.

Definition at line 56 of file QOS_Common.cpp.

References ACE_TEXT(), ACE_OS::atoi(), DDS::Duration_t::nanosec, DDS::Duration_t::sec, and ACE_OS::strcmp().

Referenced by QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos(), QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos(), and QOS_DwTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  if (sec != 0) {
    if (ACE_OS::strcmp(sec, ACE_TEXT("DURATION_INFINITY")) == 0 ||
        ACE_OS::strcmp(sec, ACE_TEXT("DURATION_INFINITE_SEC")) == 0) {
      duration.sec = 0x7fffffff;
    } else {
      duration.sec = ACE_OS::atoi(sec);
    }
  }

  if (nsec != 0) {
    if (ACE_OS::strcmp(nsec, ACE_TEXT("DURATION_INFINITY")) == 0 ||
             ACE_OS::strcmp(nsec, ACE_TEXT("DURATION_INFINITE_NSEC")) == 0) {
      duration.nanosec =  0x7fffffff;
    } else {
      duration.nanosec = ACE_OS::atoi(nsec);
    }
  }
}

get_history_kind()

void QosCommon::get_history_kind ( const ::dds::historyKind  kind, ::DDS::HistoryQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 34 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::KEEP_ALL_HISTORY_QOS, DDS::KEEP_LAST_HISTORY_QOS, and LM_ERROR.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos(), and QOS_DwTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::historyKind::KEEP_ALL_HISTORY_QOS_l:
      dds_kind = ::DDS::KEEP_ALL_HISTORY_QOS;
      break;
    case ::dds::historyKind::KEEP_LAST_HISTORY_QOS_l:
      dds_kind = ::DDS::KEEP_LAST_HISTORY_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_history_kind - ")
        ACE_TEXT("Unknown history kind found <%d>; returning KEEP_ALL_HISTORY_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::KEEP_ALL_HISTORY_QOS;
      break;
    }
}

get_liveliness_kind()

void QosCommon::get_liveliness_kind ( const ::dds::livelinessKind  kind, ::DDS::LivelinessQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 90 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::AUTOMATIC_LIVELINESS_QOS, LM_ERROR, DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS, and DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::livelinessKind::AUTOMATIC_LIVELINESS_QOS_l:
      dds_kind = ::DDS::AUTOMATIC_LIVELINESS_QOS;
      break;
    case ::dds::livelinessKind::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS_l:
      dds_kind = ::DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS;
      break;
    case ::dds::livelinessKind::MANUAL_BY_TOPIC_LIVELINESS_QOS_l:
      dds_kind = ::DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_liveliness_kind - ")
        ACE_TEXT("Unknown liveliness kind found <%d>; returning AUTOMATIC_LIVELINESS_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::AUTOMATIC_LIVELINESS_QOS;
      break;
    }
}

get_ownership_kind()

void QosCommon::get_ownership_kind ( ::dds::ownershipKind  kind, ::DDS::OwnershipQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 159 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::EXCLUSIVE_OWNERSHIP_QOS, LM_ERROR, and DDS::SHARED_OWNERSHIP_QOS.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::ownershipKind::SHARED_OWNERSHIP_QOS_l:
      dds_kind = ::DDS::SHARED_OWNERSHIP_QOS;
      break;
    case ::dds::ownershipKind::EXCLUSIVE_OWNERSHIP_QOS_l:
      dds_kind = ::DDS::EXCLUSIVE_OWNERSHIP_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_ownership_kind - ")
        ACE_TEXT("Unknown ownership kind found <%d>; returning SHARED_OWNERSHIP_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::SHARED_OWNERSHIP_QOS;
      break;
    }
}

get_qos_long()

CORBA::Long QosCommon::get_qos_long ( const ACE_TCHAR *  value )

static

get_qos_long

The QOS XML integer tags may contain text (LENGTH_UNLIMITED). This value need to be converted to a numeric value.

Definition at line 78 of file QOS_Common.cpp.

References ACE_TEXT(), ACE_OS::atoi(), and ACE_OS::strcmp().

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos(), and QOS_DwTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  if (value == 0) {
    return 0;
  } else if (ACE_OS::strcmp(value, ACE_TEXT("LENGTH_UNLIMITED")) == 0) {
    return -1;
  } else {
    return ACE_OS::atoi(value);
  }
}

get_realiability_kind()

void QosCommon::get_realiability_kind ( const dds::reliabilityKind  kind, ::DDS::ReliabilityQosPolicyKind &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 115 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::BEST_EFFORT_RELIABILITY_QOS, LM_ERROR, and DDS::RELIABLE_RELIABILITY_QOS.

Referenced by QOS_DwDrTp_Base_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::reliabilityKind::BEST_EFFORT_RELIABILITY_QOS_l:
      dds_kind = ::DDS::BEST_EFFORT_RELIABILITY_QOS;
      break;
    case ::dds::reliabilityKind::RELIABLE_RELIABILITY_QOS_l:
      dds_kind = ::DDS::RELIABLE_RELIABILITY_QOS;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_liveliness_kind - ")
        ACE_TEXT("Unknown reliability kind found <%d>; returning BEST_EFFORT_RELIABILITY_QOS\n"),
        kind.integral()));
      dds_kind = ::DDS::BEST_EFFORT_RELIABILITY_QOS;
      break;
    }
}

get_type_consistency_kind()

void QosCommon::get_type_consistency_kind ( ::dds::typeConsistencyKind  kind, ::DDS::TypeConsistencyEnforcementQosPolicyKind_t &  dds_kind  )

static

Operations which convert QOS XML kinds to QOS IDL kinds.

Definition at line 181 of file QOS_Common.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::ALLOW_TYPE_COERCION, DDS::DISALLOW_TYPE_COERCION, and LM_ERROR.

Referenced by QOS_DataReader_T< XML_QOS_TYPE, DDS_QOS_TYPE >::read_qos().

{
  switch (kind.integral())
    {
    case ::dds::typeConsistencyKind::DISALLOW_TYPE_COERCION_l:
      dds_kind = ::DDS::DISALLOW_TYPE_COERCION;
      break;
    case ::dds::typeConsistencyKind::ALLOW_TYPE_COERCION_l:
      dds_kind = ::DDS::ALLOW_TYPE_COERCION;
      break;
    default:
      ACE_ERROR((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: QosCommon::get_type_consistency_kind - ")
        ACE_TEXT("Unknown type consistency kind found <%d>; returning DISALLOW_TYPE_COERCION\n"),
        kind.integral()));
      dds_kind = ::DDS::DISALLOW_TYPE_COERCION;
      break;
    }
}

---

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

• QOS_Common.h
• QOS_Common.cpp