OpenDDS  Snapshot(2023/04/07-19:43)
Classes | Functions
OpenDDS::RTPS::ParameterListConverter Namespace Reference

Classes

struct  DiscoveredPublication_SecurityWrapper
 
struct  DiscoveredSubscription_SecurityWrapper
 

Functions

bool to_param_list (const DDS::ParticipantBuiltinTopicData &pbtd, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, DDS::ParticipantBuiltinTopicData &pbtd)
 
bool to_param_list (const DDS::Security::ParticipantBuiltinTopicData &pbtd, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, DDS::Security::ParticipantBuiltinTopicData &pbtd)
 
bool to_param_list (const DDS::Security::ParticipantBuiltinTopicDataSecure &pbtds, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, DDS::Security::ParticipantBuiltinTopicDataSecure &pbtds)
 
OpenDDS_Rtps_Export bool to_param_list (const ParticipantProxy_t &proxy, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, ParticipantProxy_t &proxy)
 
OpenDDS_Rtps_Export bool to_param_list (const Duration_t &duration, ParameterList &param_list)
 
OpenDDS_Rtps_Export bool from_param_list (const ParameterList &param_list, Duration_t &duration)
 
OpenDDS_Rtps_Export bool to_param_list (const SPDPdiscoveredParticipantData &participant_data, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, SPDPdiscoveredParticipantData &participant_data)
 
bool to_param_list (const OpenDDS::Security::SPDPdiscoveredParticipantData &participant_data, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, OpenDDS::Security::SPDPdiscoveredParticipantData &participant_data)
 
void add_DataRepresentationQos (ParameterList &param_list, const DDS::DataRepresentationIdSeq &ids)
 
bool to_param_list (const DCPS::DiscoveredWriterData &writer_data, ParameterList &param_list, bool use_xtypes, const XTypes::TypeInformation &type_info, bool map)
 
bool from_param_list (const ParameterList &param_list, DCPS::DiscoveredWriterData &writer_data, bool use_xtypes, XTypes::TypeInformation &type_info)
 
bool to_param_list (const DCPS::DiscoveredReaderData &reader_data, ParameterList &param_list, bool use_xtypes, const XTypes::TypeInformation &type_info, bool map)
 
bool from_param_list (const ParameterList &param_list, DCPS::DiscoveredReaderData &reader_data, bool use_xtypes, XTypes::TypeInformation &type_info)
 
bool to_param_list (const DDS::Security::EndpointSecurityInfo &info, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, DDS::Security::EndpointSecurityInfo &info)
 
bool to_param_list (const DDS::Security::DataTags &tags, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, DDS::Security::DataTags &tags)
 
bool to_param_list (const DiscoveredPublication_SecurityWrapper &wrapper, ParameterList &param_list, bool use_xtypes, const XTypes::TypeInformation &type_info, bool map)
 
bool from_param_list (const ParameterList &param_list, DiscoveredPublication_SecurityWrapper &wrapper, bool use_xtypes, XTypes::TypeInformation &type_info)
 
bool to_param_list (const DiscoveredSubscription_SecurityWrapper &wrapper, ParameterList &param_list, bool use_xtypes, const XTypes::TypeInformation &type_info, bool map)
 
bool from_param_list (const ParameterList &param_list, DiscoveredSubscription_SecurityWrapper &wrapper, bool use_xtypes, XTypes::TypeInformation &type_info)
 
