OpenDDS  Snapshot(2023/04/28-20:55)
Public Member Functions | Private Member Functions | List of all members
OpenDDS::RTPS::Sedp::DiscoveryReader Class Reference
Inheritance diagram for OpenDDS::RTPS::Sedp::DiscoveryReader:
Inheritance graph
[legend]
Collaboration diagram for OpenDDS::RTPS::Sedp::DiscoveryReader:
Collaboration graph
[legend]

Public Member Functions

 DiscoveryReader (const DCPS::GUID_t &sub_id, Sedp &sedp)
 
virtual ~DiscoveryReader ()
 
- Public Member Functions inherited from OpenDDS::RTPS::Sedp::Reader
 Reader (const DCPS::GUID_t &sub_id, Sedp &sedp)
 
virtual ~Reader ()
 
bool assoc (const DCPS::AssociationData &publication)
 
void data_received (const DCPS::ReceivedDataSample &sample)
 
void notify_subscription_disconnected (const DCPS::WriterIdSeq &)
 
void notify_subscription_reconnected (const DCPS::WriterIdSeq &)
 
void notify_subscription_lost (const DCPS::WriterIdSeq &)
 
void remove_associations (const DCPS::WriterIdSeq &, bool)
 
- Public Member Functions inherited from OpenDDS::DCPS::TransportReceiveListener
virtual ~TransportReceiveListener ()
 
virtual void transport_discovery_change ()
 
- Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual ~RcObject ()
 
virtual void _add_ref ()
 
virtual void _remove_ref ()
 
long ref_count () const
 
WeakObject * _get_weak_object () const
 
- Public Member Functions inherited from OpenDDS::RTPS::Sedp::Endpoint
 Endpoint (const DCPS::GUID_t &repo_id, Sedp &sedp)
 
virtual ~Endpoint ()
 
bool check_transport_qos (const DCPS::TransportInst &)
 
DCPS::GUID_t get_guid () const
 
DDS::DomainId_t domain_id () const
 
CORBA::Long get_priority_value (const DCPS::AssociationData &) const
 
void set_crypto_handles (DDS::Security::ParticipantCryptoHandle p, DDS::Security::NativeCryptoHandle e=DDS::HANDLE_NIL)
 
DDS::Security::ParticipantCryptoHandle get_crypto_handle () const
 
DDS::Security::NativeCryptoHandle get_endpoint_crypto_handle () const
 
void shutting_down ()
 
OPENDDS_STRING get_instance_name (const DCPS::GUID_t &id) const
 
EntityId_t counterpart_entity_id () const
 
GUID_t make_counterpart_guid (const DCPS::GUID_t &remote_part) const
 
bool associated_with_counterpart (const DCPS::GUID_t &remote_part) const
 
bool pending_association_with_counterpart (const DCPS::GUID_t &remote_part) const
 
bool associated_with_counterpart_if_not_pending (const DCPS::GUID_t &remote_part) const
 
RcHandle< DCPS::BitSubscriber > get_builtin_subscriber_proxy () const
 
- Public Member Functions inherited from OpenDDS::DCPS::TransportClient
void use_datalink (const GUID_t &remote_id, const DataLink_rch &link)
 
 TransportClient ()
 
virtual ~TransportClient ()
 
void enable_transport (bool reliable, bool durable)
 
void enable_transport_using_config (bool reliable, bool durable, const TransportConfig_rch &tc)
 
bool swap_bytes () const
 
bool cdr_encapsulation () const
 
const TransportLocatorSeq & connection_info () const
 
void populate_connection_info ()
 
bool is_reliable () const
 
bool associate (const AssociationData &peer, bool active)
 
void disassociate (const GUID_t &peerId)
 
void stop_associating ()
 
void stop_associating (const GUID_t *repos, CORBA::ULong length)
 
void send_final_acks ()
 
void transport_stop ()
 
void register_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid, const TransportLocatorSeq &locators, OpenDDS::DCPS::DiscoveryListener *listener)
 
void unregister_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid)
 
void register_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)
 
void unregister_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid)
 
void update_locators (const GUID_t &remote, const TransportLocatorSeq &locators)
 
WeakRcHandle< ICE::Endpoint > get_ice_endpoint ()
 
