OpenDDS  Snapshot(2023/04/25-14:16)
Namespaces | Classes | Typedefs | Enumerations | Functions | Variables
OpenDDS::RTPS Namespace Reference

Namespaces

 ParameterListConverter
 

Classes

struct  AckNackSubmessage
 
class  BuiltinAssociationRecord
 
struct  ContentFilterInfo_t
 
struct  Count_t
 
struct  DataFragSubmessage
 
struct  DataSubmessage
 
struct  DiscoveredParticipant
 
struct  DiscoveredPublication
 
struct  DiscoveredSubscription
 
struct  DiscoveredTopicData
 
struct  Duration_t
 
struct  EntityName_t
 
struct  FragmentNumber_t
 
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  LocalEntity
 
struct  LocalPublication
 
struct  LocalSubscription
 
struct  LocatorUDPv4_t
 
struct  Message
 
class  MessageParser
 
struct  NackFragSubmessage
 
struct  OpenDDSParticipantFlags_t
 
struct  OriginalWriterInfo_t
 
struct  PadSubmessage
 
union  Parameter
 
struct  ParticipantMessageData
 
struct  ParticipantProxy_t
 
struct  ProtocolVersion_t
 
class  ReaderAssociationRecord
 
struct  ReliabilityKind_t
 
struct  ReliabilityQosPolicyRtps
 
class  RtpsDiscovery
 Discovery Strategy class that implements RTPS discovery. More...
 
class  RtpsDiscoveryConfig
 
struct  SecuritySubmessage
 
class  Sedp
 
struct  SequenceNumber_t
 
class  Spdp
 
struct  SPDPdiscoveredParticipantData
 
struct  StatusInfo_t
 
union  Submessage
 
struct  SubmessageHeader
 
struct  Time_t
 
struct  TopicKind_t
 
struct  VendorId_t
 
class  WriterAssociationRecord
 

Typedefs

typedef DCPS::RcHandle< WriterAssociationRecord > WriterAssociationRecord_rch
 
typedef DCPS::RcHandle< ReaderAssociationRecord > ReaderAssociationRecord_rch
 
typedef Security::SPDPdiscoveredParticipantData ParticipantData_t
 
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 unsigned short ParameterId_t
 
typedef unsigned long OpenDDSParticipantFlagsBits_t
 
typedef sequence< Submessage > SubmessageSeq
 
typedef RcHandle< Spdp > ParticipantHandle
 
typedef OpenDDS::DCPS::RcHandle< RtpsDiscoveryConfig > RtpsDiscoveryConfig_rch
 
typedef OpenDDS::DCPS::RcHandle< RtpsDiscovery > RtpsDiscovery_rch
 

Enumerations

enum  AuthState { AUTH_STATE_HANDSHAKE, AUTH_STATE_AUTHENTICATED, AUTH_STATE_UNAUTHENTICATED }
 
enum  HandshakeState { HANDSHAKE_STATE_BEGIN_HANDSHAKE_REQUEST, HANDSHAKE_STATE_BEGIN_HANDSHAKE_REPLY, HANDSHAKE_STATE_PROCESS_HANDSHAKE, HANDSHAKE_STATE_DONE }
 
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

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)
 
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)
 
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)
 
typedef OPENDDS_MAP_CMP (GUID_t, ParticipantHandle, GUID_tKeyLessThan) ParticipantMap
 
typedef OPENDDS_MAP (DDS::DomainId_t, ParticipantMap) DomainParticipantMap
 
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::GUID_t &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 cmp_ip4 (const ACE_INET_Addr &a, const DCPS::Locator_t &locator)
 
bool is_ip_equal (const ACE_INET_Addr &a, const DCPS::Locator_t &locator)
 
void print_locator (const CORBA::ULong i, const DCPS::Locator_t &o)
 
bool ip_in_locator_list (const ACE_INET_Addr &from, const DCPS::LocatorSeq &locators)
 
bool ip_in_AgentInfo (const ACE_INET_Addr &from, const ParameterList &plist)
 
bool valid_size (const ACE_INET_Addr &a)
 
bool operator== (const StatusInfo_t &lhs, const StatusInfo_t &rhs)
 

Variables

OpenDDS::internal::special_serialization typedef sequence< Parameter > ParameterList
 
const int AC_EMPTY = 0
 
const int AC_REMOTE_RELIABLE = 1 << 0
 
const int AC_REMOTE_DURABLE = 1 << 1
 
const int AC_GENERATE_REMOTE_MATCHED_CRYPTO_HANDLE = 1 << 2
 
const int AC_SEND_LOCAL_TOKEN = 1 << 3
 
const int AC_LOCAL_TOKENS_SENT = 1 << 4
 
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 DDS::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 DDS::Security::ParticipantSecurityInfo PARTICIPANT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}
 
const DDS::Security::EndpointSecurityInfo ENDPOINT_SECURITY_ATTRIBUTES_INFO_DEFAULT = {0, 0}
 
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 = DCPS::LOCATOR_KIND_INVALID
 
const long LOCATOR_KIND_RESERVED = DCPS::LOCATOR_KIND_RESERVED
 
const long LOCATOR_KIND_UDPv4 = DCPS::LOCATOR_KIND_UDPv4
 
const long LOCATOR_KIND_UDPv6 = DCPS::LOCATOR_KIND_UDPv6
 
const unsigned long LOCATOR_PORT_INVALID = DCPS::LOCATOR_PORT_INVALID
 
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 OPENDDS_FLAG_R = 8
 
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 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 232 of file RtpsCore.idl.

◆ BuiltinEndpointSet_t

typedef unsigned long OpenDDS::RTPS::BuiltinEndpointSet_t

Definition at line 197 of file RtpsCore.idl.

◆ FilterResult_t

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

Definition at line 31 of file RtpsCore.idl.

◆ FilterSignature_t

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

Definition at line 27 of file RtpsCore.idl.

◆ FilterSignatureSeq

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

Definition at line 33 of file RtpsCore.idl.

◆ IceAgentType_t

typedef unsigned long OpenDDS::RTPS::IceAgentType_t

Definition at line 172 of file RtpsCore.idl.

◆ IceCandidateType_t

