OpenDDS::FaceTSS::config::ConnectionSettings Class Reference

#include <ConnectionSettings.h>

Public Member Functions
	ConnectionSettings ()
int	set (const char *name, const char *value)
const char *	datawriter_qos_name () const
const char *	datareader_qos_name () const
const char *	publisher_qos_name () const
const char *	subscriber_qos_name () const
const char *	config_name () const
bool	datawriter_qos_set () const
bool	datareader_qos_set () const
bool	publisher_qos_set () const
bool	subscriber_qos_set () const
bool	config_set () const

Public Attributes
char	topic_name_ [ALLOWABLE_NAME_LEN]
char	datawriter_qos_name_ [ALLOWABLE_NAME_LEN]
char	datareader_qos_name_ [ALLOWABLE_NAME_LEN]
char	publisher_qos_name_ [ALLOWABLE_NAME_LEN]
char	subscriber_qos_name_ [ALLOWABLE_NAME_LEN]
FACE::CONNECTION_ID_TYPE	connection_id_
FACE::CONNECTION_DIRECTION_TYPE	direction_
int	domain_id_
int	participant_id_
char	config_name_ [ALLOWABLE_NAME_LEN]

Static Public Attributes
static const size_t	ALLOWABLE_NAME_LEN = 64

Detailed Description

Definition at line 13 of file ConnectionSettings.h.

Constructor & Destructor Documentation

ConnectionSettings()

OpenDDS::FaceTSS::config::ConnectionSettings::ConnectionSettings

(

)

Definition at line 13 of file ConnectionSettings.cpp.

References config_name_, datareader_qos_name_, datawriter_qos_name_, publisher_qos_name_, subscriber_qos_name_, and topic_name_.

: connection_id_(0),
  direction_(FACE::SOURCE),
  domain_id_(0),
  participant_id_(0)
{
  std::strcpy(topic_name_, "");
  std::strcpy(datawriter_qos_name_, "");
  std::strcpy(datareader_qos_name_, "");
  std::strcpy(publisher_qos_name_, "");
  std::strcpy(subscriber_qos_name_, "");
  std::strcpy(config_name_, "");
}

Member Function Documentation

config_name()

const char * OpenDDS::FaceTSS::config::ConnectionSettings::config_name

(

)

const

Definition at line 140 of file ConnectionSettings.cpp.

References config_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::parse().

{
  return config_name_;
}

config_set()

bool OpenDDS::FaceTSS::config::ConnectionSettings::config_set

(

)

const

Definition at line 170 of file ConnectionSettings.cpp.

References config_name_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::FaceTSS::config::Parser::parse().

{
  return config_name_[0];
}

datareader_qos_name()

const char * OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_name

(

)

const

Definition at line 122 of file ConnectionSettings.cpp.

References datareader_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return datareader_qos_name_;
}

datareader_qos_set()

bool OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_set

(

)

const

Definition at line 152 of file ConnectionSettings.cpp.

References datareader_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return datareader_qos_name_[0];
}

datawriter_qos_name()

const char * OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_name

(

)

const

Definition at line 116 of file ConnectionSettings.cpp.

References datawriter_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return datawriter_qos_name_;
}

datawriter_qos_set()

bool OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_set

(

)

const

Definition at line 146 of file ConnectionSettings.cpp.

References datawriter_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return datawriter_qos_name_[0];
}

publisher_qos_name()

const char * OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_name

(

)

const

Definition at line 128 of file ConnectionSettings.cpp.

References publisher_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return publisher_qos_name_;
}

publisher_qos_set()

bool OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_set

(

)

const

Definition at line 158 of file ConnectionSettings.cpp.

References publisher_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return publisher_qos_name_[0];
}

set()

int OpenDDS::FaceTSS::config::ConnectionSettings::set	(	const char *	name,
		const char *	value
	)

Definition at line 28 of file ConnectionSettings.cpp.

References ACE_ERROR, ACE_TEXT(), ALLOWABLE_NAME_LEN, atoi(), config_name_, connection_id_, datareader_qos_name_, datawriter_qos_name_, direction_, domain_id_, LM_ERROR, participant_id_, publisher_qos_name_, subscriber_qos_name_, and topic_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::parse_connection().

