RESERVED_0
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

Definition at line 631 of file RtpsCore.idl.

00631                         {
00632       RESERVED_0,
00633       PAD,            /* = 0x01, Pad */
00634       RESERVED_2,
00635       RESERVED_3,
00636       RESERVED_4,
00637       RESERVED_5,
00638       ACKNACK,        /* = 0x06, AckNack */
00639       HEARTBEAT,      /* = 0x07, Heartbeat */
00640       GAP,            /* = 0x08, Gap */
00641       INFO_TS,        /* = 0x09, InfoTimestamp */
00642       RESERVED_10,
00643       RESERVED_11,
00644       INFO_SRC,       /* = 0x0c, InfoSource */
00645       INFO_REPLY_IP4, /* = 0x0d, InfoReplyIp4 */
00646       INFO_DST,       /* = 0x0e, InfoDestination */
00647       INFO_REPLY,     /* = 0x0f, InfoReply */
00648       RESERVED_16,
00649       RESERVED_17,
00650       NACK_FRAG,      /* = 0x12, NackFrag */
00651       HEARTBEAT_FRAG, /* = 0x13, HeartbeatFrag */
00652       RESERVED_20,
00653       DATA,           /* = 0x15, Data */
00654       DATA_FRAG       /* = 0x16, DataFrag */
00655     };

enum OpenDDS::RTPS::RtpsFlags

Enumerator:

FLAG_E
FLAG_Q
FLAG_D

Definition at line 47 of file Sedp.h.

00047 { FLAG_E = 1, FLAG_Q = 2, FLAG_D = 4 };

Function Documentation

template<typename T>

void OpenDDS::RTPS::marshal_key_hash	(	const T &	msg,
		KeyHash_t &	hash
	)

Definition at line 28 of file BaseMessageUtils.h.

References OpenDDS::DCPS::gen_find_size(), OpenDDS::DCPS::gen_max_marshaled_size(), MD5_Final(), MD5_Init(), MD5_Update(), and OpenDDS::RTPS::KeyHash_t::value.

00028                                                      {
00029   using OpenDDS::DCPS::Serializer;
00030 
00031   OpenDDS::DCPS::KeyOnly<const T> ko(msg);
00032 
00033   static const size_t HASH_LIMIT = 16;
00034   std::memset(hash.value, 0, HASH_LIMIT);
00035 
00036   // Key Hash must use big endian ordering.
00037   // Native==Little endian means we need to swap
00038 #if defined ACE_LITTLE_ENDIAN
00039   static const bool swap_bytes = true;
00040 #else
00041   static const bool swap_bytes = false;
00042 #endif
00043 
00044   if (gen_is_bounded_size(ko) &&
00045       gen_max_marshaled_size(ko, true /*align*/) <= HASH_LIMIT) {
00046     // If it is bounded and can always fit in 16 bytes, we will use the
00047     // marshaled key
00048     ACE_Message_Block mb(HASH_LIMIT);
00049     Serializer out_serializer(&mb, swap_bytes, Serializer::ALIGN_INITIALIZE);
00050     out_serializer << ko;
00051     std::memcpy(hash.value, mb.rd_ptr(), mb.length());
00052 
00053   } else {
00054     // We will use the hash of the marshaled key
00055     size_t size = 0, padding = 0;
00056     gen_find_size(ko, size, padding);
00057     ACE_Message_Block mb(size + padding);
00058     Serializer out_serializer(&mb, swap_bytes, Serializer::ALIGN_INITIALIZE);
00059     out_serializer << ko;
00060 
00061     MD5_CTX ctx;
00062     MD5_Init(&ctx);
00063     MD5_Update(&ctx, mb.rd_ptr(), static_cast<unsigned long>(mb.length()));
00064     MD5_Final(hash.value, &ctx);
00065   }
00066 }

void OpenDDS::RTPS::assign	(	GuidPrefix_t &	dest,
		const GuidPrefix_t &	src
	)			`[inline]`

Definition at line 68 of file BaseMessageUtils.h.

Referenced by set_ipaddress(), set_port(), and OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg().

00069 {
00070   std::memcpy(&dest[0], &src[0], sizeof(GuidPrefix_t));
00071 }

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

Definition at line 73 of file BaseMessageUtils.h.

00075 {
00076   std::memcpy(&dest[0], &src[0], sizeof(OpenDDS::DCPS::OctetArray16));
00077 }

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

Definition at line 79 of file BaseMessageUtils.h.

00081 {
00082   std::memset(&dest[0], 0, 12);
00083   dest[12] = ipv4addr_be >> 24;
00084   dest[13] = ipv4addr_be >> 16;
00085   dest[14] = ipv4addr_be >> 8;
00086   dest[15] = ipv4addr_be;
00087 }

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

Definition at line 89 of file BaseMessageUtils.h.

00090 {
00091   lhs[0] = static_cast<CORBA::Octet>(rhs);
00092   lhs[1] = static_cast<CORBA::Octet>(rhs >> 8);
00093   lhs[2] = static_cast<CORBA::Octet>(rhs >> 16);
00094 }

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

Definition at line 98 of file BaseMessageUtils.h.

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

