OpenDDS::FaceTSS::config::Parser Class Reference

#include <Parser.h>

Public Member Functions
int	parse (const char *filename)
int	find_connection (const char *name, ConnectionSettings &target)
int	find_topic (const char *name, TopicSettings &target)
int	find_qos (const ConnectionSettings &conn, QosSettings &target)

Private Member Functions
int	parse_topic (ACE_Configuration_Heap &config, ACE_Configuration_Section_Key &key, const char *topic_name)
int	parse_connection (ACE_Configuration_Heap &config, ACE_Configuration_Section_Key &key, const char *connection_name)
int	parse_qos (ACE_Configuration_Heap &config, ACE_Configuration_Section_Key &key, const char *qos_name, QosSettings::QosLevel level)
int	parse_sections (ACE_Configuration_Heap &config, const char *section_type, bool required)

Static Private Attributes
static ConnectionMap	connection_map_
static QosMap	qos_map_
static TopicMap	topic_map_

Detailed Description

Definition at line 18 of file Parser.h.

Member Function Documentation

find_connection()

int OpenDDS::FaceTSS::config::Parser::find_connection	(	const char *	name,
		ConnectionSettings &	target
	)

Definition at line 270 of file Parser.cpp.

References connection_map_.

{
  int status = 1;
  ConnectionMap::iterator result;
  if ((result = connection_map_.find(name)) != connection_map_.end()) {
    status = 0;
    target = result->second;
  }
  return status;
}

find_qos()

int OpenDDS::FaceTSS::config::Parser::find_qos	(	const ConnectionSettings &	conn,
		QosSettings &	target
	)

Definition at line 296 of file Parser.cpp.

References OpenDDS::FaceTSS::config::QosSettings::datareader_qos(), OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_set(), OpenDDS::FaceTSS::config::QosSettings::datawriter_qos(), OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_set(), OpenDDS::FaceTSS::config::ConnectionSettings::direction_, OpenDDS::FaceTSS::config::QosSettings::publisher_qos(), OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_set(), qos_map_, OpenDDS::FaceTSS::config::QosSettings::subscriber_qos(), OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_name(), and OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_set().

{
  int status = 0;
  QosMap::iterator result;
  // If thie is a SOURCE
  if (conn.direction_ == FACE::SOURCE) {
    if (conn.datawriter_qos_set()) {
      // Name specified, must be in map
      result = qos_map_.find(conn.datawriter_qos_name());
      if (result != qos_map_.end()) {
        result->second.apply_to(target.datawriter_qos());
      } else {
        // Failed
        status = 1;
      }
    }
    if (status == 0 && (conn.publisher_qos_set())) {
      // Name specified, must be in map
      result = qos_map_.find(conn.publisher_qos_name());
      if (result != qos_map_.end()) {
        result->second.apply_to(target.publisher_qos());
      } else {
        // Failed
        status = 1;
      }
    }
  // Else DESTINATION
  } else {
    if (conn.datareader_qos_set()) {
      // Name specified, must be in map
      result = qos_map_.find(conn.datareader_qos_name());
      if (result != qos_map_.end()) {
        result->second.apply_to(target.datareader_qos());
      } else {
        // Failed
        status = 1;
      }
    }
    if (status == 0 && (conn.subscriber_qos_set())) {
      // Name specified, must be in map
      result = qos_map_.find(conn.subscriber_qos_name());
      if (result != qos_map_.end()) {
        result->second.apply_to(target.subscriber_qos());
      } else {
        // Failed
        status = 1;
      }
    }
  }

  return status;
}

find_topic()

int OpenDDS::FaceTSS::config::Parser::find_topic	(	const char *	name,
		TopicSettings &	target
	)

Definition at line 283 of file Parser.cpp.

References topic_map_.

{
  int status = 1;
  TopicMap::iterator result;
  if ((result = topic_map_.find(name)) != topic_map_.end()) {
    status = 0;
    target = result->second;
  }
  return status;
}

parse()

int OpenDDS::FaceTSS::config::Parser::parse

(

const char *

filename

)