typedef unsigned long OpenDDS::RTPS::IceCandidateType_t

Definition at line 183 of file RtpsCore.idl.

◆ LocatorList

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

Definition at line 80 of file RtpsCore.idl.

◆ LongSeq8

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

Definition at line 69 of file RtpsCore.idl.

◆ OctetArray2

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

Definition at line 22 of file RtpsCore.idl.

◆ OctetArray4

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

Definition at line 23 of file RtpsCore.idl.

◆ OpenDDSParticipantFlagsBits_t

typedef unsigned long OpenDDS::RTPS::OpenDDSParticipantFlagsBits_t

Definition at line 321 of file RtpsCore.idl.

◆ ParameterId_t

typedef unsigned short OpenDDS::RTPS::ParameterId_t

Definition at line 249 of file RtpsCore.idl.

◆ ParticipantData_t

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

Definition at line 44 of file DiscoveredEntities.h.

◆ ParticipantHandle

typedef RcHandle<Spdp> OpenDDS::RTPS::ParticipantHandle

Definition at line 35 of file RtpsDiscovery.h.

◆ Property_t

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

Definition at line 48 of file RtpsCore.idl.

◆ PropertySeq

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

Definition at line 49 of file RtpsCore.idl.

◆ ReaderAssociationRecord_rch

typedef DCPS::RcHandle<ReaderAssociationRecord> OpenDDS::RTPS::ReaderAssociationRecord_rch

Definition at line 125 of file AssociationRecord.h.

◆ RtpsDiscovery_rch

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

Definition at line 367 of file RtpsDiscovery.h.

◆ RtpsDiscoveryConfig_rch

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

Definition at line 38 of file RtpsDiscovery.h.

◆ SubmessageSeq

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

Definition at line 885 of file RtpsCore.idl.

◆ Timestamp_t

typedef Time_t OpenDDS::RTPS::Timestamp_t

Definition at line 97 of file RtpsCore.idl.

◆ WriterAssociationRecord_rch

typedef DCPS::RcHandle<WriterAssociationRecord> OpenDDS::RTPS::WriterAssociationRecord_rch

Definition at line 106 of file AssociationRecord.h.

Enumeration Type Documentation

◆ AuthState

enum OpenDDS::RTPS::AuthState
Enumerator
AUTH_STATE_HANDSHAKE 
AUTH_STATE_AUTHENTICATED 
AUTH_STATE_UNAUTHENTICATED 

Definition at line 31 of file DiscoveredEntities.h.

31  {
32  AUTH_STATE_HANDSHAKE,
33  AUTH_STATE_AUTHENTICATED,
34  AUTH_STATE_UNAUTHENTICATED
35 };

◆ HandshakeState

enum OpenDDS::RTPS::HandshakeState
Enumerator
HANDSHAKE_STATE_BEGIN_HANDSHAKE_REQUEST 

Requester should call begin_handshake_request.

HANDSHAKE_STATE_BEGIN_HANDSHAKE_REPLY 

Replier should call begin_handshake_reply.

HANDSHAKE_STATE_PROCESS_HANDSHAKE 

Requester and replier should call process handshake.

HANDSHAKE_STATE_DONE 

Handshake concluded or timed out.

Definition at line 37 of file DiscoveredEntities.h.

37  {
38  HANDSHAKE_STATE_BEGIN_HANDSHAKE_REQUEST, //!< Requester should call begin_handshake_request
39  HANDSHAKE_STATE_BEGIN_HANDSHAKE_REPLY, //!< Replier should call begin_handshake_reply
40  HANDSHAKE_STATE_PROCESS_HANDSHAKE, //!< Requester and replier should call process handshake
41  HANDSHAKE_STATE_DONE //!< Handshake concluded or timed out
42 };
OpenDDS::RTPS::HANDSHAKE_STATE_BEGIN_HANDSHAKE_REQUEST
Requester should call begin_handshake_request.
Definition: DiscoveredEntities.h:38
OpenDDS::RTPS::HANDSHAKE_STATE_BEGIN_HANDSHAKE_REPLY
Replier should call begin_handshake_reply.
Definition: DiscoveredEntities.h:39
OpenDDS::RTPS::HANDSHAKE_STATE_DONE
Handshake concluded or timed out.
Definition: DiscoveredEntities.h:41
OpenDDS::RTPS::HANDSHAKE_STATE_PROCESS_HANDSHAKE
Requester and replier should call process handshake.
Definition: DiscoveredEntities.h:40

◆ 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 776 of file RtpsCore.idl.

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

Function Documentation

◆ append_submessage() [1/4]

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

Definition at line 147 of file MessageUtils.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(), and OpenDDS::RTPS::Spdp::SpdpTransport::handle_input().