bool send_response (const GUID_t &peer, const DataSampleHeader &header, Message_Block_Ptr payload)
 
void send (SendStateDataSampleList send_list, ACE_UINT64 transaction_id=0)
 
SendControlStatus send_w_control (SendStateDataSampleList send_list, const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)
 
SendControlStatus send_control (const DataSampleHeader &header, Message_Block_Ptr msg)
 
SendControlStatus send_control_to (const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination)
 
bool remove_sample (const DataSampleElement *sample)
 
bool remove_all_msgs ()
 
virtual void add_link (const DataLink_rch &link, const GUID_t &peer)
 
void terminate_send_if_suspended ()
 
bool associated_with (const GUID_t &remote) const
 
bool pending_association_with (const GUID_t &remote) const
 
GUID_t repo_id () const
 
void data_acked (const GUID_t &remote)
 
bool is_leading (const GUID_t &reader_id) const
 

Private Member Functions

virtual void data_received_i (const DCPS::ReceivedDataSample &sample, const DCPS::EntityId_t &entity_id, DCPS::Serializer &ser, DCPS::Extensibility extensibility)
 

Additional Inherited Members

- Public Types inherited from OpenDDS::DCPS::TransportClient
enum  { ASSOC_OK = 1, ASSOC_ACTIVE = 2 }
 
- Protected Member Functions inherited from OpenDDS::DCPS::TransportReceiveListener
 TransportReceiveListener ()
 
- Protected Member Functions inherited from OpenDDS::DCPS::RcObject
 RcObject ()
 
- Protected Member Functions inherited from OpenDDS::DCPS::TransportClient
void cdr_encapsulation (bool encap)
 
- Protected Attributes inherited from OpenDDS::RTPS::Sedp::Endpoint
DCPS::GUID_t repo_id_
 
Sedp & sedp_
 
AtomicBool shutting_down_
 
DDS::Security::ParticipantCryptoHandle participant_crypto_handle_
 
DDS::Security::NativeCryptoHandle endpoint_crypto_handle_
 

Detailed Description

Definition at line 641 of file Sedp.h.

Constructor & Destructor Documentation

◆ DiscoveryReader()

OpenDDS::RTPS::Sedp::DiscoveryReader::DiscoveryReader ( const DCPS::GUID_t &  sub_id,
Sedp &  sedp 
)
inline

Definition at line 643 of file Sedp.h.

References OpenDDS::XTypes::extensibility().

644  : Reader(sub_id, sedp)
645  {}
OpenDDS::RTPS::Sedp::Reader::Reader
Reader(const DCPS::GUID_t &sub_id, Sedp &sedp)
Definition: Sedp.h:612

◆ ~DiscoveryReader()

OpenDDS::RTPS::Sedp::DiscoveryReader::~DiscoveryReader ( )
virtual

Definition at line 4070 of file Sedp.cpp.

4071 {
4072 }

Member Function Documentation

◆ data_received_i()

void OpenDDS::RTPS::Sedp::DiscoveryReader::data_received_i ( const DCPS::ReceivedDataSample &  sample,
const DCPS::EntityId_t &  entity_id,
DCPS::Serializer &  ser,
DCPS::Extensibility  extensibility 
)
privatevirtual

Implements OpenDDS::RTPS::Sedp::Reader.