Definition at line 72 of file Parser.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::FaceTSS::config::ConnectionSettings::config_name(), OpenDDS::FaceTSS::config::ConnectionSettings::config_set(), OpenDDS::FaceTSS::config::ConnectionSettings::connection_id_, connection_map_, OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_set(), OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_set(), OpenDDS::FaceTSS::config::ConnectionSettings::direction_, OpenDDS::FaceTSS::config::ConnectionSettings::domain_id_, ACE_Ini_ImpExp::import_config(), OpenDDS::DCPS::StaticDiscovery::instance(), OpenDDS::DCPS::RcHandle< T >::is_nil(), LM_ERROR, ACE_Configuration_Heap::open(), OPENDDS_STRING, parse_sections(), OpenDDS::DCPS::TransportConfig::populate_locators(), OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_set(), qos_map_, OpenDDS::DCPS::set_reader_effective_data_rep_qos(), OpenDDS::DCPS::set_writer_effective_data_rep_qos(), OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_name(), OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_set(), TheServiceParticipant, TheTransportRegistry, and OpenDDS::FaceTSS::config::ConnectionSettings::topic_name_.

{
  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;

  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;
          }
        }

        DDS::PublisherQos publisher_qos(TheServiceParticipant->initial_PublisherQos());
        if (conn.publisher_qos_set()) {
          QosMap::const_iterator p = qos_map_.find(conn.publisher_qos_name());
          if (p != qos_map_.end()) {
            p->second.apply_to(publisher_qos);
          } else {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Could not find publisherqos/%s\n"),
                       conn.publisher_qos_name()));
            return -1;
          }
        }

        DCPS::TransportLocatorSeq trans_info;

        OpenDDS::DCPS::TransportConfig_rch config;

        if (conn.config_set()) {
          config = TheTransportRegistry->get_config(conn.config_name());
          if (config.is_nil()) {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Could not find config/%s\n"),
                       conn.config_name()));
            return -1;
          }
        }

        if (config.is_nil()) {
          config = TheTransportRegistry->domain_default_config(conn.domain_id_);
        }

        if (config.is_nil()) {
          config = TheTransportRegistry->global_config();
        }

        config->populate_locators(trans_info);

        // Typically, we would ensure that trans_info is not empty.
        // However, when using RTPS, trans_info will be empty so don't check.

        // Populate the userdata.
        qos.user_data.value.length(3);
        qos.user_data.value[0] = (conn.connection_id_ >> 0) & 0xFF;
        qos.user_data.value[1] = (conn.connection_id_ >> 8) & 0xFF;
        qos.user_data.value[2] = (conn.connection_id_ >> 16) & 0xFF;
        bool encapsulated_only = false;
        for (CORBA::ULong i = 0; i < trans_info.length(); ++i) {
          if (0 == std::strcmp(trans_info[i].transport_type, "rtps_udp")) {
            encapsulated_only = true;
            break;
          }
        }
        DCPS::set_writer_effective_data_rep_qos(qos.representation.value, encapsulated_only);

        OpenDDS::DCPS::EndpointRegistry::Writer w(topic_name, qos, publisher_qos, conn.config_name(), trans_info);
        OpenDDS::DCPS::StaticDiscovery::instance()->registry.writer_map.insert(std::make_pair(id, w));
      }
      break;
    case FACE::DESTINATION:
      {
        OPENDDS_STRING topic_name = conn.topic_name_;

        DDS::DataReaderQos qos(TheServiceParticipant->initial_DataReaderQos());
        if (conn.datareader_qos_set()) {
          QosMap::const_iterator p = qos_map_.find(conn.datareader_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 datareaderqos/%s\n"),
                       conn.datawriter_qos_name()));
            return -1;
          }
        }

        DDS::SubscriberQos subscriber_qos(TheServiceParticipant->initial_SubscriberQos());
        if (conn.subscriber_qos_set()) {
          QosMap::const_iterator p = qos_map_.find(conn.subscriber_qos_name());
          if (p != qos_map_.end()) {
            p->second.apply_to(subscriber_qos);
          } else {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Could not find subscriberqos/%s\n"),
                       conn.subscriber_qos_name()));
            return -1;
          }
        }

        DCPS::TransportLocatorSeq trans_info;

        OpenDDS::DCPS::TransportConfig_rch config;

        if (conn.config_set()) {
          config = TheTransportRegistry->get_config(conn.config_name());
          if (config.is_nil()) {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Could not find transport/%s\n"),
                       conn.config_name()));
            return -1;
          }
        }

        if (config.is_nil()) {
          config = TheTransportRegistry->domain_default_config(conn.domain_id_);
        }

        if (config.is_nil()) {
          config = TheTransportRegistry->global_config();
        }

        config->populate_locators(trans_info);

        // Typically, we would ensure that trans_info is not empty.
        // However, when using RTPS, trans_info will be empty so don't check.

        // Populate the userdata.
        qos.user_data.value.length(3);
        qos.user_data.value[0] = (conn.connection_id_ >> 0) & 0xFF;
        qos.user_data.value[1] = (conn.connection_id_ >> 8) & 0xFF;
        qos.user_data.value[2] = (conn.connection_id_ >> 16) & 0xFF;

        DCPS::set_reader_effective_data_rep_qos(qos.representation.value);
        OpenDDS::DCPS::EndpointRegistry::Reader r(topic_name, qos, subscriber_qos, conn.config_name(), trans_info);
        OpenDDS::DCPS::StaticDiscovery::instance()->registry.reader_map.insert(std::make_pair(id, r));
      }
      break;
    case FACE::BI_DIRECTIONAL:
    case FACE::ONE_WAY_REQUEST_SOURCE:
    case FACE::ONE_WAY_REQUEST_DESTINATION:
    case FACE::TWO_WAY_REQUEST_SYNCHRONOUS_SOURCE:
    case FACE::TWO_WAY_REQUEST_SYNCHRONOUS_DESTINATION:
    case FACE::TWO_WAY_REQUEST_REPLY_ASYNCHRONOUS_SOURCE:
    case FACE::TWO_WAY_REQUEST_REPLY_ASYNCHRONOUS_DESTINATION:
    case FACE::NOT_DEFINED_CONNECTION_DIRECTION_TYPE:
      break;
    }
  }

  DCPS::StaticDiscovery::instance()->registry.match();

  return status;
}

