OpenDDS  Snapshot(2021/07/08-18:22)
Namespaces | Classes | Typedefs | Enumerations | Functions | Variables
OpenDDS::RTPS Namespace Reference

Namespaces

 ParameterListConverter
 

Classes

struct  AckNackSubmessage
 
struct  ContentFilterInfo_t
 
struct  Count_t
 
struct  DataFragSubmessage
 
struct  DataSubmessage
 
struct  DiscoveredPublication_SecurityWrapper
 
struct  DiscoveredSubscription_SecurityWrapper
 
struct  DiscoveredTopicData
 
struct  Duration_t
 
struct  EntityName_t
 
struct  FragmentNumber_t
 
struct  FragmentNumberSet
 
struct  GapSubmessage
 
class  GuidGenerator
 
struct  Header
 
struct  HeartBeatFragSubmessage
 
struct  HeartBeatSubmessage
 
struct  IceCandidate_t
 
struct  IceGeneral_t
 
struct  InfoDestinationSubmessage
 
struct  InfoReplyIp4Submessage
 
struct  InfoReplySubmessage
 
struct  InfoSourceSubmessage
 
struct  InfoTimestampSubmessage
 
struct  KeyHash_t
 
struct  LocatorUDPv4_t
 
struct  Message
 
class  MessageParser
 
struct  NackFragSubmessage
 
class  Noop
 
struct  OpenDDSParticipantFlags_t
 
struct  OriginalWriterInfo_t
 
struct  PadSubmessage
 
union  Parameter
 
struct  ParticipantMessageData
 
struct  ParticipantProxy_t
 
struct  ProtocolVersion_t
 
struct  ReliabilityKind_t
 
struct  ReliabilityQosPolicyRtps
 
class  RtpsDiscovery
 Discovery Strategy class that implements RTPS discovery. More...
 
class  RtpsDiscoveryConfig
 
struct  SecuritySubmessage
 
class  Sedp
 
struct  SequenceNumber_t
 
struct  SequenceNumberSet
 
class  Spdp
 
struct  SPDPdiscoveredParticipantData
 
struct  StatusInfo_t
 
union  Submessage
 
struct  SubmessageHeader
 
struct  Time_t
 
struct  TopicKind_t
 
struct  VendorId_t
 

Typedefs

typedef octet OctetArray2[2]
 
typedef octet OctetArray4[4]
 
typedef long FilterSignature_t[4]
 
typedef sequence< long > FilterResult_t
 
typedef sequence< FilterSignature_t > FilterSignatureSeq
 
typedef DDS::Property_t Property_t
 
typedef DDS::PropertySeq PropertySeq
 
typedef sequence< long, 8 > LongSeq8
 
typedef sequence< OpenDDS::DCPS::Locator_t, 8 > LocatorList
 
typedef Time_t Timestamp_t
 
typedef unsigned long IceAgentType_t
 
typedef unsigned long IceCandidateType_t
 
typedef unsigned long BuiltinEndpointSet_t
 
typedef unsigned long BuiltinEndpointQos_t
 
typedef sequence< Parameter > ParameterList
 
typedef unsigned short ParameterId_t
 
typedef unsigned long OpenDDSParticipantFlagsBits_t
 
typedef sequence< Submessage > SubmessageSeq
 
typedef OpenDDS::DCPS::RcHandle< RtpsDiscoveryConfig > RtpsDiscoveryConfig_rch
 
typedef OpenDDS::DCPS::RcHandle< RtpsDiscovery > RtpsDiscovery_rch
 
typedef Security::SPDPdiscoveredParticipantData ParticipantData_t
 

Enumerations

enum  SubmessageKind {
  SUBMESSAGE_NONE, PAD, RESERVED_2, RESERVED_3,
  RESERVED_4, RESERVED_5, ACKNACK, HEARTBEAT,
  GAP, INFO_TS, RESERVED_10, RESERVED_11,
  INFO_SRC, INFO_REPLY_IP4, INFO_DST, INFO_REPLY,
  RESERVED_16, RESERVED_17, NACK_FRAG, HEARTBEAT_FRAG,
  RESERVED_20, DATA, DATA_FRAG, RESERVED_23,
  RESERVED_24, RESERVED_25, RESERVED_26, RESERVED_27,
  RESERVED_28, RESERVED_29, RESERVED_30, RESERVED_31,
  RESERVED_32, RESERVED_33, RESERVED_34, RESERVED_35,
  RESERVED_36, RESERVED_37, RESERVED_38, RESERVED_39,
  RESERVED_40, RESERVED_41, RESERVED_42, RESERVED_43,
  RESERVED_44, RESERVED_45, RESERVED_46, RESERVED_47,
  SEC_BODY, SEC_PREFIX, SEC_POSTFIX, SRTPS_PREFIX,
  SRTPS_POSTFIX, RESERVED_53_SECURITY
}
 

Functions

int locator_to_address (ACE_INET_Addr &dest, const DCPS::Locator_t &locator, bool map)
 
const DCPS::Encoding & get_locators_encoding ()
 
DDS::ReturnCode_t blob_to_locators (const DCPS::TransportBLOB &blob, DCPS::LocatorSeq &locators, bool *requires_inline_qos, unsigned int *pBytesRead)
 
void locators_to_blob (const DCPS::LocatorSeq &locators, DCPS::TransportBLOB &blob)
 
OpenDDS_Rtps_Export DCPS::LocatorSeq transport_locator_to_locator_seq (const DCPS::TransportLocator &info)
 
DCPS::TimeDuration rtps_duration_to_time_duration (const Duration_t &rtps_duration, const ProtocolVersion_t &version, const VendorId_t &vendor)
 
bool bitmapNonEmpty (const SequenceNumberSet &snSet)
 
template<typename T >
void marshal_key_hash (const T &msg, KeyHash_t &hash)
 
void assign (DCPS::OctetArray16 &dest, const DCPS::OctetArray16 &src)
 
void assign (DCPS::OctetArray16 &dest, const ACE_CDR::ULong &ipv4addr_be)
 
void assign (DCPS::EntityKey_t &lhs, unsigned int rhs)
 
void address_to_bytes (DCPS::OctetArray16 &dest, const ACE_INET_Addr &addr)
 
int address_to_kind (const ACE_INET_Addr &addr)
 
template<typename T >
void message_block_to_sequence (const ACE_Message_Block &mb_locator, T &out)
 
bool operator== (const Duration_t &x, const Duration_t &y)
 
bool operator== (const VendorId_t &v1, const VendorId_t &v2)
 
bool operator< (const ProtocolVersion_t &v1, const ProtocolVersion_t &v2)
 
DCPS::SequenceNumber to_opendds_seqnum (const RTPS::SequenceNumber_t &rtps_seqnum)
 
RTPS::SequenceNumber_t to_rtps_seqnum (const DCPS::SequenceNumber &opendds_seqnum)
 
void append_submessage (RTPS::Message &message, const RTPS::InfoDestinationSubmessage &submessage)
 
void append_submessage (RTPS::Message &message, const RTPS::InfoTimestampSubmessage &submessage)
 
void append_submessage (RTPS::Message &message, const RTPS::DataSubmessage &submessage)
 
void append_submessage (RTPS::Message &message, const RTPS::DataFragSubmessage &submessage)
 
void log_message (const char *format, const DCPS::GuidPrefix_t &prefix, bool send, const Message &message)
 Log a serialized RTPS message. More...
 
void parse_submessages (Message &message, const ACE_Message_Block &mb)
 
DDS::Security::ParticipantSecurityAttributesMask security_attributes_to_bitmask (const DDS::Security::ParticipantSecurityAttributes &sec_attr)
 
DDS::Security::EndpointSecurityAttributesMask security_attributes_to_bitmask (const DDS::Security::EndpointSecurityAttributes &sec_attr)
 
DDS::OctetSeq handle_to_octets (DDS::Security::NativeCryptoHandle handle)
 
void populate_locators (DCPS::TransportLocatorSeq &remote_data, const ParticipantData_t &pdata)
 
void create_association_data_proto (DCPS::AssociationData &proto, const ParticipantData_t &pdata)
 
void disassociate_helper_extended (DDS::Security::ExtendedBuiltinEndpointSet_t &extended_associated_endpoints, const CORBA::ULong flags, const DCPS::RepoId &id, const EntityId_t &ent, DCPS::TransportClient &client)
 
static bool decode_parameter_list (const DCPS::ReceivedDataSample &sample, Serializer &ser, DCPS::Extensibility extensibility, ParameterList &data)
 
bool locators_changed (const ParticipantProxy_t &x, const ParticipantProxy_t &y)
 
bool operator== (const DCPS::Locator_t &x, const DCPS::Locator_t &y)
 
bool operator!= (const DCPS::Locator_t &x, const DCPS::Locator_t &y)
 
bool operator== (const StatusInfo_t &lhs, const StatusInfo_t &rhs)
 

Variables

const Time_t TIME_INVALID = { 0xffffffffu, 0xffffffffu }
 
const Duration_t DURATION_ZERO = { 0, 0u }
 
const Duration_t DURATION_INFINITE = { 0x7fffffff, 0xffffffffu }
 
const VendorId_t VENDORID_UNKNOWN = { { 0 } }
 
const VendorId_t VENDORID_OPENDDS
 
const SequenceNumber_t SEQUENCENUMBER_UNKNOWN = { -1, 0 }
 
const OpenDDS::DCPS::Locator_t LOCATOR_INVALID
 
const OpenDDS::DCPS::OctetArray16 LOCATOR_ADDRESS_INVALID = { 0 }
 
const LocatorUDPv4_t LOCATORUDPv4_INVALID = { 0, 0 }
 
const ACE_CDR::Octet PROTOCOL_RTPS [] = {'R', 'T', 'P', 'S'}
 
const ProtocolVersion_t PROTOCOLVERSION_1_0 = { 1, 0 }
 
const ProtocolVersion_t PROTOCOLVERSION_1_1 = { 1, 1 }
 
const ProtocolVersion_t PROTOCOLVERSION_2_0 = { 2, 0 }
 
const ProtocolVersion_t PROTOCOLVERSION_2_1 = { 2, 1 }
 
const ProtocolVersion_t PROTOCOLVERSION_2_2 = { 2, 2 }
 
const ProtocolVersion_t PROTOCOLVERSION_2_3 = { 2, 3 }
 
const ProtocolVersion_t PROTOCOLVERSION_2_4 = { 2, 4 }
 
const ProtocolVersion_t PROTOCOLVERSION = PROTOCOLVERSION_2_4
 
const ACE_CDR::UShort DATA_OCTETS_TO_IQOS = 16
 
const ACE_CDR::UShort DATA_FRAG_OCTETS_TO_IQOS = 28
 
const ACE_CDR::UShort RTPSHDR_SZ = 20
 
const ACE_CDR::UShort SMHDR_SZ = 4
 
const ACE_CDR::UShort HEARTBEAT_SZ = 28
 
const ACE_CDR::UShort INFO_DST_SZ = 12
 
const ACE_CDR::UShort INFO_TS_SZ = 8
 
const ACE_CDR::UShort INFO_SRC_SZ = 20
 
const size_t SM_ALIGN = 4
 Alignment of RTPS Submessage. More...
 
const DCPS::EntityId_t PARTICIPANT_MESSAGE_DATA_KIND_UNKNOWN
 
const DCPS::EntityId_t PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE
 
const DCPS::EntityId_t PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE
 
const long LOCATOR_KIND_INVALID = -1
 
const long LOCATOR_KIND_RESERVED = 0
 
const long LOCATOR_KIND_UDPv4 = 1
 
const long LOCATOR_KIND_UDPv6 = 2
 
const unsigned long LOCATOR_PORT_INVALID = 0
 
const short NO_KEY = 1
 
const short WITH_KEY = 2
 
const short BEST_EFFORT = 1
 
const short RELIABLE = 2
 
const IceAgentType_t ICE_FULL = 0x0
 
const IceAgentType_t ICE_LITE = 0x1
 
const IceCandidateType_t ICE_HOST = 0x0
 
const IceCandidateType_t ICE_SERVER_REFLEXIVE = 0x1
 
const IceCandidateType_t ICE_PEER_REFLEXIVE = 0x2
 
const IceCandidateType_t ICE_RELAYED = 0x3
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_ANNOUNCER
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_DETECTOR
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_ANNOUNCER
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_DETECTOR
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_ANNOUNCER
 
const BuiltinEndpointSet_t DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_DETECTOR
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER
 
const BuiltinEndpointSet_t BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER
 
const BuiltinEndpointQos_t BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER
 
const ParameterId_t PID_PAD = 0x0000
 
const ParameterId_t PID_SENTINEL = 0x0001
 
const ParameterId_t PID_USER_DATA = 0x002c
 
const ParameterId_t PID_TOPIC_NAME = 0x0005
 
const ParameterId_t PID_TYPE_NAME = 0x0007
 
const ParameterId_t PID_GROUP_DATA = 0x002d
 
const ParameterId_t PID_TOPIC_DATA = 0x002e
 
const ParameterId_t PID_DURABILITY = 0x001d
 
const ParameterId_t PID_DURABILITY_SERVICE = 0x001e
 
const ParameterId_t PID_DEADLINE = 0x0023
 
const ParameterId_t PID_LATENCY_BUDGET = 0x0027
 