148 {
149  RTPS::Submessage sm;
150  sm.info_dst_sm(submessage);
151  DCPS::push_back(message.submessages, sm);
152 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ append_submessage() [2/4]

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

Definition at line 154 of file MessageUtils.h.

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

155 {
156  RTPS::Submessage sm;
157  sm.info_ts_sm(submessage);
158  DCPS::push_back(message.submessages, sm);
159 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ append_submessage() [3/4]

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

Definition at line 161 of file MessageUtils.h.

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

162 {
163  RTPS::Submessage sm;
164  sm.data_sm(submessage);
165  DCPS::push_back(message.submessages, sm);
166 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ append_submessage() [4/4]

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

Definition at line 168 of file MessageUtils.h.

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

169 {
170  RTPS::Submessage sm;
171  sm.data_frag_sm(submessage);
172  DCPS::push_back(message.submessages, sm);
173 }
OpenDDS::DCPS::push_back
void push_back(Seq &seq, const typename Seq::value_type &val)
std::vector-style push_back() for CORBA Sequences
Definition: Util.h:138

◆ bitmapNonEmpty()

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

Definition at line 119 of file MessageUtils.cpp.

References OPENDDS_ASSERT, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by operator<(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::process_acknack().

120 {
121  const CORBA::ULong num_ulongs = (snSet.numBits + 31) / 32;
122 
123  OPENDDS_ASSERT(num_ulongs <= snSet.bitmap.length());
124 
125  if (num_ulongs == 0) {
126  return false;
127  }
128 
129  const CORBA::ULong last_index = num_ulongs - 1;
130  for (CORBA::ULong i = 0; i < last_index; ++i) {
131  if (snSet.bitmap[i]) {
132  return true;
133  }
134  }
135 
136  const CORBA::ULong mod = snSet.numBits % 32;
137  const CORBA::ULong mask = mod ? (1 + ~(1u << (32 - mod))) : 0xFFFFFFFF;
138  return (bool)(snSet.bitmap[last_index] & mask);
139 }
OPENDDS_ASSERT
#define OPENDDS_ASSERT(C)
Definition: Definitions.h:72
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 30 of file MessageUtils.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 OpenDDS::DCPS::RtpsUdpTransport::get_connection_addrs(), marshal_key_hash(), and transport_locator_to_locator_seq().

34 {
35  ACE_Data_Block db(blob.length(), ACE_Message_Block::MB_DATA,
36  reinterpret_cast<const char*>(blob.get_buffer()),
37  0 /*alloc*/, 0 /*lock*/, ACE_Message_Block::DONT_DELETE, 0 /*db_alloc*/);
38  ACE_Message_Block mb(&db, ACE_Message_Block::DONT_DELETE, 0 /*mb_alloc*/);
39  mb.wr_ptr(mb.space());
40 
41  DCPS::Serializer ser(&mb, get_locators_encoding());
42  if (!(ser >> locators)) {
43  ACE_ERROR_RETURN((LM_ERROR,
44  ACE_TEXT("(%P|%t) blob_to_locators: ")
45  ACE_TEXT("Failed to deserialize blob's locators\n")),
46  DDS::RETCODE_ERROR);
47  }
48 
49  if (requires_inline_qos) {
50  if (!(ser >> ACE_InputCDR::to_boolean(*requires_inline_qos))) {
51  ACE_ERROR_RETURN((LM_ERROR,
52  ACE_TEXT("(%P|%t) blob_to_locators: ")
53  ACE_TEXT("Failed to deserialize blob inline QoS flag\n")),
54  DDS::RETCODE_ERROR);
55  }
56  } else {
57  if (!ser.skip(1)) {
58  ACE_ERROR_RETURN((LM_ERROR,
59  ACE_TEXT("(%P|%t) blob_to_locators: ")
60  ACE_TEXT("Failed to skip blob inline QoS flag\n")),
61  DDS::RETCODE_ERROR);
62  }
63  }
64 
65  if (pBytesRead) {
66  *pBytesRead = blob.length() - static_cast<unsigned int>(mb.length());
67  }
68  return DDS::RETCODE_OK;
69 }
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: MessageUtils.cpp:24
DDS::RETCODE_OK
const ReturnCode_t RETCODE_OK
Definition: DdsDcpsInfrastructure.idl:54
DDS::RETCODE_ERROR
const ReturnCode_t RETCODE_ERROR
Definition: DdsDcpsInfrastructure.idl:55
ACE_TEXT
ACE_TEXT("TCP_Factory")
ACE_ERROR_RETURN
#define ACE_ERROR_RETURN(X, Y)

◆ cmp_ip4()

bool OpenDDS::RTPS::cmp_ip4 ( const ACE_INET_Addr &  a,
const DCPS::Locator_t &  locator 
)

Definition at line 617 of file Spdp.cpp.

References OpenDDS::DCPS::Locator_t::address, AF_INET, ACE_INET_Addr::get_addr(), OpenDDS::DCPS::Locator_t::kind, LOCATOR_KIND_UDPv4, LOCATOR_KIND_UDPv6, and ACE_OS::memcmp().

Referenced by is_ip_equal().

618 {
619  struct sockaddr_in* sa = static_cast<struct sockaddr_in*>(a.get_addr());
620  if (sa->sin_family == AF_INET && locator.kind == LOCATOR_KIND_UDPv4) {
621  const unsigned char* ip = reinterpret_cast<const unsigned char*>(&sa->sin_addr);
622  const unsigned char* la = reinterpret_cast<const unsigned char*>(locator.address) + 12;
623  return ACE_OS::memcmp(ip, la, 4) == 0;
624  }
625  return false;
626 }
ACE_INET_Addr::get_addr
virtual void * get_addr(void) const
OpenDDS::RTPS::LOCATOR_KIND_UDPv4
const long LOCATOR_KIND_UDPv4
Definition: RtpsCore.idl:111
ACE_OS::memcmp
int memcmp(const void *t, const void *s, size_t len)

◆ create_association_data_proto()

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

Definition at line 1000 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::process_association_records_i().

1001  {
1002  proto.publication_transport_priority_ = 0;
1003  proto.remote_reliable_ = true;
1004  proto.remote_durable_ = true;
1005  DCPS::assign(proto.remote_id_.guidPrefix, pdata.participantProxy.guidPrefix);
1006  proto.participant_discovered_at_ = pdata.discoveredAt;
1007  proto.remote_transport_context_ = pdata.participantProxy.opendds_participant_flags.bits;
1008  populate_locators(proto.remote_data_, pdata);
1009 }
OpenDDS::DCPS::assign
void assign(EntityId_t &dest, const EntityId_t &src)
Definition: GuidUtils.h:157
OpenDDS::RTPS::populate_locators
void populate_locators(DCPS::TransportLocatorSeq &remote_data, const ParticipantData_t &pdata)
Definition: Sedp.cpp:970

◆ 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 4090 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().

4095 {
4096  if (sample.header_.key_fields_only_ && extensibility == DCPS::FINAL) {
4097  GUID_t guid;
4098  if (!(ser >> guid)) return false;
4099  data.length(1);
4100  data[0].guid(guid);
4101  data[0]._d(PID_ENDPOINT_GUID);
4102  } else {
4103  return ser >> data;
4104  }
4105  return true;
4106 }
OpenDDS::RTPS::PID_ENDPOINT_GUID
const ParameterId_t PID_ENDPOINT_GUID
Definition: RtpsCore.idl:298
OpenDDS::XTypes::extensibility
extensibility(MUTABLE) struct TypeLookup_getTypes_In
Definition: TypeLookup.idl:29

◆ disassociate_helper_extended()

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

Definition at line 1411 of file Sedp.cpp.

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

1414 {
1415  if (extended_associated_endpoints & flags) {
1416  client.disassociate(make_id(id, ent));
1417  extended_associated_endpoints &= ~flags;
1418  }
1419 }
OpenDDS::DCPS::make_id
GUID_t make_id(const GuidPrefix_t &prefix, const EntityId_t &entity)
Definition: GuidUtils.h:200

◆ get_locators_encoding()

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

Definition at line 24 of file MessageUtils.cpp.

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

Referenced by blob_to_locators(), OpenDDS::DCPS::RtpsUdpTransport::get_last_recv_locator(), locators_to_blob(), marshal_key_hash(), populate_locators(), OpenDDS::RTPS::Sedp::populate_origination_locator(), and OpenDDS::RTPS::Sedp::populate_transport_locator_sequence().

25 {
26  static const Encoding encoding(Encoding::KIND_XCDR1, DCPS::ENDIAN_BIG);
27  return encoding;
28 }
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 226 of file MessageUtils.h.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

227 {
228  DDS::OctetSeq handleOctets(sizeof handle);
229  handleOctets.length(handleOctets.maximum());
230  unsigned char* rawHandleOctets = handleOctets.get_buffer();
231  unsigned int handleTmp = handle;
232  for (unsigned int j = sizeof handle; j > 0; --j) {
233  rawHandleOctets[j - 1] = handleTmp & 0xff;
234  handleTmp >>= 8;
235  }
236  return handleOctets;
237 }
DDS::OctetSeq
sequence< octet > OctetSeq
Definition: DdsDcpsCore.idl:64

◆ ip_in_AgentInfo()

bool OpenDDS::RTPS::ip_in_AgentInfo ( const ACE_INET_Addr &  from,
const ParameterList &  plist 
)

Definition at line 677 of file Spdp.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), ACE_INET_Addr::is_ip_equal(), LM_ERROR, SEDP_AGENT_INFO_KEY, and SPDP_AGENT_INFO_KEY.

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

678 {
679  bool found = false;
680  ICE::AgentInfoMap ai_map;
681  if (!ParameterListConverter::from_param_list(plist, ai_map)) {
682  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ip_in_AgentInfo - failed to convert ParameterList to AgentInfoMap\n")));
683  return found;
684  }
685  ICE::AgentInfoMap::const_iterator sedp_i = ai_map.find(SEDP_AGENT_INFO_KEY);
686  if (sedp_i != ai_map.end()) {
687  const ICE::AgentInfo::CandidatesType& cs = sedp_i->second.candidates;
688  for (ICE::AgentInfo::const_iterator i = cs.begin(); i != cs.end(); ++i) {
689  if (from.is_ip_equal(i->address)) {
690  found = true;
691  break;
692  }
693  }
694  }
695  ICE::AgentInfoMap::const_iterator spdp_i = ai_map.find(SPDP_AGENT_INFO_KEY);
696  if (!found && spdp_i != ai_map.end()) {
697  const ICE::AgentInfo::CandidatesType& cs = spdp_i->second.candidates;
698  for (ICE::AgentInfo::const_iterator i = cs.begin(); i != cs.end(); ++i) {
699  if (from.is_ip_equal(i->address)) {
700  found = true;
701  break;
702  }
703  }
704  }
705  return found;
706 }
OpenDDS::RTPS::SPDP_AGENT_INFO_KEY
const char SPDP_AGENT_INFO_KEY[]
Definition: Spdp.h:56
ACE_ERROR
#define ACE_ERROR(X)
ACE_INET_Addr::is_ip_equal
bool is_ip_equal(const ACE_INET_Addr &SAP) const
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::RTPS::SEDP_AGENT_INFO_KEY
const char SEDP_AGENT_INFO_KEY[]
Definition: Spdp.h:57
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, DDS::ParticipantBuiltinTopicData &pbtd)
Definition: ParameterListConverter.cpp:344

◆ ip_in_locator_list()

bool OpenDDS::RTPS::ip_in_locator_list ( const ACE_INET_Addr &  from,
const DCPS::LocatorSeq &  locators 
)

Definition at line 660 of file Spdp.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::LogAddr::c_str(), OpenDDS::DCPS::DCPS_debug_level, ACE_Addr::get_type(), is_ip_equal(), LM_DEBUG, and print_locator().

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

661 {
662  if (DCPS::DCPS_debug_level >= 8) {
663  ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) ip_in_locator_list - from (type %d): %C\n"), from.get_type(), DCPS::LogAddr(from).c_str()));
664  }
665  for (CORBA::ULong i = 0; i < locators.length(); ++i) {
666  if (DCPS::DCPS_debug_level >= 8) {
667  print_locator(i, locators[i]);
668  }
669  if (is_ip_equal(from, locators[i])) {
670  return true;
671  }
672  }
673  return false;
674 }
ACE_DEBUG
#define ACE_DEBUG(X)
OpenDDS::DCPS::DCPS_debug_level
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
Definition: debug.cpp:30
ACE_Addr::get_type
int get_type(void) const
OpenDDS::RTPS::print_locator
void print_locator(const CORBA::ULong i, const DCPS::Locator_t &o)
Definition: Spdp.cpp:651
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::RTPS::is_ip_equal
bool is_ip_equal(const ACE_INET_Addr &a, const DCPS::Locator_t &locator)
Definition: Spdp.cpp:641
ACE_TEXT
ACE_TEXT("TCP_Factory")

◆ is_ip_equal()

bool OpenDDS::RTPS::is_ip_equal ( const ACE_INET_Addr &  a,
const DCPS::Locator_t &  locator 
)

Definition at line 641 of file Spdp.cpp.

References cmp_ip4(), and ACE_Addr::get_type().

Referenced by ip_in_locator_list().

642 {
643 #ifdef ACE_HAS_IPV6
644  if (a.get_type() == AF_INET6) {
645  return cmp_ip6(a, locator);
646  }
647 #endif
648  return cmp_ip4(a, locator);
649 }
ACE_Addr::get_type
int get_type(void) const
OpenDDS::RTPS::cmp_ip4
bool cmp_ip4(const ACE_INET_Addr &a, const DCPS::Locator_t &locator)
Definition: Spdp.cpp:617

◆ locators_changed()

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

Definition at line 5982 of file Sedp.cpp.

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

5984 {
5985  return locatorsChanged(x, y);
5986 }

◆ locators_to_blob()

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

Definition at line 71 of file MessageUtils.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 marshal_key_hash(), and OpenDDS::DCPS::RtpsUdpInst::populate_locator().

73 {
74  using namespace OpenDDS::DCPS;
75  const Encoding& encoding = get_locators_encoding();
76  size_t size = 0;
77  serialized_size(encoding, size, locators);
78  ACE_Message_Block mb_locator(size + 1);
79  Serializer ser(&mb_locator, encoding);
80  if (!(ser << locators)) {
81  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) locators_to_blob: ")
82  ACE_TEXT("Failed to serialize locators to blob\n")));
83  }
84  // Add a bool for 'requires inline qos', see Sedp::set_inline_qos():
85  // if the bool is no longer the last octet of the sequence then that function
86  // must be changed as well.
87  if (!(ser << ACE_OutputCDR::from_boolean(false))) {
88  ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) locators_to_blob: ")
89  ACE_TEXT("Failed to serialize boolean for blob\n")));
90  }
91  message_block_to_sequence(mb_locator, blob);
92 }
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::RTPS::message_block_to_sequence
void message_block_to_sequence(const ACE_Message_Block &mb_locator, T &out)
Definition: MessageUtils.h:101
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: MessageUtils.cpp:24
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::DCPS::Serializer
Class to serialize and deserialize data for DDS.
Definition: Serializer.h:369
OpenDDS::DCPS::serialized_size
void serialized_size(const Encoding &encoding, size_t &size, const SequenceNumber &)
Definition: SequenceNumber.h:197