00099 {
00100   const void* raw = addr.get_addr();
00101 #ifdef ACE_HAS_IPV6
00102   if (addr.get_type() == AF_INET6) {
00103     const sockaddr_in6* in = static_cast<const sockaddr_in6*>(raw);
00104     std::memcpy(&dest[0], &in->sin6_addr, 16);
00105   } else {
00106 #else
00107   {
00108 #endif
00109     const sockaddr_in* in = static_cast<const sockaddr_in*>(raw);
00110     std::memset(&dest[0], 0, 12);
00111     std::memcpy(&dest[12], &in->sin_addr, 4);
00112   }
00113 }

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

Definition at line 116 of file BaseMessageUtils.h.

References LOCATOR_KIND_UDPv4, and LOCATOR_KIND_UDPv6.

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

00117 {
00118 #ifdef ACE_HAS_IPV6
00119   return addr.get_type() == AF_INET6 ? LOCATOR_KIND_UDPv6 : LOCATOR_KIND_UDPv4;
00120 #else
00121   ACE_UNUSED_ARG(addr);
00122   return LOCATOR_KIND_UDPv4;
00123 #endif
00124 }

int OpenDDS::RTPS::locator_to_address	(	ACE_INET_Addr &	dest,
		const OpenDDS::DCPS::Locator_t &	locator,
		bool	map
	)			`[inline]`

Definition at line 127 of file BaseMessageUtils.h.

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

Referenced by add_param_rtps_locator(), and OpenDDS::DCPS::RtpsUdpTransport::get_connection_addr().

00130 {
00131   switch (locator.kind) {
00132 #ifdef ACE_HAS_IPV6
00133   case LOCATOR_KIND_UDPv6:
00134     dest.set_type(AF_INET6);
00135     if (dest.set_address(reinterpret_cast<const char*>(locator.address),
00136                          16, 0 /*encode*/) == -1) {
00137       return -1;
00138     }
00139     dest.set_port_number(locator.port);
00140     return 0;
00141     break;
00142 #endif
00143   case LOCATOR_KIND_UDPv4:
00144 #if !defined (ACE_HAS_IPV6) || !defined (IPV6_V6ONLY)
00145     ACE_UNUSED_ARG(map);
00146 #endif
00147     dest.set_type(AF_INET);
00148     if (dest.set_address(reinterpret_cast<const char*>(locator.address)
00149                          + 12, 4, 0 /*network order*/
00150 #if defined (ACE_HAS_IPV6) && defined (IPV6_V6ONLY)
00151                          , map ? 1 : 0 /*map IPV4 to IPV6 addr*/
00152 #endif
00153                          ) == -1) {
00154       return -1;
00155     }
00156     dest.set_port_number(locator.port);
00157     return 0;
00158     break;
00159   default:
00160     return -1;  // Unknown kind
00161   }
00162 
00163   return -1;
00164 }

DDS::ReturnCode_t OpenDDS::RTPS::blob_to_locators	(	const OpenDDS::DCPS::TransportBLOB &	blob,
		OpenDDS::DCPS::LocatorSeq &	locators,
		bool &	requires_inline_qos
	)			`[inline]`

Definition at line 167 of file BaseMessageUtils.h.

References DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

Referenced by add_param_rtps_locator(), and OpenDDS::DCPS::RtpsUdpTransport::get_connection_addr().

00171 {
00172   ACE_Data_Block db(blob.length(), ACE_Message_Block::MB_DATA,
00173       reinterpret_cast<const char*>(blob.get_buffer()),
00174       0 /*alloc*/, 0 /*lock*/, ACE_Message_Block::DONT_DELETE, 0 /*db_alloc*/);
00175   ACE_Message_Block mb(&db, ACE_Message_Block::DONT_DELETE, 0 /*mb_alloc*/);
00176   mb.wr_ptr(mb.space());
00177 
00178   using OpenDDS::DCPS::Serializer;
00179   Serializer ser(&mb, ACE_CDR_BYTE_ORDER, Serializer::ALIGN_CDR);
00180   if (!(ser >> locators)) {
00181     ACE_ERROR_RETURN((LM_ERROR,
00182                       ACE_TEXT("(%P|%t) blob_to_locators: ")
00183                       ACE_TEXT("Failed to deserialize blob's locators\n")),
00184                       DDS::RETCODE_ERROR);
00185   }
00186   if (!(ser >> ACE_InputCDR::to_boolean(requires_inline_qos))) {
00187     ACE_ERROR_RETURN((LM_ERROR,
00188                       ACE_TEXT("(%P|%t) blob_to_locators: ")
00189                       ACE_TEXT("Failed to deserialize blob's inline QoS flag\n")),
00190                       DDS::RETCODE_ERROR);
00191   }
00192   return DDS::RETCODE_OK;
00193 }

template<typename T>

void OpenDDS::RTPS::message_block_to_sequence	(	const ACE_Message_Block &	mb_locator,
		T &	out
	)

Definition at line 197 of file BaseMessageUtils.h.

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

00198 {
00199   out.length (CORBA::ULong(mb_locator.length()));
00200   std::memcpy (out.get_buffer(), mb_locator.rd_ptr(), mb_locator.length());
00201 }

void OpenDDS::RTPS::locators_to_blob	(	const OpenDDS::DCPS::LocatorSeq &	locators,
		DCPS::TransportBLOB &	blob
	)			`[inline]`

Definition at line 204 of file BaseMessageUtils.h.

References OpenDDS::DCPS::gen_find_size(), and message_block_to_sequence().

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

00205 {
00206   using OpenDDS::DCPS::Serializer;
00207   size_t size_locator = 0, padding_locator = 0;
00208   DCPS::gen_find_size(locators, size_locator, padding_locator);
00209   ACE_Message_Block mb_locator(size_locator + padding_locator + 1);
00210   Serializer ser_loc(&mb_locator, ACE_CDR_BYTE_ORDER, Serializer::ALIGN_CDR);
00211   ser_loc << locators;
00212   // Add a bool for 'requires inline qos', see Sedp::set_inline_qos():
00213   // if the bool is no longer the last octet of the sequence then that function
00214   // must be changed as well.
00215   ser_loc << ACE_OutputCDR::from_boolean(false);
00216   message_block_to_sequence(mb_locator, blob);
00217 }

void OpenDDS::RTPS::@32::add_param	(	ParameterList &	param_list,
		const Parameter &	param
	)			`[static]`

Definition at line 23 of file ParameterListConverter.cpp.

Referenced by add_param_dcps_locator(), add_param_locator_seq(), add_param_rtps_locator(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

00023                                                                     {
00024     CORBA::ULong length = param_list.length();
00025     param_list.length(length + 1);
00026     param_list[length] = param;
00027   }

void OpenDDS::RTPS::@32::add_param_locator_seq	(	ParameterList &	param_list,
		const OpenDDS::DCPS::LocatorSeq &	locator_seq,
		const ParameterId_t	pid
	)			`[static]`

Definition at line 29 of file ParameterListConverter.cpp.

References add_param().

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

00031                                                       {
00032     CORBA::ULong length = locator_seq.length();
00033     for (CORBA::ULong i = 0; i < length; ++i) {
00034       Parameter param;
00035       param.locator(locator_seq[i]);
00036       param._d(pid);
00037       add_param(param_list, param);
00038     }
00039   }

void OpenDDS::RTPS::@32::add_param_rtps_locator	(	ParameterList &	param_list,
		const DCPS::TransportLocator &	dcps_locator,
		bool	map
	)			`[static]`

Definition at line 41 of file ParameterListConverter.cpp.

References add_param(), blob_to_locators(), OpenDDS::DCPS::TransportLocator::data, locator_to_address(), PID_MULTICAST_LOCATOR, PID_UNICAST_LOCATOR, and DDS::RETCODE_OK.

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

00043                                                                   {
00044     // Convert the tls blob to an RTPS locator seq
00045     OpenDDS::DCPS::LocatorSeq locators;
00046     bool ignore_requires_inline_qos;
00047     DDS::ReturnCode_t result = blob_to_locators(dcps_locator.data, locators,
00048                                                 ignore_requires_inline_qos);
00049     if (result == DDS::RETCODE_OK) {
00050       CORBA::ULong locators_len = locators.length();
00051       for (CORBA::ULong i = 0; i < locators_len; ++i) {
00052         OpenDDS::DCPS::Locator_t& rtps_locator = locators[i];
00053         ACE_INET_Addr address;
00054         if (locator_to_address(address, rtps_locator, map) == 0) {
00055           Parameter param;
00056           param.locator(rtps_locator);
00057           if (address.is_multicast()) {
00058             param._d(PID_MULTICAST_LOCATOR);
00059           } else {
00060             param._d(PID_UNICAST_LOCATOR);
00061           }
00062           add_param(param_list, param);
00063         }
00064       }
00065     } else {
00066       ACE_DEBUG((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: add_param_rtps_locator - ")
00067                            ACE_TEXT("Unable to convert dcps_rtps ")
00068                            ACE_TEXT("TransportLocator blob to LocatorSeq\n")));
00069     }
00070   }

void OpenDDS::RTPS::@32::add_param_dcps_locator	(	ParameterList &	param_list,
		const DCPS::TransportLocator &	dcps_locator
	)			`[static]`

Definition at line 72 of file ParameterListConverter.cpp.

References add_param(), OpenDDS::RTPS::Parameter::opendds_locator, and PID_OPENDDS_LOCATOR.

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

00073                                                                 {
00074     Parameter param;
00075     param.opendds_locator(dcps_locator);
00076     param._d(PID_OPENDDS_LOCATOR);
00077     add_param(param_list, param);
00078   }

void OpenDDS::RTPS::@32::append_locator	(	OpenDDS::DCPS::LocatorSeq &	list,
		const OpenDDS::DCPS::Locator_t &	locator
	)			`[static]`

Definition at line 80 of file ParameterListConverter.cpp.

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

00080                                                                                         {
00081     CORBA::ULong length = list.length();
00082     list.length(length + 1);
00083     list[length] = locator;
00084   }

void OpenDDS::RTPS::@32::append_locator	(	OpenDDS::DCPS::TransportLocatorSeq &	list,
		const OpenDDS::DCPS::TransportLocator &	locator
	)			`[static]`

Definition at line 86 of file ParameterListConverter.cpp.

00088                                                   {
00089     CORBA::ULong length = list.length();
00090     list.length(length + 1);
00091     list[length] = locator;
00092   }

void OpenDDS::RTPS::@32::append_locators_if_present	(	OpenDDS::DCPS::TransportLocatorSeq &	list,
		const OpenDDS::DCPS::LocatorSeq &	rtps_udp_locators
	)			`[static]`

Definition at line 94 of file ParameterListConverter.cpp.

References locators_to_blob().

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

00096                                                       {
00097     if (rtps_udp_locators.length()) {
00098       CORBA::ULong length = list.length();
00099       list.length(length + 1);
00100       list[length].transport_type = "rtps_udp";
00101       locators_to_blob(rtps_udp_locators, list[length].data);
00102     }
00103   }

void OpenDDS::RTPS::@32::append_associated_writer	(	OpenDDS::DCPS::DiscoveredReaderData &	reader_data,
		const Parameter &	param
	)			`[static]`

Definition at line 111 of file ParameterListConverter.cpp.

References OpenDDS::RTPS::Parameter::guid, and OpenDDS::DCPS::DiscoveredReaderData::readerProxy.

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

00113   {
00114     CORBA::ULong len = reader_data.readerProxy.associatedWriters.length();
00115     reader_data.readerProxy.associatedWriters.length(len + 1);
00116     reader_data.readerProxy.associatedWriters[len] = param.guid();
00117   }

void OpenDDS::RTPS::@32::set_ipaddress	(	OpenDDS::DCPS::LocatorSeq &	locators,
		LocatorState &	last_state,
		const unsigned long	addr
	)			`[static]`

Definition at line 119 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::Locator_t::address, assign(), OpenDDS::DCPS::Locator_t::kind, locator_address_only, locator_complete, and LOCATOR_KIND_UDPv4.

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

00121                                                {
00122     CORBA::ULong length = locators.length();
00123     // Update last locator if the last state is port only
00124     if (last_state == locator_port_only && length > 0) {
00125       // Update last locator
00126       OpenDDS::DCPS::Locator_t& partial = locators[length - 1];
00127       OpenDDS::RTPS::assign(partial.address, addr);
00128       // there is no longer a partially complete locator, set state
00129       last_state = locator_complete;
00130     // Else there is no partially complete locator available
00131     } else {
00132       // initialize and append new locator
00133       OpenDDS::DCPS::Locator_t locator;
00134       locator.kind = LOCATOR_KIND_UDPv4;
00135       locator.port = 0;
00136       OpenDDS::RTPS::assign(locator.address, addr);
00137       locators.length(length + 1);
00138       locators[length] = locator;
00139       // there is now a paritally complete locator, set state
00140       last_state = locator_address_only;
00141     }
00142   }

void OpenDDS::RTPS::@32::set_port	(	OpenDDS::DCPS::LocatorSeq &	locators,
		LocatorState &	last_state,
		const unsigned long	port
	)			`[static]`

Definition at line 144 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::Locator_t::address, assign(), OpenDDS::DCPS::Locator_t::kind, locator_address_only, locator_complete, and LOCATOR_KIND_UDPv4.

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

00146                                           {
00147     CORBA::ULong length = locators.length();
00148     // Update last locator if the last state is address only
00149     if (last_state == locator_address_only && length > 0) {
00150       // Update last locator
00151       OpenDDS::DCPS::Locator_t& partial = locators[length - 1];
00152       partial.port = port;
00153       // there is no longer a partially complete locator, set state
00154       last_state = locator_complete;
00155     // Else there is no partially complete locator available
00156     } else {
00157       // initialize and append new locator
00158       OpenDDS::DCPS::Locator_t locator;
00159       locator.kind = LOCATOR_KIND_UDPv4;
00160       locator.port = port;
00161       OpenDDS::RTPS::assign(locator.address, 0);
00162       locators.length(length + 1);
00163       locators[length] = locator;
00164       // there is now a paritally complete locator, set state
00165       last_state = locator_port_only;
00166     }
00167   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::UserDataQosPolicy & qos ) [static]

Definition at line 169 of file ParameterListConverter.cpp.

References TheServiceParticipant.

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

00169                                                     {
00170     DDS::UserDataQosPolicy def_qos =
00171         TheServiceParticipant->initial_UserDataQosPolicy();
00172     return qos != def_qos;
00173   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::GroupDataQosPolicy & qos ) [static]

Definition at line 174 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00174                                                      {
00175     DDS::GroupDataQosPolicy def_qos =
00176         TheServiceParticipant->initial_GroupDataQosPolicy();
00177     return qos != def_qos;
00178   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::TopicDataQosPolicy & qos ) [static]

Definition at line 179 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00179                                                      {
00180     DDS::TopicDataQosPolicy def_qos =
00181         TheServiceParticipant->initial_TopicDataQosPolicy();
00182     return qos != def_qos;
00183   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::DurabilityQosPolicy & qos ) [static]

Definition at line 184 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00184                                                       {
00185     DDS::DurabilityQosPolicy def_qos =
00186         TheServiceParticipant->initial_DurabilityQosPolicy();
00187     return qos != def_qos;
00188   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::DurabilityServiceQosPolicy & qos ) [static]

Definition at line 189 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00189                                                              {
00190     DDS::DurabilityServiceQosPolicy def_qos =
00191         TheServiceParticipant->initial_DurabilityServiceQosPolicy();
00192     return qos != def_qos;
00193   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::LifespanQosPolicy & qos ) [static]

Definition at line 194 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00194                                                     {
00195     DDS::LifespanQosPolicy def_qos =
00196         TheServiceParticipant->initial_LifespanQosPolicy();
00197     return qos != def_qos;
00198   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::DeadlineQosPolicy & qos ) [static]

Definition at line 199 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00199                                                     {
00200     DDS::DeadlineQosPolicy def_qos =
00201         TheServiceParticipant->initial_DeadlineQosPolicy();
00202     return qos != def_qos;
00203   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::LatencyBudgetQosPolicy & qos ) [static]

Definition at line 204 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00204                                                          {
00205     DDS::LatencyBudgetQosPolicy def_qos =
00206         TheServiceParticipant->initial_LatencyBudgetQosPolicy();
00207     return qos != def_qos;
00208   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::LivelinessQosPolicy & qos ) [static]

Definition at line 209 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00209                                                       {
00210     DDS::LivelinessQosPolicy def_qos =
00211         TheServiceParticipant->initial_LivelinessQosPolicy();
00212     return qos != def_qos;
00213   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::OwnershipQosPolicy & qos ) [static]

Definition at line 214 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00214                                                      {
00215     DDS::OwnershipQosPolicy def_qos =
00216         TheServiceParticipant->initial_OwnershipQosPolicy();
00217     return qos != def_qos;
00218   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::OwnershipStrengthQosPolicy & qos ) [static]

Definition at line 219 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00219                                                              {
00220 #ifdef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
00221     ACE_UNUSED_ARG(qos);
00222     return false;
00223 #else
00224     DDS::OwnershipStrengthQosPolicy def_qos =
00225         TheServiceParticipant->initial_OwnershipStrengthQosPolicy();
00226     return qos != def_qos;
00227 #endif
00228   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::DestinationOrderQosPolicy & qos ) [static]

Definition at line 229 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00229                                                             {
00230     DDS::DestinationOrderQosPolicy def_qos =
00231         TheServiceParticipant->initial_DestinationOrderQosPolicy();
00232     return qos != def_qos;
00233   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::PresentationQosPolicy & qos ) [static]

Definition at line 234 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00234                                                         {
00235     DDS::PresentationQosPolicy def_qos =
00236         TheServiceParticipant->initial_PresentationQosPolicy();
00237     return qos != def_qos;
00238   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::PartitionQosPolicy & qos ) [static]

Definition at line 239 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00239                                                      {
00240     DDS::PartitionQosPolicy def_qos =
00241         TheServiceParticipant->initial_PartitionQosPolicy();
00242     return qos != def_qos;
00243   }

bool OpenDDS::RTPS::@32::not_default ( const DDS::TimeBasedFilterQosPolicy & qos ) [static]

Definition at line 245 of file ParameterListConverter.cpp.

References TheServiceParticipant.

00246   {
00247     DDS::TimeBasedFilterQosPolicy def_qos =
00248       TheServiceParticipant->initial_TimeBasedFilterQosPolicy();
00249     return qos != def_qos;
00250   }

bool OpenDDS::RTPS::@32::not_default ( const OpenDDS::DCPS::ContentFilterProperty_t & cfprop ) [static]

Definition at line 252 of file ParameterListConverter.cpp.

References OpenDDS::DCPS::ContentFilterProperty_t::filterExpression.

00253   {
00254     return std::strlen(cfprop.filterExpression);
00255   }

void OpenDDS::RTPS::@32::normalize ( DDS::Duration_t & dur ) [static]

Definition at line 257 of file ParameterListConverter.cpp.

References DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, DDS::Duration_t::nanosec, DDS::Duration_t::sec, and DDS::TIME_INVALID_NSEC.

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

00258   {
00259     // Interoperability note:
00260     // Some other DDS implementations were observed sending
00261     // "infinite" durations using 0xffffffff nanoseconds
00262     if (dur.sec == DDS::DURATION_INFINITE_SEC &&
00263         dur.nanosec == DDS::TIME_INVALID_NSEC) {
00264       dur.nanosec = DDS::DURATION_INFINITE_NSEC;
00265     }
00266   }

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

Definition at line 372 of file Sedp.cpp.

References OpenDDS::RTPS::ParticipantProxy_t::guidPrefix, message_block_to_sequence(), OpenDDS::RTPS::ParticipantProxy_t::metatrafficMulticastLocatorList, OpenDDS::RTPS::ParticipantProxy_t::metatrafficUnicastLocatorList, OpenDDS::RTPS::SPDPdiscoveredParticipantData::participantProxy, OpenDDS::DCPS::AssociationData::publication_transport_priority_, OpenDDS::DCPS::AssociationData::remote_data_, OpenDDS::DCPS::AssociationData::remote_durable_, OpenDDS::DCPS::AssociationData::remote_id_, and OpenDDS::DCPS::AssociationData::remote_reliable_.

Referenced by OpenDDS::RTPS::Sedp::associate(), and OpenDDS::RTPS::Sedp::Task::svc_i().

00373                                                                           {
00374   proto.publication_transport_priority_ = 0;
00375   proto.remote_reliable_ = true;
00376   proto.remote_durable_ = true;
00377   std::memcpy(proto.remote_id_.guidPrefix, pdata.participantProxy.guidPrefix,
00378               sizeof(GuidPrefix_t));
00379 
00380   const OpenDDS::DCPS::LocatorSeq& mll =
00381     pdata.participantProxy.metatrafficMulticastLocatorList;
00382   const OpenDDS::DCPS::LocatorSeq& ull =
00383     pdata.participantProxy.metatrafficUnicastLocatorList;
00384   const CORBA::ULong locator_count = mll.length() + ull.length();
00385 
00386   ACE_Message_Block mb_locator(4 + locator_count * sizeof(OpenDDS::DCPS::Locator_t) + 1);
00387   using DCPS::Serializer;
00388   Serializer ser_loc(&mb_locator, ACE_CDR_BYTE_ORDER, Serializer::ALIGN_CDR);
00389   ser_loc << locator_count;
00390 
00391   for (CORBA::ULong i = 0; i < mll.length(); ++i) {
00392     ser_loc << mll[i];
00393   }
00394   for (CORBA::ULong i = 0; i < ull.length(); ++i) {
00395     ser_loc << ull[i];
00396   }
00397   ser_loc << ACE_OutputCDR::from_boolean(false); // requires_inline_qos
00398 
00399   proto.remote_data_.length(1);
00400   proto.remote_data_[0].transport_type = "rtps_udp";
00401   message_block_to_sequence (mb_locator, proto.remote_data_[0].data);
00402 }

static bool OpenDDS::RTPS::decode_parameter_list	(	const DCPS::ReceivedDataSample &	sample,
		DCPS::Serializer &	ser,
		const ACE_CDR::Octet &	encap,
		ParameterList &	data
	)			`[static]`

Definition at line 1654 of file Sedp.cpp.

References OpenDDS::DCPS::ReceivedDataSample::header_, and PID_ENDPOINT_GUID.

Referenced by OpenDDS::RTPS::Sedp::Reader::data_received().

01658 {
01659   bool ok = true;
01660   if (ok && sample.header_.key_fields_only_ && encap < 2) {
01661     GUID_t guid;
01662     ok &= (ser >> guid);
01663     data.length(1);
01664     data[0].guid(guid);
01665     data[0]._d(PID_ENDPOINT_GUID);
01666   } else {
01667     ok &= (ser >> data);
01668   }
01669   return ok;
01670 }

bool OpenDDS::RTPS::@38::disposed ( const ParameterList & inlineQos ) [static]

Definition at line 40 of file Spdp.cpp.

References PID_STATUS_INFO.

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

00041   {
00042     for (CORBA::ULong i = 0; i < inlineQos.length(); ++i) {
00043       if (inlineQos[i]._d() == PID_STATUS_INFO) {
00044         return inlineQos[i].status_info().value[3] & 1;
00045       }
00046     }
00047     return false;
00048   }

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

Definition at line 46 of file RtpsSampleHeader.cpp.

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

00047 {
00048   return
00049     (lhs.value[3] == rhs.value[3]) &&
00050     (lhs.value[2] == rhs.value[2]) &&
00051     (lhs.value[1] == rhs.value[1]) &&
00052     (lhs.value[0] == rhs.value[0]);
00053 }

Variable Documentation

const Time_t OpenDDS::RTPS::TIME_ZERO = { 0, 0 }

Definition at line 17 of file BaseMessageTypes.h.

const Time_t OpenDDS::RTPS::TIME_INVALID = { -1, 0xffffffff }

Definition at line 18 of file BaseMessageTypes.h.

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

const Time_t OpenDDS::RTPS::TIME_INFINITE = { 0x7fffffff, 0xffffffff }

Definition at line 19 of file BaseMessageTypes.h.

const double OpenDDS::RTPS::NANOS_TO_RTPS_FRACS = 4.294967296

Definition at line 22 of file BaseMessageTypes.h.

Referenced by OpenDDS::DCPS::add_timestamp(), and OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::fill_header().

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

Definition at line 24 of file BaseMessageTypes.h.

const VendorId_t OpenDDS::RTPS::VENDORID_OPENDDS

Initial value:

      { { OpenDDS::DCPS::VENDORID_OCI[0], OpenDDS::DCPS::VENDORID_OCI[1] } }

Definition at line 25 of file BaseMessageTypes.h.

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

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

Definition at line 45 of file BaseMessageTypes.h.

Referenced by OpenDDS::DCPS::DataWriterImpl::create_control_message(), OpenDDS::DCPS::DisjointSequence::cumulative_ack(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element(), OpenDDS::DCPS::DisjointSequence::last_ack(), OpenDDS::DCPS::TransportQueueElement::sequence(), and OpenDDS::DCPS::TransportCustomizedElement::sequence().

const OpenDDS::DCPS::Locator_t OpenDDS::RTPS::LOCATOR_INVALID

Initial value:

      { LOCATOR_KIND_INVALID, LOCATOR_PORT_INVALID, { 0 } }

Definition at line 47 of file BaseMessageTypes.h.

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

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

Definition at line 49 of file BaseMessageTypes.h.

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

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

Definition at line 51 of file BaseMessageTypes.h.

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

Definition at line 53 of file BaseMessageTypes.h.

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

Definition at line 54 of file BaseMessageTypes.h.

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

Definition at line 55 of file BaseMessageTypes.h.

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

Definition at line 56 of file BaseMessageTypes.h.

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

Definition at line 57 of file BaseMessageTypes.h.

const ProtocolVersion_t OpenDDS::RTPS::PROTOCOLVERSION = PROTOCOLVERSION_2_2

Definition at line 58 of file BaseMessageTypes.h.

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

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

Definition at line 17 of file MessageTypes.h.

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

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

Definition at line 18 of file MessageTypes.h.

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

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

Definition at line 20 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpSendStrategy::marshal_transport_header(), and OpenDDS::DCPS::RtpsTransportHeader::max_marshaled_size().

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

Definition at line 21 of file MessageTypes.h.

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

Definition at line 22 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeats_manual().

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

Definition at line 23 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::add_gap_submsg(), OpenDDS::DCPS::RtpsUdpDataLink::marshal_gaps(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::RtpsUdpDataLink::send_ack_nacks(), OpenDDS::DCPS::RtpsUdpDataLink::send_durability_gaps(), and OpenDDS::DCPS::RtpsUdpDataLink::send_heartbeat_replies().

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

Definition at line 24 of file MessageTypes.h.

Referenced by OpenDDS::DCPS::add_timestamp().

const OctetArray4 OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_UNKNOWN

Initial value:

        { 0x00, 0x00, 0x00, 0x00 }

Definition at line 27 of file MessageTypes.h.

const OctetArray4 OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE

Initial value:

        { 0x00, 0x00, 0x00, 0x01 }

Definition at line 29 of file MessageTypes.h.

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

const OctetArray4 OpenDDS::RTPS::PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE

Initial value:

        { 0x00, 0x00, 0x00, 0x02 }

Definition at line 31 of file MessageTypes.h.

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

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

Definition at line 93 of file RtpsCore.idl.

const long OpenDDS::RTPS::LOCATOR_KIND_RESERVED = 0

Definition at line 94 of file RtpsCore.idl.

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv4 = 1

Definition at line 95 of file RtpsCore.idl.

Referenced by address_to_kind(), locator_to_address(), set_ipaddress(), set_port(), OpenDDS::DCPS::RtpsUdpReceiveStrategy::MessageReceiver::submsg(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const long OpenDDS::RTPS::LOCATOR_KIND_UDPv6 = 2

Definition at line 96 of file RtpsCore.idl.

Referenced by address_to_kind(), and locator_to_address().

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

Definition at line 97 of file RtpsCore.idl.

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

const short OpenDDS::RTPS::NO_KEY = 1

Definition at line 116 of file RtpsCore.idl.

const short OpenDDS::RTPS::WITH_KEY = 2

Definition at line 117 of file RtpsCore.idl.

const short OpenDDS::RTPS::BEST_EFFORT = 1

Definition at line 126 of file RtpsCore.idl.

const short OpenDDS::RTPS::RELIABLE = 3

Definition at line 127 of file RtpsCore.idl.

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_ANNOUNCER

Initial value:

      1 << 0

Definition at line 152 of file RtpsCore.idl.

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

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_DETECTOR

Initial value:

      1 << 1

Definition at line 154 of file RtpsCore.idl.

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

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_ANNOUNCER

Initial value:

      1 << 2

Definition at line 156 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PUBLICATION_DETECTOR

Initial value:

      1 << 3

Definition at line 158 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::Task::svc_i(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_ANNOUNCER

Initial value:

      1 << 4

Definition at line 160 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_SUBSCRIPTION_DETECTOR

Initial value:

      1 << 5

Definition at line 162 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::Task::svc_i(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_ANNOUNCER

Initial value:

      1 << 6

Definition at line 164 of file RtpsCore.idl.

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_PROXY_DETECTOR

Initial value:

      1 << 7

Definition at line 166 of file RtpsCore.idl.

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_ANNOUNCER

Initial value:

      1 << 8

Definition at line 168 of file RtpsCore.idl.

const BuiltinEndpointSet_t OpenDDS::RTPS::DISC_BUILTIN_ENDPOINT_PARTICIPANT_STATE_DETECTOR

Initial value:

      1 << 9

Definition at line 170 of file RtpsCore.idl.

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_WRITER

Initial value:

      1 << 10

Definition at line 172 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::Sedp::disassociate(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const BuiltinEndpointSet_t OpenDDS::RTPS::BUILTIN_ENDPOINT_PARTICIPANT_MESSAGE_DATA_READER

Initial value:

      1 << 11

Definition at line 174 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Sedp::disassociate(), OpenDDS::RTPS::Sedp::Task::svc_i(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

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

Definition at line 193 of file RtpsCore.idl.

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

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

Definition at line 194 of file RtpsCore.idl.

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

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

Definition at line 195 of file RtpsCore.idl.

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

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

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

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

Definition at line 197 of file RtpsCore.idl.

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

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

Definition at line 198 of file RtpsCore.idl.

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

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

Definition at line 199 of file RtpsCore.idl.

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

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

Definition at line 200 of file RtpsCore.idl.

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

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

Definition at line 201 of file RtpsCore.idl.

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

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

Definition at line 202 of file RtpsCore.idl.

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

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

Definition at line 203 of file RtpsCore.idl.

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

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

Definition at line 204 of file RtpsCore.idl.

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

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

Definition at line 205 of file RtpsCore.idl.

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

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

Definition at line 206 of file RtpsCore.idl.

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

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

Definition at line 207 of file RtpsCore.idl.

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

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

Definition at line 208 of file RtpsCore.idl.

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

Definition at line 209 of file RtpsCore.idl.

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

Definition at line 210 of file RtpsCore.idl.

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

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

Definition at line 211 of file RtpsCore.idl.

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

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

Definition at line 212 of file RtpsCore.idl.

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

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

Definition at line 213 of file RtpsCore.idl.

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

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

Definition at line 214 of file RtpsCore.idl.

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

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

Definition at line 215 of file RtpsCore.idl.

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

Definition at line 216 of file RtpsCore.idl.

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

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

Definition at line 217 of file RtpsCore.idl.

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

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

Definition at line 218 of file RtpsCore.idl.

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

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

Definition at line 219 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_MULTICAST_IPADDRESS = 0x0011

Definition at line 220 of file RtpsCore.idl.

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

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

Definition at line 221 of file RtpsCore.idl.

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

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

Definition at line 222 of file RtpsCore.idl.

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

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

Definition at line 223 of file RtpsCore.idl.

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

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

Definition at line 224 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_DEFAULT_UNICAST_IPADDRESS = 0x000c

Definition at line 225 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_DEFAULT_UNICAST_PORT = 0x000e

Definition at line 226 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_IPADDRESS = 0x0045

Definition at line 227 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_UNICAST_PORT = 0x000d

Definition at line 228 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_IPADDRESS = 0x000b

Definition at line 229 of file RtpsCore.idl.

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

const ParameterId_t OpenDDS::RTPS::PID_METATRAFFIC_MULTICAST_PORT = 0x0046

Definition at line 230 of file RtpsCore.idl.

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

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

Definition at line 231 of file RtpsCore.idl.

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

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

Definition at line 232 of file RtpsCore.idl.

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

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

Definition at line 233 of file RtpsCore.idl.

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

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

Definition at line 234 of file RtpsCore.idl.

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

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

Definition at line 235 of file RtpsCore.idl.

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

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

Definition at line 236 of file RtpsCore.idl.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), and OpenDDS::RTPS::ParameterListConverter::to_param_list().

const ParameterId_t OpenDDS::RTPS::PID_PARTICIPANT_ENTITYID = 0x0051

Definition at line 237 of file RtpsCore.idl.

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

Definition at line 238 of file RtpsCore.idl.

const ParameterId_t OpenDDS::RTPS::PID_GROUP_ENTITYID = 0x0053

Definition at line 239 of file RtpsCore.idl.

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

Definition at line 240 of file RtpsCore.idl.

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

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

Definition at line 241 of file RtpsCore.idl.

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

Definition at line 242 of file RtpsCore.idl.

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

Definition at line 243 of file RtpsCore.idl.

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

Definition at line 244 of file RtpsCore.idl.

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

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

Definition at line 245 of file RtpsCore.idl.

Referenced by disposed(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

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

Definition at line 247 of file RtpsCore.idl.

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

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

Definition at line 249 of file RtpsCore.idl.

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

Definition at line 250 of file RtpsCore.idl.

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

Definition at line 251 of file RtpsCore.idl.

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

Definition at line 252 of file RtpsCore.idl.

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

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

Definition at line 255 of file RtpsCore.idl.

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

Definition at line 256 of file RtpsCore.idl.

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

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

Definition at line 263 of file RtpsCore.idl.

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

Definition at line 264 of file RtpsCore.idl.

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

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

Definition at line 265 of file RtpsCore.idl.

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

const ACE_TCHAR OpenDDS::RTPS::RTPS_SECTION_NAME[] = ACE_TEXT("rtps_discovery") [static]

Definition at line 60 of file RtpsDiscovery.cpp.

Referenced by OpenDDS::RTPS::RtpsDiscovery::Config::discovery_config().

RtpsDiscovery::StaticInitializer OpenDDS::RTPS::initialize_rtps [static]

Definition at line 148 of file RtpsDiscovery.h.

const int OpenDDS::RTPS::LEASE_MULT = 10 [static]

Definition at line 36 of file Spdp.cpp.

const CORBA::UShort OpenDDS::RTPS::encap_LE = 0x0300 [static]

Definition at line 37 of file Spdp.cpp.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::dispose_unregister(), OpenDDS::RTPS::Spdp::SpdpTransport::handle_input(), and OpenDDS::RTPS::Spdp::SpdpTransport::write_i().

const CORBA::UShort OpenDDS::RTPS::encap_BE = 0x0200 [static]

Definition at line 38 of file Spdp.cpp.

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

Generated on Fri Feb 12 20:06:48 2016 for OpenDDS by

1.4.7


Classes
class	GuidGenerator
struct	ContentFilterInfo_t
struct	Property_t
struct	EntityName_t
struct	Count_t
struct	SequenceNumber_t
struct	SequenceNumberSet
struct	Time_t
struct	LocatorUDPv4_t
struct	TopicKind_t
struct	ReliabilityKind_t
struct	KeyHash_t
struct	StatusInfo_t
struct	ProtocolVersion_t
struct	VendorId_t
struct	OriginalWriterInfo_t
union	Parameter
struct	SubmessageHeader
struct	FragmentNumber_t
struct	FragmentNumberSet
struct	AckNackSubmessage
struct	GapSubmessage
struct	InfoReplySubmessage
struct	NackFragSubmessage
struct	ParticipantProxy_t
struct	SPDPdiscoveredParticipantData
struct	ParticipantMessageData
struct	Header
struct	DataSubmessage
struct	DataFragSubmessage
struct	HeartBeatSubmessage
struct	HeartBeatFragSubmessage
struct	InfoDestinationSubmessage
struct	InfoSourceSubmessage
struct	InfoTimestampSubmessage
struct	PadSubmessage
struct	InfoReplyIp4Submessage
union	Submessage
struct	DiscoveredTopicData
class	RtpsDiscovery
	Discovery Strategy class that implements RTPS discovery. More...
class	Sedp
class	WaitForAcks
	A class to wait on acknowledgments from other threads. More...
class	Spdp
Namespaces
namespace	ParameterListConverter
Typedefs
typedef octet	OctetArray2 [2]
typedef octet	OctetArray4 [4]
typedef long	FilterSignature_t [4]
typedef sequence< long >	FilterResult_t
typedef sequence< FilterSignature_t >	FilterSignatureSeq
typedef sequence< Property_t >	PropertySeq
typedef sequence< long, 8 >	LongSeq8
typedef sequence< OpenDDS::DCPS::Locator_t, 8 >	LocatorList
typedef Time_t	Timestamp_t
typedef Time_t	Duration_t
typedef unsigned long	BuiltinEndpointSet_t
typedef sequence< Parameter >	ParameterList
typedef unsigned short	ParameterId_t
typedef sequence< Submessage >	SubmessageSeq
typedef OpenDDS::DCPS::RcHandle< RtpsDiscovery >	RtpsDiscovery_rch
Enumerations
enum	SubmessageKind { RESERVED_0, 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 }
enum	RtpsFlags { FLAG_E = 1, FLAG_Q = 2, FLAG_D = 4 }
Functions
template<typename T>
void	marshal_key_hash (const T &msg, KeyHash_t &hash)
void	assign (GuidPrefix_t &dest, const GuidPrefix_t &src)
void	assign (OpenDDS::DCPS::OctetArray16 &dest, const OpenDDS::DCPS::OctetArray16 &src)
void	assign (OpenDDS::DCPS::OctetArray16 &dest, const ACE_CDR::ULong &ipv4addr_be)
void	assign (DCPS::EntityKey_t &lhs, unsigned int rhs)
void	address_to_bytes (OpenDDS::DCPS::OctetArray16 &dest, const ACE_INET_Addr &addr)
int	address_to_kind (const ACE_INET_Addr &addr)
int	locator_to_address (ACE_INET_Addr &dest, const OpenDDS::DCPS::Locator_t &locator, bool map)
DDS::ReturnCode_t	blob_to_locators (const OpenDDS::DCPS::TransportBLOB &blob, OpenDDS::DCPS::LocatorSeq &locators, bool &requires_inline_qos)
template<typename T>
void	message_block_to_sequence (const ACE_Message_Block &mb_locator, T &out)
void	locators_to_blob (const OpenDDS::DCPS::LocatorSeq &locators, DCPS::TransportBLOB &blob)
void	add_param (ParameterList &param_list, const Parameter &param)
void	add_param_locator_seq (ParameterList &param_list, const OpenDDS::DCPS::LocatorSeq &locator_seq, const ParameterId_t pid)
void	add_param_rtps_locator (ParameterList &param_list, const DCPS::TransportLocator &dcps_locator, bool map)
void	add_param_dcps_locator (ParameterList &param_list, const DCPS::TransportLocator &dcps_locator)
void	append_locator (OpenDDS::DCPS::LocatorSeq &list, const OpenDDS::DCPS::Locator_t &locator)
void	append_locator (OpenDDS::DCPS::TransportLocatorSeq &list, const OpenDDS::DCPS::TransportLocator &locator)
void	append_locators_if_present (OpenDDS::DCPS::TransportLocatorSeq &list, const OpenDDS::DCPS::LocatorSeq &rtps_udp_locators)
void	append_associated_writer (OpenDDS::DCPS::DiscoveredReaderData &reader_data, const Parameter &param)
void	set_ipaddress (OpenDDS::DCPS::LocatorSeq &locators, LocatorState &last_state, const unsigned long addr)
void	set_port (OpenDDS::DCPS::LocatorSeq &locators, LocatorState &last_state, const unsigned long port)
bool	not_default (const DDS::UserDataQosPolicy &qos)
bool	not_default (const DDS::GroupDataQosPolicy &qos)
bool	not_default (const DDS::TopicDataQosPolicy &qos)
bool	not_default (const DDS::DurabilityQosPolicy &qos)
bool	not_default (const DDS::DurabilityServiceQosPolicy &qos)
bool	not_default (const DDS::LifespanQosPolicy &qos)
bool	not_default (const DDS::DeadlineQosPolicy &qos)
bool	not_default (const DDS::LatencyBudgetQosPolicy &qos)
bool	not_default (const DDS::LivelinessQosPolicy &qos)
bool	not_default (const DDS::OwnershipQosPolicy &qos)
bool	not_default (const DDS::OwnershipStrengthQosPolicy &qos)
bool	not_default (const DDS::DestinationOrderQosPolicy &qos)
bool	not_default (const DDS::PresentationQosPolicy &qos)
bool	not_default (const DDS::PartitionQosPolicy &qos)
bool	not_default (const DDS::TimeBasedFilterQosPolicy &qos)
bool	not_default (const OpenDDS::DCPS::ContentFilterProperty_t &cfprop)
void	normalize (DDS::Duration_t &dur)
void	create_association_data_proto (DCPS::AssociationData &proto, const SPDPdiscoveredParticipantData &pdata)
static bool	decode_parameter_list (const DCPS::ReceivedDataSample &sample, DCPS::Serializer &ser, const ACE_CDR::Octet &encap, ParameterList &data)
bool	disposed (const ParameterList &inlineQos)
bool	operator== (const StatusInfo_t &lhs, const StatusInfo_t &rhs)
Variables
const Time_t	TIME_ZERO = { 0, 0 }
const Time_t	TIME_INVALID = { -1, 0xffffffff }
const Time_t	TIME_INFINITE = { 0x7fffffff, 0xffffffff }
const double	NANOS_TO_RTPS_FRACS = 4.294967296
const VendorId_t	VENDORID_UNKNOWN = { { 0 } }
const VendorId_t	VENDORID_OPENDDS
const SequenceNumber_t	SEQUENCENUMBER_UNKNOWN = { -1, 0 }
const OpenDDS::DCPS::Locator_t	LOCATOR_INVALID
const OpenDDS::DCPS::OctetArray16	LOCATOR_ADDRESS_INVALID = { 0 }
const LocatorUDPv4_t	LOCATORUDPv4_INVALID = { 0, 0 }
const 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 = PROTOCOLVERSION_2_2
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 OctetArray4	PARTICIPANT_MESSAGE_DATA_KIND_UNKNOWN
const OctetArray4	PARTICIPANT_MESSAGE_DATA_KIND_AUTOMATIC_LIVELINESS_UPDATE
const OctetArray4	PARTICIPANT_MESSAGE_DATA_KIND_MANUAL_LIVELINESS_UPDATE
const long	LOCATOR_KIND_INVALID = -1
const long	LOCATOR_KIND_RESERVED = 0
const long	LOCATOR_KIND_UDPv4 = 1
const long	LOCATOR_KIND_UDPv6 = 2
const unsigned long	LOCATOR_PORT_INVALID = 0
const short	NO_KEY = 1
const short	WITH_KEY = 2
const short	BEST_EFFORT = 1
const short	RELIABLE = 3
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 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_MULTICAST_IPADDRESS = 0x0011
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_DEFAULT_UNICAST_IPADDRESS = 0x000c
const ParameterId_t	PID_DEFAULT_UNICAST_PORT = 0x000e
const ParameterId_t	PID_METATRAFFIC_UNICAST_IPADDRESS = 0x0045
const ParameterId_t	PID_METATRAFFIC_UNICAST_PORT = 0x000d
const ParameterId_t	PID_METATRAFFIC_MULTICAST_IPADDRESS = 0x000b
const ParameterId_t	PID_METATRAFFIC_MULTICAST_PORT = 0x0046
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_PARTICIPANT_ENTITYID = 0x0051
const ParameterId_t	PID_GROUP_GUID = 0x0052
const ParameterId_t	PID_GROUP_ENTITYID = 0x0053
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	PIDMASK_VENDOR_SPECIFIC = 0x8000
const ParameterId_t	PIDMASK_INCOMPATIBLE = 0x4000
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 ACE_TCHAR	RTPS_SECTION_NAME [] = ACE_TEXT("rtps_discovery")
static RtpsDiscovery::StaticInitializer	initialize_rtps
const int	LEASE_MULT = 10
const CORBA::UShort	encap_LE = 0x0300
const CORBA::UShort	encap_BE = 0x0200

OpenDDS::RTPS Namespace Reference

Classes

Namespaces

Typedefs

Enumerations

Functions

Variables

Typedef Documentation

Enumeration Type Documentation

Function Documentation

Variable Documentation