const ParameterId_t PID_LIVELINESS = 0x001b
 
const ParameterId_t PID_RELIABILITY = 0x001a
 
const ParameterId_t PID_LIFESPAN = 0x002b
 
const ParameterId_t PID_DESTINATION_ORDER = 0x0025
 
const ParameterId_t PID_HISTORY = 0x0040
 
const ParameterId_t PID_RESOURCE_LIMITS = 0x0041
 
const ParameterId_t PID_OWNERSHIP = 0x001f
 
const ParameterId_t PID_OWNERSHIP_STRENGTH = 0x0006
 
const ParameterId_t PID_PRESENTATION = 0x0021
 
const ParameterId_t PID_PARTITION = 0x0029
 
const ParameterId_t PID_TIME_BASED_FILTER = 0x0004
 
const ParameterId_t PID_TRANSPORT_PRIORITY = 0x0049
 
const ParameterId_t PID_PROTOCOL_VERSION = 0x0015
 
const ParameterId_t PID_VENDORID = 0x0016
 
const ParameterId_t PID_UNICAST_LOCATOR = 0x002f
 
const ParameterId_t PID_MULTICAST_LOCATOR = 0x0030
 
const ParameterId_t PID_DEFAULT_UNICAST_LOCATOR = 0x0031
 
const ParameterId_t PID_DEFAULT_MULTICAST_LOCATOR = 0x0048
 
const ParameterId_t PID_METATRAFFIC_UNICAST_LOCATOR = 0x0032
 
const ParameterId_t PID_METATRAFFIC_MULTICAST_LOCATOR = 0x0033
 
const ParameterId_t PID_EXPECTS_INLINE_QOS = 0x0043
 
const ParameterId_t PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT = 0x0034
 
const ParameterId_t PID_PARTICIPANT_BUILTIN_ENDPOINTS = 0x0044
 
const ParameterId_t PID_PARTICIPANT_LEASE_DURATION = 0x0002
 
const ParameterId_t PID_CONTENT_FILTER_PROPERTY = 0x0035
 
const ParameterId_t PID_PARTICIPANT_GUID = 0x0050
 
const ParameterId_t PID_GROUP_GUID = 0x0052
 
const ParameterId_t PID_BUILTIN_ENDPOINT_SET = 0x0058
 
const ParameterId_t PID_PROPERTY_LIST = 0x0059
 
const ParameterId_t PID_TYPE_MAX_SIZE_SERIALIZED = 0x0060
 
const ParameterId_t PID_ENTITY_NAME = 0x0062
 
const ParameterId_t PID_KEY_HASH = 0x0070
 
const ParameterId_t PID_STATUS_INFO = 0x0071
 
const ParameterId_t PID_ENDPOINT_GUID = 0x005a
 
const ParameterId_t PID_CONTENT_FILTER_INFO = 0x0055
 
const ParameterId_t PID_COHERENT_SET = 0x0056
 
const ParameterId_t PID_DIRECTED_WRITE = 0x0057
 
const ParameterId_t PID_ORIGINAL_WRITER_INFO = 0x0061
 
const ParameterId_t PID_DATA_REPRESENTATION = 0x0073
 
const ParameterId_t PID_XTYPES_TYPE_CONSISTENCY = 0x0074
 
const ParameterId_t PID_XTYPES_TYPE_INFORMATION = 0x0075
 
const ParameterId_t PIDMASK_VENDOR_SPECIFIC = 0x8000
 
const ParameterId_t PIDMASK_INCOMPATIBLE = 0x4000
 
const ParameterId_t PID_DOMAIN_ID = 0x000f
 
const ParameterId_t PID_DOMAIN_TAG = 0x4014
 
const ParameterId_t PID_BUILTIN_ENDPOINT_QOS = 0x0077
 
const OpenDDSParticipantFlagsBits_t PFLAGS_EMPTY = 0x0
 
const OpenDDSParticipantFlagsBits_t PFLAGS_NO_ASSOCIATED_WRITERS = 0x1
 
const OpenDDSParticipantFlagsBits_t PFLAGS_DIRECTED_HEARTBEAT = 0x2
 
const OpenDDSParticipantFlagsBits_t PFLAGS_REFLECT_HEARTBEAT_COUNT = 0x4
 
const OpenDDSParticipantFlagsBits_t PFLAGS_THIS_VERSION = PFLAGS_DIRECTED_HEARTBEAT | PFLAGS_NO_ASSOCIATED_WRITERS
 
const ParameterId_t PID_OPENDDS_BASE = PIDMASK_VENDOR_SPECIFIC + 0x3000
 
const ParameterId_t PID_OPENDDS_LOCATOR = PID_OPENDDS_BASE + 1
 
const ParameterId_t PID_OPENDDS_ASSOCIATED_WRITER = PID_OPENDDS_BASE + 2
 
const ParameterId_t PID_OPENDDS_ICE_GENERAL = PID_OPENDDS_BASE + 3
 
const ParameterId_t PID_OPENDDS_ICE_CANDIDATE = PID_OPENDDS_BASE + 4
 
const ParameterId_t PID_OPENDDS_PARTICIPANT_FLAGS = PID_OPENDDS_BASE + 5
 
const ParameterId_t PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT = PID_OPENDDS_BASE + 6
 
const octet FLAG_E = 1
 
const octet FLAG_Q = 2
 
const octet FLAG_F = 2
 
const octet FLAG_I = 2
 
const octet FLAG_M = 2
 
const octet FLAG_D = 4
 
const octet FLAG_L = 4
 
const octet FLAG_K_IN_FRAG = 4
 
const octet FLAG_K_IN_DATA = 8
 
const octet FLAG_N_IN_FRAG = 8
 
const octet FLAG_N_IN_DATA = 16
 
const char RTPS_DISCOVERY_ENDPOINT_ANNOUNCEMENTS [] = "OpenDDS.RtpsDiscovery.EndpointAnnouncements"
 
const char RTPS_DISCOVERY_TYPE_LOOKUP_SERVICE [] = "OpenDDS.RtpsDiscovery.TypeLookupService"
 
const char RTPS_RELAY_APPLICATION_PARTICIPANT [] = "OpenDDS.Rtps.RelayApplicationParticipant"
 
const char RTPS_REFLECT_HEARTBEAT_COUNT [] = "OpenDDS.Rtps.ReflectHeartbeatCount"
 
static RtpsDiscovery::StaticInitializer initialize_rtps
 
const DDS::Security::ParticipantSecurityInfo PARTICIPANT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}
 
const DDS::Security::EndpointSecurityInfo ENDPOINT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}
 
const char SPDP_AGENT_INFO_KEY [] = "SPDP"
 
const char SEDP_AGENT_INFO_KEY [] = "SEDP"
 
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER = {{0xff, 0x00, 0x03}, 0xc2}
 
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER = {{0xff, 0x00, 0x03}, 0xc7}
 
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER = {{0xff, 0x00, 0x04}, 0xc2}
 
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER = {{0xff, 0x00, 0x04}, 0xc7}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER = {{0xff, 0x02, 0x00}, 0xc2}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER = {{0xff, 0x02, 0x00}, 0xc7}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER = {{0x00, 0x02, 0x01}, 0xc3}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_READER = {{0x00, 0x02, 0x01}, 0xc4}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER = {{0xff, 0x02, 0x02}, 0xc3}
 
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER = {{0xff, 0x02, 0x02}, 0xc4}
 
const EntityId_t ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER = {{0xff, 0x01, 0x01}, 0xc2}
 
const EntityId_t ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER = {{0xff, 0x01, 0x01}, 0xc7}
 
const EntityId_t ENTITYID_TL_SVC_REQ_WRITER_SECURE = {{0xff, 0x03, 0x00}, 0xc3 }
 
const EntityId_t ENTITYID_TL_SVC_REQ_READER_SECURE = {{0xff, 0x03, 0x00}, 0xc4 }
 
const EntityId_t ENTITYID_TL_SVC_REPLY_WRITER_SECURE = {{0xff, 0x03, 0x01}, 0xc3 }
 
const EntityId_t ENTITYID_TL_SVC_REPLY_READER_SECURE = {{0xff, 0x03, 0x01}, 0xc4 }
 

Typedef Documentation

◆ BuiltinEndpointQos_t

typedef unsigned long OpenDDS::RTPS::BuiltinEndpointQos_t

Definition at line 230 of file RtpsCore.idl.

◆ BuiltinEndpointSet_t

typedef unsigned long OpenDDS::RTPS::BuiltinEndpointSet_t

Definition at line 195 of file RtpsCore.idl.

◆ FilterResult_t

typedef sequence<long> OpenDDS::RTPS::FilterResult_t

Definition at line 30 of file RtpsCore.idl.

◆ FilterSignature_t

typedef long OpenDDS::RTPS::FilterSignature_t[4]

Definition at line 26 of file RtpsCore.idl.

◆ FilterSignatureSeq

typedef sequence<FilterSignature_t> OpenDDS::RTPS::FilterSignatureSeq

Definition at line 32 of file RtpsCore.idl.

◆ IceAgentType_t

typedef unsigned long OpenDDS::RTPS::IceAgentType_t

Definition at line 170 of file RtpsCore.idl.

◆ IceCandidateType_t

typedef unsigned long OpenDDS::RTPS::IceCandidateType_t

Definition at line 181 of file RtpsCore.idl.

◆ LocatorList

typedef sequence<OpenDDS::DCPS::Locator_t, 8> OpenDDS::RTPS::LocatorList

Definition at line 81 of file RtpsCore.idl.

◆ LongSeq8

typedef sequence<long, 8> OpenDDS::RTPS::LongSeq8

Definition at line 68 of file RtpsCore.idl.

◆ OctetArray2

typedef octet OpenDDS::RTPS::OctetArray2[2]

Definition at line 21 of file RtpsCore.idl.

◆ OctetArray4

typedef octet OpenDDS::RTPS::OctetArray4[4]

Definition at line 22 of file RtpsCore.idl.

◆ OpenDDSParticipantFlagsBits_t

typedef unsigned long OpenDDS::RTPS::OpenDDSParticipantFlagsBits_t

Definition at line 318 of file RtpsCore.idl.

◆ ParameterId_t

typedef unsigned short OpenDDS::RTPS::ParameterId_t

Definition at line 246 of file RtpsCore.idl.

◆ ParameterList

typedef sequence<Parameter> OpenDDS::RTPS::ParameterList

Definition at line 234 of file RtpsCore.idl.

◆ ParticipantData_t

typedef Security::SPDPdiscoveredParticipantData OpenDDS::RTPS::ParticipantData_t

Definition at line 63 of file Sedp.h.

◆ Property_t

typedef DDS::Property_t OpenDDS::RTPS::Property_t

Definition at line 47 of file RtpsCore.idl.

◆ PropertySeq

typedef DDS::PropertySeq OpenDDS::RTPS::PropertySeq

Definition at line 48 of file RtpsCore.idl.

◆ RtpsDiscovery_rch

typedef OpenDDS::DCPS::RcHandle<RtpsDiscovery> OpenDDS::RTPS::RtpsDiscovery_rch

Definition at line 799 of file RtpsDiscovery.h.

◆ RtpsDiscoveryConfig_rch

typedef OpenDDS::DCPS::RcHandle<RtpsDiscoveryConfig> OpenDDS::RTPS::RtpsDiscoveryConfig_rch

Definition at line 626 of file RtpsDiscovery.h.

◆ SubmessageSeq

typedef sequence<Submessage> OpenDDS::RTPS::SubmessageSeq

Definition at line 878 of file RtpsCore.idl.

◆ Timestamp_t

typedef Time_t OpenDDS::RTPS::Timestamp_t

Definition at line 95 of file RtpsCore.idl.

Enumeration Type Documentation

◆ SubmessageKind

enum OpenDDS::RTPS::SubmessageKind
Enumerator
SUBMESSAGE_NONE 
PAD 
RESERVED_2 
RESERVED_3 
RESERVED_4 
RESERVED_5 
ACKNACK 
HEARTBEAT 
GAP 
INFO_TS 
RESERVED_10 
RESERVED_11 
INFO_SRC 
INFO_REPLY_IP4 
INFO_DST 
INFO_REPLY 
RESERVED_16 
RESERVED_17 
NACK_FRAG 
HEARTBEAT_FRAG 
RESERVED_20 
DATA 
DATA_FRAG 
RESERVED_23 
RESERVED_24 
RESERVED_25 
RESERVED_26 
RESERVED_27 
RESERVED_28 
RESERVED_29 
RESERVED_30 
RESERVED_31 
RESERVED_32 
RESERVED_33 
RESERVED_34 
RESERVED_35 
RESERVED_36 
RESERVED_37 
RESERVED_38 
RESERVED_39 
RESERVED_40 
RESERVED_41 
RESERVED_42 
RESERVED_43 
RESERVED_44 
RESERVED_45 
RESERVED_46 
RESERVED_47 
SEC_BODY 
SEC_PREFIX 
SEC_POSTFIX 
SRTPS_PREFIX 
SRTPS_POSTFIX 
RESERVED_53_SECURITY 

Definition at line 770 of file RtpsCore.idl.