◆ marshal_key_hash()

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

Definition at line 51 of file MessageUtils.h.

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

52 {
53  using DCPS::Serializer;
54  using DCPS::Encoding;
55  typedef DCPS::MarshalTraits<T> Traits;
56 
57  DCPS::KeyOnly<const T> ko(msg);
58 
59  static const size_t hash_limit = 16;
60  std::memset(hash.value, 0, hash_limit);
61 
62  const Encoding encoding(Encoding::KIND_XCDR1, DCPS::ENDIAN_BIG);
63  const OpenDDS::DCPS::SerializedSizeBound bound =
64  Traits::key_only_serialized_size_bound(encoding);
65 
66  if (bound && bound.get() <= hash_limit) {
67  // If it is bounded and can always fit in 16 bytes, we will use the
68  // marshaled key
69  ACE_Message_Block mb(hash_limit);
70  Serializer out_serializer(&mb, encoding);
71  out_serializer << ko;
72  std::memcpy(hash.value, mb.rd_ptr(), mb.length());
73 
74  } else {
75  // We will use the hash of the marshaled key
76  ACE_Message_Block mb(serialized_size(encoding, ko));
77  Serializer out_serializer(&mb, encoding);
78  out_serializer << ko;
79 
80  DCPS::MD5Hash(hash.value, mb.rd_ptr(), mb.length());
81  }
82 }
OpenDDS::DCPS::MD5Hash
void MD5Hash(MD5Result &result, const void *input, size_t size)
Definition: Hash.cpp:323
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 SequenceNumber &)
Definition: SequenceNumber.h:197
OpenDDS::Security::SSL::hash
int hash(const std::vector< const DDS::OctetSeq *> &src, DDS::OctetSeq &dst)
Definition: security/SSL/Utils.cpp:132