bool to_param_list (const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
 
bool from_param_list (const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
 

Function Documentation

◆ add_DataRepresentationQos()

OpenDDS_Rtps_Export void OpenDDS::RTPS::ParameterListConverter::add_DataRepresentationQos ( ParameterList &  param_list,
const DDS::DataRepresentationIdSeq &  ids 
)

Definition at line 789 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::push_back(), OpenDDS::RTPS::Parameter::representation, OpenDDS::DCPS::set_reader_effective_data_rep_qos(), DDS::DataRepresentationQosPolicy::value, and DDS::XCDR_DATA_REPRESENTATION.

Referenced by OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::DiscoveredSubscription_SecurityWrapper(), and to_param_list().

790 {
791  DDS::DataRepresentationQosPolicy dr_qos;
792  dr_qos.value = ids;
793  DCPS::set_reader_effective_data_rep_qos(dr_qos.value);
794  if (dr_qos.value.length() != 1 || dr_qos.value[0] != DDS::XCDR_DATA_REPRESENTATION) {
795  Parameter param;
796  param.representation(dr_qos);
797  DCPS::push_back(param_list, param);
798  }
799 }
DDS::XCDR_DATA_REPRESENTATION
const DataRepresentationId_t XCDR_DATA_REPRESENTATION
Definition: DdsDcpsCore.idl:271
DDS::DataRepresentationQosPolicy::value
DataRepresentationIdSeq value
Definition: DdsDcpsCore.idl:280
OpenDDS::DCPS::set_reader_effective_data_rep_qos
void set_reader_effective_data_rep_qos(DDS::DataRepresentationIdSeq &qos)
Definition: DCPS_Utils.cpp:517
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ from_param_list() [1/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DDS::ParticipantBuiltinTopicData &  pbtd 
)

Definition at line 344 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::PID_USER_DATA, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, and OpenDDS::RTPS::Parameter::user_data.

Referenced by OpenDDS::RTPS::Spdp::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::DiscoveredSubscription_SecurityWrapper(), from_param_list(), OpenDDS::RTPS::ip_in_AgentInfo(), and OpenDDS::RTPS::Spdp::process_participant_ice().

346 {
347  pbtd.user_data.value.length(0);
348 
349  const CORBA::ULong length = param_list.length();
350  for (CORBA::ULong i = 0; i < length; ++i) {
351  const Parameter& param = param_list[i];
352  switch (param._d()) {
353  case PID_USER_DATA:
354  pbtd.user_data = param.user_data();
355  break;
356  default:
357  if (param._d() & PIDMASK_INCOMPATIBLE) {
358  return false;
359  }
360  }
361  }
362 
363  return true;
364 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
OpenDDS::RTPS::PID_USER_DATA
const ParameterId_t PID_USER_DATA
Definition: RtpsCore.idl:253
CORBA::ULong
ACE_CDR::ULong ULong

◆ from_param_list() [2/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DDS::Security::ParticipantBuiltinTopicData &  pbtd 
)

Definition at line 397 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicData::base, DDS::Security::ParticipantBuiltinTopicData::extended_builtin_endpoints, OpenDDS::RTPS::Parameter::extended_builtin_endpoints, from_param_list(), DDS::Security::ParticipantBuiltinTopicData::identity_token, OpenDDS::RTPS::Parameter::identity_token, DDS::Security::ParticipantSecurityInfo::participant_security_attributes, OpenDDS::RTPS::Parameter::participant_security_info, DDS::Security::ParticipantBuiltinTopicData::permissions_token, OpenDDS::RTPS::Parameter::permissions_token, DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS, DDS::Security::PID_IDENTITY_TOKEN, DDS::Security::PID_PARTICIPANT_SECURITY_INFO, DDS::Security::PID_PERMISSIONS_TOKEN, OpenDDS::RTPS::PID_PROPERTY_LIST, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, DDS::Security::ParticipantSecurityInfo::plugin_participant_security_attributes, DDS::Security::ParticipantBuiltinTopicData::property, OpenDDS::RTPS::Parameter::property, and DDS::Security::ParticipantBuiltinTopicData::security_info.

399 {
400  if (!from_param_list(param_list, pbtd.base))
401  return false;
402 
403  pbtd.security_info.participant_security_attributes = 0;
404  pbtd.security_info.plugin_participant_security_attributes = 0;
405 
406  const CORBA::ULong length = param_list.length();
407  for (CORBA::ULong i = 0; i < length; ++i) {
408  const Parameter& param = param_list[i];
409  switch (param._d()) {
410  case DDS::Security::PID_IDENTITY_TOKEN:
411  pbtd.identity_token = param.identity_token();
412  break;
413  case DDS::Security::PID_PERMISSIONS_TOKEN:
414  pbtd.permissions_token = param.permissions_token();
415  break;
416  case PID_PROPERTY_LIST:
417  pbtd.property = param.property();
418  break;
419  case DDS::Security::PID_PARTICIPANT_SECURITY_INFO:
420  pbtd.security_info = param.participant_security_info();
421  break;
422  case DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS:
423  pbtd.extended_builtin_endpoints = param.extended_builtin_endpoints();
424  break;
425  default:
426  if (param._d() & PIDMASK_INCOMPATIBLE) {
427  return false;
428  }
429  }
430  }
431 
432  return true;
433 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
DDS::Security::PID_IDENTITY_TOKEN
const ParameterId_t PID_IDENTITY_TOKEN
Definition: DdsSecurityParams.idl:27
DDS::Security::ParticipantBuiltinTopicData::extended_builtin_endpoints
ExtendedBuiltinEndpointSet_t extended_builtin_endpoints
Definition: DdsSecurityCore.idl:118
DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS
const ParameterId_t PID_EXTENDED_BUILTIN_ENDPOINTS
Definition: DdsSecurityParams.idl:34
CORBA::ULong
ACE_CDR::ULong ULong
DDS::Security::PID_PERMISSIONS_TOKEN
const ParameterId_t PID_PERMISSIONS_TOKEN
Definition: DdsSecurityParams.idl:28
DDS::Security::ParticipantSecurityInfo::plugin_participant_security_attributes
PluginParticipantSecurityAttributesMask plugin_participant_security_attributes
Definition: DdsSecurityParams.idl:78
DDS::Security::PID_PARTICIPANT_SECURITY_INFO
const ParameterId_t PID_PARTICIPANT_SECURITY_INFO
Definition: DdsSecurityParams.idl:31
DDS::Security::ParticipantSecurityInfo::participant_security_attributes
ParticipantSecurityAttributesMask participant_security_attributes
Definition: DdsSecurityParams.idl:77
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625
DDS::Security::ParticipantBuiltinTopicData::base
DDS::ParticipantBuiltinTopicData base
Definition: DdsSecurityCore.idl:111
OpenDDS::RTPS::PID_PROPERTY_LIST
const ParameterId_t PID_PROPERTY_LIST
Definition: RtpsCore.idl:290

◆ from_param_list() [3/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DDS::Security::ParticipantBuiltinTopicDataSecure &  pbtds 
)

Definition at line 447 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicDataSecure::base, from_param_list(), DDS::Security::ParticipantBuiltinTopicDataSecure::identity_status_token, OpenDDS::RTPS::Parameter::identity_status_token, OpenDDS_Rtps_Export, DDS::Security::PID_IDENTITY_STATUS_TOKEN, and OpenDDS::RTPS::PIDMASK_INCOMPATIBLE.

449 {
450  if (!from_param_list(param_list, pbtds.base))
451  return false;
452 
453  const CORBA::ULong length = param_list.length();
454  for (CORBA::ULong i = 0; i < length; ++i) {
455  const Parameter& param = param_list[i];
456  switch (param._d()) {
457  case DDS::Security::PID_IDENTITY_STATUS_TOKEN:
458  pbtds.identity_status_token = param.identity_status_token();
459  break;
460  default:
461  if (param._d() & PIDMASK_INCOMPATIBLE) {
462  return false;
463  }
464  }
465  }
466 
467  return true;
468 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
DDS::Security::PID_IDENTITY_STATUS_TOKEN
const ParameterId_t PID_IDENTITY_STATUS_TOKEN
Definition: DdsSecurityParams.idl:32
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625

◆ from_param_list() [4/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
ParticipantProxy_t &  proxy 
)

Definition at line 569 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParticipantProxy_t::availableBuiltinEndpoints, OpenDDS::RTPS::ParticipantProxy_t::availableExtendedBuiltinEndpoints, OpenDDS::RTPS::OpenDDSParticipantFlags_t::bits, OpenDDS::RTPS::Parameter::builtin_endpoints, OpenDDS::RTPS::Parameter::builtinEndpointQos, OpenDDS::RTPS::ParticipantProxy_t::builtinEndpointQos, OpenDDS::RTPS::Parameter::count, OpenDDS::RTPS::ParticipantProxy_t::defaultMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::defaultUnicastLocatorList, OpenDDS::RTPS::Parameter::domainId, OpenDDS::RTPS::ParticipantProxy_t::domainId, OpenDDS::RTPS::Parameter::expects_inline_qos, OpenDDS::RTPS::ParticipantProxy_t::expectsInlineQos, OpenDDS::RTPS::Parameter::extended_builtin_endpoints, OpenDDS::RTPS::Parameter::guid, OpenDDS::DCPS::GUID_t::guidPrefix, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::RTPS::Parameter::locator, OpenDDS::RTPS::ParticipantProxy_t::manualLivelinessCount, ACE_OS::memcpy(), OpenDDS::RTPS::ParticipantProxy_t::metatrafficMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::metatrafficUnicastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::opendds_participant_flags, OpenDDS_Rtps_Export, OpenDDS::RTPS::Parameter::opendds_rtps_relay_application_participant, OpenDDS::RTPS::ParticipantProxy_t::opendds_rtps_relay_application_participant, OpenDDS::RTPS::Parameter::participant_builtin_endpoints, OpenDDS::RTPS::Parameter::participant_flags, OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_QOS, OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_SET, OpenDDS::RTPS::PID_DEFAULT_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_DEFAULT_UNICAST_LOCATOR, OpenDDS::RTPS::PID_DOMAIN_ID, OpenDDS::RTPS::PID_EXPECTS_INLINE_QOS, DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS, OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_LOCATOR, OpenDDS::RTPS::PID_OPENDDS_PARTICIPANT_FLAGS, OpenDDS::RTPS::PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT, OpenDDS::RTPS::PID_PAD, OpenDDS::RTPS::PID_PARTICIPANT_BUILTIN_ENDPOINTS, OpenDDS::RTPS::PID_PARTICIPANT_GUID, OpenDDS::RTPS::PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT, OpenDDS::RTPS::PID_PROPERTY_LIST, OpenDDS::RTPS::PID_PROTOCOL_VERSION, OpenDDS::RTPS::PID_SENTINEL, OpenDDS::RTPS::PID_VENDORID, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, OpenDDS::RTPS::Parameter::property, OpenDDS::RTPS::ParticipantProxy_t::property, OpenDDS::RTPS::ParticipantProxy_t::protocolVersion, OpenDDS::DCPS::push_back(), OpenDDS::RTPS::Count_t::value, OpenDDS::RTPS::Parameter::vendor, OpenDDS::RTPS::VendorId_t::vendorId, OpenDDS::RTPS::ParticipantProxy_t::vendorId, and OpenDDS::RTPS::Parameter::version.

571 {
572  // Start by setting defaults
573  proxy.availableBuiltinEndpoints = 0;
574 #ifdef OPENDDS_SECURITY
575  proxy.availableExtendedBuiltinEndpoints = 0;
576 #endif
577  proxy.expectsInlineQos = false;
578  proxy.opendds_participant_flags.bits = 0;
579  proxy.opendds_rtps_relay_application_participant = false;
580 
581  const CORBA::ULong length = param_list.length();
582  for (CORBA::ULong i = 0; i < length; ++i) {
583  const Parameter& param = param_list[i];
584  switch (param._d()) {
585  case PID_BUILTIN_ENDPOINT_QOS:
586  proxy.builtinEndpointQos = param.builtinEndpointQos();
587  break;
588  case PID_DOMAIN_ID:
589  proxy.domainId = param.domainId();
590  break;
591  case PID_PROTOCOL_VERSION:
592  proxy.protocolVersion = param.version();
593  break;
594  case PID_PARTICIPANT_GUID:
595  ACE_OS::memcpy(proxy.guidPrefix,
596  param.guid().guidPrefix, sizeof(GuidPrefix_t));
597  break;
598  case PID_VENDORID:
599  ACE_OS::memcpy(proxy.vendorId.vendorId,
600  param.vendor().vendorId, sizeof(OctetArray2));
601  break;
602  case PID_EXPECTS_INLINE_QOS:
603  proxy.expectsInlineQos =
604  param.expects_inline_qos();
605  break;
606  case PID_PARTICIPANT_BUILTIN_ENDPOINTS:
607  proxy.availableBuiltinEndpoints =
608  param.participant_builtin_endpoints();
609  break;
610  case PID_BUILTIN_ENDPOINT_SET:
611  // Interoperability note:
612  // OpenSplice uses this in place of PID_PARTICIPANT_BUILTIN_ENDPOINTS
613  // Table 9.13 indicates that PID_PARTICIPANT_BUILTIN_ENDPOINTS should be
614  // used to represent ParticipantProxy::availableBuiltinEndpoints
615  proxy.availableBuiltinEndpoints =
616  param.builtin_endpoints();
617  break;
618 #ifdef OPENDDS_SECURITY
619  case DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS:
620  proxy.availableExtendedBuiltinEndpoints =
621  param.extended_builtin_endpoints();
622  break;
623 #endif
624  case PID_METATRAFFIC_UNICAST_LOCATOR:
625  DCPS::push_back(
626  proxy.metatrafficUnicastLocatorList,
627  param.locator());
628  break;
629  case PID_METATRAFFIC_MULTICAST_LOCATOR:
630  DCPS::push_back(
631  proxy.metatrafficMulticastLocatorList,
632  param.locator());
633  break;
634  case PID_DEFAULT_UNICAST_LOCATOR:
635  DCPS::push_back(
636  proxy.defaultUnicastLocatorList,
637  param.locator());
638  break;
639  case PID_DEFAULT_MULTICAST_LOCATOR:
640  DCPS::push_back(
641  proxy.defaultMulticastLocatorList,
642  param.locator());
643  break;
644  case PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT:
645  proxy.manualLivelinessCount.value =
646  param.count().value;
647  break;
648  case PID_PROPERTY_LIST:
649  proxy.property = param.property();
650  break;
651  case PID_OPENDDS_PARTICIPANT_FLAGS:
652  proxy.opendds_participant_flags = param.participant_flags();
653  break;
654  case PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT:
655  proxy.opendds_rtps_relay_application_participant = param.opendds_rtps_relay_application_participant();
656  break;
657  case PID_SENTINEL:
658  case PID_PAD:
659  // ignore
660  break;
661  default:
662  if (param._d() & PIDMASK_INCOMPATIBLE) {
663  return false;
664  }
665  }
666  }
667 
668  return true;
669 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
OpenDDS::RTPS::PID_DOMAIN_ID
const ParameterId_t PID_DOMAIN_ID
Definition: RtpsCore.idl:314
OpenDDS::DCPS::GuidPrefix_t
octet GuidPrefix_t[12]
Definition: DdsDcpsGuid.idl:19
OpenDDS::RTPS::PID_PROTOCOL_VERSION
const ParameterId_t PID_PROTOCOL_VERSION
Definition: RtpsCore.idl:274
OpenDDS::RTPS::PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT
const ParameterId_t PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT
Definition: RtpsCore.idl:283
OpenDDS::RTPS::PID_PARTICIPANT_GUID
const ParameterId_t PID_PARTICIPANT_GUID
Definition: RtpsCore.idl:287
ACE_OS::memcpy
void * memcpy(void *t, const void *s, size_t len)
OpenDDS::RTPS::PID_EXPECTS_INLINE_QOS
const ParameterId_t PID_EXPECTS_INLINE_QOS
Definition: RtpsCore.idl:282
OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_QOS
const ParameterId_t PID_BUILTIN_ENDPOINT_QOS
Definition: RtpsCore.idl:317
OpenDDS::RTPS::PID_DEFAULT_MULTICAST_LOCATOR
const ParameterId_t PID_DEFAULT_MULTICAST_LOCATOR
Definition: RtpsCore.idl:279
OpenDDS::RTPS::PID_SENTINEL
const ParameterId_t PID_SENTINEL
Definition: RtpsCore.idl:252
DDS::Security::PID_EXTENDED_BUILTIN_ENDPOINTS
const ParameterId_t PID_EXTENDED_BUILTIN_ENDPOINTS
Definition: DdsSecurityParams.idl:34
OpenDDS::RTPS::PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT
const ParameterId_t PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT
Definition: RtpsCore.idl:342
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_SET
const ParameterId_t PID_BUILTIN_ENDPOINT_SET
Definition: RtpsCore.idl:289
OpenDDS::RTPS::PID_VENDORID
const ParameterId_t PID_VENDORID
Definition: RtpsCore.idl:275
OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_LOCATOR
const ParameterId_t PID_METATRAFFIC_MULTICAST_LOCATOR
Definition: RtpsCore.idl:281
OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_LOCATOR
const ParameterId_t PID_METATRAFFIC_UNICAST_LOCATOR
Definition: RtpsCore.idl:280
OpenDDS::RTPS::PID_PAD
const ParameterId_t PID_PAD
Definition: RtpsCore.idl:251
OpenDDS::RTPS::PID_DEFAULT_UNICAST_LOCATOR
const ParameterId_t PID_DEFAULT_UNICAST_LOCATOR
Definition: RtpsCore.idl:278
OpenDDS::RTPS::OctetArray2
octet OctetArray2[2]
Definition: RtpsCore.idl:22
OpenDDS::RTPS::PID_OPENDDS_PARTICIPANT_FLAGS
const ParameterId_t PID_OPENDDS_PARTICIPANT_FLAGS
Definition: RtpsCore.idl:341
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
OpenDDS::RTPS::PID_PARTICIPANT_BUILTIN_ENDPOINTS
const ParameterId_t PID_PARTICIPANT_BUILTIN_ENDPOINTS
Definition: RtpsCore.idl:284
OpenDDS::RTPS::PID_PROPERTY_LIST
const ParameterId_t PID_PROPERTY_LIST
Definition: RtpsCore.idl:290

◆ from_param_list() [5/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
Duration_t &  duration 
)

Definition at line 688 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::duration, OpenDDS::RTPS::Duration_t::fraction, OpenDDS_Rtps_Export, OpenDDS::RTPS::PID_PARTICIPANT_LEASE_DURATION, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, and OpenDDS::RTPS::Duration_t::seconds.

690 {
691  duration.seconds = 100;
692  duration.fraction = 0;
693 
694  const CORBA::ULong length = param_list.length();
695  for (CORBA::ULong i = 0; i < length; ++i) {
696  const Parameter& param = param_list[i];
697  switch (param._d()) {
698  case PID_PARTICIPANT_LEASE_DURATION:
699  duration = param.duration();
700  break;
701  default:
702  if (param._d() & PIDMASK_INCOMPATIBLE) {
703  return false;
704  }
705  }
706  }
707  return true;
708 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_PARTICIPANT_LEASE_DURATION
const ParameterId_t PID_PARTICIPANT_LEASE_DURATION
Definition: RtpsCore.idl:285

◆ from_param_list() [6/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
SPDPdiscoveredParticipantData &  participant_data 
)

Definition at line 723 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::SPDPdiscoveredParticipantData::ddsParticipantData, from_param_list(), OpenDDS::RTPS::SPDPdiscoveredParticipantData::leaseDuration, and OpenDDS::RTPS::SPDPdiscoveredParticipantData::participantProxy.

725 {
726  bool result = from_param_list(param_list, participant_data.ddsParticipantData);
727  if (result) {
728  result = from_param_list(param_list, participant_data.participantProxy);
729  if (result) {
730  result = from_param_list(param_list, participant_data.leaseDuration);
731  }
732  }
733 
734  return result;
735 }
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625

◆ from_param_list() [7/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
OpenDDS::Security::SPDPdiscoveredParticipantData &  participant_data 
)

Definition at line 755 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicData::base, DDS::Security::ParticipantBuiltinTopicDataSecure::base, OpenDDS::Security::SPDPdiscoveredParticipantData::dataKind, OpenDDS::Security::SPDPdiscoveredParticipantData::ddsParticipantDataSecure, OpenDDS::Security::DPDK_ENHANCED, OpenDDS::Security::DPDK_SECURE, from_param_list(), OpenDDS::Security::SPDPdiscoveredParticipantData::leaseDuration, and OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy.

757 {
758  bool result = false;
759 
760  participant_data.dataKind = find_data_kind(param_list);
761  switch (participant_data.dataKind) {
762  case OpenDDS::Security::DPDK_SECURE: {
763  result = from_param_list(param_list, participant_data.ddsParticipantDataSecure);
764  break;
765  }
766  case OpenDDS::Security::DPDK_ENHANCED: {
767  result = from_param_list(param_list, participant_data.ddsParticipantDataSecure.base);
768  break;
769  }
770  default: {
771  result = from_param_list(param_list, participant_data.ddsParticipantDataSecure.base.base);
772  break;
773  }
774  }
775 
776  if (result) {
777  result = from_param_list(param_list, participant_data.participantProxy);
778  if (result) {
779  result = from_param_list(param_list, participant_data.leaseDuration);
780  }
781  }
782 
783  return result;
784 }
OpenDDS::Security::SPDPdiscoveredParticipantData::ddsParticipantDataSecure
DDS::Security::ParticipantBuiltinTopicDataSecure ddsParticipantDataSecure
Definition: RtpsSecurity.idl:28
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625
OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy
OpenDDS::RTPS::ParticipantProxy_t participantProxy
Definition: RtpsSecurity.idl:29
DDS::Security::ParticipantBuiltinTopicData::base
DDS::ParticipantBuiltinTopicData base
Definition: DdsSecurityCore.idl:111

◆ from_param_list() [8/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DCPS::DiscoveredWriterData &  writer_data,
bool  use_xtypes,
XTypes::TypeInformation &  type_info 
)

Definition at line 963 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::WriterProxy_t::allLocators, OpenDDS::RTPS::BEST_EFFORT, DDS::BEST_EFFORT_RELIABILITY_QOS, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, OpenDDS::RTPS::Parameter::deadline, OpenDDS::RTPS::Parameter::destination_order, OpenDDS::RTPS::Parameter::durability, OpenDDS::RTPS::Parameter::durability_service, OpenDDS::RTPS::Parameter::group_data, OpenDDS::RTPS::Parameter::guid, OpenDDS::RTPS::ReliabilityQosPolicyRtps::kind, OpenDDS::RTPS::Parameter::latency_budget, OpenDDS::RTPS::Parameter::lifespan, OpenDDS::RTPS::Parameter::liveliness, OpenDDS::RTPS::Parameter::locator, OpenDDS::RTPS::ReliabilityQosPolicyRtps::max_blocking_time, OpenDDS::RTPS::Parameter::opendds_locator, OpenDDS::RTPS::Parameter::ownership, OpenDDS::RTPS::Parameter::ownership_strength, OpenDDS::RTPS::Parameter::partition, OpenDDS::RTPS::PID_DATA_REPRESENTATION, OpenDDS::RTPS::PID_DEADLINE, OpenDDS::RTPS::PID_DESTINATION_ORDER, OpenDDS::RTPS::PID_DURABILITY, OpenDDS::RTPS::PID_DURABILITY_SERVICE, OpenDDS::RTPS::PID_ENDPOINT_GUID, OpenDDS::RTPS::PID_GROUP_DATA, OpenDDS::RTPS::PID_LATENCY_BUDGET, OpenDDS::RTPS::PID_LIFESPAN, OpenDDS::RTPS::PID_LIVELINESS, OpenDDS::RTPS::PID_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_OPENDDS_LOCATOR, OpenDDS::RTPS::PID_OWNERSHIP, OpenDDS::RTPS::PID_OWNERSHIP_STRENGTH, OpenDDS::RTPS::PID_PAD, OpenDDS::RTPS::PID_PARTITION, OpenDDS::RTPS::PID_PRESENTATION, OpenDDS::RTPS::PID_RELIABILITY, OpenDDS::RTPS::PID_SENTINEL, OpenDDS::RTPS::PID_TOPIC_DATA, OpenDDS::RTPS::PID_TOPIC_NAME, OpenDDS::RTPS::PID_TYPE_NAME, OpenDDS::RTPS::PID_UNICAST_LOCATOR, OpenDDS::RTPS::PID_USER_DATA, OpenDDS::RTPS::PID_XTYPES_TYPE_INFORMATION, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, OpenDDS::RTPS::Parameter::presentation, OpenDDS::DCPS::push_back(), OpenDDS::RTPS::Parameter::reliability, DDS::RELIABLE_RELIABILITY_QOS, OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::RTPS::Parameter::representation, OpenDDS::RTPS::Parameter::string_data, TheServiceParticipant, OpenDDS::RTPS::Parameter::topic_data, OpenDDS::RTPS::Parameter::user_data, OpenDDS::RTPS::ReliabilityKind_t::value, DDS::DataRepresentationQosPolicy::value, OpenDDS::DCPS::DiscoveredWriterData::writerProxy, and DDS::XCDR_DATA_REPRESENTATION.

967 {
968  // Collect the rtps_udp locators before appending them to allLocators
969  DCPS::LocatorSeq rtps_udp_locators;
970 
971  // Start by setting defaults
972  writer_data.ddsPublicationData.topic_name = "";
973  writer_data.ddsPublicationData.type_name = "";
974  writer_data.ddsPublicationData.durability =
975  TheServiceParticipant->initial_DurabilityQosPolicy();
976  writer_data.ddsPublicationData.durability_service =
977  TheServiceParticipant->initial_DurabilityServiceQosPolicy();
978  writer_data.ddsPublicationData.deadline =
979  TheServiceParticipant->initial_DeadlineQosPolicy();
980  writer_data.ddsPublicationData.latency_budget =
981  TheServiceParticipant->initial_LatencyBudgetQosPolicy();
982  writer_data.ddsPublicationData.liveliness =
983  TheServiceParticipant->initial_LivelinessQosPolicy();
984  writer_data.ddsPublicationData.reliability =
985  TheServiceParticipant->initial_DataWriterQos().reliability;
986  writer_data.ddsPublicationData.lifespan =
987  TheServiceParticipant->initial_LifespanQosPolicy();
988  writer_data.ddsPublicationData.user_data =
989  TheServiceParticipant->initial_UserDataQosPolicy();
990  writer_data.ddsPublicationData.ownership =
991  TheServiceParticipant->initial_OwnershipQosPolicy();
992 #ifdef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
993  writer_data.ddsPublicationData.ownership_strength.value = 0;
994 #else
995  writer_data.ddsPublicationData.ownership_strength =
996  TheServiceParticipant->initial_OwnershipStrengthQosPolicy();
997 #endif
998  writer_data.ddsPublicationData.destination_order =
999  TheServiceParticipant->initial_DestinationOrderQosPolicy();
1000  writer_data.ddsPublicationData.presentation =
1001  TheServiceParticipant->initial_PresentationQosPolicy();
1002  writer_data.ddsPublicationData.partition =
1003  TheServiceParticipant->initial_PartitionQosPolicy();
1004  writer_data.ddsPublicationData.topic_data =
1005  TheServiceParticipant->initial_TopicDataQosPolicy();
1006  writer_data.ddsPublicationData.group_data =
1007  TheServiceParticipant->initial_GroupDataQosPolicy();
1008  writer_data.ddsPublicationData.representation.value.length(1);
1009  writer_data.ddsPublicationData.representation.value[0] = DDS::XCDR_DATA_REPRESENTATION;
1010 
1011  const CORBA::ULong length = param_list.length();
1012  for (CORBA::ULong i = 0; i < length; ++i) {
1013  const Parameter& param = param_list[i];
1014  switch (param._d()) {
1015  case PID_TOPIC_NAME:
1016  writer_data.ddsPublicationData.topic_name = param.string_data();
1017  break;
1018  case PID_TYPE_NAME:
1019  writer_data.ddsPublicationData.type_name = param.string_data();
1020  break;
1021  case PID_DURABILITY:
1022  writer_data.ddsPublicationData.durability = param.durability();
1023  break;
1024  case PID_DURABILITY_SERVICE:
1025  writer_data.ddsPublicationData.durability_service =
1026  param.durability_service();
1027  // Interoperability note: calling normalize() shouldn't be required
1028  normalize(writer_data.ddsPublicationData.durability_service.service_cleanup_delay);
1029  break;
1030  case PID_DEADLINE:
1031  writer_data.ddsPublicationData.deadline = param.deadline();
1032  // Interoperability note: calling normalize() shouldn't be required
1033  normalize(writer_data.ddsPublicationData.deadline.period);
1034  break;
1035  case PID_LATENCY_BUDGET:
1036  writer_data.ddsPublicationData.latency_budget = param.latency_budget();
1037  // Interoperability note: calling normalize() shouldn't be required
1038  normalize(writer_data.ddsPublicationData.latency_budget.duration);
1039  break;
1040  case PID_LIVELINESS:
1041  writer_data.ddsPublicationData.liveliness = param.liveliness();
1042  // Interoperability note: calling normalize() shouldn't be required
1043  normalize(writer_data.ddsPublicationData.liveliness.lease_duration);
1044  break;
1045  case PID_RELIABILITY:
1046  writer_data.ddsPublicationData.reliability.max_blocking_time = param.reliability().max_blocking_time;
1047  // Interoperability note:
1048  // Spec creators for RTPS have reliability indexed at 1
1049  {
1050  if (param.reliability().kind.value == RTPS::BEST_EFFORT) {
1051  writer_data.ddsPublicationData.reliability.kind = DDS::BEST_EFFORT_RELIABILITY_QOS;
1052  } else { // default to RELIABLE for writers
1053  writer_data.ddsPublicationData.reliability.kind = DDS::RELIABLE_RELIABILITY_QOS;
1054  }
1055  }
1056  normalize(writer_data.ddsPublicationData.reliability.max_blocking_time);
1057  break;
1058  case PID_LIFESPAN:
1059  writer_data.ddsPublicationData.lifespan = param.lifespan();
1060  // Interoperability note: calling normalize() shouldn't be required
1061  normalize(writer_data.ddsPublicationData.lifespan.duration);
1062  break;
1063  case PID_USER_DATA:
1064  writer_data.ddsPublicationData.user_data = param.user_data();
1065  break;
1066  case PID_OWNERSHIP:
1067  writer_data.ddsPublicationData.ownership = param.ownership();
1068  break;
1069  case PID_OWNERSHIP_STRENGTH:
1070  writer_data.ddsPublicationData.ownership_strength = param.ownership_strength();
1071  break;
1072  case PID_DESTINATION_ORDER:
1073  writer_data.ddsPublicationData.destination_order = param.destination_order();
1074  break;
1075  case PID_PRESENTATION:
1076  writer_data.ddsPublicationData.presentation = param.presentation();
1077  break;
1078  case PID_PARTITION:
1079  writer_data.ddsPublicationData.partition = param.partition();
1080  break;
1081  case PID_TOPIC_DATA:
1082  writer_data.ddsPublicationData.topic_data = param.topic_data();
1083  break;
1084  case PID_GROUP_DATA:
1085  writer_data.ddsPublicationData.group_data = param.group_data();
1086  break;
1087  case PID_DATA_REPRESENTATION:
1088  if (param.representation().value.length() != 0) {
1089  writer_data.ddsPublicationData.representation = param.representation();
1090  }
1091  break;
1092  case PID_ENDPOINT_GUID:
1093  writer_data.writerProxy.remoteWriterGuid = param.guid();
1094  break;
1095  case PID_UNICAST_LOCATOR:
1096  DCPS::push_back(rtps_udp_locators, param.locator());
1097  break;
1098  case PID_MULTICAST_LOCATOR:
1099  DCPS::push_back(rtps_udp_locators, param.locator());
1100  break;
1101  case PID_OPENDDS_LOCATOR:
1102  // Append the rtps_udp_locators, if any, first, to preserve order
1103  append_locators_if_present(writer_data.writerProxy.allLocators,
1104  rtps_udp_locators);
1105  rtps_udp_locators.length(0);
1106  DCPS::push_back(writer_data.writerProxy.allLocators,
1107  param.opendds_locator());
1108  break;
1109  case PID_SENTINEL:
1110  case PID_PAD:
1111  // ignore
1112  break;
1113  case PID_XTYPES_TYPE_INFORMATION:
1114  if (use_xtypes) {
1115  extract_type_info_param(param, type_info);
1116  }
1117  break;
1118  default:
1119  if (param._d() & PIDMASK_INCOMPATIBLE) {
1120  return false;
1121  }
1122  }
1123  }
1124  // Append additional rtps_udp_locators, if any
1125  append_locators_if_present(writer_data.writerProxy.allLocators,
1126  rtps_udp_locators);
1127  rtps_udp_locators.length(0);
1128  return true;
1129 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
OpenDDS::RTPS::PID_MULTICAST_LOCATOR
const ParameterId_t PID_MULTICAST_LOCATOR
Definition: RtpsCore.idl:277
OpenDDS::RTPS::PID_TOPIC_DATA
const ParameterId_t PID_TOPIC_DATA
Definition: RtpsCore.idl:257
OpenDDS::RTPS::PID_GROUP_DATA
const ParameterId_t PID_GROUP_DATA
Definition: RtpsCore.idl:256
OpenDDS::RTPS::PID_USER_DATA
const ParameterId_t PID_USER_DATA
Definition: RtpsCore.idl:253
OpenDDS::RTPS::BEST_EFFORT
const short BEST_EFFORT
Definition: RtpsCore.idl:141
OpenDDS::RTPS::PID_XTYPES_TYPE_INFORMATION
const ParameterId_t PID_XTYPES_TYPE_INFORMATION
Definition: RtpsCore.idl:308
DDS::XCDR_DATA_REPRESENTATION
const DataRepresentationId_t XCDR_DATA_REPRESENTATION
Definition: DdsDcpsCore.idl:271
OpenDDS::RTPS::PID_LATENCY_BUDGET
const ParameterId_t PID_LATENCY_BUDGET
Definition: RtpsCore.idl:261
OpenDDS::RTPS::PID_SENTINEL
const ParameterId_t PID_SENTINEL
Definition: RtpsCore.idl:252
OpenDDS::RTPS::PID_LIVELINESS
const ParameterId_t PID_LIVELINESS
Definition: RtpsCore.idl:262
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_LIFESPAN
const ParameterId_t PID_LIFESPAN
Definition: RtpsCore.idl:264
OpenDDS::RTPS::PID_PAD
const ParameterId_t PID_PAD
Definition: RtpsCore.idl:251
OpenDDS::RTPS::PID_DURABILITY
const ParameterId_t PID_DURABILITY
Definition: RtpsCore.idl:258
OpenDDS::RTPS::PID_TOPIC_NAME
const ParameterId_t PID_TOPIC_NAME
Definition: RtpsCore.idl:254
OpenDDS::RTPS::PID_DURABILITY_SERVICE
const ParameterId_t PID_DURABILITY_SERVICE
Definition: RtpsCore.idl:259
OpenDDS::RTPS::PID_DESTINATION_ORDER
const ParameterId_t PID_DESTINATION_ORDER
Definition: RtpsCore.idl:265
OpenDDS::RTPS::PID_OPENDDS_LOCATOR
const ParameterId_t PID_OPENDDS_LOCATOR
Definition: RtpsCore.idl:337
OpenDDS::RTPS::PID_PRESENTATION
const ParameterId_t PID_PRESENTATION
Definition: RtpsCore.idl:270
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:296
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
OpenDDS::RTPS::PID_TYPE_NAME
const ParameterId_t PID_TYPE_NAME
Definition: RtpsCore.idl:255
OpenDDS::RTPS::PID_OWNERSHIP
const ParameterId_t PID_OWNERSHIP
Definition: RtpsCore.idl:268
OpenDDS::RTPS::PID_RELIABILITY
const ParameterId_t PID_RELIABILITY
Definition: RtpsCore.idl:263
TheServiceParticipant
#define TheServiceParticipant
Definition: Service_Participant.h:792
OpenDDS::RTPS::PID_PARTITION
const ParameterId_t PID_PARTITION
Definition: RtpsCore.idl:271
OpenDDS::RTPS::PID_OWNERSHIP_STRENGTH
const ParameterId_t PID_OWNERSHIP_STRENGTH
Definition: RtpsCore.idl:269
OpenDDS::RTPS::PID_DATA_REPRESENTATION
const ParameterId_t PID_DATA_REPRESENTATION
Definition: RtpsCore.idl:302
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: OpenddsDcpsExt.idl:92
OpenDDS::RTPS::PID_DEADLINE
const ParameterId_t PID_DEADLINE
Definition: RtpsCore.idl:260
OpenDDS::RTPS::PID_UNICAST_LOCATOR
const ParameterId_t PID_UNICAST_LOCATOR
Definition: RtpsCore.idl:276

◆ from_param_list() [9/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DCPS::DiscoveredReaderData &  reader_data,
bool  use_xtypes,
XTypes::TypeInformation &  type_info 
)

Definition at line 1307 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::ReaderProxy_t::allLocators, OpenDDS::DCPS::ReaderProxy_t::associatedWriters, DDS::BEST_EFFORT_RELIABILITY_QOS, OpenDDS::RTPS::Parameter::content_filter_property, OpenDDS::DCPS::ContentFilterProperty_t::contentFilteredTopicName, OpenDDS::DCPS::DiscoveredReaderData::contentFilterProperty, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, OpenDDS::RTPS::Parameter::deadline, OpenDDS::RTPS::Parameter::destination_order, OpenDDS::RTPS::Parameter::durability, OpenDDS::DCPS::ReaderProxy_t::expectsInlineQos, OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters, OpenDDS::DCPS::ContentFilterProperty_t::filterClassName, OpenDDS::DCPS::ContentFilterProperty_t::filterExpression, OpenDDS::RTPS::Parameter::group_data, OpenDDS::RTPS::Parameter::guid, OpenDDS::RTPS::ReliabilityQosPolicyRtps::kind, OpenDDS::RTPS::Parameter::latency_budget, OpenDDS::RTPS::Parameter::liveliness, OpenDDS::RTPS::Parameter::locator, OpenDDS::RTPS::ReliabilityQosPolicyRtps::max_blocking_time, OpenDDS::RTPS::Parameter::opendds_locator, OpenDDS::RTPS::Parameter::ownership, OpenDDS::RTPS::Parameter::partition, OpenDDS::RTPS::PID_CONTENT_FILTER_PROPERTY, OpenDDS::RTPS::PID_DATA_REPRESENTATION, OpenDDS::RTPS::PID_DEADLINE, OpenDDS::RTPS::PID_DESTINATION_ORDER, OpenDDS::RTPS::PID_DURABILITY, OpenDDS::RTPS::PID_ENDPOINT_GUID, OpenDDS::RTPS::PID_GROUP_DATA, OpenDDS::RTPS::PID_LATENCY_BUDGET, OpenDDS::RTPS::PID_LIVELINESS, OpenDDS::RTPS::PID_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_OPENDDS_ASSOCIATED_WRITER, OpenDDS::RTPS::PID_OPENDDS_LOCATOR, OpenDDS::RTPS::PID_OWNERSHIP, OpenDDS::RTPS::PID_PAD, OpenDDS::RTPS::PID_PARTITION, OpenDDS::RTPS::PID_PRESENTATION, OpenDDS::RTPS::PID_RELIABILITY, OpenDDS::RTPS::PID_SENTINEL, OpenDDS::RTPS::PID_TIME_BASED_FILTER, OpenDDS::RTPS::PID_TOPIC_DATA, OpenDDS::RTPS::PID_TOPIC_NAME, OpenDDS::RTPS::PID_TYPE_NAME, OpenDDS::RTPS::PID_UNICAST_LOCATOR, OpenDDS::RTPS::PID_USER_DATA, OpenDDS::RTPS::PID_XTYPES_TYPE_CONSISTENCY, OpenDDS::RTPS::PID_XTYPES_TYPE_INFORMATION, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, OpenDDS::RTPS::Parameter::presentation, OpenDDS::DCPS::push_back(), OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::DCPS::ContentFilterProperty_t::relatedTopicName, OpenDDS::RTPS::Parameter::reliability, OpenDDS::RTPS::RELIABLE, DDS::RELIABLE_RELIABILITY_QOS, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, OpenDDS::RTPS::Parameter::representation, OpenDDS::RTPS::Parameter::string_data, TheServiceParticipant, OpenDDS::RTPS::Parameter::time_based_filter, OpenDDS::RTPS::Parameter::topic_data, OpenDDS::RTPS::Parameter::type_consistency, OpenDDS::RTPS::Parameter::user_data, OpenDDS::RTPS::ReliabilityKind_t::value, DDS::DataRepresentationQosPolicy::value, and DDS::XCDR_DATA_REPRESENTATION.

1311 {
1312  // Collect the rtps_udp locators before appending them to allLocators
1313 
1314  DCPS::LocatorSeq rtps_udp_locators;
1315  // Start by setting defaults
1316  reader_data.ddsSubscriptionData.topic_name = "";
1317  reader_data.ddsSubscriptionData.type_name = "";
1318  reader_data.ddsSubscriptionData.durability =
1319  TheServiceParticipant->initial_DurabilityQosPolicy();
1320  reader_data.ddsSubscriptionData.deadline =
1321  TheServiceParticipant->initial_DeadlineQosPolicy();
1322  reader_data.ddsSubscriptionData.latency_budget =
1323  TheServiceParticipant->initial_LatencyBudgetQosPolicy();
1324  reader_data.ddsSubscriptionData.liveliness =
1325  TheServiceParticipant->initial_LivelinessQosPolicy();
1326  reader_data.ddsSubscriptionData.reliability =
1327  TheServiceParticipant->initial_DataReaderQos().reliability;
1328  reader_data.ddsSubscriptionData.ownership =
1329  TheServiceParticipant->initial_OwnershipQosPolicy();
1330  reader_data.ddsSubscriptionData.destination_order =
1331  TheServiceParticipant->initial_DestinationOrderQosPolicy();
1332  reader_data.ddsSubscriptionData.user_data =
1333  TheServiceParticipant->initial_UserDataQosPolicy();
1334  reader_data.ddsSubscriptionData.time_based_filter =
1335  TheServiceParticipant->initial_TimeBasedFilterQosPolicy();
1336  reader_data.ddsSubscriptionData.presentation =
1337  TheServiceParticipant->initial_PresentationQosPolicy();
1338  reader_data.ddsSubscriptionData.partition =
1339  TheServiceParticipant->initial_PartitionQosPolicy();
1340  reader_data.ddsSubscriptionData.topic_data =
1341  TheServiceParticipant->initial_TopicDataQosPolicy();
1342  reader_data.ddsSubscriptionData.group_data =
1343  TheServiceParticipant->initial_GroupDataQosPolicy();
1344  reader_data.ddsSubscriptionData.representation.value.length(1);
1345  reader_data.ddsSubscriptionData.representation.value[0] = DDS::XCDR_DATA_REPRESENTATION;
1346  reader_data.ddsSubscriptionData.type_consistency =
1347  TheServiceParticipant->initial_TypeConsistencyEnforcementQosPolicy();
1348  reader_data.readerProxy.expectsInlineQos = false;
1349  reader_data.contentFilterProperty.contentFilteredTopicName = "";
1350  reader_data.contentFilterProperty.relatedTopicName = "";
1351  reader_data.contentFilterProperty.filterClassName = "";
1352  reader_data.contentFilterProperty.filterExpression = "";
1353  reader_data.contentFilterProperty.expressionParameters.length(0);
1354 
1355  const CORBA::ULong length = param_list.length();
1356  for (CORBA::ULong i = 0; i < length; ++i) {
1357  const Parameter& param = param_list[i];
1358  switch (param._d()) {
1359  case PID_TOPIC_NAME:
1360  reader_data.ddsSubscriptionData.topic_name = param.string_data();
1361  break;
1362  case PID_TYPE_NAME:
1363  reader_data.ddsSubscriptionData.type_name = param.string_data();
1364  break;
1365  case PID_DURABILITY:
1366  reader_data.ddsSubscriptionData.durability = param.durability();
1367  break;
1368  case PID_DEADLINE:
1369  reader_data.ddsSubscriptionData.deadline = param.deadline();
1370  // Interoperability note: calling normalize() shouldn't be required
1371  normalize(reader_data.ddsSubscriptionData.deadline.period);
1372  break;
1373  case PID_LATENCY_BUDGET:
1374  reader_data.ddsSubscriptionData.latency_budget = param.latency_budget();
1375  // Interoperability note: calling normalize() shouldn't be required
1376  normalize(reader_data.ddsSubscriptionData.latency_budget.duration);
1377  break;
1378  case PID_LIVELINESS:
1379  reader_data.ddsSubscriptionData.liveliness = param.liveliness();
1380  // Interoperability note: calling normalize() shouldn't be required
1381  normalize(reader_data.ddsSubscriptionData.liveliness.lease_duration);
1382  break;
1383  case PID_RELIABILITY:
1384  reader_data.ddsSubscriptionData.reliability.max_blocking_time = param.reliability().max_blocking_time;
1385  // Interoperability note:
1386  // Spec creators for RTPS have reliability indexed at 1
1387  {
1388  const CORBA::Short rtpsKind = param.reliability().kind.value;
1389  const CORBA::Short OLD_RELIABLE_VALUE = 3;
1390  if (rtpsKind == RTPS::RELIABLE || rtpsKind == OLD_RELIABLE_VALUE) {
1391  reader_data.ddsSubscriptionData.reliability.kind = DDS::RELIABLE_RELIABILITY_QOS;
1392  } else { // default to BEST_EFFORT for readers
1393  reader_data.ddsSubscriptionData.reliability.kind = DDS::BEST_EFFORT_RELIABILITY_QOS;
1394  }
1395  }
1396  break;
1397  case PID_USER_DATA:
1398  reader_data.ddsSubscriptionData.user_data = param.user_data();
1399  break;
1400  case PID_OWNERSHIP:
1401  reader_data.ddsSubscriptionData.ownership = param.ownership();
1402  break;
1403  case PID_DESTINATION_ORDER:
1404  reader_data.ddsSubscriptionData.destination_order = param.destination_order();
1405  break;
1406  case PID_TIME_BASED_FILTER:
1407  reader_data.ddsSubscriptionData.time_based_filter = param.time_based_filter();
1408  // Interoperability note: calling normalize() shouldn't be required
1409  normalize(reader_data.ddsSubscriptionData.time_based_filter.minimum_separation);
1410  break;
1411  case PID_PRESENTATION:
1412  reader_data.ddsSubscriptionData.presentation = param.presentation();
1413  break;
1414  case PID_PARTITION:
1415  reader_data.ddsSubscriptionData.partition = param.partition();
1416  break;
1417  case PID_TOPIC_DATA:
1418  reader_data.ddsSubscriptionData.topic_data = param.topic_data();
1419  break;
1420  case PID_GROUP_DATA:
1421  reader_data.ddsSubscriptionData.group_data = param.group_data();
1422  break;
1423  case PID_DATA_REPRESENTATION:
1424  if (param.representation().value.length() != 0) {
1425  reader_data.ddsSubscriptionData.representation = param.representation();
1426  }
1427  break;
1428  case PID_XTYPES_TYPE_CONSISTENCY:
1429  reader_data.ddsSubscriptionData.type_consistency = param.type_consistency();
1430  break;
1431  case PID_ENDPOINT_GUID:
1432  reader_data.readerProxy.remoteReaderGuid = param.guid();
1433  break;
1434  case PID_UNICAST_LOCATOR:
1435  DCPS::push_back(rtps_udp_locators, param.locator());
1436  break;
1437  case PID_MULTICAST_LOCATOR:
1438  DCPS::push_back(rtps_udp_locators, param.locator());
1439  break;
1440  case PID_CONTENT_FILTER_PROPERTY:
1441  reader_data.contentFilterProperty = param.content_filter_property();
1442  break;
1443  case PID_OPENDDS_LOCATOR:
1444  // Append the rtps_udp_locators, if any, first, to preserve order
1445  append_locators_if_present(reader_data.readerProxy.allLocators,
1446  rtps_udp_locators);
1447  rtps_udp_locators.length(0);
1448  DCPS::push_back(reader_data.readerProxy.allLocators,
1449  param.opendds_locator());
1450  break;
1451  case PID_OPENDDS_ASSOCIATED_WRITER:
1452  DCPS::push_back(reader_data.readerProxy.associatedWriters, param.guid());
1453  break;
1454  case PID_SENTINEL:
1455  case PID_PAD:
1456  // ignore
1457  break;
1458  case PID_XTYPES_TYPE_INFORMATION:
1459  if (use_xtypes) {
1460  extract_type_info_param(param, type_info);
1461  }
1462  break;
1463  default:
1464  if (param._d() & PIDMASK_INCOMPATIBLE) {
1465  return false;
1466  }
1467  }
1468  }
1469  // Append additional rtps_udp_locators, if any
1470  append_locators_if_present(reader_data.readerProxy.allLocators,
1471  rtps_udp_locators);
1472  rtps_udp_locators.length(0);
1473  return true;
1474 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
OpenDDS::RTPS::PID_MULTICAST_LOCATOR
const ParameterId_t PID_MULTICAST_LOCATOR
Definition: RtpsCore.idl:277
OpenDDS::RTPS::PID_TOPIC_DATA
const ParameterId_t PID_TOPIC_DATA
Definition: RtpsCore.idl:257
OpenDDS::RTPS::PID_GROUP_DATA
const ParameterId_t PID_GROUP_DATA
Definition: RtpsCore.idl:256
CORBA::Short
ACE_CDR::Short Short
OpenDDS::RTPS::PID_CONTENT_FILTER_PROPERTY
const ParameterId_t PID_CONTENT_FILTER_PROPERTY
Definition: RtpsCore.idl:286
OpenDDS::RTPS::PID_USER_DATA
const ParameterId_t PID_USER_DATA
Definition: RtpsCore.idl:253
OpenDDS::RTPS::PID_XTYPES_TYPE_INFORMATION
const ParameterId_t PID_XTYPES_TYPE_INFORMATION
Definition: RtpsCore.idl:308
DDS::XCDR_DATA_REPRESENTATION
const DataRepresentationId_t XCDR_DATA_REPRESENTATION
Definition: DdsDcpsCore.idl:271
OpenDDS::RTPS::PID_TIME_BASED_FILTER
const ParameterId_t PID_TIME_BASED_FILTER
Definition: RtpsCore.idl:272
OpenDDS::RTPS::PID_LATENCY_BUDGET
const ParameterId_t PID_LATENCY_BUDGET
Definition: RtpsCore.idl:261
OpenDDS::RTPS::PID_SENTINEL
const ParameterId_t PID_SENTINEL
Definition: RtpsCore.idl:252
OpenDDS::RTPS::PID_XTYPES_TYPE_CONSISTENCY
const ParameterId_t PID_XTYPES_TYPE_CONSISTENCY
Definition: RtpsCore.idl:305
OpenDDS::RTPS::PID_LIVELINESS
const ParameterId_t PID_LIVELINESS
Definition: RtpsCore.idl:262
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_PAD
const ParameterId_t PID_PAD
Definition: RtpsCore.idl:251
OpenDDS::RTPS::PID_DURABILITY
const ParameterId_t PID_DURABILITY
Definition: RtpsCore.idl:258
OpenDDS::RTPS::PID_TOPIC_NAME
const ParameterId_t PID_TOPIC_NAME
Definition: RtpsCore.idl:254
OpenDDS::RTPS::PID_OPENDDS_ASSOCIATED_WRITER
const ParameterId_t PID_OPENDDS_ASSOCIATED_WRITER
Definition: RtpsCore.idl:338
OpenDDS::RTPS::RELIABLE
const short RELIABLE
Definition: RtpsCore.idl:142
OpenDDS::RTPS::PID_DESTINATION_ORDER
const ParameterId_t PID_DESTINATION_ORDER
Definition: RtpsCore.idl:265
OpenDDS::RTPS::PID_OPENDDS_LOCATOR
const ParameterId_t PID_OPENDDS_LOCATOR
Definition: RtpsCore.idl:337
OpenDDS::RTPS::PID_PRESENTATION
const ParameterId_t PID_PRESENTATION
Definition: RtpsCore.idl:270
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:296
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
OpenDDS::RTPS::PID_TYPE_NAME
const ParameterId_t PID_TYPE_NAME
Definition: RtpsCore.idl:255
OpenDDS::RTPS::PID_OWNERSHIP
const ParameterId_t PID_OWNERSHIP
Definition: RtpsCore.idl:268
OpenDDS::RTPS::PID_RELIABILITY
const ParameterId_t PID_RELIABILITY
Definition: RtpsCore.idl:263
TheServiceParticipant
#define TheServiceParticipant
Definition: Service_Participant.h:792
OpenDDS::RTPS::PID_PARTITION
const ParameterId_t PID_PARTITION
Definition: RtpsCore.idl:271
OpenDDS::RTPS::PID_DATA_REPRESENTATION
const ParameterId_t PID_DATA_REPRESENTATION
Definition: RtpsCore.idl:302
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: OpenddsDcpsExt.idl:92
OpenDDS::RTPS::PID_DEADLINE
const ParameterId_t PID_DEADLINE
Definition: RtpsCore.idl:260
OpenDDS::RTPS::PID_UNICAST_LOCATOR
const ParameterId_t PID_UNICAST_LOCATOR
Definition: RtpsCore.idl:276

◆ from_param_list() [10/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DDS::Security::EndpointSecurityInfo &  info 
)

Definition at line 1486 of file ParameterListConverter.cpp.

References DDS::Security::EndpointSecurityInfo::endpoint_security_attributes, OpenDDS::RTPS::Parameter::endpoint_security_info, DDS::Security::PID_ENDPOINT_SECURITY_INFO, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, and DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes.

1488 {
1489  info.endpoint_security_attributes = 0;
1490  info.plugin_endpoint_security_attributes = 0;
1491 
1492  const unsigned int len = param_list.length();
1493  for (unsigned int i = 0; i < len; ++i) {
1494  const Parameter& p = param_list[i];
1495  switch (p._d()) {
1496  case DDS::Security::PID_ENDPOINT_SECURITY_INFO:
1497  info = p.endpoint_security_info();
1498  break;
1499  default:
1500  if (p._d() & PIDMASK_INCOMPATIBLE) {
1501  return false;
1502  }
1503  }
1504  }
1505 
1506  return true;
1507 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
DDS::Security::EndpointSecurityInfo::plugin_endpoint_security_attributes
PluginEndpointSecurityAttributesMask plugin_endpoint_security_attributes
Definition: DdsSecurityParams.idl:100
DDS::Security::EndpointSecurityInfo::endpoint_security_attributes
EndpointSecurityAttributesMask endpoint_security_attributes
Definition: DdsSecurityParams.idl:99
DDS::Security::PID_ENDPOINT_SECURITY_INFO
const ParameterId_t PID_ENDPOINT_SECURITY_INFO
Definition: DdsSecurityParams.idl:30

◆ from_param_list() [11/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DDS::Security::DataTags &  tags 
)

Definition at line 1518 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::data_tags, DDS::Security::PID_DATA_TAGS, OpenDDS::RTPS::PIDMASK_INCOMPATIBLE, and DDS::Security::DataTags::tags.

1520 {
1521  tags.tags.length(0);
1522 
1523  const unsigned int len = param_list.length();
1524  for (unsigned int i = 0; i < len; ++i) {
1525  const Parameter& p = param_list[i];
1526  switch (p._d()) {
1527  case DDS::Security::PID_DATA_TAGS:
1528  tags = p.data_tags();
1529  break;
1530  default:
1531  if (p._d() & PIDMASK_INCOMPATIBLE) {
1532  return false;
1533  }
1534  }
1535  }
1536 
1537  return true;
1538 }
OpenDDS::RTPS::PIDMASK_INCOMPATIBLE
const ParameterId_t PIDMASK_INCOMPATIBLE
Definition: RtpsCore.idl:312
DDS::Security::PID_DATA_TAGS
const ParameterId_t PID_DATA_TAGS
Definition: DdsSecurityParams.idl:29

◆ from_param_list() [12/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DiscoveredPublication_SecurityWrapper &  wrapper,
bool  use_xtypes,
XTypes::TypeInformation &  type_info 
)

Definition at line 1554 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data_tags, from_param_list(), and OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::security_info.

1558 {
1559  bool result = from_param_list(param_list, wrapper.data, use_xtypes, type_info) &&
1560  from_param_list(param_list, wrapper.security_info) &&
1561  from_param_list(param_list, wrapper.data_tags);
1562 
1563  return result;
1564 }
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625

◆ from_param_list() [13/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
DiscoveredSubscription_SecurityWrapper &  wrapper,
bool  use_xtypes,
XTypes::TypeInformation &  type_info 
)

Definition at line 1580 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data_tags, from_param_list(), and OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::security_info.

1584 {
1585  bool result = from_param_list(param_list, wrapper.data, use_xtypes, type_info) &&
1586  from_param_list(param_list, wrapper.security_info) &&
1587  from_param_list(param_list, wrapper.data_tags);
1588 
1589  return result;
1590 }
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, ICE::AgentInfoMap &ai_map)
Definition: ParameterListConverter.cpp:1625

◆ from_param_list() [14/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::from_param_list ( const ParameterList &  param_list,
ICE::AgentInfoMap &  ai_map 
)

Definition at line 1625 of file ParameterListConverter.cpp.

References OpenDDS::ICE::Candidate::address, OpenDDS::RTPS::IceGeneral_t::agent_type, OpenDDS::ICE::Candidate::foundation, OpenDDS::RTPS::IceCandidate_t::foundation, OpenDDS::RTPS::Parameter::ice_candidate, OpenDDS::RTPS::Parameter::ice_general, OpenDDS::RTPS::IceGeneral_t::key, OpenDDS::RTPS::IceCandidate_t::key, OpenDDS::RTPS::IceCandidate_t::locator, OpenDDS::DCPS::locator_to_address(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, OPENDDS_STRING, OpenDDS::ICE::AgentInfo::password, OpenDDS::RTPS::IceGeneral_t::password, OpenDDS::RTPS::PID_OPENDDS_ICE_CANDIDATE, OpenDDS::RTPS::PID_OPENDDS_ICE_GENERAL, OpenDDS::ICE::Candidate::priority, OpenDDS::RTPS::IceCandidate_t::priority, OpenDDS::ICE::Candidate::type, OpenDDS::ICE::AgentInfo::type, OpenDDS::RTPS::IceCandidate_t::type, OpenDDS::ICE::AgentInfo::username, and OpenDDS::RTPS::IceGeneral_t::username.

1627 {
1628  for (CORBA::ULong idx = 0, count = param_list.length(); idx != count; ++idx) {
1629  const Parameter& parameter = param_list[idx];
1630  switch (parameter._d()) {
1631  case PID_OPENDDS_ICE_GENERAL: {
1632  const IceGeneral_t& ice_general = parameter.ice_general();
1633  ICE::AgentInfo& agent_info = ai_map[OPENDDS_STRING(ice_general.key.in())];
1634  agent_info.type = static_cast<ICE::AgentType>(ice_general.agent_type);
1635  agent_info.username = ice_general.username;
1636  agent_info.password = ice_general.password;
1637  break;
1638  }
1639  case PID_OPENDDS_ICE_CANDIDATE: {
1640  const IceCandidate_t& ice_candidate = parameter.ice_candidate();
1641  ICE::Candidate candidate;
1642 #if IPV6_V6ONLY
1643  // https://tools.ietf.org/html/rfc8445
1644 
1645  // IPv4-mapped IPv6 addresses SHOULD NOT be included in the
1646  // address candidates unless the application using ICE does not
1647  // support IPv4 (i.e., it is an IPv6-only application
1648  // [RFC4038]).
1649  const bool map_ipv4_to_ipv6 = true;
1650 #else
1651  const bool map_ipv4_to_ipv6 = false;
1652 #endif
1653  if (locator_to_address(candidate.address, ice_candidate.locator, map_ipv4_to_ipv6) != 0) {
1654  return false;
1655  }
1656  candidate.foundation = ice_candidate.foundation;
1657  candidate.priority = ice_candidate.priority;
1658  candidate.type = static_cast<ICE::CandidateType>(ice_candidate.type);
1659  ai_map[OPENDDS_STRING(ice_candidate.key.in())].candidates.push_back(candidate);
1660  break;
1661  }
1662  default:
1663  // Do nothing.
1664  break;
1665  }
1666  }
1667  return true;
1668 }
OpenDDS::ICE::CandidateType
CandidateType
Definition: Ice.h:35
OpenDDS::RTPS::PID_OPENDDS_ICE_GENERAL
const ParameterId_t PID_OPENDDS_ICE_GENERAL
Definition: RtpsCore.idl:339
OpenDDS::RTPS::PID_OPENDDS_ICE_CANDIDATE
const ParameterId_t PID_OPENDDS_ICE_CANDIDATE
Definition: RtpsCore.idl:340
OPENDDS_STRING
#define OPENDDS_STRING
Definition: PoolAllocator.h:190
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::ICE::AgentType
AgentType
Definition: Ice.h:30
OpenDDS::DCPS::locator_to_address
int locator_to_address(ACE_INET_Addr &dest, const DCPS::Locator_t &locator, bool map)
Definition: NetworkResource.cpp:857

◆ to_param_list() [1/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DDS::ParticipantBuiltinTopicData &  pbtd,
ParameterList &  param_list 
)

Definition at line 332 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Parameter::user_data.

Referenced by OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::DiscoveredSubscription_SecurityWrapper(), OpenDDS::RTPS::Spdp::local_participant_data_as_octets(), to_param_list(), OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure(), OpenDDS::RTPS::Spdp::SpdpTransport::write_i(), OpenDDS::RTPS::Sedp::write_publication_data_secure(), OpenDDS::RTPS::Sedp::write_publication_data_unsecure(), OpenDDS::RTPS::Sedp::write_subscription_data_secure(), and OpenDDS::RTPS::Sedp::write_subscription_data_unsecure().

334 {
335  if (not_default(pbtd.user_data)) {
336  Parameter param_ud;
337  param_ud.user_data(pbtd.user_data);
338  DCPS::push_back(param_list, param_ud);
339  }
340 
341  return true;
342 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [2/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DDS::Security::ParticipantBuiltinTopicData &  pbtd,
ParameterList &  param_list 
)

Definition at line 367 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicData::base, DDS::Security::ParticipantBuiltinTopicData::extended_builtin_endpoints, OpenDDS::RTPS::Parameter::extended_builtin_endpoints, DDS::Security::ParticipantBuiltinTopicData::identity_token, OpenDDS::RTPS::Parameter::identity_token, OpenDDS::RTPS::Parameter::participant_security_info, DDS::Security::ParticipantBuiltinTopicData::permissions_token, OpenDDS::RTPS::Parameter::permissions_token, DDS::Security::ParticipantBuiltinTopicData::property, OpenDDS::RTPS::Parameter::property, OpenDDS::DCPS::push_back(), DDS::Security::ParticipantBuiltinTopicData::security_info, and to_param_list().

369 {
370  to_param_list(pbtd.base, param_list);
371 
372  Parameter param_it;
373  param_it.identity_token(pbtd.identity_token);
374  DCPS::push_back(param_list, param_it);
375 
376  Parameter param_pt;
377  param_pt.permissions_token(pbtd.permissions_token);
378  DCPS::push_back(param_list, param_pt);
379 
380  if (not_default(pbtd.property)) {
381  Parameter param_p;
382  param_p.property(pbtd.property);
383  DCPS::push_back(param_list, param_p);
384  }
385 
386  Parameter param_psi;
387  param_psi.participant_security_info(pbtd.security_info);
388  DCPS::push_back(param_list, param_psi);
389 
390  Parameter param_ebe;
391  param_ebe.extended_builtin_endpoints(pbtd.extended_builtin_endpoints);
392  DCPS::push_back(param_list, param_ebe);
393 
394  return true;
395 }
DDS::Security::ParticipantBuiltinTopicData::extended_builtin_endpoints
ExtendedBuiltinEndpointSet_t extended_builtin_endpoints
Definition: DdsSecurityCore.idl:118
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
DDS::Security::ParticipantBuiltinTopicData::base
DDS::ParticipantBuiltinTopicData base
Definition: DdsSecurityCore.idl:111

◆ to_param_list() [3/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DDS::Security::ParticipantBuiltinTopicDataSecure &  pbtds,
ParameterList &  param_list 
)

Definition at line 435 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicDataSecure::base, DDS::Security::ParticipantBuiltinTopicDataSecure::identity_status_token, OpenDDS::RTPS::Parameter::identity_status_token, OpenDDS::DCPS::push_back(), and to_param_list().

437 {
438  to_param_list(pbtds.base, param_list);
439 
440  Parameter param_ist;
441  param_ist.identity_status_token(pbtds.identity_status_token);
442  DCPS::push_back(param_list, param_ist);
443 
444  return true;
445 }
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [4/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const ParticipantProxy_t &  proxy,
ParameterList &  param_list 
)

Definition at line 472 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParticipantProxy_t::availableBuiltinEndpoints, OpenDDS::RTPS::ParticipantProxy_t::availableExtendedBuiltinEndpoints, OpenDDS::RTPS::Parameter::builtin_endpoints, OpenDDS::RTPS::Parameter::builtinEndpointQos, OpenDDS::RTPS::ParticipantProxy_t::builtinEndpointQos, OpenDDS::RTPS::Parameter::count, OpenDDS::RTPS::ParticipantProxy_t::defaultMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::defaultUnicastLocatorList, OpenDDS::RTPS::Parameter::domainId, OpenDDS::RTPS::ParticipantProxy_t::domainId, OpenDDS::RTPS::Parameter::expects_inline_qos, OpenDDS::RTPS::ParticipantProxy_t::expectsInlineQos, OpenDDS::RTPS::Parameter::extended_builtin_endpoints, OpenDDS::RTPS::Parameter::guid, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::DCPS::make_part_guid(), OpenDDS::RTPS::ParticipantProxy_t::manualLivelinessCount, OpenDDS::RTPS::ParticipantProxy_t::metatrafficMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::metatrafficUnicastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::opendds_participant_flags, OpenDDS::RTPS::Parameter::opendds_rtps_relay_application_participant, OpenDDS::RTPS::ParticipantProxy_t::opendds_rtps_relay_application_participant, OpenDDS::RTPS::Parameter::participant_builtin_endpoints, OpenDDS::RTPS::Parameter::participant_flags, OpenDDS::RTPS::PID_DEFAULT_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_DEFAULT_UNICAST_LOCATOR, OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_LOCATOR, OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_LOCATOR, OpenDDS::RTPS::PID_PARTICIPANT_GUID, OpenDDS::RTPS::Parameter::property, OpenDDS::RTPS::ParticipantProxy_t::property, OpenDDS::RTPS::ParticipantProxy_t::protocolVersion, OpenDDS::DCPS::push_back(), OpenDDS::RTPS::Parameter::vendor, OpenDDS::RTPS::ParticipantProxy_t::vendorId, and OpenDDS::RTPS::Parameter::version.

474 {
475  Parameter beq_param;
476  beq_param.builtinEndpointQos(proxy.builtinEndpointQos);
477  DCPS::push_back(param_list, beq_param);
478 
479  Parameter pd_param;
480  pd_param.domainId(proxy.domainId);
481  DCPS::push_back(param_list, pd_param);
482 
483  Parameter pv_param;
484  pv_param.version(proxy.protocolVersion);
485  DCPS::push_back(param_list, pv_param);
486 
487  Parameter gp_param;
488  gp_param.guid(DCPS::make_part_guid(proxy.guidPrefix));
489  gp_param._d(PID_PARTICIPANT_GUID);
490  DCPS::push_back(param_list, gp_param);
491 
492  Parameter vid_param;
493  vid_param.vendor(proxy.vendorId);
494  DCPS::push_back(param_list, vid_param);
495 
496  if (proxy.expectsInlineQos) {
497  Parameter eiq_param; // Default is false
498  eiq_param.expects_inline_qos(proxy.expectsInlineQos);
499  DCPS::push_back(param_list, eiq_param);
500  }
501 
502  Parameter abe_param;
503  abe_param.participant_builtin_endpoints(
504  proxy.availableBuiltinEndpoints);
505  DCPS::push_back(param_list, abe_param);
506 
507  // Interoperability note:
508  // For interoperability with other DDS implemenations, we'll encode the
509  // availableBuiltinEndpoints as PID_BUILTIN_ENDPOINT_SET in addition to
510  // PID_PARTICIPANT_BUILTIN_ENDPOINTS (above).
511  Parameter be_param;
512  be_param.builtin_endpoints(
513  proxy.availableBuiltinEndpoints);
514  DCPS::push_back(param_list, be_param);
515 
516 #ifdef OPENDDS_SECURITY
517  Parameter ebe_param;
518  ebe_param.extended_builtin_endpoints(
519  proxy.availableExtendedBuiltinEndpoints);
520  DCPS::push_back(param_list, ebe_param);
521 #endif
522 
523  // Each locator
524  push_back_locator_seq(
525  param_list,
526  proxy.metatrafficUnicastLocatorList,
527  PID_METATRAFFIC_UNICAST_LOCATOR);
528 
529  push_back_locator_seq(
530  param_list,
531  proxy.metatrafficMulticastLocatorList,
532  PID_METATRAFFIC_MULTICAST_LOCATOR);
533 
534  push_back_locator_seq(
535  param_list,
536  proxy.defaultUnicastLocatorList,
537  PID_DEFAULT_UNICAST_LOCATOR);
538 
539  push_back_locator_seq(
540  param_list,
541  proxy.defaultMulticastLocatorList,
542  PID_DEFAULT_MULTICAST_LOCATOR);
543 
544  Parameter ml_param;
545  ml_param.count(proxy.manualLivelinessCount);
546  DCPS::push_back(param_list, ml_param);
547 
548  if (not_default(proxy.property)) {
549  Parameter param_p;
550  param_p.property(proxy.property);
551  DCPS::push_back(param_list, param_p);
552  }
553 
554  if (not_default(proxy.opendds_participant_flags)) {
555  Parameter param_opf;
556  param_opf.participant_flags(proxy.opendds_participant_flags);
557  DCPS::push_back(param_list, param_opf);
558  }
559 
560  if (proxy.opendds_rtps_relay_application_participant) {
561  Parameter param;
562  param.opendds_rtps_relay_application_participant(proxy.opendds_rtps_relay_application_participant);
563  DCPS::push_back(param_list, param);
564  }
565 
566  return true;
567 }
OpenDDS::RTPS::PID_PARTICIPANT_GUID
const ParameterId_t PID_PARTICIPANT_GUID
Definition: RtpsCore.idl:287
OpenDDS::RTPS::PID_DEFAULT_MULTICAST_LOCATOR
const ParameterId_t PID_DEFAULT_MULTICAST_LOCATOR
Definition: RtpsCore.idl:279
OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_LOCATOR
const ParameterId_t PID_METATRAFFIC_MULTICAST_LOCATOR
Definition: RtpsCore.idl:281
OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_LOCATOR
const ParameterId_t PID_METATRAFFIC_UNICAST_LOCATOR
Definition: RtpsCore.idl:280
OpenDDS::RTPS::PID_DEFAULT_UNICAST_LOCATOR
const ParameterId_t PID_DEFAULT_UNICAST_LOCATOR
Definition: RtpsCore.idl:278
OpenDDS::DCPS::make_part_guid
OpenDDS_Dcps_Export GUID_t make_part_guid(const GuidPrefix_t &prefix)
Definition: GuidUtils.h:216
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [5/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const Duration_t &  duration,
ParameterList &  param_list 
)

Definition at line 674 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::duration, OpenDDS::RTPS::Duration_t::fraction, OpenDDS_Rtps_Export, OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Duration_t::seconds.

676 {
677  if ((duration.seconds != 100) ||
678  (duration.fraction != 0)) {
679  Parameter ld_param;
680  ld_param.duration(duration);
681  DCPS::push_back(param_list, ld_param);
682  }
683 
684  return true;
685 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [6/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const SPDPdiscoveredParticipantData &  participant_data,
ParameterList &  param_list 
)

Definition at line 713 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::SPDPdiscoveredParticipantData::ddsParticipantData, OpenDDS::RTPS::SPDPdiscoveredParticipantData::leaseDuration, OpenDDS::RTPS::SPDPdiscoveredParticipantData::participantProxy, and to_param_list().

715 {
716  to_param_list(participant_data.ddsParticipantData, param_list);
717  to_param_list(participant_data.participantProxy, param_list);
718  to_param_list(participant_data.leaseDuration, param_list);
719 
720  return true;
721 }
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592

◆ to_param_list() [7/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const OpenDDS::Security::SPDPdiscoveredParticipantData &  participant_data,
ParameterList &  param_list 
)

Definition at line 738 of file ParameterListConverter.cpp.

References DDS::Security::ParticipantBuiltinTopicData::base, DDS::Security::ParticipantBuiltinTopicDataSecure::base, OpenDDS::Security::SPDPdiscoveredParticipantData::dataKind, OpenDDS::Security::SPDPdiscoveredParticipantData::ddsParticipantDataSecure, OpenDDS::Security::DPDK_ENHANCED, OpenDDS::Security::DPDK_SECURE, OpenDDS::Security::SPDPdiscoveredParticipantData::leaseDuration, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, and to_param_list().

740 {
741  if (participant_data.dataKind == OpenDDS::Security::DPDK_SECURE) {
742  to_param_list(participant_data.ddsParticipantDataSecure, param_list);
743  } else if (participant_data.dataKind == OpenDDS::Security::DPDK_ENHANCED) {
744  to_param_list(participant_data.ddsParticipantDataSecure.base, param_list);
745  } else {
746  to_param_list(participant_data.ddsParticipantDataSecure.base.base, param_list);
747  }
748 
749  to_param_list(participant_data.participantProxy, param_list);
750  to_param_list(participant_data.leaseDuration, param_list);
751 
752  return true;
753 }
OpenDDS::Security::SPDPdiscoveredParticipantData::ddsParticipantDataSecure
DDS::Security::ParticipantBuiltinTopicDataSecure ddsParticipantDataSecure
Definition: RtpsSecurity.idl:28
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592
OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy
OpenDDS::RTPS::ParticipantProxy_t participantProxy
Definition: RtpsSecurity.idl:29
DDS::Security::ParticipantBuiltinTopicData::base
DDS::ParticipantBuiltinTopicData base
Definition: DdsSecurityCore.idl:111

◆ to_param_list() [8/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DCPS::DiscoveredWriterData &  writer_data,
ParameterList &  param_list,
bool  use_xtypes,
const XTypes::TypeInformation &  type_info,
bool  map 
)

Definition at line 801 of file ParameterListConverter.cpp.

References ACE_ERROR, add_DataRepresentationQos(), OpenDDS::DCPS::WriterProxy_t::allLocators, OpenDDS::RTPS::BEST_EFFORT, DDS::BEST_EFFORT_RELIABILITY_QOS, OpenDDS::DCPS::DiscoveredWriterData::ddsPublicationData, OpenDDS::RTPS::Parameter::deadline, OpenDDS::RTPS::Parameter::destination_order, OpenDDS::RTPS::Parameter::durability, OpenDDS::RTPS::Parameter::durability_service, OpenDDS::RTPS::Parameter::group_data, OpenDDS::RTPS::Parameter::guid, OpenDDS::RTPS::ReliabilityQosPolicyRtps::kind, OpenDDS::RTPS::Parameter::latency_budget, OpenDDS::RTPS::Parameter::lifespan, OpenDDS::RTPS::Parameter::liveliness, LM_WARNING, OpenDDS::DCPS::log_level, OpenDDS::RTPS::ReliabilityQosPolicyRtps::max_blocking_time, OpenDDS::RTPS::Parameter::ownership, OpenDDS::RTPS::Parameter::ownership_strength, OpenDDS::RTPS::Parameter::partition, OpenDDS::RTPS::PID_ENDPOINT_GUID, OpenDDS::RTPS::PID_TOPIC_NAME, OpenDDS::RTPS::PID_TYPE_NAME, OpenDDS::RTPS::Parameter::presentation, OpenDDS::DCPS::push_back(), OpenDDS::RTPS::Parameter::reliability, OpenDDS::RTPS::RELIABLE, OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::RTPS::Parameter::string_data, OpenDDS::RTPS::Parameter::topic_data, OpenDDS::DCPS::TransportLocator::transport_type, OpenDDS::RTPS::Parameter::user_data, OpenDDS::RTPS::ReliabilityKind_t::value, OpenDDS::DCPS::LogLevel::Warning, and OpenDDS::DCPS::DiscoveredWriterData::writerProxy.

806 {
807  // Ignore builtin topic key
808 
809  {
810  Parameter param;
811  param.string_data(writer_data.ddsPublicationData.topic_name);
812  param._d(PID_TOPIC_NAME);
813  DCPS::push_back(param_list, param);
814  }
815 
816  {
817  Parameter param;
818  param.string_data(writer_data.ddsPublicationData.type_name);
819  param._d(PID_TYPE_NAME);
820  DCPS::push_back(param_list, param);
821  }
822 
823  if (use_xtypes) {
824  add_type_info_param(param_list, type_info);
825  }
826 
827  if (not_default(writer_data.ddsPublicationData.durability)) {
828  Parameter param;
829  param.durability(writer_data.ddsPublicationData.durability);
830  DCPS::push_back(param_list, param);
831  }
832 
833  if (not_default(writer_data.ddsPublicationData.durability_service)) {
834  Parameter param;
835  param.durability_service(writer_data.ddsPublicationData.durability_service);
836  DCPS::push_back(param_list, param);
837  }
838 
839  if (not_default(writer_data.ddsPublicationData.deadline)) {
840  Parameter param;
841  param.deadline(writer_data.ddsPublicationData.deadline);
842  DCPS::push_back(param_list, param);
843  }
844 
845  if (not_default(writer_data.ddsPublicationData.latency_budget)) {
846  Parameter param;
847  param.latency_budget(writer_data.ddsPublicationData.latency_budget);
848  DCPS::push_back(param_list, param);
849  }
850 
851  if (not_default(writer_data.ddsPublicationData.liveliness)) {
852  Parameter param;
853  param.liveliness(writer_data.ddsPublicationData.liveliness);
854  DCPS::push_back(param_list, param);
855  }
856 
857  // Interoperability note:
858  // For interoperability, always write the reliability info
859  {
860  Parameter param;
861  ReliabilityQosPolicyRtps reliability;
862  reliability.max_blocking_time = writer_data.ddsPublicationData.reliability.max_blocking_time;
863 
864  if (writer_data.ddsPublicationData.reliability.kind == DDS::BEST_EFFORT_RELIABILITY_QOS) {
865  reliability.kind.value = RTPS::BEST_EFFORT;
866  } else { // default to RELIABLE for writers
867  reliability.kind.value = RTPS::RELIABLE;
868  }
869 
870  param.reliability(reliability);
871  DCPS::push_back(param_list, param);
872  }
873 
874  if (not_default(writer_data.ddsPublicationData.lifespan)) {
875  Parameter param;
876  param.lifespan(writer_data.ddsPublicationData.lifespan);
877  DCPS::push_back(param_list, param);
878  }
879 
880  if (not_default(writer_data.ddsPublicationData.user_data)) {
881  Parameter param;
882  param.user_data(writer_data.ddsPublicationData.user_data);
883  DCPS::push_back(param_list, param);
884  }
885 
886  if (not_default(writer_data.ddsPublicationData.ownership)) {
887  Parameter param;
888  param.ownership(writer_data.ddsPublicationData.ownership);
889  DCPS::push_back(param_list, param);
890  }
891 
892  if (not_default(writer_data.ddsPublicationData.ownership_strength)) {
893  Parameter param;
894  param.ownership_strength(writer_data.ddsPublicationData.ownership_strength);
895  DCPS::push_back(param_list, param);
896  }
897 
898  if (not_default(writer_data.ddsPublicationData.destination_order)) {
899  Parameter param;
900  param.destination_order(writer_data.ddsPublicationData.destination_order);
901  DCPS::push_back(param_list, param);
902  }
903 
904  if (not_default(writer_data.ddsPublicationData.presentation)) {
905  Parameter param;
906  param.presentation(writer_data.ddsPublicationData.presentation);
907  DCPS::push_back(param_list, param);
908  }
909 
910  if (not_default(writer_data.ddsPublicationData.partition)) {
911  Parameter param;
912  param.partition(writer_data.ddsPublicationData.partition);
913  DCPS::push_back(param_list, param);
914  }
915 
916  if (not_default(writer_data.ddsPublicationData.topic_data)) {
917  Parameter param;
918  param.topic_data(writer_data.ddsPublicationData.topic_data);
919  DCPS::push_back(param_list, param);
920  }
921 
922  if (not_default(writer_data.ddsPublicationData.group_data)) {
923  Parameter param;
924  param.group_data(writer_data.ddsPublicationData.group_data);
925  DCPS::push_back(param_list, param);
926  }
927 
928  add_DataRepresentationQos(param_list, writer_data.ddsPublicationData.representation.value);
929 
930  {
931  Parameter param;
932  param.guid(writer_data.writerProxy.remoteWriterGuid);
933  param._d(PID_ENDPOINT_GUID);
934  DCPS::push_back(param_list, param);
935  }
936  const CORBA::ULong locator_len = writer_data.writerProxy.allLocators.length();
937 
938  // Serialize from allLocators, rather than the unicastLocatorList
939  // and multicastLocatorList. This allows OpenDDS transports to be
940  // serialized in the proper order using custom PIDs.
941  for (CORBA::ULong i = 0; i < locator_len; ++i) {
942  // Each locator has a blob of interest
943  const DCPS::TransportLocator& tl = writer_data.writerProxy.allLocators[i];
944  // If this is an rtps udp transport
945  if (!std::strcmp(tl.transport_type, "rtps_udp")) {
946  // Append the locator's deserialized locator and an RTPS PID
947  push_back_rtps_locator(param_list, tl, map);
948  // Otherwise, this is an OpenDDS, custom transport
949  } else {
950  // Append the blob and a custom PID
951  push_back_dcps_locator(param_list, tl);
952  if (!std::strcmp(tl.transport_type, "multicast")
953  && DCPS::log_level >= DCPS::LogLevel::Warning) {
954  ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: ParameterListConverter::to_param_list(dwd): "
955  "Multicast transport with RTPS discovery has known issues\n"));
956  }
957  }
958  }
959 
960  return true;
961 }
OpenDDS::DCPS::log_level
OpenDDS_Dcps_Export LogLevel log_level
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::RTPS::BEST_EFFORT
const short BEST_EFFORT
Definition: RtpsCore.idl:141
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_TOPIC_NAME
const ParameterId_t PID_TOPIC_NAME
Definition: RtpsCore.idl:254
OpenDDS::RTPS::RELIABLE
const short RELIABLE
Definition: RtpsCore.idl:142
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:296
OpenDDS::RTPS::ParameterListConverter::add_DataRepresentationQos
void add_DataRepresentationQos(ParameterList &param_list, const DDS::DataRepresentationIdSeq &ids)
Definition: ParameterListConverter.cpp:789
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
OpenDDS::RTPS::PID_TYPE_NAME
const ParameterId_t PID_TYPE_NAME
Definition: RtpsCore.idl:255

◆ to_param_list() [9/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DCPS::DiscoveredReaderData &  reader_data,
ParameterList &  param_list,
bool  use_xtypes,
const XTypes::TypeInformation &  type_info,
bool  map 
)

Definition at line 1133 of file ParameterListConverter.cpp.

References ACE_ERROR, add_DataRepresentationQos(), OpenDDS::DCPS::ReaderProxy_t::allLocators, OpenDDS::DCPS::ReaderProxy_t::associatedWriters, OpenDDS::RTPS::BEST_EFFORT, OpenDDS::RTPS::Parameter::content_filter_property, OpenDDS::DCPS::DiscoveredReaderData::contentFilterProperty, OpenDDS::DCPS::DiscoveredReaderData::ddsSubscriptionData, OpenDDS::RTPS::Parameter::deadline, OpenDDS::RTPS::Parameter::destination_order, OpenDDS::RTPS::Parameter::durability, OpenDDS::DCPS::ContentFilterProperty_t::filterClassName, OpenDDS::RTPS::Parameter::group_data, OpenDDS::RTPS::Parameter::guid, OpenDDS::RTPS::ReliabilityQosPolicyRtps::kind, OpenDDS::RTPS::Parameter::latency_budget, OpenDDS::RTPS::Parameter::liveliness, LM_WARNING, OpenDDS::DCPS::log_level, OpenDDS::RTPS::ReliabilityQosPolicyRtps::max_blocking_time, OpenDDS::RTPS::Parameter::ownership, OpenDDS::RTPS::Parameter::partition, OpenDDS::RTPS::PID_ENDPOINT_GUID, OpenDDS::RTPS::PID_OPENDDS_ASSOCIATED_WRITER, OpenDDS::RTPS::PID_TOPIC_NAME, OpenDDS::RTPS::PID_TYPE_NAME, OpenDDS::RTPS::Parameter::presentation, OpenDDS::DCPS::push_back(), OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::RTPS::Parameter::reliability, OpenDDS::RTPS::RELIABLE, DDS::RELIABLE_RELIABILITY_QOS, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, OpenDDS::RTPS::Parameter::string_data, OpenDDS::RTPS::Parameter::time_based_filter, OpenDDS::RTPS::Parameter::topic_data, OpenDDS::DCPS::TransportLocator::transport_type, OpenDDS::RTPS::Parameter::type_consistency, OpenDDS::RTPS::Parameter::user_data, OpenDDS::RTPS::ReliabilityKind_t::value, and OpenDDS::DCPS::LogLevel::Warning.

1138 {
1139  // Ignore builtin topic key
1140  {
1141  Parameter param;
1142  param.string_data(reader_data.ddsSubscriptionData.topic_name);
1143  param._d(PID_TOPIC_NAME);
1144  DCPS::push_back(param_list, param);
1145  }
1146 
1147  if (use_xtypes) {
1148  add_type_info_param(param_list, type_info);
1149  }
1150 
1151  {
1152  Parameter param;
1153  param.string_data(reader_data.ddsSubscriptionData.type_name);
1154  param._d(PID_TYPE_NAME);
1155  DCPS::push_back(param_list, param);
1156  }
1157 
1158  if (not_default(reader_data.ddsSubscriptionData.durability)) {
1159  Parameter param;
1160  param.durability(reader_data.ddsSubscriptionData.durability);
1161  DCPS::push_back(param_list, param);
1162  }
1163 
1164  if (not_default(reader_data.ddsSubscriptionData.deadline)) {
1165  Parameter param;
1166  param.deadline(reader_data.ddsSubscriptionData.deadline);
1167  DCPS::push_back(param_list, param);
1168  }
1169 
1170  if (not_default(reader_data.ddsSubscriptionData.latency_budget)) {
1171  Parameter param;
1172  param.latency_budget(reader_data.ddsSubscriptionData.latency_budget);
1173  DCPS::push_back(param_list, param);
1174  }
1175 
1176  if (not_default(reader_data.ddsSubscriptionData.liveliness)) {
1177  Parameter param;
1178  param.liveliness(reader_data.ddsSubscriptionData.liveliness);
1179  DCPS::push_back(param_list, param);
1180  }
1181 
1182  // Interoperability note:
1183  // For interoperability, always write the reliability info
1184  // if (not_default(reader_data.ddsSubscriptionData.reliability, false))
1185  {
1186  Parameter param;
1187  ReliabilityQosPolicyRtps reliability;
1188  reliability.max_blocking_time = reader_data.ddsSubscriptionData.reliability.max_blocking_time;
1189 
1190  if (reader_data.ddsSubscriptionData.reliability.kind == DDS::RELIABLE_RELIABILITY_QOS) {
1191  reliability.kind.value = RTPS::RELIABLE;
1192  } else { // default to BEST_EFFORT for readers
1193  reliability.kind.value = RTPS::BEST_EFFORT;
1194  }
1195 
1196  param.reliability(reliability);
1197  DCPS::push_back(param_list, param);
1198  }
1199 
1200  if (not_default(reader_data.ddsSubscriptionData.ownership)) {
1201  Parameter param;
1202  param.ownership(reader_data.ddsSubscriptionData.ownership);
1203  DCPS::push_back(param_list, param);
1204  }
1205 
1206  if (not_default(reader_data.ddsSubscriptionData.destination_order)) {
1207  Parameter param;
1208  param.destination_order(reader_data.ddsSubscriptionData.destination_order);
1209  DCPS::push_back(param_list, param);
1210  }
1211 
1212  if (not_default(reader_data.ddsSubscriptionData.user_data)) {
1213  Parameter param;
1214  param.user_data(reader_data.ddsSubscriptionData.user_data);
1215  DCPS::push_back(param_list, param);
1216  }
1217 
1218  if (not_default(reader_data.ddsSubscriptionData.time_based_filter)) {
1219  Parameter param;
1220  param.time_based_filter(reader_data.ddsSubscriptionData.time_based_filter);
1221  DCPS::push_back(param_list, param);
1222  }
1223 
1224  if (not_default(reader_data.ddsSubscriptionData.presentation)) {
1225  Parameter param;
1226  param.presentation(reader_data.ddsSubscriptionData.presentation);
1227  DCPS::push_back(param_list, param);
1228  }
1229 
1230  if (not_default(reader_data.ddsSubscriptionData.partition)) {
1231  Parameter param;
1232  param.partition(reader_data.ddsSubscriptionData.partition);
1233  DCPS::push_back(param_list, param);
1234  }
1235 
1236  if (not_default(reader_data.ddsSubscriptionData.topic_data)) {
1237  Parameter param;
1238  param.topic_data(reader_data.ddsSubscriptionData.topic_data);
1239  DCPS::push_back(param_list, param);
1240  }
1241 
1242  if (not_default(reader_data.ddsSubscriptionData.group_data)) {
1243  Parameter param;
1244  param.group_data(reader_data.ddsSubscriptionData.group_data);
1245  DCPS::push_back(param_list, param);
1246  }
1247 
1248  add_DataRepresentationQos(param_list, reader_data.ddsSubscriptionData.representation.value);
1249 
1250  if (not_default(reader_data.ddsSubscriptionData.type_consistency)) {
1251  Parameter param;
1252  param.type_consistency(reader_data.ddsSubscriptionData.type_consistency);
1253  DCPS::push_back(param_list, param);
1254  }
1255 
1256  {
1257  Parameter param;
1258  param.guid(reader_data.readerProxy.remoteReaderGuid);
1259  param._d(PID_ENDPOINT_GUID);
1260  DCPS::push_back(param_list, param);
1261  }
1262 
1263  if (not_default(reader_data.contentFilterProperty)) {
1264  Parameter param;
1265  DCPS::ContentFilterProperty_t cfprop_copy = reader_data.contentFilterProperty;
1266  if (!std::strlen(cfprop_copy.filterClassName)) {
1267  cfprop_copy.filterClassName = "DDSSQL";
1268  }
1269  param.content_filter_property(cfprop_copy);
1270  DCPS::push_back(param_list, param);
1271  }
1272 
1273  CORBA::ULong i;
1274  const CORBA::ULong locator_len = reader_data.readerProxy.allLocators.length();
1275  // Serialize from allLocators, rather than the unicastLocatorList
1276  // and multicastLocatorList. This allows OpenDDS transports to be
1277  // serialized in the proper order using custom PIDs.
1278  for (i = 0; i < locator_len; ++i) {
1279  // Each locator has a blob of interest
1280  const DCPS::TransportLocator& tl = reader_data.readerProxy.allLocators[i];
1281  // If this is an rtps udp transport
1282  if (!std::strcmp(tl.transport_type, "rtps_udp")) {
1283  // Append the locator's deserialized locator and an RTPS PID
1284  push_back_rtps_locator(param_list, tl, map);
1285  // Otherwise, this is an OpenDDS, custom transport
1286  } else {
1287  // Append the blob and a custom PID
1288  push_back_dcps_locator(param_list, tl);
1289  if (!std::strcmp(tl.transport_type, "multicast")
1290  && DCPS::log_level >= DCPS::LogLevel::Warning) {
1291  ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: ParameterListConverter::to_param_list(drd): "
1292  "Multicast transport with RTPS discovery has known issues\n"));
1293  }
1294  }
1295  }
1296 
1297  const CORBA::ULong num_associations = reader_data.readerProxy.associatedWriters.length();
1298  for (i = 0; i < num_associations; ++i) {
1299  Parameter param;
1300  param.guid(reader_data.readerProxy.associatedWriters[i]);
1301  param._d(PID_OPENDDS_ASSOCIATED_WRITER);
1302  DCPS::push_back(param_list, param);
1303  }
1304  return true;
1305 }
OpenDDS::DCPS::log_level
OpenDDS_Dcps_Export LogLevel log_level
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::RTPS::BEST_EFFORT
const short BEST_EFFORT
Definition: RtpsCore.idl:141
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::PID_TOPIC_NAME
const ParameterId_t PID_TOPIC_NAME
Definition: RtpsCore.idl:254
OpenDDS::RTPS::PID_OPENDDS_ASSOCIATED_WRITER
const ParameterId_t PID_OPENDDS_ASSOCIATED_WRITER
Definition: RtpsCore.idl:338
OpenDDS::RTPS::RELIABLE
const short RELIABLE
Definition: RtpsCore.idl:142
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:296
OpenDDS::RTPS::ParameterListConverter::add_DataRepresentationQos
void add_DataRepresentationQos(ParameterList &param_list, const DDS::DataRepresentationIdSeq &ids)
Definition: ParameterListConverter.cpp:789
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
OpenDDS::RTPS::PID_TYPE_NAME
const ParameterId_t PID_TYPE_NAME
Definition: RtpsCore.idl:255

◆ to_param_list() [10/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DDS::Security::EndpointSecurityInfo &  info,
ParameterList &  param_list 
)

Definition at line 1477 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::endpoint_security_info, and OpenDDS::DCPS::push_back().

1479 {
1480  Parameter param;
1481  param.endpoint_security_info(info);
1482  DCPS::push_back(param_list, param);
1483  return true;
1484 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [11/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DDS::Security::DataTags &  tags,
ParameterList &  param_list 
)

Definition at line 1509 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::data_tags, and OpenDDS::DCPS::push_back().

1511 {
1512  Parameter param;
1513  param.data_tags(tags);
1514  DCPS::push_back(param_list, param);
1515  return true;
1516 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ to_param_list() [12/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DiscoveredPublication_SecurityWrapper &  wrapper,
ParameterList &  param_list,
bool  use_xtypes,
const XTypes::TypeInformation &  type_info,
bool  map 
)

Definition at line 1540 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data_tags, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::security_info, and to_param_list().

1545 {
1546  bool result = to_param_list(wrapper.data, param_list, use_xtypes, type_info, map);
1547 
1548  to_param_list(wrapper.security_info, param_list);
1549  to_param_list(wrapper.data_tags, param_list);
1550 
1551  return result;
1552 }
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592

◆ to_param_list() [13/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const DiscoveredSubscription_SecurityWrapper &  wrapper,
ParameterList &  param_list,
bool  use_xtypes,
const XTypes::TypeInformation &  type_info,
bool  map 
)

Definition at line 1566 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data_tags, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::security_info, and to_param_list().

1571 {
1572  bool result = to_param_list(wrapper.data, param_list, use_xtypes, type_info, map);
1573 
1574  to_param_list(wrapper.security_info, param_list);
1575  to_param_list(wrapper.data_tags, param_list);
1576 
1577  return result;
1578 }
OpenDDS::RTPS::ParameterListConverter::to_param_list
bool to_param_list(const ICE::AgentInfoMap &ai_map, ParameterList &param_list)
Definition: ParameterListConverter.cpp:1592

◆ to_param_list() [14/14]

OpenDDS_Rtps_Export bool OpenDDS::RTPS::ParameterListConverter::to_param_list ( const ICE::AgentInfoMap &  ai_map,
ParameterList &  param_list 
)

Definition at line 1592 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::Locator_t::address, OpenDDS::DCPS::address_to_locator(), OpenDDS::RTPS::IceGeneral_t::agent_type, OpenDDS::ICE::AgentInfo::candidates, OpenDDS::RTPS::IceCandidate_t::foundation, OpenDDS::RTPS::Parameter::ice_candidate, OpenDDS::RTPS::Parameter::ice_general, OpenDDS::RTPS::IceGeneral_t::key, OpenDDS::RTPS::IceCandidate_t::key, OpenDDS::RTPS::IceCandidate_t::locator, OpenDDS::ICE::AgentInfo::password, OpenDDS::RTPS::IceGeneral_t::password, OpenDDS::RTPS::IceCandidate_t::priority, OpenDDS::DCPS::push_back(), OpenDDS::ICE::AgentInfo::type, OpenDDS::RTPS::IceCandidate_t::type, OpenDDS::ICE::AgentInfo::username, and OpenDDS::RTPS::IceGeneral_t::username.

1594 {
1595  for (ICE::AgentInfoMap::const_iterator map_pos = ai_map.begin(), limit = ai_map.end(); map_pos != limit; ++map_pos) {
1596  const ICE::AgentInfo& agent_info = map_pos->second;
1597  IceGeneral_t ice_general;
1598  ice_general.key = map_pos->first.c_str();
1599  ice_general.agent_type = agent_info.type;
1600  ice_general.username = agent_info.username.c_str();
1601  ice_general.password = agent_info.password.c_str();
1602 
1603  Parameter param_general;
1604  param_general.ice_general(ice_general);
1605  DCPS::push_back(param_list, param_general);
1606 
1607  for (ICE::AgentInfo::CandidatesType::const_iterator pos = agent_info.candidates.begin(),
1608  limit = agent_info.candidates.end(); pos != limit; ++pos) {
1609  IceCandidate_t ice_candidate;
1610  ice_candidate.key = map_pos->first.c_str();
1611  address_to_locator(ice_candidate.locator, pos->address);
1612  ice_candidate.foundation = pos->foundation.c_str();
1613  ice_candidate.priority = pos->priority;
1614  ice_candidate.type = pos->type;
1615 
1616  Parameter param;
1617  param.ice_candidate(ice_candidate);
1618  DCPS::push_back(param_list, param);
1619  }
1620  }
1621 
1622  return true;
1623 }
OpenDDS::DCPS::address_to_locator
OpenDDS_Dcps_Export void address_to_locator(Locator_t &locator, const ACE_INET_Addr &addr)
Definition: NetworkResource.cpp:895
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138
Generated by   doxygen 1.8.13