parse_connection()

int OpenDDS::FaceTSS::config::Parser::parse_connection ( ACE_Configuration_Heap &  config, ACE_Configuration_Section_Key &  key, const char *  connection_name  )

private

Definition at line 383 of file Parser.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), connection_map_, ACE_Configuration_Heap::enumerate_values(), ACE_Configuration_Heap::get_string_value(), LM_ERROR, OpenDDS::FaceTSS::config::ConnectionSettings::set(), ACE_Configuration::STRING, and value.

Referenced by parse_sections().

{
  int status = 0;
  int value_index = 0;
  ACE_TString value_name, value;
  ACE_Configuration::VALUETYPE value_type;

  ConnectionSettings connection;

  while (!config.enumerate_values(key,
                                  value_index++,
                                  value_name,
                                  value_type)) {
    if (value_type == ACE_Configuration::STRING) {
      status = config.get_string_value(key, value_name.c_str(), value);
      if (!status) {
        status = status || connection.set(value_name.c_str(), value.c_str());
      }
    } else {
      ACE_ERROR((LM_ERROR, ACE_TEXT("unexpected value type %d\n"), value_type));
      status = -1;
      break;
    }
  }
  if (!status) {
    connection_map_[connection_name] = connection;
  }
  return status;
}

parse_qos()

int OpenDDS::FaceTSS::config::Parser::parse_qos ( ACE_Configuration_Heap &  config, ACE_Configuration_Section_Key &  key, const char *  qos_name, QosSettings::QosLevel  level  )

private

Definition at line 416 of file Parser.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), ACE_Configuration_Heap::enumerate_values(), ACE_Configuration_Heap::get_string_value(), LM_ERROR, qos_map_, OpenDDS::FaceTSS::config::QosSettings::set_qos(), ACE_Configuration::STRING, and value.

Referenced by parse_sections().

{
  int status = 0;
  int value_index = 0;
  ACE_TString value_name, value;
  ACE_Configuration::VALUETYPE value_type;

  // Find existing or create new settings
  QosSettings& qos = qos_map_[qos_name];

  while (!config.enumerate_values(key,
                                  value_index++,
                                  value_name,
                                  value_type)) {
    if (value_type == ACE_Configuration::STRING) {
      status = config.get_string_value(key, value_name.c_str(), value);
      if (!status) {
        status = status ||
                 qos.set_qos(level, value_name.c_str(), value.c_str());
      }
    } else {
      ACE_ERROR((LM_ERROR, ACE_TEXT("unexpected value type %d\n"), value_type));
      status = -1;
      break;
    }
  }
  return status;
}

parse_sections()

int OpenDDS::FaceTSS::config::Parser::parse_sections ( ACE_Configuration_Heap &  config, const char *  section_type, bool  required  )

private