770  {
771  SUBMESSAGE_NONE,
772  PAD, /* = 0x01, Pad */
773  RESERVED_2,
774  RESERVED_3,
775  RESERVED_4,
776  RESERVED_5,
777  ACKNACK, /* = 0x06, AckNack */
778  HEARTBEAT, /* = 0x07, Heartbeat */
779  GAP, /* = 0x08, Gap */
780  INFO_TS, /* = 0x09, InfoTimestamp */
781  RESERVED_10,
782  RESERVED_11,
783  INFO_SRC, /* = 0x0c, InfoSource */
784  INFO_REPLY_IP4, /* = 0x0d, InfoReplyIp4 */
785  INFO_DST, /* = 0x0e, InfoDestination */
786  INFO_REPLY, /* = 0x0f, InfoReply */
787  RESERVED_16,
788  RESERVED_17,
789  NACK_FRAG, /* = 0x12, NackFrag */
790  HEARTBEAT_FRAG, /* = 0x13, HeartbeatFrag */
791  RESERVED_20,
792  DATA, /* = 0x15, Data */
793  DATA_FRAG, /* = 0x16, DataFrag */
794  RESERVED_23,
795  RESERVED_24,
796  RESERVED_25,
797  RESERVED_26,
798  RESERVED_27,
799  RESERVED_28,
800  RESERVED_29,
801  RESERVED_30,
802  RESERVED_31,
803  RESERVED_32,
804  RESERVED_33,
805  RESERVED_34,
806  RESERVED_35,
807  RESERVED_36,
808  RESERVED_37,
809  RESERVED_38,
810  RESERVED_39,
811  RESERVED_40,
812  RESERVED_41,
813  RESERVED_42,
814  RESERVED_43,
815  RESERVED_44,
816  RESERVED_45,
817  RESERVED_46,
818  RESERVED_47,
819  SEC_BODY, // SubmessageKinds 0x30-3f reserved for security
820  SEC_PREFIX,
821  SEC_POSTFIX,
822  SRTPS_PREFIX,
823  SRTPS_POSTFIX,
824  RESERVED_53_SECURITY
825  };

Function Documentation

◆ address_to_bytes()

void OpenDDS::RTPS::address_to_bytes ( DCPS::OctetArray16 &  dest,
const ACE_INET_Addr &  addr 
)
inline

Definition at line 97 of file BaseMessageUtils.h.

References ACE_INET_Addr::get_addr(), and ACE_Addr::get_type().

Referenced by OpenDDS::STUN::operator<<(), OpenDDS::DCPS::RtpsUdpInst::populate_locator(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

98 {
99  const void* raw = addr.get_addr();
100 #ifdef ACE_HAS_IPV6
101  if (addr.get_type() == AF_INET6) {
102  const sockaddr_in6* in = static_cast<const sockaddr_in6*>(raw);
103  std::memcpy(&dest[0], &in->sin6_addr, 16);
104  } else {
105 #else
106  {
107 #endif
108  const sockaddr_in* in = static_cast<const sockaddr_in*>(raw);
109  std::memset(&dest[0], 0, 12);
110  std::memcpy(&dest[12], &in->sin_addr, 4);
111  }
112 }
ACE_Addr::get_type
int get_type(void) const
ACE_INET_Addr::get_addr
virtual void * get_addr(void) const

◆ address_to_kind()

int OpenDDS::RTPS::address_to_kind ( const ACE_INET_Addr &  addr)
inline

Definition at line 115 of file BaseMessageUtils.h.

References blob_to_locators(), get_locators_encoding(), ACE_Addr::get_type(), LOCATOR_KIND_UDPv4, LOCATOR_KIND_UDPv6, locator_to_address(), locators_to_blob(), OpenDDS_Rtps_Export, and transport_locator_to_locator_seq().

Referenced by OpenDDS::DCPS::RtpsUdpInst::populate_locator(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

116 {
117 #ifdef ACE_HAS_IPV6
118  return addr.get_type() == AF_INET6 ? LOCATOR_KIND_UDPv6 : LOCATOR_KIND_UDPv4;
119 #else
120  ACE_UNUSED_ARG(addr);
121  return LOCATOR_KIND_UDPv4;
122 #endif
123 }
ACE_Addr::get_type
int get_type(void) const
OpenDDS::RTPS::LOCATOR_KIND_UDPv6
const long LOCATOR_KIND_UDPv6
Definition: RtpsCore.idl:110
OpenDDS::RTPS::LOCATOR_KIND_UDPv4
const long LOCATOR_KIND_UDPv4
Definition: RtpsCore.idl:109

◆ append_submessage() [1/4]

void OpenDDS::RTPS::append_submessage ( RTPS::Message &  message,
const RTPS::InfoDestinationSubmessage &  submessage 
)
inline

Definition at line 226 of file BaseMessageUtils.h.

References OpenDDS::RTPS::Submessage::info_dst_sm, OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Message::submessages.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), parse_submessages(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

227 {
228  RTPS::Submessage sm;
229  sm.info_dst_sm(submessage);
230  DCPS::push_back(message.submessages, sm);
231 }
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:136

◆ append_submessage() [2/4]

void OpenDDS::RTPS::append_submessage ( RTPS::Message &  message,
const RTPS::InfoTimestampSubmessage &  submessage 
)
inline

Definition at line 233 of file BaseMessageUtils.h.

References OpenDDS::RTPS::Submessage::info_ts_sm, OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Message::submessages.

234 {
235  RTPS::Submessage sm;
236  sm.info_ts_sm(submessage);
237  DCPS::push_back(message.submessages, sm);
238 }
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:136

◆ append_submessage() [3/4]

void OpenDDS::RTPS::append_submessage ( RTPS::Message &  message,
const RTPS::DataSubmessage &  submessage 
)
inline

Definition at line 240 of file BaseMessageUtils.h.

References OpenDDS::RTPS::Submessage::data_sm, OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Message::submessages.

241 {
242  RTPS::Submessage sm;
243  sm.data_sm(submessage);
244  DCPS::push_back(message.submessages, sm);
245 }
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:136

◆ append_submessage() [4/4]

void OpenDDS::RTPS::append_submessage ( RTPS::Message &  message,
const RTPS::DataFragSubmessage &  submessage 
)
inline

Definition at line 247 of file BaseMessageUtils.h.

References OpenDDS::RTPS::Submessage::data_frag_sm, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::push_back(), and OpenDDS::RTPS::Message::submessages.

248 {
249  RTPS::Submessage sm;
250  sm.data_frag_sm(submessage);
251  DCPS::push_back(message.submessages, sm);
252 }
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:136

◆ assign() [1/3]

void OpenDDS::RTPS::assign ( DCPS::OctetArray16 &  dest,
const DCPS::OctetArray16 &  src 
)
inline

Definition at line 72 of file BaseMessageUtils.h.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg(), and OpenDDS::RTPS::Spdp::SpdpTransport::thread_status_task().

74 {
75  std::memcpy(&dest[0], &src[0], sizeof(DCPS::OctetArray16));
76 }
DDS::OctetArray16
octet OctetArray16[16]
Definition: DdsDcpsCore.idl:390

◆ assign() [2/3]

void OpenDDS::RTPS::assign ( DCPS::OctetArray16 &  dest,
const ACE_CDR::ULong &  ipv4addr_be 
)
inline

Definition at line 78 of file BaseMessageUtils.h.

80 {
81  std::memset(&dest[0], 0, 12);
82  dest[12] = ipv4addr_be >> 24;
83  dest[13] = ipv4addr_be >> 16;
84  dest[14] = ipv4addr_be >> 8;
85  dest[15] = ipv4addr_be;
86 }

◆ assign() [3/3]

void OpenDDS::RTPS::assign ( DCPS::EntityKey_t &  lhs,
unsigned int  rhs 
)
inline

Definition at line 88 of file BaseMessageUtils.h.

89 {
90  lhs[0] = static_cast<CORBA::Octet>(rhs);
91  lhs[1] = static_cast<CORBA::Octet>(rhs >> 8);
92  lhs[2] = static_cast<CORBA::Octet>(rhs >> 16);
93 }
CORBA::Octet
ACE_CDR::Octet Octet

◆ bitmapNonEmpty()

OpenDDS_Rtps_Export bool OpenDDS::RTPS::bitmapNonEmpty ( const SequenceNumberSet &  snSet)

Definition at line 221 of file BaseMessageUtils.cpp.

References OpenDDS::RTPS::SequenceNumberSet::bitmap, OpenDDS::RTPS::SequenceNumberSet::numBits, OPENDDS_ASSERT, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack().

222 {
223  const CORBA::ULong num_ulongs = (snSet.numBits + 31) / 32;
224 
225  OPENDDS_ASSERT(num_ulongs <= snSet.bitmap.length());
226 
227  if (num_ulongs == 0) {
228  return false;
229  }
230 
231  const CORBA::ULong last_index = num_ulongs - 1;
232  for (CORBA::ULong i = 0; i < last_index; ++i) {
233  if (snSet.bitmap[i]) {
234  return true;
235  }
236  }
237 
238  const CORBA::ULong mod = snSet.numBits % 32;
239  const CORBA::ULong mask = mod ? (1 + ~(1u << (32 - mod))) : 0xFFFFFFFF;
240  return (bool)(snSet.bitmap[last_index] & mask);
241 }
OPENDDS_ASSERT
#define OPENDDS_ASSERT(C)
Definition: Definitions.h:67
CORBA::ULong
ACE_CDR::ULong ULong

◆ blob_to_locators()

OpenDDS_Rtps_Export DDS::ReturnCode_t OpenDDS::RTPS::blob_to_locators ( const DCPS::TransportBLOB &  blob,
DCPS::LocatorSeq &  locators,
bool *  requires_inline_qos,
unsigned int *  pBytesRead 
)

Definition at line 64 of file BaseMessageUtils.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), ACE_Message_Block::DONT_DELETE, get_locators_encoding(), ACE_Message_Block::length(), LM_ERROR, ACE_Message_Block::MB_DATA, DDS::RETCODE_ERROR, DDS::RETCODE_OK, OpenDDS::DCPS::Serializer::skip(), ACE_Message_Block::space(), and ACE_Message_Block::wr_ptr().

Referenced by address_to_kind(), OpenDDS::DCPS::RtpsUdpTransport::get_connection_addrs(), and transport_locator_to_locator_seq().

68 {
69  ACE_Data_Block db(blob.length(), ACE_Message_Block::MB_DATA,
70  reinterpret_cast<const char*>(blob.get_buffer()),
71  0 /*alloc*/, 0 /*lock*/, ACE_Message_Block::DONT_DELETE, 0 /*db_alloc*/);
72  ACE_Message_Block mb(&db, ACE_Message_Block::DONT_DELETE, 0 /*mb_alloc*/);
73  mb.wr_ptr(mb.space());
74 
75  DCPS::Serializer ser(&mb, get_locators_encoding());
76  if (!(ser >> locators)) {
77  ACE_ERROR_RETURN((LM_ERROR,
78  ACE_TEXT("(%P|%t) blob_to_locators: ")
79  ACE_TEXT("Failed to deserialize blob's locators\n")),
80  DDS::RETCODE_ERROR);
81  }
82 
83  if (requires_inline_qos) {
84  if (!(ser >> ACE_InputCDR::to_boolean(*requires_inline_qos))) {
85  ACE_ERROR_RETURN((LM_ERROR,
86  ACE_TEXT("(%P|%t) blob_to_locators: ")
87  ACE_TEXT("Failed to deserialize blob inline QoS flag\n")),
88  DDS::RETCODE_ERROR);
89  }
90  } else {
91  if (!ser.skip(1)) {
92  ACE_ERROR_RETURN((LM_ERROR,
93  ACE_TEXT("(%P|%t) blob_to_locators: ")
94  ACE_TEXT("Failed to skip blob inline QoS flag\n")),
95  DDS::RETCODE_ERROR);
96  }
97  }
98 
99  if (pBytesRead) {
100  *pBytesRead = blob.length() - static_cast<unsigned int>(mb.length());
101  }
102  return DDS::RETCODE_OK;
103 }
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: BaseMessageUtils.cpp:58
ACE_TEXT
ACE_TEXT("TCP_Factory")
ACE_ERROR_RETURN
#define ACE_ERROR_RETURN(X, Y)
DDS::RETCODE_ERROR
const ReturnCode_t RETCODE_ERROR
Definition: DdsDcpsInfrastructure.idl:55
DDS::RETCODE_OK
const ReturnCode_t RETCODE_OK
Definition: DdsDcpsInfrastructure.idl:54

◆ create_association_data_proto()

void OpenDDS::RTPS::create_association_data_proto ( DCPS::AssociationData &  proto,
const ParticipantData_t &  pdata 
)

Definition at line 945 of file Sedp.cpp.

References OpenDDS::DCPS::assign(), OpenDDS::RTPS::OpenDDSParticipantFlags_t::bits, OpenDDS::Security::SPDPdiscoveredParticipantData::discoveredAt, OpenDDS::DCPS::GUID_t::guidPrefix, OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, OpenDDS::RTPS::ParticipantProxy_t::opendds_participant_flags, OpenDDS::DCPS::AssociationData::participant_discovered_at_, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, populate_locators(), OpenDDS::DCPS::AssociationData::publication_transport_priority_, OpenDDS::DCPS::AssociationData::remote_data_, OpenDDS::DCPS::AssociationData::remote_durable_, OpenDDS::DCPS::AssociationData::remote_id_, OpenDDS::DCPS::AssociationData::remote_reliable_, and OpenDDS::DCPS::AssociationData::remote_transport_context_.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::associate_preauth(), OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), and OpenDDS::RTPS::Sedp::associate_volatile().

946  {
947  proto.publication_transport_priority_ = 0;
948  proto.remote_reliable_ = true;
949  proto.remote_durable_ = true;
950  DCPS::assign(proto.remote_id_.guidPrefix, pdata.participantProxy.guidPrefix);
951  proto.participant_discovered_at_ = pdata.discoveredAt;
952  proto.remote_transport_context_ = pdata.participantProxy.opendds_participant_flags.bits;
953  populate_locators(proto.remote_data_, pdata);
954 }
OpenDDS::RTPS::populate_locators
void populate_locators(DCPS::TransportLocatorSeq &remote_data, const ParticipantData_t &pdata)
Definition: Sedp.cpp:915
OpenDDS::DCPS::assign
void assign(EntityKey_t &lhs, unsigned int rhs)
Definition: DiscoveryBase.h:79

◆ decode_parameter_list()

static bool OpenDDS::RTPS::decode_parameter_list ( const DCPS::ReceivedDataSample &  sample,
Serializer &  ser,
DCPS::Extensibility  extensibility,
ParameterList &  data 
)
static

Definition at line 4403 of file Sedp.cpp.

References OpenDDS::DCPS::FINAL, OpenDDS::DCPS::ReceivedDataSample::header_, OpenDDS::DCPS::DataSampleHeader::key_fields_only_, and PID_ENDPOINT_GUID.

Referenced by OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i().

4408 {
4409  if (sample.header_.key_fields_only_ && extensibility == DCPS::FINAL) {
4410  GUID_t guid;
4411  if (!(ser >> guid)) return false;
4412  data.length(1);
4413  data[0].guid(guid);
4414  data[0]._d(PID_ENDPOINT_GUID);
4415  } else {
4416  return ser >> data;
4417  }
4418  return true;
4419 }
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:295

◆ disassociate_helper_extended()

void OpenDDS::RTPS::disassociate_helper_extended ( DDS::Security::ExtendedBuiltinEndpointSet_t &  extended_associated_endpoints,
const CORBA::ULong  flags,
const DCPS::RepoId &  id,
const EntityId_t &  ent,
DCPS::TransportClient &  client 
)

Definition at line 1309 of file Sedp.cpp.

References OpenDDS::DCPS::TransportClient::disassociate(), and OpenDDS::DCPS::make_id().

1312 {
1313  if (extended_associated_endpoints & flags) {
1314  client.disassociate(make_id(id, ent));
1315  extended_associated_endpoints &= ~flags;
1316  }
1317 }
OpenDDS::DCPS::make_id
RepoId make_id(const GuidPrefix_t &prefix, const EntityId_t &entity)
Definition: GuidUtils.h:202

◆ get_locators_encoding()

OpenDDS_Rtps_Export const DCPS::Encoding & OpenDDS::RTPS::get_locators_encoding ( )

Definition at line 58 of file BaseMessageUtils.cpp.

References OpenDDS::STUN::encoding(), OpenDDS::DCPS::ENDIAN_BIG, and OpenDDS::DCPS::Encoding::KIND_XCDR1.

Referenced by address_to_kind(), blob_to_locators(), locators_to_blob(), populate_locators(), and OpenDDS::RTPS::Sedp::shutting_down().

59 {
60  static const Encoding encoding(Encoding::KIND_XCDR1, DCPS::ENDIAN_BIG);
61  return encoding;
62 }
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)