Definition at line 4258 of file Sedp.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::ReaderProxy_t::allLocators, DDS::Security::ParticipantBuiltinTopicData::base, DDS::Security::ParticipantBuiltinTopicDataSecure::base, OpenDDS::DCPS::BUILTIN_TOPIC_KEY_UNKNOWN, OpenDDS::XTypes::TypeInformation::complete, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::data, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::data, OpenDDS::RTPS::Sedp::data_received(), OpenDDS::Security::SPDPdiscoveredParticipantData::ddsParticipantDataSecure, OpenDDS::RTPS::decode_parameter_list(), OpenDDS::Security::SPDPdiscoveredParticipantData::discoveredAt, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER, OpenDDS::DCPS::ReaderProxy_t::expectsInlineQos, OpenDDS::RTPS::ParameterListConverter::from_param_list(), OpenDDS::DCPS::guid_to_bit_key(), OpenDDS::RTPS::Spdp::handle_participant_data(), OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::have_ice_agent_info, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::have_ice_agent_info, OpenDDS::RTPS::DiscoveredSubscription::have_ice_agent_info_, OpenDDS::RTPS::DiscoveredPublication::have_ice_agent_info_, OpenDDS::DCPS::ReceivedDataSample::header_, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::ice_agent_info, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::ice_agent_info, OpenDDS::RTPS::DiscoveredSubscription::ice_agent_info_, OpenDDS::RTPS::DiscoveredPublication::ice_agent_info_, OpenDDS::XTypes::TypeIdentifier::kind(), LM_ERROR, OpenDDS::DCPS::make_part_guid(), OpenDDS::DCPS::DataSampleHeader::message_id_, OpenDDS::XTypes::TypeInformation::minimal, OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OpenDDS::RTPS::Spdp::process_participant_ice(), OpenDDS::DCPS::DataSampleHeader::publication_id_, OpenDDS::RTPS::DiscoveredSubscription::reader_data_, OpenDDS::DCPS::DiscoveredReaderData::readerProxy, OpenDDS::DCPS::ReaderProxy_t::remoteReaderGuid, OpenDDS::DCPS::WriterProxy_t::remoteWriterGuid, OpenDDS::RTPS::Sedp::Endpoint::sedp_, OpenDDS::RTPS::Sedp::set_inline_qos(), OpenDDS::RTPS::Sedp::spdp_, OpenDDS::XTypes::TK_NONE, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, OpenDDS::RTPS::ParameterListConverter::DiscoveredPublication_SecurityWrapper::type_info, OpenDDS::RTPS::ParameterListConverter::DiscoveredSubscription_SecurityWrapper::type_info, OpenDDS::RTPS::DiscoveredSubscription::type_info_, OpenDDS::RTPS::DiscoveredPublication::type_info_, OpenDDS::RTPS::Sedp::type_lookup_service_, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, OpenDDS::RTPS::Sedp::use_xtypes_, OpenDDS::RTPS::DiscoveredPublication::writer_data_, OpenDDS::DCPS::DiscoveredWriterData::writerProxy, and OpenDDS::DCPS::SequenceNumber::ZERO().

