Method parse_topics

dds/DCPS/StaticDiscovery.cpp:1739–1780

}

int
StaticDiscovery::parse_topics()
{
  RcHandle<ConfigStoreImpl> config_store = TheServiceParticipant->config_store();
  const ConfigStoreImpl::StringList sections = config_store->get_section_names("TOPIC");

  // Loop through the [topic/*] sections
  for (ConfigStoreImpl::StringList::const_iterator pos = sections.begin(), limit = sections.end();
       pos != limit; ++pos) {
    const String& topic_name = *pos;

    if (DCPS_debug_level > 0) {
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: StaticDiscovery::parse_topics ")
                 ACE_TEXT("processing [topic/%C] section.\n"),
                 topic_name.c_str()));
    }

    EndpointRegistry::Topic topic;
    topic.name = config_store->get((String("TOPIC_") + topic_name + "_NAME").c_str(), topic_name);
    topic.type_name = config_store->get((String("TOPIC_") + topic_name + "_TYPE_NAME").c_str(), "");
    if (topic.type_name.empty()) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) StaticDiscovery::parse_topics ")
                 ACE_TEXT("No type_name specified for [topic/%C] section.\n"),
                 topic_name.c_str()));
      return -1;
    }
    if (topic.type_name.size() >= TYPE_NAME_MAX) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) StaticDiscovery::parse_topics ")
                 ACE_TEXT("type_name (%C) must be less than 128 characters in [topic/%C] section.\n"),
                 topic.type_name.c_str(), topic_name.c_str()));
      return -1;

    }

    registry.topic_map[topic_name] = topic;
  }

  return 0;
}

int
StaticDiscovery::parse_datawriterqos()