Definition at line 449 of file Parser.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::FaceTSS::config::QosSettings::datareader, OpenDDS::FaceTSS::config::QosSettings::datawriter, ACE_Configuration_Heap::enumerate_sections(), LM_ERROR, ACE_Configuration_Heap::open_section(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, parse_connection(), parse_qos(), parse_topic(), OpenDDS::FaceTSS::config::QosSettings::publisher, ACE_Configuration::root_section(), and OpenDDS::FaceTSS::config::QosSettings::subscriber.

Referenced by parse().

{
  int status = 0;
  ACE_Configuration_Section_Key key;
  // If we can't open this section
  if (config.open_section(config.root_section(),
                          section_type,
                          0, // don't create if missing
                          key) != 0) {
    if (required) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("Could not open %C section in config file, status %d\n"), section_type, status));
      status = -1;
    }
  // Else, we can open this section
  } else {
    // Open subsections
    int section_index = 0;
    ACE_TString section_name;

    while (!config.enumerate_sections(key,
                                      section_index++,
                                      section_name)) {
      ACE_Configuration_Section_Key subkey;
      // Open subsection
      if (config.open_section(key,
                              section_name.c_str(),
                              0, // don't create if missing
                              subkey) != 0) {
        ACE_ERROR((LM_ERROR, ACE_TEXT("Could not open subsections of %C\n"), section_name.c_str()));
        break;
      }

      if (std::strcmp(section_type, CONNECTION_SECTION) == 0) {
        status = parse_connection(config, subkey, section_name.c_str());
      } else if (std::strcmp(section_type, TOPIC_SECTION) == 0) {
        status = parse_topic(config, subkey, section_name.c_str());
      } else if (std::strcmp(section_type, DATAWRITER_QOS_SECTION) == 0) {
        status = parse_qos(
            config, subkey, section_name.c_str(), QosSettings::datawriter);
      } else if (std::strcmp(section_type, DATAREADER_QOS_SECTION) == 0) {
        status = parse_qos(
            config, subkey, section_name.c_str(), QosSettings::datareader);
      } else if (std::strcmp(section_type, PUBLISHER_QOS_SECTION) == 0) {
        status = parse_qos(
            config, subkey, section_name.c_str(), QosSettings::publisher);
      } else if (std::strcmp(section_type, SUBSCRIBER_QOS_SECTION) == 0) {
        status = parse_qos(
            config, subkey, section_name.c_str(), QosSettings::subscriber);
      } else {
        ACE_ERROR((LM_ERROR, ACE_TEXT("unknown section %C\n"), section_type));
      }
    }
  }
  return status;
}

parse_topic()

int OpenDDS::FaceTSS::config::Parser::parse_topic ( ACE_Configuration_Heap &  config, ACE_Configuration_Section_Key &  key, const char *  topic_name  )

private

Definition at line 350 of file Parser.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), ACE_Configuration_Heap::enumerate_values(), ACE_Configuration_Heap::get_string_value(), LM_ERROR, OpenDDS::FaceTSS::config::TopicSettings::set(), ACE_Configuration::STRING, topic_map_, and value.

Referenced by parse_sections().

{
  int status = 0;
  int value_index = 0;
  ACE_TString value_name, value;
  ACE_Configuration::VALUETYPE value_type;

  TopicSettings topic;

  while (!config.enumerate_values(key,
                                  value_index++,
                                  value_name,
                                  value_type)) {
    if (value_type == ACE_Configuration::STRING) {
      status = config.get_string_value(key, value_name.c_str(), value);
      if (!status) {
        status = status || topic.set(value_name.c_str(), value.c_str());
      }
    } else {
      ACE_ERROR((LM_ERROR, ACE_TEXT("unexpected value type %d\n"), value_type));
      status = -1;
      break;
    }
  }
  if (!status) {
    topic_map_[topic_name] = topic;
  }
  return status;
}

Member Data Documentation

connection_map_

ConnectionMap OpenDDS::FaceTSS::config::Parser::connection_map_

staticprivate

Definition at line 27 of file Parser.h.

Referenced by find_connection(), parse(), and parse_connection().

qos_map_

QosMap OpenDDS::FaceTSS::config::Parser::qos_map_

staticprivate

Definition at line 28 of file Parser.h.

Referenced by find_qos(), parse(), and parse_qos().

topic_map_

TopicMap OpenDDS::FaceTSS::config::Parser::topic_map_

staticprivate

Definition at line 29 of file Parser.h.

Referenced by find_topic(), and parse_topic().

---

The documentation for this class was generated from the following files:

• Parser.h
• Parser.cpp