◆ 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 101 of file MessageUtils.h.

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

Referenced by OpenDDS::DCPS::RtpsUdpTransport::get_last_recv_locator(), locators_to_blob(), populate_locators(), OpenDDS::RTPS::Sedp::populate_origination_locator(), and OpenDDS::RTPS::Sedp::populate_transport_locator_sequence().

102 {
103  out.length (CORBA::ULong(mb_locator.length()));
104  std::memcpy (out.get_buffer(), mb_locator.rd_ptr(), mb_locator.length());
105 }
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

◆ OPENDDS_MAP()

typedef OpenDDS::RTPS::OPENDDS_MAP ( DDS::DomainId_t  ,
ParticipantMap   
)

◆ OPENDDS_MAP_CMP()

typedef OpenDDS::RTPS::OPENDDS_MAP_CMP ( GUID_t  ,
ParticipantHandle  ,
GUID_tKeyLessThan   
)

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

◆ operator<()

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

Definition at line 121 of file MessageUtils.h.

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

122 {
123  return (v1.major < v2.major || (v1.major == v2.major && v1.minor < v2.minor));
124 }

◆ operator==() [1/3]

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

Definition at line 45 of file RtpsSampleHeader.cpp.

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

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

◆ operator==() [2/3]

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

Definition at line 109 of file MessageUtils.h.

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

110 {
111  return x.seconds == y.seconds && x.fraction == y.fraction;
112 }

◆ operator==() [3/3]

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

Definition at line 114 of file MessageUtils.h.

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

115 {
116  return (v1.vendorId[0] == v2.vendorId[0] && v1.vendorId[1] == v2.vendorId[1]);
117 }

◆ populate_locators()

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

Definition at line 970 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().