4262 {
4263  const DCPS::MessageId id = static_cast<DCPS::MessageId>(sample.header_.message_id_);
4264 
4265  if (entity_id == ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER) {
4266  ParameterList data;
4267  if (!decode_parameter_list(sample, ser, extensibility, data)) {
4268  ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::DiscoveryReader::data_received_i - ")
4269  ACE_TEXT("failed to deserialize data\n")));
4270  return;
4271  }
4272 
4273  DiscoveredPublication wdata;
4274  if (!ParameterListConverter::from_param_list(data, wdata.writer_data_, sedp_.use_xtypes_, wdata.type_info_)) {
4275  ACE_ERROR((LM_ERROR,
4276  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4277  ACE_TEXT("failed to convert from ParameterList ")
4278  ACE_TEXT("to DiscoveredWriterData\n")));
4279  return;
4280  }
4281 #ifdef OPENDDS_SECURITY
4282  wdata.have_ice_agent_info_ = false;
4283  ICE::AgentInfoMap ai_map;
4284  if (!ParameterListConverter::from_param_list(data, ai_map)) {
4285  ACE_ERROR((LM_ERROR,
4286  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4287  ACE_TEXT("failed to convert from ParameterList ")
4288  ACE_TEXT("to ICE Agent info\n")));
4289  return;
4290  }
4291  ICE::AgentInfoMap::const_iterator pos = ai_map.find("DATA");
4292  if (pos != ai_map.end()) {
4293  wdata.have_ice_agent_info_ = true;
4294  wdata.ice_agent_info_ = pos->second;
4295  }
4296 #endif
4297 
4298  if (wdata.type_info_.minimal.typeid_with_size.type_id.kind() != XTypes::TK_NONE ||
4299  wdata.type_info_.complete.typeid_with_size.type_id.kind() != XTypes::TK_NONE) {
4300  const GUID_t& remote_guid = wdata.writer_data_.writerProxy.remoteWriterGuid;
4301  DDS::BuiltinTopicKey_t key = DCPS::guid_to_bit_key(remote_guid);
4302  sedp_.type_lookup_service_->cache_type_info(key, wdata.type_info_);
4303  }
4304 
4305  sedp_.data_received(id, wdata);
4306 
4307 #ifdef OPENDDS_SECURITY
4308  } else if (entity_id == ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER) {
4309  ParameterList data;
4310  if (!decode_parameter_list(sample, ser, extensibility, data)) {
4311  ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::DiscoveryReader::data_received_i - ")
4312  ACE_TEXT("failed to deserialize data\n")));
4313  return;
4314  }
4315 
4316  ParameterListConverter::DiscoveredPublication_SecurityWrapper wdata_secure = ParameterListConverter::DiscoveredPublication_SecurityWrapper();
4317 
4318  if (!ParameterListConverter::from_param_list(data, wdata_secure, sedp_.use_xtypes_, wdata_secure.type_info)) {
4319  ACE_ERROR((LM_ERROR,
4320  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4321  ACE_TEXT("failed to convert from ParameterList ")
4322  ACE_TEXT("to DiscoveredPublication_SecurityWrapper\n")));
4323  return;
4324  }
4325 
4326  wdata_secure.have_ice_agent_info = false;
4327  ICE::AgentInfoMap ai_map;
4328  if (!ParameterListConverter::from_param_list(data, ai_map)) {
4329  ACE_ERROR((LM_ERROR,
4330  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4331  ACE_TEXT("failed to convert from ParameterList ")
4332  ACE_TEXT("to ICE Agent info\n")));
4333  return;
4334  }
4335  ICE::AgentInfoMap::const_iterator pos = ai_map.find("DATA");
4336  if (pos != ai_map.end()) {
4337  wdata_secure.have_ice_agent_info = true;
4338  wdata_secure.ice_agent_info = pos->second;
4339  }
4340 
4341  if (wdata_secure.type_info.minimal.typeid_with_size.type_id.kind() != XTypes::TK_NONE ||
4342  wdata_secure.type_info.complete.typeid_with_size.type_id.kind() != XTypes::TK_NONE) {
4343  const GUID_t& remote_guid = wdata_secure.data.writerProxy.remoteWriterGuid;
4344  DDS::BuiltinTopicKey_t key = DCPS::guid_to_bit_key(remote_guid);
4345  sedp_.type_lookup_service_->cache_type_info(key, wdata_secure.type_info);
4346  }
4347 
4348  sedp_.data_received(id, wdata_secure);
4349 #endif
4350  } else if (entity_id == ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER) {
4351  ParameterList data;
4352  if (!decode_parameter_list(sample, ser, extensibility, data)) {
4353  ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::DiscoveryReader::data_received_i - ")
4354  ACE_TEXT("failed to deserialize data\n")));
4355  return;
4356  }
4357 
4358  DiscoveredSubscription rdata;
4359  if (!ParameterListConverter::from_param_list(data, rdata.reader_data_, sedp_.use_xtypes_, rdata.type_info_)) {
4360  ACE_ERROR((LM_ERROR,
4361  ACE_TEXT("(%P|%t) ERROR Sedp::DiscoveryReader::data_received_i - ")
4362  ACE_TEXT("failed to convert from ParameterList ")
4363  ACE_TEXT("to DiscoveredReaderData\n")));
4364  return;
4365  }
4366 #ifdef OPENDDS_SECURITY
4367  rdata.have_ice_agent_info_ = false;
4368  ICE::AgentInfoMap ai_map;
4369  if (!ParameterListConverter::from_param_list(data, ai_map)) {
4370  ACE_ERROR((LM_ERROR,
4371  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4372  ACE_TEXT("failed to convert from ParameterList ")
4373  ACE_TEXT("to ICE Agent info\n")));
4374  return;
4375  }
4376  ICE::AgentInfoMap::const_iterator pos = ai_map.find("DATA");
4377  if (pos != ai_map.end()) {
4378  rdata.have_ice_agent_info_ = true;
4379  rdata.ice_agent_info_ = pos->second;
4380  }
4381 #endif
4382  if (rdata.reader_data_.readerProxy.expectsInlineQos) {
4383  set_inline_qos(rdata.reader_data_.readerProxy.allLocators);
4384  }
4385 
4386  if (rdata.type_info_.minimal.typeid_with_size.type_id.kind() != XTypes::TK_NONE ||
4387  rdata.type_info_.complete.typeid_with_size.type_id.kind() != XTypes::TK_NONE) {
4388  const GUID_t& remote_guid = rdata.reader_data_.readerProxy.remoteReaderGuid;
4389  DDS::BuiltinTopicKey_t key = DCPS::guid_to_bit_key(remote_guid);
4390  sedp_.type_lookup_service_->cache_type_info(key, rdata.type_info_);
4391  }
4392 
4393  sedp_.data_received(id, rdata);
4394 
4395 #ifdef OPENDDS_SECURITY
4396  } else if (entity_id == ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER) {
4397  ParameterList data;
4398  if (!decode_parameter_list(sample, ser, extensibility, data)) {
4399  ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::DiscoveryReader::data_received_i - ")
4400  ACE_TEXT("failed to deserialize data\n")));
4401  return;
4402  }
4403 
4404  ParameterListConverter::DiscoveredSubscription_SecurityWrapper rdata_secure;
4405  if (!ParameterListConverter::from_param_list(data, rdata_secure, sedp_.use_xtypes_, rdata_secure.type_info)) {
4406  ACE_ERROR((LM_ERROR,
4407  ACE_TEXT("(%P|%t) ERROR Sedp::DiscoveryReader::data_received_i - ")
4408  ACE_TEXT("failed to convert from ParameterList ")
4409  ACE_TEXT("to DiscoveredSubscription_SecurityWrapper\n")));
4410  return;
4411  }
4412 
4413  rdata_secure.have_ice_agent_info = false;
4414  ICE::AgentInfoMap ai_map;
4415  if (!ParameterListConverter::from_param_list(data, ai_map)) {
4416  ACE_ERROR((LM_ERROR,
4417  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4418  ACE_TEXT("failed to convert from ParameterList ")
4419  ACE_TEXT("to ICE Agent info\n")));
4420  return;
4421  }
4422  ICE::AgentInfoMap::const_iterator pos = ai_map.find("DATA");
4423  if (pos != ai_map.end()) {
4424  rdata_secure.have_ice_agent_info = true;
4425  rdata_secure.ice_agent_info = pos->second;
4426  }
4427 
4428  if ((rdata_secure.data).readerProxy.expectsInlineQos) {
4429  set_inline_qos((rdata_secure.data).readerProxy.allLocators);
4430  }
4431 
4432  if (rdata_secure.type_info.minimal.typeid_with_size.type_id.kind() != XTypes::TK_NONE ||
4433  rdata_secure.type_info.complete.typeid_with_size.type_id.kind() != XTypes::TK_NONE) {
4434  const GUID_t& remote_guid = rdata_secure.data.readerProxy.remoteReaderGuid;
4435  DDS::BuiltinTopicKey_t key = DCPS::guid_to_bit_key(remote_guid);
4436  sedp_.type_lookup_service_->cache_type_info(key, rdata_secure.type_info);
4437  }
4438 
4439  sedp_.data_received(id, rdata_secure);
4440 
4441  } else if (entity_id == ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER) {
4442 
4443  ParameterList data;
4444  if (!decode_parameter_list(sample, ser, extensibility, data)) {
4445  ACE_ERROR((LM_ERROR, ACE_TEXT("ERROR: Sedp::DiscoveryReader::data_received_i - ")
4446  ACE_TEXT("failed to deserialize data\n")));
4447  return;
4448  }
4449 
4450  Security::SPDPdiscoveredParticipantData pdata;
4451  pdata.ddsParticipantDataSecure.base.base.key = DCPS::BUILTIN_TOPIC_KEY_UNKNOWN;
4452  pdata.discoveredAt = MTZERO;
4453 
4454  if (!ParameterListConverter::from_param_list(data, pdata)) {
4455  ACE_ERROR((LM_ERROR,
4456  ACE_TEXT("(%P|%t) ERROR: Sedp::DiscoveryReader::data_received_i - ")
4457  ACE_TEXT("failed to convert from ParameterList ")
4458  ACE_TEXT("to Security::SPDPdiscoveredParticipantData\n")));
4459  return;
4460  }
4461  const GUID_t guid = make_part_guid(sample.header_.publication_id_);
4462  sedp_.spdp_.process_participant_ice(data, pdata, guid);
4463  sedp_.spdp_.handle_participant_data(id, pdata, DCPS::MonotonicTimePoint::now(), DCPS::SequenceNumber::ZERO(), ACE_INET_Addr(), true);
4464 
4465 #endif
4466  }
4467 }
OpenDDS::RTPS::ParameterListConverter::from_param_list
bool from_param_list(const ParameterList &param_list, DDS::ParticipantBuiltinTopicData &pbtd)
Definition: ParameterListConverter.cpp:344
OpenDDS::RTPS::Spdp::process_participant_ice
void process_participant_ice(const ParameterList &plist, const ParticipantData_t &pdata, const DCPS::GUID_t &guid)
Definition: Spdp.cpp:4373
ACE_ERROR
#define ACE_ERROR(X)
OpenDDS::RTPS::decode_parameter_list
static bool decode_parameter_list(const DCPS::ReceivedDataSample &sample, Serializer &ser, DCPS::Extensibility extensibility, ParameterList &data)
Definition: Sedp.cpp:4090
key
sequence< octet > key
OpenDDS::RTPS::Sedp::type_lookup_service_
XTypes::TypeLookupService_rch type_lookup_service_
Definition: Sedp.h:1240
OpenDDS::DCPS::BUILTIN_TOPIC_KEY_UNKNOWN
const DDS::BuiltinTopicKey_t BUILTIN_TOPIC_KEY_UNKNOWN
Definition: BuiltInTopicUtils.h:85
OpenDDS::RTPS::Sedp::use_xtypes_
const bool use_xtypes_
Definition: Sedp.h:1246
OpenDDS::DCPS::MessageId
MessageId
One byte message id (<256)
Definition: DataSampleHeader.h:35
OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now
static TimePoint_T< MonotonicClock > now()
Definition: TimePoint_T.inl:41
OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER
Definition: MessageTypes.h:79
OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER
Definition: GuidUtils.h:40
OpenDDS::DCPS::SequenceNumber::ZERO
static SequenceNumber ZERO()
Definition: SequenceNumber.h:133
OpenDDS::RTPS::Sedp::set_inline_qos
static void set_inline_qos(DCPS::TransportLocatorSeq &locators)
Definition: Sedp.cpp:5159
ParameterList
sequence< Parameter > ParameterList
ACE_TEXT
ACE_TEXT("TCP_Factory")
OpenDDS::DCPS::make_part_guid
OpenDDS_Dcps_Export GUID_t make_part_guid(const GuidPrefix_t &prefix)
Definition: GuidUtils.h:216
OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER
Definition: MessageTypes.h:77
OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER
Definition: GuidUtils.h:42
OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER
const EntityId_t ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER
Definition: MessageTypes.h:87
OpenDDS::XTypes::TK_NONE
const TypeKind TK_NONE
Definition: TypeObject.h:213
OpenDDS::RTPS::Sedp::data_received
void data_received(DCPS::MessageId message_id, const DiscoveredPublication &wdata)
Definition: Sedp.cpp:2279
OpenDDS::DCPS::guid_to_bit_key
OpenDDS_Dcps_Export DDS::BuiltinTopicKey_t guid_to_bit_key(const GUID_t &guid)
Definition: GuidUtils.h:243
OpenDDS::XTypes::extensibility
extensibility(MUTABLE) struct TypeLookup_getTypes_In
Definition: TypeLookup.idl:29
OpenDDS::RTPS::Spdp::handle_participant_data
void handle_participant_data(DCPS::MessageId id, const ParticipantData_t &pdata, const DCPS::MonotonicTimePoint &now, const DCPS::SequenceNumber &seq, const ACE_INET_Addr &from, bool from_sedp)
Definition: Spdp.cpp:710
The documentation for this class was generated from the following files:
Generated by   doxygen 1.8.13