◆ handle_to_octets()

DDS::OctetSeq OpenDDS::RTPS::handle_to_octets ( DDS::Security::NativeCryptoHandle  handle)
inline

Definition at line 101 of file SecurityHelpers.h.

102 {
103  DDS::OctetSeq handleOctets(sizeof handle);
104  handleOctets.length(handleOctets.maximum());
105  unsigned char* rawHandleOctets = handleOctets.get_buffer();
106  unsigned int handleTmp = handle;
107  for (unsigned int j = sizeof handle; j > 0; --j) {
108  rawHandleOctets[j - 1] = handleTmp & 0xff;
109  handleTmp >>= 8;
110  }
111  return handleOctets;
112 }
DDS::OctetSeq
sequence< octet > OctetSeq
Definition: DdsDcpsCore.idl:46

◆ locator_to_address()

OpenDDS_Rtps_Export int OpenDDS::RTPS::locator_to_address ( ACE_INET_Addr &  dest,
const DCPS::Locator_t &  locator,
bool  map 
)

Definition at line 21 of file BaseMessageUtils.cpp.

References OpenDDS::DCPS::Locator_t::address, AF_INET, OpenDDS::DCPS::Locator_t::kind, LOCATOR_KIND_UDPv4, LOCATOR_KIND_UDPv6, ACE_INET_Addr::set_address(), ACE_INET_Addr::set_port_number(), and ACE_Addr::set_type().

Referenced by address_to_kind(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), and OpenDDS::DCPS::RtpsUdpTransport::get_connection_addrs().

24 {
25  switch (locator.kind) {
26 #ifdef ACE_HAS_IPV6
27  case LOCATOR_KIND_UDPv6:
28  dest.set_type(AF_INET6);
29  if (dest.set_address(reinterpret_cast<const char*>(locator.address),
30  16, 0 /*encode*/) == -1) {
31  return -1;
32  }
33  dest.set_port_number(locator.port);
34  return 0;
35 #endif
36  case LOCATOR_KIND_UDPv4:
37 #if !defined (ACE_HAS_IPV6) || !defined (IPV6_V6ONLY)
38  ACE_UNUSED_ARG(map);
39 #endif
40  dest.set_type(AF_INET);
41  if (dest.set_address(reinterpret_cast<const char*>(locator.address)
42  + 12, 4, 0 /*network order*/
43 #if defined (ACE_HAS_IPV6) && defined (IPV6_V6ONLY)
44  , map ? 1 : 0 /*map IPV4 to IPV6 addr*/
45 #endif
46  ) == -1) {
47  return -1;
48  }
49  dest.set_port_number(locator.port);
50  return 0;
51  default:
52  return -1; // Unknown kind
53  }
54 
55  return -1;
56 }
ACE_INET_Addr::set_port_number
void set_port_number(u_short, int encode=1)
ACE_Addr::set_type
void set_type(int type)
OpenDDS::RTPS::LOCATOR_KIND_UDPv6
const long LOCATOR_KIND_UDPv6
Definition: RtpsCore.idl:110
OpenDDS::RTPS::LOCATOR_KIND_UDPv4
const long LOCATOR_KIND_UDPv4
Definition: RtpsCore.idl:109
ACE_INET_Addr::set_address
int set_address(const char *ip_addr, int len, int encode=1, int map=0)

◆ locators_changed()

bool OpenDDS::RTPS::locators_changed ( const ParticipantProxy_t &  x,
const ParticipantProxy_t &  y 
)

Definition at line 6232 of file Sedp.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::RTPS::Spdp::handle_participant_data(), and OpenDDS::RTPS::Sedp::SubscriptionAgentInfoListener::SubscriptionAgentInfoListener().

6234 {
6235  return locatorsChanged(x, y);
6236 }

◆ locators_to_blob()

OpenDDS_Rtps_Export void OpenDDS::RTPS::locators_to_blob ( const DCPS::LocatorSeq &  locators,
DCPS::TransportBLOB &  blob 
)

Definition at line 105 of file BaseMessageUtils.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::STUN::encoding(), get_locators_encoding(), LM_ERROR, message_block_to_sequence(), OpenDDS_Rtps_Export, and OpenDDS::DCPS::serialized_size().

Referenced by address_to_kind(), and OpenDDS::DCPS::RtpsUdpInst::populate_locator().

107 {
108  using namespace OpenDDS::DCPS;
109  const Encoding& encoding = get_locators_encoding();
110  size_t size = 0;
111  serialized_size(encoding, size, locators);
112  ACE_Message_Block mb_locator(size + 1);
113  Serializer ser(&mb_locator, encoding);
114  if (!(ser << locators)) {
115  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) locators_to_blob: ")
116  ACE_TEXT("Failed to serialize locators to blob\n")));
117  }
118  // Add a bool for 'requires inline qos', see Sedp::set_inline_qos():
119  // if the bool is no longer the last octet of the sequence then that function
120  // must be changed as well.
121  if (!(ser << ACE_OutputCDR::from_boolean(false))) {
122  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) locators_to_blob: ")
123  ACE_TEXT("Failed to serialize boolean for blob\n")));
124  }
125  message_block_to_sequence(mb_locator, blob);
126 }
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
OpenDDS::DCPS::serialized_size
void serialized_size(const Encoding &encoding, size_t &size, const XTypes::TypeLookup_getTypes_In &stru)
Definition: TypeLookup.cpp:13
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: BaseMessageUtils.cpp:58
OpenDDS::DCPS::Serializer
Class to serialize and deserialize data for DDS.
Definition: Serializer.h:355
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::RTPS::message_block_to_sequence
void message_block_to_sequence(const ACE_Message_Block &mb_locator, T &out)
Definition: BaseMessageUtils.h:147

◆ log_message()

OpenDDS_Rtps_Export void OpenDDS::RTPS::log_message ( const char *  format,
const DCPS::GuidPrefix_t &  prefix,
bool  send,
const Message &  message 
)

Log a serialized RTPS message.

Definition at line 34 of file RTPS/Logging.cpp.