972 {
973  const DCPS::LocatorSeq& mll =
974  pdata.participantProxy.metatrafficMulticastLocatorList;
975  const DCPS::LocatorSeq& ull =
976  pdata.participantProxy.metatrafficUnicastLocatorList;
977  const CORBA::ULong locator_count = mll.length() + ull.length();
978 
979  const Encoding& encoding = get_locators_encoding();
980  ACE_Message_Block mb_locator(
981  DCPS::uint32_cdr_size +
982  (locator_count * serialized_size(encoding, DCPS::Locator_t())) + DCPS::boolean_cdr_size);
983  Serializer ser_loc(&mb_locator, encoding);
984  ser_loc << locator_count;
985 
986  for (CORBA::ULong i = 0; i < mll.length(); ++i) {
987  ser_loc << mll[i];
988  }
989  for (CORBA::ULong i = 0; i < ull.length(); ++i) {
990  ser_loc << ull[i];
991  }
992  ser_loc << ACE_OutputCDR::from_boolean(false); // requires_inline_qos
993 
994  remote_data.length(1);
995  remote_data[0].transport_type = "rtps_udp";
996  message_block_to_sequence (mb_locator, remote_data[0].data);
997 }
OpenDDS::DCPS::uint32_cdr_size
const size_t uint32_cdr_size
Definition: Serializer.h:96
OpenDDS::RTPS::message_block_to_sequence
void message_block_to_sequence(const ACE_Message_Block &mb_locator, T &out)
Definition: MessageUtils.h:101
OpenDDS::RTPS::get_locators_encoding
const DCPS::Encoding & get_locators_encoding()
Definition: MessageUtils.cpp:24
CORBA::ULong
ACE_CDR::ULong ULong
OpenDDS::STUN::encoding
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: OpenddsDcpsExt.idl:92
OpenDDS::DCPS::boolean_cdr_size
const size_t boolean_cdr_size
Definition: Serializer.h:89
OpenDDS::DCPS::serialized_size
void serialized_size(const Encoding &encoding, size_t &size, const SequenceNumber &)
Definition: SequenceNumber.h:197

◆ print_locator()

void OpenDDS::RTPS::print_locator ( const CORBA::ULong  i,
const DCPS::Locator_t &  o 
)

Definition at line 651 of file Spdp.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::Locator_t::address, OpenDDS::DCPS::LogAddr::c_str(), OpenDDS::DCPS::Locator_t::kind, LM_DEBUG, and OpenDDS::DCPS::locator_to_address().

Referenced by ip_in_locator_list().

651  {
652  const unsigned char* a = reinterpret_cast<const unsigned char*>(o.address);
653  ACE_INET_Addr addr;
654  bool b = locator_to_address(addr, o, false) == 0;
655  ACE_DEBUG((LM_DEBUG, ACE_TEXT("locator%d(kind:%d)[%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d.%d] locator_to_address:%C\n"),
656  i, o.kind, a[0], a[1], a[2], a[3], a[4], a[5], a[6], a[7], a[8], a[9], a[10], a[11], a[12], a[13], a[14], a[15],
657  (b ? DCPS::LogAddr(addr).c_str() : "failed")));
658 }
ACE_DEBUG
#define ACE_DEBUG(X)
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::DCPS::locator_to_address
int locator_to_address(ACE_INET_Addr &dest, const DCPS::Locator_t &locator, bool map)
Definition: NetworkResource.cpp:857

◆ 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 102 of file MessageUtils.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().

103 {
104  if (rtps_duration == DURATION_INFINITE) {
105  return DCPS::TimeDuration::max_value;
106  }
107 
108  if (version < PROTOCOLVERSION_2_4 && vendor == VENDORID_OPENDDS) {
109  return OpenDDS::DCPS::TimeDuration(
110  rtps_duration.seconds,
111  static_cast<ACE_UINT32>(rtps_duration.fraction / 1000));
112  } else {
113  return OpenDDS::DCPS::TimeDuration(
114  rtps_duration.seconds,
115  DCPS::uint32_fractional_seconds_to_microseconds(rtps_duration.fraction));
116  }
117 }
OpenDDS::RTPS::DURATION_INFINITE
const Duration_t DURATION_INFINITE
Definition: MessageTypes.h:23
OpenDDS::RTPS::VENDORID_OPENDDS
const VendorId_t VENDORID_OPENDDS
Definition: MessageTypes.h:26
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:286
OpenDDS::RTPS::PROTOCOLVERSION_2_4
const ProtocolVersion_t PROTOCOLVERSION_2_4
Definition: MessageTypes.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 177 of file MessageUtils.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().

178 {
179  using namespace DDS::Security;
180 
181  ParticipantSecurityAttributesMask result = PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID;
182  if (sec_attr.is_rtps_protected) {
183  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_RTPS_PROTECTED;
184  }
185  if (sec_attr.is_discovery_protected) {
186  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED;
187  }
188  if (sec_attr.is_liveliness_protected) {
189  result |= PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED;
190  }
191  return result;
192 }
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_VALID
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
Definition: DdsSecurityParams.idl:63
DDS::Security::PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
const ParticipantSecurityAttributesMask PARTICIPANT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
Definition: DdsSecurityParams.idl:62
DDS::Security::ParticipantSecurityAttributesMask
unsigned long ParticipantSecurityAttributesMask
Definition: DdsSecurityParams.idl:58

◆ 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 195 of file MessageUtils.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.

196 {
197  using namespace DDS::Security;
198 
199  EndpointSecurityAttributesMask result = ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID;
200 
201  if (sec_attr.base.is_read_protected)
202  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_READ_PROTECTED;
203 
204  if (sec_attr.base.is_write_protected)
205  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_WRITE_PROTECTED;
206 
207  if (sec_attr.base.is_discovery_protected)
208  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED;
209 
210  if (sec_attr.base.is_liveliness_protected)
211  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED;
212 
213  if (sec_attr.is_submessage_protected)
214  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED;
215 
216  if (sec_attr.is_payload_protected)
217  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED;
218 
219  if (sec_attr.is_key_protected)
220  result |= ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED;
221 
222  return result;
223 }
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_LIVELINESS_PROTECTED
Definition: DdsSecurityParams.idl:90
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_SUBMESSAGE_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_SUBMESSAGE_PROTECTED
Definition: DdsSecurityParams.idl:87
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_PAYLOAD_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_PAYLOAD_PROTECTED
Definition: DdsSecurityParams.idl:88
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_KEY_PROTECTED
Definition: DdsSecurityParams.idl:89
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_DISCOVERY_PROTECTED
Definition: DdsSecurityParams.idl:86
DDS::Security::EndpointSecurityAttributesMask
unsigned long EndpointSecurityAttributesMask
Definition: DdsSecurityParams.idl:81
DDS::Security::ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
const EndpointSecurityAttributesMask ENDPOINT_SECURITY_ATTRIBUTES_FLAG_IS_VALID
Definition: DdsSecurityParams.idl:91

◆ to_opendds_seqnum()

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

Definition at line 132 of file MessageUtils.h.

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

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), 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().

