Method init

dds/DCPS/RTPS/Sedp.cpp:403–640

  {}

DDS::ReturnCode_t
Sedp::init(const GUID_t& guid,
           const RtpsDiscovery& disco,
           DDS::DomainId_t domainId,
           DDS::UInt16 ipv4_participant_port_id,
#ifdef ACE_HAS_IPV6
           DDS::UInt16 ipv6_participant_port_id,
#endif
           XTypes::TypeLookupService_rch tls)
{
  type_lookup_service_ = tls;

  const String uniqueId = DCPS::GuidConverter(guid).uniqueParticipantId() + '_' + DCPS::to_dds_string(domainId);

  // configure one transport
  transport_inst_ = TheTransportRegistry->create_inst(
                      DCPS::TransportRegistry::DEFAULT_INST_PREFIX + String("SEDPTransportInst_") + uniqueId,
                      "rtps_udp");
  config_store_->add_section("TRANSPORT", transport_inst_->name());

  // Be careful to not call any function that causes the transport be
  // to created before the configuration is complete.

  config_store_->set_uint32(transport_inst_->config_key("MAX_MESSAGE_SIZE").c_str(),
                            static_cast<DDS::UInt32>(disco.config()->sedp_max_message_size()));
  config_store_->set(transport_inst_->config_key("HEARTBEAT_PERIOD").c_str(),
                     disco.config()->sedp_heartbeat_period(), ConfigStoreImpl::Format_IntegerMilliseconds);
  config_store_->set(transport_inst_->config_key("NAK_RESPONSE_DELAY").c_str(),
                     disco.config()->sedp_nak_response_delay(), ConfigStoreImpl::Format_IntegerMilliseconds);
  config_store_->set_boolean(transport_inst_->config_key("RESPONSIVE_MODE").c_str(),
                             disco.config()->sedp_responsive_mode());
  config_store_->set(transport_inst_->config_key("SEND_DELAY").c_str(),
                     disco.config()->sedp_send_delay(), ConfigStoreImpl::Format_IntegerMilliseconds);
  config_store_->set_int32(transport_inst_->config_key("SEND_BUFFER_SIZE").c_str(),
                           disco.config()->send_buffer_size());
  config_store_->set_int32(transport_inst_->config_key("RCV_BUFFER_SIZE").c_str(),
                           disco.config()->recv_buffer_size());
  transport_inst_->receive_preallocated_message_blocks(disco.config()->sedp_receive_preallocated_message_blocks());
  transport_inst_->receive_preallocated_data_blocks(disco.config()->sedp_receive_preallocated_data_blocks());

  set_port_mode(transport_inst_->config_key("PORT_MODE").c_str(), disco.config()->sedp_port_mode());
  config_store_->set_int32(transport_inst_->config_key("PB").c_str(), disco.config()->pb());
  config_store_->set_int32(transport_inst_->config_key("DG").c_str(), disco.config()->dg());
  config_store_->set_int32(transport_inst_->config_key("PG").c_str(), disco.config()->pg());
  config_store_->set_int32(transport_inst_->config_key("D2").c_str(), disco.config()->dx());
  config_store_->set_int32(transport_inst_->config_key("D3").c_str(), disco.config()->dy());

  const bool sedp_multicast = disco.sedp_multicast();
  config_store_->set_boolean(transport_inst_->config_key("USE_MULTICAST").c_str(), sedp_multicast);
  if (sedp_multicast) {
    config_store_->set(transport_inst_->config_key("MULTICAST_GROUP_ADDRESS").c_str(),
                       disco.config()->sedp_multicast_address(domainId),
                       ConfigStoreImpl::Format_Optional_Port,
                       ConfigStoreImpl::Kind_IPV4);

    config_store_->set_uint32(transport_inst_->config_key("TTL").c_str(), disco.ttl());
    config_store_->set(transport_inst_->config_key("MULTICAST_INTERFACE").c_str(), disco.multicast_interface());
  }