{
  int status = 0;
  if (!std::strcmp(name, "id")) {
    connection_id_ = atoi(value);
  } else if (!std::strcmp(name, "participantid")) {
    participant_id_ = atoi(value);
  } else if (!std::strcmp(name, "domain")) {
    domain_id_ = atoi(value);
  } else if (!std::strcmp(name, "topic")) {
    if (std::strlen(value) >= ALLOWABLE_NAME_LEN) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("topic name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(topic_name_, value, sizeof(topic_name_));
    }
  } else if (!std::strcmp(name, "datawriterqos")) {
    if (std::strlen(value) >= ALLOWABLE_NAME_LEN) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("datawriterqos name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(datawriter_qos_name_, value, sizeof(datawriter_qos_name_));
    }
  } else if (!std::strcmp(name, "datareaderqos")) {
    if (std::strlen(value) >= ALLOWABLE_NAME_LEN) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("datareaderqos name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(datareader_qos_name_, value, sizeof(datareader_qos_name_));
    }
  } else if (!std::strcmp(name, "publisherqos")) {
    if (std::strlen(value) >= ALLOWABLE_NAME_LEN) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("publisherqos name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(publisher_qos_name_, value, sizeof(publisher_qos_name_));
    }
  } else if (!std::strcmp(name, "subscriberqos")) {
    if (std::strlen(value) >= ALLOWABLE_NAME_LEN) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("subscriberqos name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(subscriber_qos_name_, value, sizeof(subscriber_qos_name_));
    }
  } else if (!std::strcmp(name, "direction")) {
    if (!std::strcmp(value, "source") ||
        !std::strcmp(value, "one_way_request_source") ||
        !std::strcmp(value, "two_way_request_synchronous_source") ||
        !std::strcmp(value, "two_way_request_reply_asynchronous_source")) {
      direction_ = FACE::SOURCE;
    } else if (!std::strcmp(value, "destination") ||
               !std::strcmp(value, "one_way_request_destination") ||
               !std::strcmp(value, "two_way_request_synchronous_destination") ||
               !std::strcmp(value, "two_way_request_reply_asynchronous_destination")) {
      direction_ = FACE::DESTINATION;
    } else if (!std::strcmp(value, "bi_directional") ||
               !std::strcmp(value, "not_defined_connection_direction_type")) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("Direction not supported: %C\n"), value));
      status = 1;
    } else {
      ACE_ERROR((LM_ERROR, ACE_TEXT("Don't know of direction %C\n"), value));
      status = 1;
    }
  } else if (!std::strcmp(name, "config")) {
    // Guarantee that value will fit in config_name_ and still be null terminated
    // config_name_ is sized to ALLOWABLE_NAME_LEN
    if (std::strlen(value) >= sizeof(config_name_)) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("config name %C exceeds allowable length,"
        "must be < %B\n"), value, ALLOWABLE_NAME_LEN));
      status = 1;
    } else {
      std::strncpy(config_name_, value, sizeof(config_name_));
    }
  } else {
    // no match
    ACE_ERROR((LM_ERROR, ACE_TEXT("Don't know of setting %C\n"), name));
    status = 1;
  }

  return status;
}

subscriber_qos_name()

const char * OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_name

(

)

const

Definition at line 134 of file ConnectionSettings.cpp.

References subscriber_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return subscriber_qos_name_;
}

subscriber_qos_set()

bool OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_set

(

)

const

Definition at line 164 of file ConnectionSettings.cpp.

References subscriber_qos_name_.

Referenced by OpenDDS::FaceTSS::config::Parser::find_qos(), and OpenDDS::FaceTSS::config::Parser::parse().

{
  return subscriber_qos_name_[0];
}

Member Data Documentation

ALLOWABLE_NAME_LEN

const size_t OpenDDS::FaceTSS::config::ConnectionSettings::ALLOWABLE_NAME_LEN = 64

static

Definition at line 15 of file ConnectionSettings.h.

Referenced by set().

config_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::config_name_[ALLOWABLE_NAME_LEN]

Definition at line 42 of file ConnectionSettings.h.

Referenced by config_name(), config_set(), ConnectionSettings(), FACE::TS::Create_Connection(), and set().

connection_id_

FACE::CONNECTION_ID_TYPE OpenDDS::FaceTSS::config::ConnectionSettings::connection_id_

Definition at line 38 of file ConnectionSettings.h.

Referenced by FACE::TS::Create_Connection(), FACE::TS::Get_Connection_Parameters(), OpenDDS::FaceTSS::config::Parser::parse(), and set().

datareader_qos_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::datareader_qos_name_[ALLOWABLE_NAME_LEN]

Definition at line 35 of file ConnectionSettings.h.

Referenced by ConnectionSettings(), datareader_qos_name(), datareader_qos_set(), and set().

datawriter_qos_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::datawriter_qos_name_[ALLOWABLE_NAME_LEN]

Definition at line 34 of file ConnectionSettings.h.

Referenced by ConnectionSettings(), datawriter_qos_name(), datawriter_qos_set(), and set().

direction_

FACE::CONNECTION_DIRECTION_TYPE OpenDDS::FaceTSS::config::ConnectionSettings::direction_

Definition at line 39 of file ConnectionSettings.h.

Referenced by FACE::TS::Create_Connection(), OpenDDS::FaceTSS::config::Parser::find_qos(), OpenDDS::FaceTSS::config::Parser::parse(), and set().

domain_id_

int OpenDDS::FaceTSS::config::ConnectionSettings::domain_id_

Definition at line 40 of file ConnectionSettings.h.

Referenced by FACE::TS::Create_Connection(), OpenDDS::FaceTSS::config::Parser::parse(), and set().

participant_id_

int OpenDDS::FaceTSS::config::ConnectionSettings::participant_id_

Definition at line 41 of file ConnectionSettings.h.

Referenced by FACE::TS::Create_Connection(), and set().

publisher_qos_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::publisher_qos_name_[ALLOWABLE_NAME_LEN]

Definition at line 36 of file ConnectionSettings.h.

Referenced by ConnectionSettings(), publisher_qos_name(), publisher_qos_set(), and set().

subscriber_qos_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::subscriber_qos_name_[ALLOWABLE_NAME_LEN]

Definition at line 37 of file ConnectionSettings.h.

Referenced by ConnectionSettings(), set(), subscriber_qos_name(), and subscriber_qos_set().

topic_name_

char OpenDDS::FaceTSS::config::ConnectionSettings::topic_name_[ALLOWABLE_NAME_LEN]

Definition at line 33 of file ConnectionSettings.h.

Referenced by ConnectionSettings(), FACE::TS::Create_Connection(), OpenDDS::FaceTSS::config::Parser::parse(), and set().

---

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

• ConnectionSettings.h
• ConnectionSettings.cpp