References ACE_DEBUG, LM_DEBUG, and OpenDDS::DCPS::vwrite().

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::DCPS::RtpsUdpDataLink::durability_resend(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::finish_message(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::RtpsUdpSendStrategy::marshal_transport_header(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

38 {
39 #ifdef OPENDDS_HAS_JSON_VALUE_WRITER
40  DCPS::JsonValueWriter<> jvw;
41  jvw.begin_struct();
42  jvw.begin_struct_member("guidPrefix");
43  vwrite(jvw, prefix);
44  jvw.end_struct_member();
45  jvw.begin_struct_member("send");
46  jvw.write_boolean(send);
47  jvw.end_struct_member();
48  jvw.begin_struct_member("message");
49  vwrite(jvw, message);
50  jvw.end_struct_member();
51  jvw.end_struct();
52  ACE_DEBUG((LM_DEBUG, format, jvw.buffer().GetString()));
53 #else
54  ACE_UNUSED_ARG(format);
55  ACE_UNUSED_ARG(prefix);
56  ACE_UNUSED_ARG(send);
57  ACE_UNUSED_ARG(message);
58  ACE_DEBUG((LM_DEBUG, "ERROR: OpenDDS lacks JSON serialization support, can't log RTPS messages\n"));
59 #endif
60 }
ACE_DEBUG
#define ACE_DEBUG(X)
OpenDDS::DCPS::vwrite
void vwrite(ValueWriter &vw, const GuidPrefix_t &prefix)
Definition: RTPS/Logging.cpp:21

◆ marshal_key_hash()

template<typename T >
void OpenDDS::RTPS::marshal_key_hash ( const T &  msg,
KeyHash_t &  hash 
)

Definition at line 40 of file BaseMessageUtils.h.

References OpenDDS::STUN::encoding(), OpenDDS::DCPS::ENDIAN_BIG, OpenDDS::DCPS::SerializedSizeBound::get(), OpenDDS::DCPS::Encoding::KIND_XCDR1, ACE_Message_Block::length(), OpenDDS::DCPS::MD5Hash(), ACE_Message_Block::rd_ptr(), OpenDDS::DCPS::serialized_size(), and OpenDDS::RTPS::KeyHash_t::value.

40  {
41  using DCPS::Serializer;
42  using DCPS::Encoding;
43  typedef DCPS::MarshalTraits<T> Traits;
44 
45  DCPS::KeyOnly<const T> ko(msg);
46 
47  static const size_t hash_limit = 16;
48  std::memset(hash.value, 0, hash_limit);
49 
50  const Encoding encoding(Encoding::KIND_XCDR1, DCPS::ENDIAN_BIG);
51  const OpenDDS::DCPS::SerializedSizeBound bound =
52  Traits::key_only_serialized_size_bound(encoding);
53 
54  if (bound && bound.get() <= hash_limit) {
55  // If it is bounded and can always fit in 16 bytes, we will use the
56  // marshaled key
57  ACE_Message_Block mb(hash_limit);
58  Serializer out_serializer(&mb, encoding);
59  out_serializer << ko;
60  std::memcpy(hash.value, mb.rd_ptr(), mb.length());
61 
62  } else {
63  // We will use the hash of the marshaled key
64  ACE_Message_Block mb(serialized_size(encoding, ko));
65  Serializer out_serializer(&mb, encoding);
66  out_serializer << ko;
67 
68  DCPS::MD5Hash(hash.value, mb.rd_ptr(), mb.length());
69  }
70 }
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
OpenDDS::DCPS::serialized_size
void serialized_size(const Encoding &encoding, size_t &size, const XTypes::TypeLookup_getTypes_In &stru)
Definition: TypeLookup.cpp:13
OpenDDS::Security::SSL::hash
int hash(const std::vector< const DDS::OctetSeq *> &src, DDS::OctetSeq &dst)
Definition: Utils.cpp:132
OpenDDS::DCPS::MD5Hash
void MD5Hash(MD5Result &result, const void *input, size_t size)
Definition: Hash.cpp:323

◆ message_block_to_sequence()

template<typename T >
void OpenDDS::RTPS::message_block_to_sequence ( const ACE_Message_Block &  mb_locator,
T &  out 
)

Definition at line 147 of file BaseMessageUtils.h.

References ACE_Message_Block::length(), and ACE_Message_Block::rd_ptr().

Referenced by locators_to_blob(), populate_locators(), and OpenDDS::RTPS::Sedp::shutting_down().

148 {
149  out.length (CORBA::ULong(mb_locator.length()));
150  std::memcpy (out.get_buffer(), mb_locator.rd_ptr(), mb_locator.length());
151 }
ACE_Message_Block::length
size_t length(void) const
ACE_Message_Block::rd_ptr
char * rd_ptr(void) const
CORBA::ULong
ACE_CDR::ULong ULong

◆ operator!=()

bool OpenDDS::RTPS::operator!= ( const DCPS::Locator_t &  x,
const DCPS::Locator_t &  y 
)

Definition at line 3726 of file Spdp.cpp.

References OpenDDS::DCPS::Locator_t::address, and OpenDDS::DCPS::Locator_t::kind.

3727 {
3728  return x.kind != y.kind && x.port != y.port && x.address != y.address;
3729 }

◆ operator<()

bool OpenDDS::RTPS::operator< ( const ProtocolVersion_t &  v1,
const ProtocolVersion_t &  v2 
)
inline

Definition at line 167 of file BaseMessageUtils.h.

References OpenDDS::RTPS::ProtocolVersion_t::major, OpenDDS::RTPS::ProtocolVersion_t::minor, OpenDDS_Rtps_Export, and rtps_duration_to_time_duration().

168 {
169  return (v1.major < v2.major || (v1.major == v2.major && v1.minor < v2.minor));
170 }

◆ operator==() [1/4]

bool OpenDDS::RTPS::operator== ( const StatusInfo_t &  lhs,
const StatusInfo_t &  rhs 
)
inline

Definition at line 46 of file RtpsSampleHeader.cpp.

References OpenDDS::RTPS::StatusInfo_t::value.

47 {
48  return
49  (lhs.value[3] == rhs.value[3]) &&
50  (lhs.value[2] == rhs.value[2]) &&
51  (lhs.value[1] == rhs.value[1]) &&
52  (lhs.value[0] == rhs.value[0]);
53 }

◆ operator==() [2/4]

bool OpenDDS::RTPS::operator== ( const Duration_t &  x,
const Duration_t &  y 
)
inline

Definition at line 155 of file BaseMessageUtils.h.

References OpenDDS::RTPS::Duration_t::fraction, and OpenDDS::RTPS::Duration_t::seconds.

156 {
157  return x.seconds == y.seconds && x.fraction == y.fraction;
158 }

◆ operator==() [3/4]

bool OpenDDS::RTPS::operator== ( const VendorId_t &  v1,
const VendorId_t &  v2 
)
inline

Definition at line 160 of file BaseMessageUtils.h.

References OpenDDS::RTPS::VendorId_t::vendorId.

161 {
162  return (v1.vendorId[0] == v2.vendorId[0] && v1.vendorId[1] == v2.vendorId[1]);
163 }

◆ operator==() [4/4]

bool OpenDDS::RTPS::operator== ( const DCPS::Locator_t &  x,
const DCPS::Locator_t &  y 
)

Definition at line 3720 of file Spdp.cpp.

References OpenDDS::DCPS::Locator_t::address, and OpenDDS::DCPS::Locator_t::kind.

3721 {
3722  return x.kind == y.kind && x.port == y.port && x.address == y.address;
3723 }

◆ parse_submessages()

OpenDDS_Rtps_Export void OpenDDS::RTPS::parse_submessages ( Message &  message,
const ACE_Message_Block &  mb 
)

Definition at line 62 of file RTPS/Logging.cpp.

References ACE_ERROR, ACE_TEXT(), append_submessage(), DATA, DATA_FRAG, INFO_DST, INFO_TS, LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::RTPS::MessageParser::parseSubmessageHeader(), OpenDDS::RTPS::MessageParser::serializer(), OpenDDS::RTPS::MessageParser::skipToNextSubmessage(), OpenDDS::RTPS::MessageParser::submessageHeader(), and OpenDDS::RTPS::SubmessageHeader::submessageId.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::durability_resend().

64 {
65  MessageParser mp(mb);
66  DCPS::Serializer& ser = mp.serializer();
67 
68  while (mp.parseSubmessageHeader()) {
69  switch (mp.submessageHeader().submessageId) {
70  case RTPS::INFO_DST: {
71  RTPS::InfoDestinationSubmessage sm;
72  ser >> sm;
73  append_submessage(message, sm);
74  break;
75  }
76  case RTPS::INFO_TS: {
77  RTPS::InfoTimestampSubmessage sm;
78  ser >> sm;
79  append_submessage(message, sm);
80  break;
81  }
82  case RTPS::DATA: {
83  RTPS::DataSubmessage sm;
84  ser >> sm;
85  append_submessage(message, sm);
86  break;
87  }
88  case RTPS::DATA_FRAG: {
89  RTPS::DataFragSubmessage sm;
90  ser >> sm;
91  append_submessage(message, sm);
92  break;
93  }
94  default:
95  ACE_ERROR((LM_ERROR,
96  ACE_TEXT("(%P|%t) ERROR: parse_submessages() - ")
97  ACE_TEXT("unhandle submessageId %d\n"), mp.submessageHeader().submessageId));
98  break;
99  }
100  mp.skipToNextSubmessage();
101  }
102 }
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::RTPS::append_submessage
void append_submessage(RTPS::Message &message, const RTPS::InfoDestinationSubmessage &submessage)
Definition: BaseMessageUtils.h:226
ACE_TEXT
ACE_TEXT("TCP_Factory")

◆ populate_locators()

void OpenDDS::RTPS::populate_locators ( DCPS::TransportLocatorSeq &  remote_data,
const ParticipantData_t &  pdata 
)

Definition at line 915 of file Sedp.cpp.

References OpenDDS::DCPS::boolean_cdr_size, OpenDDS::STUN::encoding(), get_locators_encoding(), message_block_to_sequence(), OpenDDS::RTPS::ParticipantProxy_t::metatrafficMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::metatrafficUnicastLocatorList, OpenDDS::Security::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::DCPS::serialized_size(), and OpenDDS::DCPS::uint32_cdr_size.

Referenced by create_association_data_proto(), and OpenDDS::RTPS::Sedp::update_locators().

917 {
918  const DCPS::LocatorSeq& mll =
919  pdata.participantProxy.metatrafficMulticastLocatorList;
920  const DCPS::LocatorSeq& ull =
921  pdata.participantProxy.metatrafficUnicastLocatorList;
922  const CORBA::ULong locator_count = mll.length() + ull.length();
923 
924  const Encoding& encoding = get_locators_encoding();
925  ACE_Message_Block mb_locator(
926  DCPS::uint32_cdr_size +
927  (locator_count * serialized_size(encoding, DCPS::Locator_t())) + DCPS::boolean_cdr_size);
928  Serializer ser_loc(&mb_locator, encoding);
929  ser_loc << locator_count;
930 
931  for (CORBA::ULong i = 0; i < mll.length(); ++i) {
932  ser_loc << mll[i];
933  }
934  for (CORBA::ULong i = 0; i < ull.length(); ++i) {
935  ser_loc << ull[i];
936  }
937  ser_loc << ACE_OutputCDR::from_boolean(false); // requires_inline_qos
938 
939  remote_data.length(1);
940  remote_data[0].transport_type = "rtps_udp";
941  message_block_to_sequence (mb_locator, remote_data[0].data);
942 }
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
OpenDDS::DCPS::serialized_size
void serialized_size(const Encoding &encoding, size_t &size, const XTypes::TypeLookup_getTypes_In &stru)
Definition: TypeLookup.cpp:13
OpenDDS::DCPS::uint32_cdr_size
const size_t uint32_cdr_size
Definition: Serializer.h:84
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: BaseMessageUtils.cpp:58
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: DdsDcpsInfoUtils.idl:97
OpenDDS::DCPS::boolean_cdr_size
const size_t boolean_cdr_size
Definition: Serializer.h:77
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::message_block_to_sequence
void message_block_to_sequence(const ACE_Message_Block &mb_locator, T &out)
Definition: BaseMessageUtils.h:147

◆ rtps_duration_to_time_duration()

OpenDDS_Rtps_Export DCPS::TimeDuration OpenDDS::RTPS::rtps_duration_to_time_duration ( const Duration_t &  rtps_duration,
const ProtocolVersion_t &  version,
const VendorId_t &  vendor 
)

Definition at line 204 of file BaseMessageUtils.cpp.

References DURATION_INFINITE, OpenDDS::RTPS::Duration_t::fraction, OpenDDS::DCPS::TimeDuration::max_value, PROTOCOLVERSION_2_4, OpenDDS::RTPS::Duration_t::seconds, OpenDDS::DCPS::uint32_fractional_seconds_to_microseconds(), and VENDORID_OPENDDS.

Referenced by operator<(), OpenDDS::RTPS::Spdp::process_location_updates_i(), and OpenDDS::RTPS::Spdp::update_lease_expiration_i().

205 {
206  if (rtps_duration == DURATION_INFINITE) {
207  return DCPS::TimeDuration::max_value;
208  }
209 
210  if (version < PROTOCOLVERSION_2_4 && vendor == VENDORID_OPENDDS) {
211  return OpenDDS::DCPS::TimeDuration(
212  rtps_duration.seconds,
213  static_cast<ACE_UINT32>(rtps_duration.fraction / 1000));
214  } else {
215  return OpenDDS::DCPS::TimeDuration(
216  rtps_duration.seconds,
217  DCPS::uint32_fractional_seconds_to_microseconds(rtps_duration.fraction));
218  }
219 }
OpenDDS::RTPS::DURATION_INFINITE
const Duration_t DURATION_INFINITE
Definition: BaseMessageTypes.h:23
OpenDDS::DCPS::uint32_fractional_seconds_to_microseconds
ACE_INLINE OpenDDS_Dcps_Export ACE_UINT32 uint32_fractional_seconds_to_microseconds(ACE_UINT32 fraction)
Definition: Time_Helper.inl:259
OpenDDS::RTPS::VENDORID_OPENDDS
const VendorId_t VENDORID_OPENDDS
Definition: BaseMessageTypes.h:26
OpenDDS::RTPS::PROTOCOLVERSION_2_4
const ProtocolVersion_t PROTOCOLVERSION_2_4
Definition: BaseMessageTypes.h:66

◆ security_attributes_to_bitmask() [1/2]

DDS::Security::ParticipantSecurityAttributesMask OpenDDS::RTPS::security_attributes_to_bitmask ( const DDS::Security::ParticipantSecurityAttributes &  sec_attr)
inline

Definition at line 52 of file SecurityHelpers.h.

References DDS::Security::ParticipantSecurityAttributes::is_discovery_protected, DDS::Security::ParticipantSecurityAttributes::is_liveliness_protected, DDS::Security::ParticipantSecurityAttributes::is_rtps_protected, DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED, DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED, DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_RTPS_PROTECTED, and DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID.

Referenced by OpenDDS::RTPS::Spdp::build_local_pdata(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::check_encoded(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::decode_payload(), OpenDDS::RTPS::Sedp::write_publication_data_secure(), and OpenDDS::RTPS::Sedp::write_subscription_data_secure().

53 {
54  using namespace DDS::Security;
55 
56  ParticipantSecurityAttributesMask result = PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID;
57  if (sec_attr.is_rtps_protected) {
58  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_RTPS_PROTECTED;
59  }
60  if (sec_attr.is_discovery_protected) {
61  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED;
62  }
63  if (sec_attr.is_liveliness_protected) {
64  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED;
65  }
66  return result;
67 }
DDS::Security::ParticipantSecurityAttributesMask
unsigned long ParticipantSecurityAttributesMask
Definition: DdsSecurityParams.idl:58
DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
Definition: DdsSecurityParams.idl:63
DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_RTPS_PROTECTED
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_RTPS_PROTECTED
Definition: DdsSecurityParams.idl:60
DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
Definition: DdsSecurityParams.idl:61
DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
Definition: DdsSecurityParams.idl:62

◆ security_attributes_to_bitmask() [2/2]

DDS::Security::EndpointSecurityAttributesMask OpenDDS::RTPS::security_attributes_to_bitmask ( const DDS::Security::EndpointSecurityAttributes &  sec_attr)
inline

Definition at line 70 of file SecurityHelpers.h.

References DDS::Security::EndpointSecurityAttributes::base, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_READ_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID, DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_WRITE_PROTECTED, DDS::Security::TopicSecurityAttributes::is_discovery_protected, DDS::Security::EndpointSecurityAttributes::is_key_protected, DDS::Security::TopicSecurityAttributes::is_liveliness_protected, DDS::Security::EndpointSecurityAttributes::is_payload_protected, DDS::Security::TopicSecurityAttributes::is_read_protected, DDS::Security::EndpointSecurityAttributes::is_submessage_protected, and DDS::Security::TopicSecurityAttributes::is_write_protected.

71 {
72  using namespace DDS::Security;
73 
74  EndpointSecurityAttributesMask result = ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID;
75 
76  if (sec_attr.base.is_read_protected)
77  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_READ_PROTECTED;
78 
79  if (sec_attr.base.is_write_protected)
80  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_WRITE_PROTECTED;
81 
82  if (sec_attr.base.is_discovery_protected)
83  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED;
84 
85  if (sec_attr.base.is_liveliness_protected)
86  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED;
87 
88  if (sec_attr.is_submessage_protected)
89  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED;
90 
91  if (sec_attr.is_payload_protected)
92  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED;
93 
94  if (sec_attr.is_key_protected)
95  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED;
96 
97  return result;
98 }
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_WRITE_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_WRITE_PROTECTED
Definition: DdsSecurityParams.idl:85
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
Definition: DdsSecurityParams.idl:86
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED
Definition: DdsSecurityParams.idl:88
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
Definition: DdsSecurityParams.idl:91
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_READ_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_READ_PROTECTED
Definition: DdsSecurityParams.idl:84
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED
Definition: DdsSecurityParams.idl:87
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
Definition: DdsSecurityParams.idl:90
DDS::Security::EndpointSecurityAttributesMask
unsigned long EndpointSecurityAttributesMask
Definition: DdsSecurityParams.idl:81
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED
Definition: DdsSecurityParams.idl:89

◆ to_opendds_seqnum()

DCPS::SequenceNumber OpenDDS::RTPS::to_opendds_seqnum ( const RTPS::SequenceNumber_t &  rtps_seqnum)
inline

Definition at line 211 of file BaseMessageUtils.h.

References OpenDDS::RTPS::SequenceNumber_t::high, OpenDDS::RTPS::SequenceNumber_t::low, and OpenDDS::DCPS::SequenceNumber::setValue().

Referenced by OpenDDS::RTPS::Spdp::data_received(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_gaps_i(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_data_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_gap_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_heartbeat_frag_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_heartbeat_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_nackfrag(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::process_type_lookup_reply(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::process_type_lookup_request(), and OpenDDS::RTPS::Sedp::TypeLookupReplyWriter::send_type_lookup_reply().

212 {
213  DCPS::SequenceNumber opendds_seqnum;
214  opendds_seqnum.setValue(rtps_seqnum.high, rtps_seqnum.low);
215  return opendds_seqnum;
216 }

◆ to_rtps_seqnum()

RTPS::SequenceNumber_t OpenDDS::RTPS::to_rtps_seqnum ( const DCPS::SequenceNumber &  opendds_seqnum)
inline

Definition at line 218 of file BaseMessageUtils.h.

References OpenDDS::DCPS::SequenceNumber::getHigh(), OpenDDS::DCPS::SequenceNumber::getLow(), OpenDDS::RTPS::SequenceNumber_t::high, and OpenDDS::RTPS::SequenceNumber_t::low.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::add_gap_submsg_i(), OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::gather_ack_nacks_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_directed_heartbeat_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_gaps_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_heartbeats_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::generate_nack_frags_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::initialize_heartbeat(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::send_heartbeats_manual_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_interesting_ack_nack(), OpenDDS::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

219 {
220  RTPS::SequenceNumber_t rtps_seqnum;
221  rtps_seqnum.high = opendds_seqnum.getHigh();
222  rtps_seqnum.low = opendds_seqnum.getLow();
223  return rtps_seqnum;
224 }

◆ transport_locator_to_locator_seq()

OpenDDS_Rtps_Export DCPS::LocatorSeq OpenDDS::RTPS::transport_locator_to_locator_seq ( const DCPS::TransportLocator &  info)

Definition at line 129 of file BaseMessageUtils.cpp.

References blob_to_locators(), and OpenDDS::DCPS::TransportLocator::data.

Referenced by address_to_kind(), OpenDDS::RTPS::Sedp::multicast_locators(), and OpenDDS::RTPS::Sedp::unicast_locators().

130 {
131  DCPS::LocatorSeq locators;
132  blob_to_locators(info.data, locators);
133  return locators;
134 }
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: DdsDcpsInfoUtils.idl:97
OpenDDS::RTPS::blob_to_locators
DDS::ReturnCode_t blob_to_locators(const DCPS::TransportBLOB &blob, DCPS::LocatorSeq &locators, bool *requires_inline_qos, unsigned int *pBytesRead)
Definition: BaseMessageUtils.cpp:64

Variable Documentation

◆ BEST_EFFORT

const short OpenDDS::RTPS::BEST_EFFORT = 1

Definition at line 140 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::DCPS::RtpsSampleHeader::populate_inline_qos(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

◆ BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER

const BuiltinEndpointQos_t OpenDDS::RTPS::BEST_EFFORT_PARTICIPANT_MESSAGE_DATA_READER
Initial value:
=
1 << 0

Definition at line 231 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::associate_secure_endpoints(), and OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader().

◆ BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER
Initial value:
=
1 << 11

Definition at line 218 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER
Initial value:
=
1 << 10

Definition at line 216 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Sedp::signal_liveliness_unsecure(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), OpenDDS::RTPS::Sedp::write_durable_participant_message_data(), and OpenDDS::RTPS::Sedp::write_participant_message_data().

◆ BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_READER
Initial value:
=
1 << 15

Definition at line 227 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REPLY_DATA_WRITER
Initial value:
=
1 << 14

Definition at line 225 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_READER
Initial value:
=
1 << 13

Definition at line 223 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_TYPE_LOOKUP_REQUEST_DATA_WRITER
Initial value:
=
1 << 12

Definition at line 221 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ DATA_FRAG_OCTETS_TO_IQOS

const ACE_CDR::UShort OpenDDS::RTPS::DATA_FRAG_OCTETS_TO_IQOS = 28

Definition at line 20 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::split().

◆ DATA_OCTETS_TO_IQOS

const ACE_CDR::UShort OpenDDS::RTPS::DATA_OCTETS_TO_IQOS = 16

Definition at line 19 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble_i(), and OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport().

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_ANNOUNCER

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_ANNOUNCER
Initial value:
=
1 << 0

Definition at line 196 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::handle_participant_data(), OpenDDS::RTPS::Spdp::init(), and OpenDDS::RTPS::Sedp::update_locators().

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_DETECTOR

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_DETECTOR
Initial value:
=
1 << 1

Definition at line 198 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::handle_participant_data(), OpenDDS::RTPS::Spdp::init(), and OpenDDS::RTPS::Sedp::update_locators().

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_ANNOUNCER

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_ANNOUNCER
Initial value:
=
1 << 6

Definition at line 208 of file RtpsCore.idl.

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_DETECTOR

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_DETECTOR
Initial value:
=
1 << 7

Definition at line 210 of file RtpsCore.idl.

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_ANNOUNCER

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_ANNOUNCER
Initial value:
=
1 << 8

Definition at line 212 of file RtpsCore.idl.

◆ DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_DETECTOR

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_DETECTOR
Initial value:
=
1 << 9

Definition at line 214 of file RtpsCore.idl.

◆ DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER
Initial value:
=
1 << 2

Definition at line 200 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), OpenDDS::RTPS::Sedp::write_durable_publication_data(), and OpenDDS::RTPS::Sedp::write_publication_data_unsecure().

◆ DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR
Initial value:
=
1 << 3

Definition at line 202 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER
Initial value:
=
1 << 4

Definition at line 204 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::init(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), OpenDDS::RTPS::Sedp::write_durable_subscription_data(), and OpenDDS::RTPS::Sedp::write_subscription_data_unsecure().

◆ DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR
Initial value:
=
1 << 5

Definition at line 206 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Spdp::init(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ DURATION_INFINITE

const Duration_t OpenDDS::RTPS::DURATION_INFINITE = { 0x7fffffff, 0xffffffffu }

Definition at line 23 of file BaseMessageTypes.h.

Referenced by rtps_duration_to_time_duration().

◆ DURATION_ZERO

const Duration_t OpenDDS::RTPS::DURATION_ZERO = { 0, 0u }

Definition at line 22 of file BaseMessageTypes.h.

◆ ENDPOINT_SECURITY_ATTRIBUTES_INFO_DEFAULT

const DDS::Security::EndpointSecurityInfo OpenDDS::RTPS::ENDPOINT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}

Definition at line 49 of file SecurityHelpers.h.

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_READER = {{0xff, 0x02, 0x00}, 0xc7}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 34 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER = {{0xff, 0x02, 0x00}, 0xc2}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 33 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::LivelinessReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_READER = {{0x00, 0x02, 0x01}, 0xc4}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 36 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_preauth(), OpenDDS::RTPS::Spdp::attempt_authentication(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Spdp::handle_handshake_message(), OpenDDS::RTPS::Spdp::process_handshake_resends(), OpenDDS::RTPS::Spdp::send_handshake_message(), OpenDDS::DCPS::RtpsUdpDataLink::separate_message(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER = {{0x00, 0x02, 0x01}, 0xc3}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 35 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_preauth(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::SecurityReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::DCPS::RtpsUdpSendStrategy::encode_rtps_message(), OpenDDS::DCPS::RtpsUdpDataLink::separate_message(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_READER = {{0xff, 0x02, 0x02}, 0xc4}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 38 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_volatile(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::cleanup_volatile_crypto(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::disassociate_volatile(), OpenDDS::RTPS::Sedp::send_datareader_crypto_tokens(), OpenDDS::RTPS::Sedp::send_datawriter_crypto_tokens(), OpenDDS::RTPS::Spdp::send_participant_crypto_tokens(), OpenDDS::DCPS::RtpsUdpDataLink::separate_message(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER = {{0xff, 0x02, 0x02}, 0xc3}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 37 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_volatile(), OpenDDS::RTPS::Sedp::cleanup_volatile_crypto(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::SecurityReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::disassociate_volatile(), OpenDDS::DCPS::RtpsUdpSendStrategy::encode_rtps_message(), OpenDDS::RTPS::Sedp::send_datareader_crypto_tokens(), OpenDDS::RTPS::Sedp::send_datawriter_crypto_tokens(), OpenDDS::RTPS::Spdp::send_participant_crypto_tokens(), OpenDDS::DCPS::RtpsUdpDataLink::separate_message(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_READER = {{0xff, 0x00, 0x03}, 0xc7}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 30 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), and OpenDDS::RTPS::Sedp::write_publication_data_secure().

◆ ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER = {{0xff, 0x00, 0x03}, 0xc2}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 29 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_READER = {{0xff, 0x00, 0x04}, 0xc7}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 32 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), and OpenDDS::RTPS::Sedp::write_subscription_data_secure().

◆ ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER = {{0xff, 0x00, 0x04}, 0xc2}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 31 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER

const EntityId_t OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_READER = {{0xff, 0x01, 0x01}, 0xc7}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 40 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), OpenDDS::RTPS::Sedp::update_locators(), and OpenDDS::RTPS::Sedp::write_dcps_participant_secure().

◆ ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER

const EntityId_t OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER = {{0xff, 0x01, 0x01}, 0xc2}

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 39 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_TL_SVC_REPLY_READER_SECURE

const EntityId_t OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_READER_SECURE = {{0xff, 0x03, 0x01}, 0xc4 }

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 45 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_TL_SVC_REPLY_WRITER_SECURE

const EntityId_t OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_WRITER_SECURE = {{0xff, 0x03, 0x01}, 0xc3 }

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 44 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_TL_SVC_REQ_READER_SECURE

const EntityId_t OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_READER_SECURE = {{0xff, 0x03, 0x00}, 0xc4 }

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 43 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_writer_to_reader(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Sedp::send_type_lookup_request(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ ENTITYID_TL_SVC_REQ_WRITER_SECURE

const EntityId_t OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE = {{0xff, 0x03, 0x00}, 0xc3 }

The below entities are from the security spec. V1.1 section 7.3.7.1 "Mapping of the EntityIds for the Builtin DataWriters and DataReaders"

Definition at line 42 of file SecurityHelpers.h.

Referenced by OpenDDS::RTPS::Sedp::associate_secure_endpoints(), OpenDDS::RTPS::Sedp::associate_secure_reader_to_writer(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::disassociate_security_builtins(), OpenDDS::RTPS::Sedp::generate_remote_crypto_handles(), OpenDDS::RTPS::Sedp::send_builtin_crypto_tokens(), OpenDDS::RTPS::Spdp::start_ice(), OpenDDS::RTPS::Spdp::stop_ice(), and OpenDDS::RTPS::Sedp::update_locators().

◆ FLAG_D

const octet OpenDDS::RTPS::FLAG_D = 4

Definition at line 522 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::RtpsSampleHeader::init(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble_i(), OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ FLAG_E

const octet OpenDDS::RTPS::FLAG_E = 1

Definition at line 517 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::add_gap_submsg_i(), OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), OpenDDS::DCPS::RtpsUdpDataLink::bundle_mapped_meta_submessages(), OpenDDS::Security::CryptoBuiltInImpl::decode_submessage(), OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::gather_ack_nacks_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_gaps_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::gather_preassociation_acknack_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::generate_nack_frags_i(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::RtpsSampleHeader::init(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::initialize_heartbeat(), OpenDDS::RTPS::MessageParser::parseSubmessageHeader(), OpenDDS::DCPS::RtpsSampleHeader::payload_byte_order(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::send_heartbeats_manual_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_interesting_ack_nack(), OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport(), OpenDDS::DCPS::RtpsSampleHeader::split(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

◆ FLAG_F

const octet OpenDDS::RTPS::FLAG_F = 2

Definition at line 519 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::gather_ack_nacks_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_nack_replies_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_heartbeat_frag_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsReader::process_heartbeat_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::send_heartbeats_manual_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i(), and OpenDDS::DCPS::RtpsUdpDataLink::send_interesting_ack_nack().

◆ FLAG_I

const octet OpenDDS::RTPS::FLAG_I = 2

Definition at line 520 of file RtpsCore.idl.

◆ FLAG_K_IN_DATA

const octet OpenDDS::RTPS::FLAG_K_IN_DATA = 8

Definition at line 525 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::RtpsSampleHeader::init(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::reassemble_i(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ FLAG_K_IN_FRAG

const octet OpenDDS::RTPS::FLAG_K_IN_FRAG = 4

Definition at line 524 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ FLAG_L

const octet OpenDDS::RTPS::FLAG_L = 4

Definition at line 523 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::deliver_sample_i(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::send_heartbeats_manual_i(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i().

◆ FLAG_M

const octet OpenDDS::RTPS::FLAG_M = 2

Definition at line 521 of file RtpsCore.idl.

◆ FLAG_N_IN_DATA

const octet OpenDDS::RTPS::FLAG_N_IN_DATA = 16

Definition at line 527 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpSendStrategy::encode_payload(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ FLAG_N_IN_FRAG

const octet OpenDDS::RTPS::FLAG_N_IN_FRAG = 8

Definition at line 526 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::split().

◆ FLAG_Q

const octet OpenDDS::RTPS::FLAG_Q = 2

Definition at line 518 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::DCPS::RtpsUdpSendStrategy::encode_payload(), OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ HEARTBEAT_SZ

const ACE_CDR::UShort OpenDDS::RTPS::HEARTBEAT_SZ = 28

Definition at line 24 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::initialize_heartbeat(), OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::send_heartbeats_manual_i(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i().

◆ ICE_FULL

const IceAgentType_t OpenDDS::RTPS::ICE_FULL = 0x0

Definition at line 171 of file RtpsCore.idl.

◆ ICE_HOST

const IceCandidateType_t OpenDDS::RTPS::ICE_HOST = 0x0

Definition at line 182 of file RtpsCore.idl.

◆ ICE_LITE

const IceAgentType_t OpenDDS::RTPS::ICE_LITE = 0x1

Definition at line 172 of file RtpsCore.idl.

◆ ICE_PEER_REFLEXIVE

const IceCandidateType_t OpenDDS::RTPS::ICE_PEER_REFLEXIVE = 0x2

Definition at line 184 of file RtpsCore.idl.

◆ ICE_RELAYED

const IceCandidateType_t OpenDDS::RTPS::ICE_RELAYED = 0x3

Definition at line 185 of file RtpsCore.idl.

◆ ICE_SERVER_REFLEXIVE

const IceCandidateType_t OpenDDS::RTPS::ICE_SERVER_REFLEXIVE = 0x1

Definition at line 183 of file RtpsCore.idl.

◆ INFO_DST_SZ

const ACE_CDR::UShort OpenDDS::RTPS::INFO_DST_SZ = 12

Definition at line 25 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), OpenDDS::DCPS::RtpsUdpDataLink::bundle_mapped_meta_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages().

◆ INFO_SRC_SZ

const ACE_CDR::UShort OpenDDS::RTPS::INFO_SRC_SZ = 20

Definition at line 27 of file MessageTypes.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::Security::CryptoBuiltInImpl::encode_rtps_message().

◆ INFO_TS_SZ

const ACE_CDR::UShort OpenDDS::RTPS::INFO_TS_SZ = 8

Definition at line 26 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::payload_byte_order().

◆ initialize_rtps

RtpsDiscovery::StaticInitializer OpenDDS::RTPS::initialize_rtps
static

Definition at line 797 of file RtpsDiscovery.h.

◆ LOCATOR_ADDRESS_INVALID

const OpenDDS::DCPS::OctetArray16 OpenDDS::RTPS::LOCATOR_ADDRESS_INVALID = { 0 }

Definition at line 54 of file BaseMessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset().

◆ LOCATOR_INVALID

const OpenDDS::DCPS::Locator_t OpenDDS::RTPS::LOCATOR_INVALID
Initial value:
=
{ LOCATOR_KIND_INVALID, LOCATOR_PORT_INVALID, { 0 } }
OpenDDS::RTPS::LOCATOR_PORT_INVALID
const unsigned long LOCATOR_PORT_INVALID
Definition: RtpsCore.idl:111
OpenDDS::RTPS::LOCATOR_KIND_INVALID
const long LOCATOR_KIND_INVALID
Definition: RtpsCore.idl:107

Definition at line 52 of file BaseMessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg().

◆ LOCATOR_KIND_INVALID

const long OpenDDS::RTPS::LOCATOR_KIND_INVALID = -1

Definition at line 107 of file RtpsCore.idl.

◆ LOCATOR_KIND_RESERVED

const long OpenDDS::RTPS::LOCATOR_KIND_RESERVED = 0

Definition at line 108 of file RtpsCore.idl.

◆ LOCATOR_KIND_UDPv4

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv4 = 1

Definition at line 109 of file RtpsCore.idl.

Referenced by address_to_kind(), OpenDDS::RTPS::Spdp::build_local_pdata(), locator_to_address(), and OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg().

◆ LOCATOR_KIND_UDPv6

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv6 = 2

Definition at line 110 of file RtpsCore.idl.

Referenced by address_to_kind(), and locator_to_address().

◆ LOCATOR_PORT_INVALID

const unsigned long OpenDDS::RTPS::LOCATOR_PORT_INVALID = 0

Definition at line 111 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset().

◆ LOCATORUDPv4_INVALID

const LocatorUDPv4_t OpenDDS::RTPS::LOCATORUDPv4_INVALID = { 0, 0 }

Definition at line 56 of file BaseMessageTypes.h.

◆ NO_KEY

const short OpenDDS::RTPS::NO_KEY = 1

Definition at line 130 of file RtpsCore.idl.

◆ PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE

const DCPS::EntityId_t OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE
Initial value:
=
{{0x00, 0x00, 0x00}, 0x01}

Definition at line 34 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::signal_liveliness_secure(), and OpenDDS::RTPS::Sedp::signal_liveliness_unsecure().

◆ PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE

const DCPS::EntityId_t OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE
Initial value:
=
{{0x00, 0x00, 0x00}, 0x02}

Definition at line 36 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::signal_liveliness_secure(), and OpenDDS::RTPS::Sedp::signal_liveliness_unsecure().

◆ PARTICIPANT_MESSAGE_DATA_KIND_UNKNOWN

const DCPS::EntityId_t OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_UNKNOWN
Initial value:
=
{{0x00, 0x00, 0x00}, 0x00}

Definition at line 32 of file MessageTypes.h.

◆ PARTICIPANT_SECURITY_ATTRIBUTES_INFO_DEFAULT

const DDS::Security::ParticipantSecurityInfo OpenDDS::RTPS::PARTICIPANT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}

Definition at line 48 of file SecurityHelpers.h.

◆ PFLAGS_DIRECTED_HEARTBEAT

const OpenDDSParticipantFlagsBits_t OpenDDS::RTPS::PFLAGS_DIRECTED_HEARTBEAT = 0x2

Definition at line 321 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo::sends_directed_hb().

◆ PFLAGS_EMPTY

const OpenDDSParticipantFlagsBits_t OpenDDS::RTPS::PFLAGS_EMPTY = 0x0

Definition at line 319 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::get_participant_flags().

◆ PFLAGS_NO_ASSOCIATED_WRITERS

const OpenDDSParticipantFlagsBits_t OpenDDS::RTPS::PFLAGS_NO_ASSOCIATED_WRITERS = 0x1

Definition at line 320 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::is_expectant_opendds().

◆ PFLAGS_REFLECT_HEARTBEAT_COUNT

const OpenDDSParticipantFlagsBits_t OpenDDS::RTPS::PFLAGS_REFLECT_HEARTBEAT_COUNT = 0x4

Definition at line 323 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::init(), and OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::reflects_heartbeat_count().

◆ PFLAGS_THIS_VERSION

const OpenDDSParticipantFlagsBits_t OpenDDS::RTPS::PFLAGS_THIS_VERSION = PFLAGS_DIRECTED_HEARTBEAT | PFLAGS_NO_ASSOCIATED_WRITERS

Definition at line 324 of file RtpsCore.idl.

◆ PID_BUILTIN_ENDPOINT_QOS

const ParameterId_t OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_QOS = 0x0077

Definition at line 316 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_BUILTIN_ENDPOINT_SET

const ParameterId_t OpenDDS::RTPS::PID_BUILTIN_ENDPOINT_SET = 0x0058

Definition at line 288 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_COHERENT_SET

const ParameterId_t OpenDDS::RTPS::PID_COHERENT_SET = 0x0056

Definition at line 298 of file RtpsCore.idl.

◆ PID_CONTENT_FILTER_INFO

const ParameterId_t OpenDDS::RTPS::PID_CONTENT_FILTER_INFO = 0x0055

Definition at line 297 of file RtpsCore.idl.

◆ PID_CONTENT_FILTER_PROPERTY

const ParameterId_t OpenDDS::RTPS::PID_CONTENT_FILTER_PROPERTY = 0x0035

Definition at line 285 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DATA_REPRESENTATION

const ParameterId_t OpenDDS::RTPS::PID_DATA_REPRESENTATION = 0x0073

Definition at line 301 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DEADLINE

const ParameterId_t OpenDDS::RTPS::PID_DEADLINE = 0x0023

Definition at line 259 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DEFAULT_MULTICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_DEFAULT_MULTICAST_LOCATOR = 0x0048

Definition at line 278 of file RtpsCore.idl.

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

◆ PID_DEFAULT_UNICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_DEFAULT_UNICAST_LOCATOR = 0x0031

Definition at line 277 of file RtpsCore.idl.

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

◆ PID_DESTINATION_ORDER

const ParameterId_t OpenDDS::RTPS::PID_DESTINATION_ORDER = 0x0025

Definition at line 264 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DIRECTED_WRITE

const ParameterId_t OpenDDS::RTPS::PID_DIRECTED_WRITE = 0x0057

Definition at line 299 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::getDirectedWriteReaders().

◆ PID_DOMAIN_ID

const ParameterId_t OpenDDS::RTPS::PID_DOMAIN_ID = 0x000f

Definition at line 313 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DOMAIN_TAG

const ParameterId_t OpenDDS::RTPS::PID_DOMAIN_TAG = 0x4014

Definition at line 314 of file RtpsCore.idl.

◆ PID_DURABILITY

const ParameterId_t OpenDDS::RTPS::PID_DURABILITY = 0x001d

Definition at line 257 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_DURABILITY_SERVICE

const ParameterId_t OpenDDS::RTPS::PID_DURABILITY_SERVICE = 0x001e

Definition at line 258 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_ENDPOINT_GUID

const ParameterId_t OpenDDS::RTPS::PID_ENDPOINT_GUID = 0x005a

Definition at line 295 of file RtpsCore.idl.

Referenced by decode_parameter_list(), OpenDDS::RTPS::Sedp::DiscoveryWriter::DiscoveryWriter(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

◆ PID_ENTITY_NAME

const ParameterId_t OpenDDS::RTPS::PID_ENTITY_NAME = 0x0062

Definition at line 291 of file RtpsCore.idl.

◆ PID_EXPECTS_INLINE_QOS

const ParameterId_t OpenDDS::RTPS::PID_EXPECTS_INLINE_QOS = 0x0043

Definition at line 281 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_GROUP_DATA

const ParameterId_t OpenDDS::RTPS::PID_GROUP_DATA = 0x002d

Definition at line 255 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_GROUP_GUID

const ParameterId_t OpenDDS::RTPS::PID_GROUP_GUID = 0x0052

Definition at line 287 of file RtpsCore.idl.

◆ PID_HISTORY

const ParameterId_t OpenDDS::RTPS::PID_HISTORY = 0x0040

Definition at line 265 of file RtpsCore.idl.

◆ PID_KEY_HASH

const ParameterId_t OpenDDS::RTPS::PID_KEY_HASH = 0x0070

Definition at line 292 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::into_received_data_sample().

◆ PID_LATENCY_BUDGET

const ParameterId_t OpenDDS::RTPS::PID_LATENCY_BUDGET = 0x0027

Definition at line 260 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_LIFESPAN

const ParameterId_t OpenDDS::RTPS::PID_LIFESPAN = 0x002b

Definition at line 263 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_LIVELINESS

const ParameterId_t OpenDDS::RTPS::PID_LIVELINESS = 0x001b

Definition at line 261 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_METATRAFFIC_MULTICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_LOCATOR = 0x0033

Definition at line 280 of file RtpsCore.idl.

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

◆ PID_METATRAFFIC_UNICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_LOCATOR = 0x0032

Definition at line 279 of file RtpsCore.idl.

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

◆ PID_MULTICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_MULTICAST_LOCATOR = 0x0030

Definition at line 276 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OPENDDS_ASSOCIATED_WRITER

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_ASSOCIATED_WRITER = PID_OPENDDS_BASE + 2

Definition at line 337 of file RtpsCore.idl.

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

◆ PID_OPENDDS_BASE

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_BASE = PIDMASK_VENDOR_SPECIFIC + 0x3000

Definition at line 335 of file RtpsCore.idl.

◆ PID_OPENDDS_ICE_CANDIDATE

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_ICE_CANDIDATE = PID_OPENDDS_BASE + 4

Definition at line 339 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OPENDDS_ICE_GENERAL

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_ICE_GENERAL = PID_OPENDDS_BASE + 3

Definition at line 338 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OPENDDS_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_LOCATOR = PID_OPENDDS_BASE + 1

Definition at line 336 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OPENDDS_PARTICIPANT_FLAGS

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_PARTICIPANT_FLAGS = PID_OPENDDS_BASE + 5

Definition at line 340 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT

const ParameterId_t OpenDDS::RTPS::PID_OPENDDS_RTPS_RELAY_APPLICATION_PARTICIPANT = PID_OPENDDS_BASE + 6

Definition at line 341 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_ORIGINAL_WRITER_INFO

const ParameterId_t OpenDDS::RTPS::PID_ORIGINAL_WRITER_INFO = 0x0061

Definition at line 300 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

◆ PID_OWNERSHIP

const ParameterId_t OpenDDS::RTPS::PID_OWNERSHIP = 0x001f

Definition at line 267 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_OWNERSHIP_STRENGTH

const ParameterId_t OpenDDS::RTPS::PID_OWNERSHIP_STRENGTH = 0x0006

Definition at line 268 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PAD

const ParameterId_t OpenDDS::RTPS::PID_PAD = 0x0000

Definition at line 250 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PARTICIPANT_BUILTIN_ENDPOINTS

const ParameterId_t OpenDDS::RTPS::PID_PARTICIPANT_BUILTIN_ENDPOINTS = 0x0044

Definition at line 283 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PARTICIPANT_GUID

const ParameterId_t OpenDDS::RTPS::PID_PARTICIPANT_GUID = 0x0050

Definition at line 286 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::Security::extract_participant_guid_from_cpdata(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::RTPS::Spdp::handle_auth_request(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::RTPS::ParameterListConverter::to_param_list(), and OpenDDS::RTPS::Sedp::write_dcps_participant_dispose().

◆ PID_PARTICIPANT_LEASE_DURATION

const ParameterId_t OpenDDS::RTPS::PID_PARTICIPANT_LEASE_DURATION = 0x0002

Definition at line 284 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT

const ParameterId_t OpenDDS::RTPS::PID_PARTICIPANT_MANUAL_LIVELINESS_COUNT = 0x0034

Definition at line 282 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PARTITION

const ParameterId_t OpenDDS::RTPS::PID_PARTITION = 0x0029

Definition at line 270 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

◆ PID_PRESENTATION

const ParameterId_t OpenDDS::RTPS::PID_PRESENTATION = 0x0021

Definition at line 269 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

◆ PID_PROPERTY_LIST

const ParameterId_t OpenDDS::RTPS::PID_PROPERTY_LIST = 0x0059

Definition at line 289 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_PROTOCOL_VERSION

const ParameterId_t OpenDDS::RTPS::PID_PROTOCOL_VERSION = 0x0015

Definition at line 273 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_RELIABILITY

const ParameterId_t OpenDDS::RTPS::PID_RELIABILITY = 0x001a

Definition at line 262 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_RESOURCE_LIMITS

const ParameterId_t OpenDDS::RTPS::PID_RESOURCE_LIMITS = 0x0041

Definition at line 266 of file RtpsCore.idl.

◆ PID_SENTINEL

const ParameterId_t OpenDDS::RTPS::PID_SENTINEL = 0x0001

Definition at line 251 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_STATUS_INFO

const ParameterId_t OpenDDS::RTPS::PID_STATUS_INFO = 0x0071

Definition at line 293 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

◆ PID_TIME_BASED_FILTER

const ParameterId_t OpenDDS::RTPS::PID_TIME_BASED_FILTER = 0x0004

Definition at line 271 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_TOPIC_DATA

const ParameterId_t OpenDDS::RTPS::PID_TOPIC_DATA = 0x002e

Definition at line 256 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_TOPIC_NAME

const ParameterId_t OpenDDS::RTPS::PID_TOPIC_NAME = 0x0005

Definition at line 253 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::DCPS::RtpsSampleHeader::populate_inline_qos(), OpenDDS::DCPS::RtpsSampleHeader::process_iqos(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

◆ PID_TRANSPORT_PRIORITY

const ParameterId_t OpenDDS::RTPS::PID_TRANSPORT_PRIORITY = 0x0049

Definition at line 272 of file RtpsCore.idl.

◆ PID_TYPE_MAX_SIZE_SERIALIZED

const ParameterId_t OpenDDS::RTPS::PID_TYPE_MAX_SIZE_SERIALIZED = 0x0060

Definition at line 290 of file RtpsCore.idl.

◆ PID_TYPE_NAME

const ParameterId_t OpenDDS::RTPS::PID_TYPE_NAME = 0x0007

Definition at line 254 of file RtpsCore.idl.

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

◆ PID_UNICAST_LOCATOR

const ParameterId_t OpenDDS::RTPS::PID_UNICAST_LOCATOR = 0x002f

Definition at line 275 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_USER_DATA

const ParameterId_t OpenDDS::RTPS::PID_USER_DATA = 0x002c

Definition at line 252 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_VENDORID

const ParameterId_t OpenDDS::RTPS::PID_VENDORID = 0x0016

Definition at line 274 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_XTYPES_TYPE_CONSISTENCY

const ParameterId_t OpenDDS::RTPS::PID_XTYPES_TYPE_CONSISTENCY = 0x0074

Definition at line 304 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PID_XTYPES_TYPE_INFORMATION

const ParameterId_t OpenDDS::RTPS::PID_XTYPES_TYPE_INFORMATION = 0x0075

Definition at line 307 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PIDMASK_INCOMPATIBLE

const ParameterId_t OpenDDS::RTPS::PIDMASK_INCOMPATIBLE = 0x4000

Definition at line 311 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list().

◆ PIDMASK_VENDOR_SPECIFIC

const ParameterId_t OpenDDS::RTPS::PIDMASK_VENDOR_SPECIFIC = 0x8000

Definition at line 310 of file RtpsCore.idl.

◆ PROTOCOL_RTPS

const ACE_CDR::Octet OpenDDS::RTPS::PROTOCOL_RTPS[] = {'R', 'T', 'P', 'S'}

Definition at line 58 of file BaseMessageTypes.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), OpenDDS::DCPS::RtpsTransportHeader::init(), and OpenDDS::DCPS::RtpsUdpSendStrategy::RtpsUdpSendStrategy().

◆ PROTOCOLVERSION

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION = PROTOCOLVERSION_2_4

Definition at line 67 of file BaseMessageTypes.h.

Referenced by OpenDDS::RTPS::Spdp::build_local_pdata(), OpenDDS::DCPS::RtpsTransportHeader::init(), OpenDDS::DCPS::RtpsUdpSendStrategy::RtpsUdpSendStrategy(), and OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport().

◆ PROTOCOLVERSION_1_0

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_1_0 = { 1, 0 }

Definition at line 60 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_1_1

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_1_1 = { 1, 1 }

Definition at line 61 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_2_0

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_2_0 = { 2, 0 }

Definition at line 62 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_2_1

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_2_1 = { 2, 1 }

Definition at line 63 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_2_2

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_2_2 = { 2, 2 }

Definition at line 64 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_2_3

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_2_3 = { 2, 3 }

Definition at line 65 of file BaseMessageTypes.h.

◆ PROTOCOLVERSION_2_4

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION_2_4 = { 2, 4 }

Definition at line 66 of file BaseMessageTypes.h.

Referenced by rtps_duration_to_time_duration().

◆ RELIABLE

const short OpenDDS::RTPS::RELIABLE = 2

Definition at line 141 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::DCPS::RtpsSampleHeader::populate_inline_qos(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

◆ RTPS_DISCOVERY_ENDPOINT_ANNOUNCEMENTS

const char OpenDDS::RTPS::RTPS_DISCOVERY_ENDPOINT_ANNOUNCEMENTS[] = "OpenDDS.RtpsDiscovery.EndpointAnnouncements"

Definition at line 32 of file RtpsDiscovery.h.

Referenced by OpenDDS::RTPS::Spdp::init().

◆ RTPS_DISCOVERY_TYPE_LOOKUP_SERVICE

const char OpenDDS::RTPS::RTPS_DISCOVERY_TYPE_LOOKUP_SERVICE[] = "OpenDDS.RtpsDiscovery.TypeLookupService"

Definition at line 33 of file RtpsDiscovery.h.

Referenced by OpenDDS::RTPS::Spdp::init().

◆ RTPS_REFLECT_HEARTBEAT_COUNT

const char OpenDDS::RTPS::RTPS_REFLECT_HEARTBEAT_COUNT[] = "OpenDDS.Rtps.ReflectHeartbeatCount"

Definition at line 35 of file RtpsDiscovery.h.

Referenced by OpenDDS::RTPS::Spdp::init().

◆ RTPS_RELAY_APPLICATION_PARTICIPANT

const char OpenDDS::RTPS::RTPS_RELAY_APPLICATION_PARTICIPANT[] = "OpenDDS.Rtps.RelayApplicationParticipant"

Definition at line 34 of file RtpsDiscovery.h.

Referenced by OpenDDS::RTPS::Spdp::init().

◆ RTPSHDR_SZ

const ACE_CDR::UShort OpenDDS::RTPS::RTPSHDR_SZ = 20

Definition at line 22 of file MessageTypes.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::encode_rtps_message(), OpenDDS::DCPS::RtpsTransportHeader::get_max_serialized_size(), OpenDDS::DCPS::RtpsUdpSendStrategy::marshal_transport_header(), and OpenDDS::DCPS::RtpsUdpReceiveStrategy::receive_bytes().

◆ SEDP_AGENT_INFO_KEY

const char OpenDDS::RTPS::SEDP_AGENT_INFO_KEY[] = "SEDP"

Definition at line 60 of file Spdp.h.

Referenced by OpenDDS::RTPS::Spdp::process_participant_ice(), OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

◆ SEQUENCENUMBER_UNKNOWN

const SequenceNumber_t OpenDDS::RTPS::SEQUENCENUMBER_UNKNOWN = { -1, 0 }

Definition at line 50 of file BaseMessageTypes.h.

◆ SM_ALIGN

const size_t OpenDDS::RTPS::SM_ALIGN = 4

Alignment of RTPS Submessage.

Definition at line 30 of file MessageTypes.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::encode_rtps_message(), and OpenDDS::Security::CryptoBuiltInImpl::encode_submessage().

◆ SMHDR_SZ

const ACE_CDR::UShort OpenDDS::RTPS::SMHDR_SZ = 4

Definition at line 23 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::add_gap_submsg_i(), OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), OpenDDS::Security::CryptoBuiltInImpl::decode_submessage(), OpenDDS::DCPS::RtpsUdpSendStrategy::encode_rtps_message(), OpenDDS::Security::CryptoBuiltInImpl::encode_rtps_message(), OpenDDS::Security::CryptoBuiltInImpl::encode_submessage(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), OpenDDS::DCPS::RtpsSampleHeader::init(), OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert(), OpenDDS::Security::CryptoBuiltInImpl::preprocess_secure_submsg(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::receive_bytes(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::sec_submsg_to_octets(), and OpenDDS::DCPS::RtpsSampleHeader::split().

◆ SPDP_AGENT_INFO_KEY

const char OpenDDS::RTPS::SPDP_AGENT_INFO_KEY[] = "SPDP"

Definition at line 59 of file Spdp.h.

Referenced by OpenDDS::RTPS::Spdp::process_participant_ice(), OpenDDS::RTPS::Sedp::DiscoveryWriter::write_dcps_participant_secure(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

◆ TIME_INVALID

const Time_t OpenDDS::RTPS::TIME_INVALID = { 0xffffffffu, 0xffffffffu }

Definition at line 20 of file BaseMessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::reset().

◆ VENDORID_OPENDDS

const VendorId_t OpenDDS::RTPS::VENDORID_OPENDDS
Initial value:
=
{ { OpenDDS::DCPS::VENDORID_OCI[0], OpenDDS::DCPS::VENDORID_OCI[1] } }
OpenDDS::DCPS::VENDORID_OCI
const GuidVendorId_t VENDORID_OCI
Vendor Id value specified for OCI is used for OpenDDS.
Definition: GuidUtils.h:29

Definition at line 26 of file BaseMessageTypes.h.

Referenced by OpenDDS::RTPS::Spdp::build_local_pdata(), rtps_duration_to_time_duration(), OpenDDS::DCPS::RtpsUdpSendStrategy::RtpsUdpSendStrategy(), and OpenDDS::RTPS::Spdp::SpdpTransport::SpdpTransport().

◆ VENDORID_UNKNOWN

const VendorId_t OpenDDS::RTPS::VENDORID_UNKNOWN = { { 0 } }

Definition at line 25 of file BaseMessageTypes.h.

◆ WITH_KEY

const short OpenDDS::RTPS::WITH_KEY = 2

Definition at line 131 of file RtpsCore.idl.

Generated by   doxygen 1.8.13