Method parse

dds/FACE/config/Parser.cpp:71–271

TopicMap Parser::topic_map_;

int
Parser::parse(const char* filename)
{
  ACE_Configuration_Heap config;
  config.open();
  ACE_Ini_ImpExp import(config);
  int status = import.import_config(filename);
  if (status) {
    ACE_ERROR((LM_ERROR,
               ACE_TEXT("(%P|%t) ERROR: Initialize() ")
               ACE_TEXT("import_config () returned %d\n"),
               status));
    return status;
  }

  status = parse_sections(config, DATAWRITER_QOS_SECTION, false) ||
    parse_sections(config, DATAREADER_QOS_SECTION, false) ||
    parse_sections(config, PUBLISHER_QOS_SECTION, false) ||
    parse_sections(config, SUBSCRIBER_QOS_SECTION, false) ||
    parse_sections(config, TOPIC_SECTION, true) ||
    parse_sections(config, CONNECTION_SECTION, true);

  if (status)
    return status;

  status = TheServiceParticipant->load_configuration(config,
                                                     filename);

  if (status)
    return status;

  const DDS::DomainParticipantFactory_var dpf = TheParticipantFactory;
  // For the configuration to be loaded.
  ACE_UNUSED_ARG(dpf);

  for (ConnectionMap::const_iterator pos = connection_map_.begin(), limit = connection_map_.end();
       pos != limit;
       ++pos) {
    const ConnectionSettings& conn = pos->second;
    OpenDDS::DCPS::GUID_t id = build_id(conn);

    switch (conn.direction_) {
    case FACE::SOURCE:
      {
        OPENDDS_STRING topic_name = conn.topic_name_;

        DDS::DataWriterQos qos(TheServiceParticipant->initial_DataWriterQos());
        if (conn.datawriter_qos_set()) {
          QosMap::const_iterator p = qos_map_.find(conn.datawriter_qos_name());
          if (p != qos_map_.end()) {
            p->second.apply_to(qos);
          } else {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Could not find datawriterqos/%s\n"),
                       conn.datawriter_qos_name()));
            return -1;
          }
        }