133 {
134  DCPS::SequenceNumber opendds_seqnum;
135  opendds_seqnum.setValue(rtps_seqnum.high, rtps_seqnum.low);
136  return opendds_seqnum;
137 }

◆ to_rtps_seqnum()

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

Definition at line 139 of file MessageUtils.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::RTPS::Sedp::TypeLookupRequestWriter::send_type_lookup_request(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

140 {
141  RTPS::SequenceNumber_t rtps_seqnum;
142  rtps_seqnum.high = opendds_seqnum.getHigh();
143  rtps_seqnum.low = opendds_seqnum.getLow();
144  return rtps_seqnum;
145 }

◆ transport_locator_to_locator_seq()

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

Definition at line 95 of file MessageUtils.cpp.

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

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

96 {
97  DCPS::LocatorSeq locators;
98  blob_to_locators(info.data, locators);
99  return locators;
100 }
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: MessageUtils.cpp:30
OpenDDS::DCPS::LocatorSeq
sequence< Locator_t > LocatorSeq
Definition: OpenddsDcpsExt.idl:92

◆ valid_size()

bool OpenDDS::RTPS::valid_size ( const ACE_INET_Addr &  a)

Definition at line 2983 of file Spdp.cpp.

References ACE_INET_Addr::get_addr_size(), and ACE_Addr::get_size().

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::handle_input().

2984 {
2985  return a.get_size() <= a.get_addr_size();
2986 }
ACE_Addr::get_size
int get_size(void) const
ACE_INET_Addr::get_addr_size
int get_addr_size(void) const

Variable Documentation

◆ AC_EMPTY

const int OpenDDS::RTPS::AC_EMPTY = 0

Definition at line 20 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::Sedp::associate().

◆ AC_GENERATE_REMOTE_MATCHED_CRYPTO_HANDLE

const int OpenDDS::RTPS::AC_GENERATE_REMOTE_MATCHED_CRYPTO_HANDLE = 1 << 2

Definition at line 23 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::associate_volatile(), and OpenDDS::RTPS::BuiltinAssociationRecord::generate_remote_matched_crypto_handle().

◆ AC_LOCAL_TOKENS_SENT

const int OpenDDS::RTPS::AC_LOCAL_TOKENS_SENT = 1 << 4

Definition at line 25 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::BuiltinAssociationRecord::local_tokens_sent().

◆ AC_REMOTE_DURABLE

const int OpenDDS::RTPS::AC_REMOTE_DURABLE = 1 << 1

Definition at line 22 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), and OpenDDS::RTPS::BuiltinAssociationRecord::remote_durable().

◆ AC_REMOTE_RELIABLE

const int OpenDDS::RTPS::AC_REMOTE_RELIABLE = 1 << 0

Definition at line 21 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::associate_volatile(), and OpenDDS::RTPS::BuiltinAssociationRecord::remote_reliable().

◆ AC_SEND_LOCAL_TOKEN

const int OpenDDS::RTPS::AC_SEND_LOCAL_TOKEN = 1 << 3

Definition at line 24 of file AssociationRecord.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), and OpenDDS::RTPS::BuiltinAssociationRecord::send_local_token().

◆ BEST_EFFORT

const short OpenDDS::RTPS::BEST_EFFORT = 1

Definition at line 142 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 233 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate().

◆ BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER

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

Definition at line 220 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 218 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 229 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 227 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 225 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 223 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 103 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 102 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 198 of file RtpsCore.idl.

Referenced by 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 200 of file RtpsCore.idl.

Referenced by 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 210 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 212 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 214 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 216 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 202 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 204 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 206 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 208 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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 MessageTypes.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 MessageTypes.h.

◆ ENDPOINT_SECURITY_ATTRIBUTES_INFO_DEFAULT

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

Definition at line 97 of file MessageTypes.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 82 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), 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 81 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::LivelinessReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 84 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Spdp::attempt_authentication(), 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 83 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::SecurityReader::data_received_i(), OpenDDS::DCPS::RtpsUdpSendStrategy::encode_rtps_message(), OpenDDS::RTPS::Spdp::process_handshake_resends(), 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 86 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), 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_volatile(), OpenDDS::RTPS::Sedp::remote_has_local_endpoint_token_i(), OpenDDS::RTPS::Sedp::remote_has_local_participant_token_i(), 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 85 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::associate_volatile(), OpenDDS::RTPS::Sedp::cleanup_volatile_crypto(), OpenDDS::RTPS::Sedp::data_acked_i(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::SecurityReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 78 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::remote_knows_about_local_i(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), 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 77 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::data_acked_i(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 80 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::remote_knows_about_local_i(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), 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 79 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::data_acked_i(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 88 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::replay_durable_data_for(), 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 87 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 93 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 92 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::TypeLookupReplyReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 91 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::association_complete_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 90 of file MessageTypes.h.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::Reader::data_received(), OpenDDS::RTPS::Sedp::TypeLookupRequestReader::data_received_i(), OpenDDS::RTPS::Sedp::disassociate(), 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 526 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 521 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::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 523 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), 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(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual_i().

◆ FLAG_I

const octet OpenDDS::RTPS::FLAG_I = 2

Definition at line 524 of file RtpsCore.idl.

◆ FLAG_K_IN_DATA

const octet OpenDDS::RTPS::FLAG_K_IN_DATA = 8

Definition at line 530 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 528 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 527 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 525 of file RtpsCore.idl.

◆ FLAG_N_IN_DATA

const octet OpenDDS::RTPS::FLAG_N_IN_DATA = 16

Definition at line 532 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 531 of file RtpsCore.idl.

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

◆ FLAG_Q

const octet OpenDDS::RTPS::FLAG_Q = 2

Definition at line 522 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 107 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 173 of file RtpsCore.idl.

◆ ICE_HOST

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

Definition at line 184 of file RtpsCore.idl.

◆ ICE_LITE

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

Definition at line 174 of file RtpsCore.idl.

◆ ICE_PEER_REFLEXIVE

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

Definition at line 186 of file RtpsCore.idl.

◆ ICE_RELAYED

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

Definition at line 187 of file RtpsCore.idl.

◆ ICE_SERVER_REFLEXIVE

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

Definition at line 185 of file RtpsCore.idl.

◆ INFO_DST_SZ

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

Definition at line 108 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 110 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 109 of file MessageTypes.h.

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

◆ initialize_rtps

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

Definition at line 365 of file RtpsDiscovery.h.

◆ LOCATOR_ADDRESS_INVALID

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

Definition at line 54 of file MessageTypes.h.

◆ LOCATOR_INVALID

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

Definition at line 52 of file MessageTypes.h.

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

◆ LOCATOR_KIND_INVALID

const long OpenDDS::RTPS::LOCATOR_KIND_INVALID = DCPS::LOCATOR_KIND_INVALID

Definition at line 109 of file RtpsCore.idl.

◆ LOCATOR_KIND_RESERVED

const long OpenDDS::RTPS::LOCATOR_KIND_RESERVED = DCPS::LOCATOR_KIND_RESERVED

Definition at line 110 of file RtpsCore.idl.

◆ LOCATOR_KIND_UDPv4

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv4 = DCPS::LOCATOR_KIND_UDPv4

Definition at line 111 of file RtpsCore.idl.

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

◆ LOCATOR_KIND_UDPv6

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv6 = DCPS::LOCATOR_KIND_UDPv6

Definition at line 112 of file RtpsCore.idl.

Referenced by cmp_ip4().

◆ LOCATOR_PORT_INVALID

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

Definition at line 113 of file RtpsCore.idl.

◆ LOCATORUDPv4_INVALID

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

Definition at line 56 of file MessageTypes.h.

◆ NO_KEY

const short OpenDDS::RTPS::NO_KEY = 1

Definition at line 132 of file RtpsCore.idl.

◆ OPENDDS_FLAG_R

const octet OpenDDS::RTPS::OPENDDS_FLAG_R = 8

Definition at line 529 of file RtpsCore.idl.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::bundle_and_send_submessages(), and OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::gather_nack_replies_i().

◆ ParameterList

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

Definition at line 236 of file RtpsCore.idl.

Referenced by OpenDDS::Security::extract_participant_guid_from_cpdata(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages().

◆ 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 117 of file MessageTypes.h.

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

◆ 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 119 of file MessageTypes.h.

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

◆ 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 115 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 96 of file MessageTypes.h.

◆ PFLAGS_DIRECTED_HEARTBEAT

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

Definition at line 324 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 322 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 323 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 326 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 327 of file RtpsCore.idl.

◆ PID_BUILTIN_ENDPOINT_QOS

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

Definition at line 319 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 291 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 301 of file RtpsCore.idl.

◆ PID_CONTENT_FILTER_INFO

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

Definition at line 300 of file RtpsCore.idl.

◆ PID_CONTENT_FILTER_PROPERTY

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

Definition at line 288 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 304 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 262 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 281 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 280 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 267 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 302 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 316 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 317 of file RtpsCore.idl.

◆ PID_DURABILITY

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

Definition at line 260 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 261 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 298 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 294 of file RtpsCore.idl.

◆ PID_EXPECTS_INLINE_QOS

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

Definition at line 284 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 258 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 290 of file RtpsCore.idl.

◆ PID_HISTORY

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

Definition at line 268 of file RtpsCore.idl.

◆ PID_KEY_HASH

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

Definition at line 295 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 263 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 266 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 264 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 283 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 282 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 279 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 340 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 338 of file RtpsCore.idl.

◆ PID_OPENDDS_ICE_CANDIDATE

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

Definition at line 342 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 341 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 339 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 343 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 344 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 303 of file RtpsCore.idl.

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

◆ PID_OWNERSHIP

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

Definition at line 270 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 271 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 253 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 286 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 289 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 287 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 285 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 273 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 272 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 292 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 276 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 265 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 269 of file RtpsCore.idl.

◆ PID_SENTINEL

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

Definition at line 254 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 296 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 274 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 259 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 256 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 275 of file RtpsCore.idl.

◆ PID_TYPE_MAX_SIZE_SERIALIZED

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

Definition at line 293 of file RtpsCore.idl.

◆ PID_TYPE_NAME

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

Definition at line 257 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 278 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 255 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 277 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 307 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 310 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 314 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 313 of file RtpsCore.idl.

◆ PROTOCOL_RTPS

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

Definition at line 58 of file MessageTypes.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 MessageTypes.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 MessageTypes.h.

◆ PROTOCOLVERSION_1_1

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

Definition at line 61 of file MessageTypes.h.

◆ PROTOCOLVERSION_2_0

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

Definition at line 62 of file MessageTypes.h.

◆ PROTOCOLVERSION_2_1

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

Definition at line 63 of file MessageTypes.h.

◆ PROTOCOLVERSION_2_2

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

Definition at line 64 of file MessageTypes.h.

◆ PROTOCOLVERSION_2_3

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

Definition at line 65 of file MessageTypes.h.

◆ PROTOCOLVERSION_2_4

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

Definition at line 66 of file MessageTypes.h.

Referenced by rtps_duration_to_time_duration().

◆ RELIABLE

const short OpenDDS::RTPS::RELIABLE = 2

Definition at line 143 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 40 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 41 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 43 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 42 of file RtpsDiscovery.h.

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

◆ RTPSHDR_SZ

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

Definition at line 105 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 57 of file Spdp.h.

Referenced by ip_in_AgentInfo(), 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 MessageTypes.h.

◆ SM_ALIGN

const size_t OpenDDS::RTPS::SM_ALIGN = 4

Alignment of RTPS Submessage.

Definition at line 113 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 106 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::Security::CryptoBuiltInImpl::preprocess_secure_submsg(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::receive_bytes(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::sec_submsg_to_octets(), OpenDDS::DCPS::RtpsSampleHeader::split(), and OpenDDS::DCPS::RtpsUdpDataLink::submsgs_to_msgblock().

◆ SPDP_AGENT_INFO_KEY

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

Definition at line 56 of file Spdp.h.

Referenced by ip_in_AgentInfo(), 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 MessageTypes.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 MessageTypes.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 MessageTypes.h.

◆ WITH_KEY

const short OpenDDS::RTPS::WITH_KEY = 2

Definition at line 133 of file RtpsCore.idl.

Generated by   doxygen 1.8.13