OpenDDS::FaceTSS::config Namespace Reference


Classes

class  ConnectionSettings
class  Parser
class  QosSettings
class  TopicSettings

Functions

typedef OPENDDS_MAP (OPENDDS_STRING, ConnectionSettings) ConnectionMap
OpenDDS::DCPS::RepoId build_id (const ConnectionSettings &conn)
bool set_presentation_access_scope_qos (DDS::PresentationQosPolicy &target, const char *name, const char *value)
bool set_bool_qos_value (bool &target, const char *value)
bool set_duration_qos_value (DDS::Duration_t &target, const char *prefix_match, const char *name, const char *value)
bool set_presentation_coherent_access_qos (DDS::PresentationQosPolicy &target, const char *name, const char *value)
bool set_presentation_ordered_access_qos (DDS::PresentationQosPolicy &target, const char *name, const char *value)
bool set_partition_name_qos (DDS::PartitionQosPolicy &target, const char *name, const char *value)
bool set_durability_kind_qos (DDS::DurabilityQosPolicy &target, const char *name, const char *value)
bool set_deadline_period_qos (DDS::DeadlineQosPolicy &target, const char *name, const char *value)
bool set_latency_budget_duration_qos (DDS::LatencyBudgetQosPolicy &target, const char *name, const char *value)
bool set_liveliness_kind_qos (DDS::LivelinessQosPolicy &target, const char *name, const char *value)
bool set_liveliness_lease_duration_qos (DDS::LivelinessQosPolicy &target, const char *name, const char *value)
bool set_reliability_kind_qos (DDS::ReliabilityQosPolicy &target, const char *name, const char *value)
bool set_reliability_max_blocking_time_qos (DDS::ReliabilityQosPolicy &target, const char *name, const char *value)
bool set_destination_order_kind_qos (DDS::DestinationOrderQosPolicy &target, const char *name, const char *value)
bool set_history_kind_qos (DDS::HistoryQosPolicy &target, const char *name, const char *value)
bool set_history_depth_qos (DDS::HistoryQosPolicy &target, const char *name, const char *value)
bool set_resource_limits_max_samples_qos (DDS::ResourceLimitsQosPolicy &target, const char *name, const char *value)
bool set_resource_limits_max_instances_qos (DDS::ResourceLimitsQosPolicy &target, const char *name, const char *value)
bool set_resource_limits_max_samples_per_instance_qos (DDS::ResourceLimitsQosPolicy &target, const char *name, const char *value)
bool set_transport_priority_qos (DDS::TransportPriorityQosPolicy &target, const char *name, const char *value)
bool set_lifespan_duration_qos (DDS::LifespanQosPolicy &target, const char *name, const char *value)
bool set_ownership_kind_qos (DDS::OwnershipQosPolicy &target, const char *name, const char *value)
bool set_ownership_strength_value_qos (DDS::OwnershipStrengthQosPolicy &target, const char *name, const char *value)
bool set_time_based_filter_minimum_separation (DDS::TimeBasedFilterQosPolicy &target, const char *name, const char *value)
bool set_reader_data_lifecycle_autopurge_nowriter_samples_delay (DDS::ReaderDataLifecycleQosPolicy &target, const char *name, const char *value)
bool set_reader_data_lifecycle_autopurge_disposed_samples_delay (DDS::ReaderDataLifecycleQosPolicy &target, const char *name, const char *value)
void log_parser_error (const char *section, const char *name, const char *value)
typedef OPENDDS_MAP (OPENDDS_STRING, QosSettings) QosMap
typedef OPENDDS_MAP (OPENDDS_STRING, TopicSettings) TopicMap

Variables

const char * TOPIC_SECTION = "topic"
const char * CONNECTION_SECTION = "connection"
const char * DATAWRITER_QOS_SECTION = "datawriterqos"
const char * DATAREADER_QOS_SECTION = "datareaderqos"
const char * PUBLISHER_QOS_SECTION = "publisherqos"
const char * SUBSCRIBER_QOS_SECTION = "subscriberqos"


Function Documentation

typedef OpenDDS::FaceTSS::config::OPENDDS_MAP ( OPENDDS_STRING  ,
ConnectionSettings   
)

OpenDDS::DCPS::RepoId OpenDDS::FaceTSS::config::@77::build_id ( const ConnectionSettings &  conn  )  [static]

Definition at line 23 of file Parser.cpp.

References OpenDDS::DCPS::EndpointRegistry::build_id(), OpenDDS::FaceTSS::config::ConnectionSettings::connection_id_, OpenDDS::FaceTSS::config::ConnectionSettings::direction_, OpenDDS::FaceTSS::config::ConnectionSettings::domain_id_, OpenDDS::DCPS::ENTITYKIND_USER_READER_WITH_KEY, OpenDDS::DCPS::ENTITYKIND_USER_WRITER_WITH_KEY, and OpenDDS::FaceTSS::config::ConnectionSettings::participant_id_.

Referenced by OpenDDS::DCPS::StaticDiscovery::add_domain_participant(), OpenDDS::FaceTSS::config::Parser::parse(), OpenDDS::DCPS::StaticDiscovery::parse_endpoints(), OpenDDS::DCPS::StaticDiscovery::pre_reader(), and OpenDDS::DCPS::StaticDiscovery::pre_writer().

00024   {
00025     unsigned char participant_key[6];
00026     participant_key[0] = (conn.participant_id_ >> 0) & 0xFF;
00027     participant_key[1] = (conn.participant_id_ >> 8) & 0xFF;
00028     participant_key[2] = (conn.participant_id_ >> 16) & 0xFF;
00029     participant_key[3] = (conn.participant_id_ >> 24) & 0xFF;
00030     participant_key[4] = 0; //(conn.domain_id_ >> 32) & 0xFF;
00031     participant_key[5] = 0; //(conn.domain_id_ >> 40) & 0xFF;
00032 
00033     unsigned char entity_key[3];
00034     entity_key[0] = (conn.connection_id_ >> 0) & 0xFF;
00035     entity_key[1] = (conn.connection_id_ >> 8) & 0xFF;
00036     entity_key[2] = (conn.connection_id_ >> 16) & 0xFF;
00037 
00038     unsigned char entity_kind = 0;
00039     switch (conn.direction_) {
00040     case FACE::SOURCE:
00041       entity_kind = DCPS::ENTITYKIND_USER_WRITER_WITH_KEY;
00042       break;
00043     case FACE::DESTINATION:
00044       entity_kind = DCPS::ENTITYKIND_USER_READER_WITH_KEY;
00045       break;
00046     case FACE::BI_DIRECTIONAL:
00047     case FACE::ONE_WAY_REQUEST_SOURCE:
00048     case FACE::ONE_WAY_REQUEST_DESTINATION:
00049     case FACE::TWO_WAY_REQUEST_SYNCHRONOUS_SOURCE:
00050     case FACE::TWO_WAY_REQUEST_SYNCHRONOUS_DESTINATION:
00051     case FACE::TWO_WAY_REQUEST_REPLY_ASYNCHRONOUS_SOURCE:
00052     case FACE::TWO_WAY_REQUEST_REPLY_ASYNCHRONOUS_DESTINATION:
00053     case FACE::NOT_DEFINED_CONNECTION_DIRECTION_TYPE:
00054       break;
00055     }
00056     return OpenDDS::DCPS::EndpointRegistry::build_id(conn.domain_id_,
00057                                                      participant_key,
00058                                                      OpenDDS::DCPS::EndpointRegistry::build_id(entity_key,
00059                                                                                                entity_kind));
00060   }

bool OpenDDS::FaceTSS::config::set_presentation_access_scope_qos ( DDS::PresentationQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 63 of file QosSettings.cpp.

References DDS::PresentationQosPolicy::access_scope, DDS::GROUP_PRESENTATION_QOS, DDS::INSTANCE_PRESENTATION_QOS, and DDS::TOPIC_PRESENTATION_QOS.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00067 {
00068   bool matched = false;
00069   if (!std::strcmp(name, "presentation.access_scope")) {
00070     if (!std::strcmp(value, "INSTANCE")) {
00071       target.access_scope = DDS::INSTANCE_PRESENTATION_QOS;
00072       matched = true;
00073     }
00074     if (!std::strcmp(value, "TOPIC")) {
00075       target.access_scope = DDS::TOPIC_PRESENTATION_QOS;
00076       matched = true;
00077     }
00078     if (!std::strcmp(value, "GROUP")) {
00079       target.access_scope = DDS::GROUP_PRESENTATION_QOS;
00080       matched = true;
00081     }
00082   }
00083   return matched;
00084 }

bool OpenDDS::FaceTSS::config::set_bool_qos_value ( bool &  target,
const char *  value 
)

Definition at line 88 of file QosSettings.cpp.

Referenced by set_presentation_coherent_access_qos(), and set_presentation_ordered_access_qos().

00089 {
00090   bool matched = false;
00091   if (!std::strcmp(value, "true")) {
00092     target = true;
00093     matched = true;
00094   } else if (!std::strcmp(value, "false")) {
00095     target = false;
00096     matched = true;
00097   }
00098   return matched;
00099 }

bool OpenDDS::FaceTSS::config::set_duration_qos_value ( DDS::Duration_t target,
const char *  prefix_match,
const char *  name,
const char *  value 
)

Definition at line 103 of file QosSettings.cpp.

References DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, DDS::Duration_t::nanosec, and DDS::Duration_t::sec.

Referenced by set_deadline_period_qos(), set_latency_budget_duration_qos(), set_lifespan_duration_qos(), set_liveliness_lease_duration_qos(), set_reader_data_lifecycle_autopurge_disposed_samples_delay(), set_reader_data_lifecycle_autopurge_nowriter_samples_delay(), set_reliability_max_blocking_time_qos(), and set_time_based_filter_minimum_separation().

00107 {
00108   char buffer[64];
00109   std::strncpy(buffer, prefix_match, 64 - 4);
00110   std::strcat(buffer, ".sec");
00111   if (!std::strcmp(name, buffer)) {
00112     if (!std::strcmp(value, "DURATION_INFINITE_SEC")) {
00113       target.sec=DDS::DURATION_INFINITE_SEC;
00114       return true;
00115     }
00116     target.sec = atoi(value);
00117     return true;
00118   }
00119   std::strncpy(buffer, prefix_match, 64 - 7);
00120   std::strcat(buffer, ".nanosec");
00121   if (!std::strcmp(name, buffer)) {
00122     if (!std::strcmp(value, "DURATION_INFINITE_NSEC")) {
00123       target.nanosec=DDS::DURATION_INFINITE_NSEC;
00124       return true;
00125     }
00126     target.nanosec = atoi(value);
00127     return true;
00128   }
00129   return false;
00130 }

bool OpenDDS::FaceTSS::config::set_presentation_coherent_access_qos ( DDS::PresentationQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 133 of file QosSettings.cpp.

References DDS::PresentationQosPolicy::coherent_access, and set_bool_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00137 {
00138   bool matched = false;
00139   if (!std::strcmp(name, "presentation.coherent_access")) {
00140     matched = set_bool_qos_value(target.coherent_access, value);
00141   }
00142   return matched;
00143 }

bool OpenDDS::FaceTSS::config::set_presentation_ordered_access_qos ( DDS::PresentationQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 146 of file QosSettings.cpp.

References DDS::PresentationQosPolicy::ordered_access, and set_bool_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00150 {
00151   bool matched = false;
00152   if (!std::strcmp(name, "presentation.ordered_access")) {
00153     matched = set_bool_qos_value(target.ordered_access, value);
00154   }
00155   return matched;
00156 }

bool OpenDDS::FaceTSS::config::set_partition_name_qos ( DDS::PartitionQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 159 of file QosSettings.cpp.

References DDS::PartitionQosPolicy::name.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00161 {
00162   bool matched = false;
00163   if (!std::strcmp(name, "partition.name")) {
00164     // Value can be a comma-separated list
00165     const char* start = value;
00166     char buffer[128];
00167     std::memset(buffer, 0, sizeof(buffer));
00168     while (const char* next_comma = std::strchr(start, ',')) {
00169       // Copy into temp buffer, won't have null
00170       std::strncpy(buffer, start, next_comma - start);
00171       // Append null
00172       buffer[next_comma - start] = '\0';
00173       // Add to QOS
00174       target.name.length(target.name.length() + 1);
00175       target.name[target.name.length() - 1] = static_cast<const char*>(buffer);
00176       // Advance pointer
00177       start = next_comma + 1;
00178     }
00179     // Append everything after last comma
00180     target.name.length(target.name.length() + 1);
00181     target.name[target.name.length() - 1] = start;
00182 
00183     matched = true;
00184   }
00185   return matched;
00186 }

bool OpenDDS::FaceTSS::config::set_durability_kind_qos ( DDS::DurabilityQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 189 of file QosSettings.cpp.

References DDS::DurabilityQosPolicy::kind, DDS::PERSISTENT_DURABILITY_QOS, DDS::TRANSIENT_DURABILITY_QOS, DDS::TRANSIENT_LOCAL_DURABILITY_QOS, and DDS::VOLATILE_DURABILITY_QOS.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00191 {
00192   bool matched = false;
00193   if (!std::strcmp(name, "durability.kind")) {
00194     if (!std::strcmp(value, "VOLATILE")) {
00195       target.kind = DDS::VOLATILE_DURABILITY_QOS;
00196       matched = true;
00197     } else if (!std::strcmp(value, "TRANSIENT_LOCAL")) {
00198       target.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
00199       matched = true;
00200 #ifndef OPENDDS_NO_PERSISTENCE_PROFILE
00201     } else if (!std::strcmp(value, "TRANSIENT")) {
00202       target.kind = DDS::TRANSIENT_DURABILITY_QOS;
00203       matched = true;
00204     } else if (!std::strcmp(value, "PERSISTENT")) {
00205       target.kind = DDS::PERSISTENT_DURABILITY_QOS;
00206       matched = true;
00207 #endif
00208     }
00209   }
00210   return matched;
00211 }

bool OpenDDS::FaceTSS::config::set_deadline_period_qos ( DDS::DeadlineQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 214 of file QosSettings.cpp.

References DDS::DeadlineQosPolicy::period, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00216 {
00217   return set_duration_qos_value(target.period, "deadline.period", name, value);
00218 }

bool OpenDDS::FaceTSS::config::set_latency_budget_duration_qos ( DDS::LatencyBudgetQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 221 of file QosSettings.cpp.

References DDS::LatencyBudgetQosPolicy::duration, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00223 {
00224   return set_duration_qos_value(
00225     target.duration, "latency_budget.duration", name, value);
00226 }

bool OpenDDS::FaceTSS::config::set_liveliness_kind_qos ( DDS::LivelinessQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 228 of file QosSettings.cpp.

References DDS::AUTOMATIC_LIVELINESS_QOS, DDS::LivelinessQosPolicy::kind, DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS, and DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00230 {
00231   bool matched = false;
00232   if (!std::strcmp(name, "liveliness.kind")) {
00233     if (!std::strcmp(value, "AUTOMATIC")) {
00234       target.kind = DDS::AUTOMATIC_LIVELINESS_QOS;
00235       matched = true;
00236     } else if (!std::strcmp(value, "MANUAL_BY_TOPIC")) {
00237       target.kind = DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS;
00238       matched = true;
00239     } else if (!std::strcmp(value, "MANUAL_BY_PARTICIPANT")) {
00240       target.kind = DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS;
00241       matched = true;
00242     }
00243   }
00244   return matched;
00245 }

bool OpenDDS::FaceTSS::config::set_liveliness_lease_duration_qos ( DDS::LivelinessQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 247 of file QosSettings.cpp.

References DDS::LivelinessQosPolicy::lease_duration, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00249 {
00250   return set_duration_qos_value(
00251     target.lease_duration, "liveliness.lease_duration", name, value);
00252 }

bool OpenDDS::FaceTSS::config::set_reliability_kind_qos ( DDS::ReliabilityQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 254 of file QosSettings.cpp.

References DDS::BEST_EFFORT_RELIABILITY_QOS, DDS::ReliabilityQosPolicy::kind, and DDS::RELIABLE_RELIABILITY_QOS.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00256 {
00257   bool matched = false;
00258   if (!std::strcmp(name, "reliability.kind")) {
00259     if (!std::strcmp(value, "BEST_EFFORT")) {
00260       target.kind = DDS::BEST_EFFORT_RELIABILITY_QOS;
00261       matched = true;
00262     } else if (!std::strcmp(value, "RELIABLE")) {
00263       target.kind = DDS::RELIABLE_RELIABILITY_QOS;
00264       matched = true;
00265     }
00266   }
00267   return matched;
00268 }

bool OpenDDS::FaceTSS::config::set_reliability_max_blocking_time_qos ( DDS::ReliabilityQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 270 of file QosSettings.cpp.

References DDS::ReliabilityQosPolicy::max_blocking_time, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00272 {
00273   return set_duration_qos_value(
00274     target.max_blocking_time, "reliability.max_blocking_time", name, value);
00275 }

bool OpenDDS::FaceTSS::config::set_destination_order_kind_qos ( DDS::DestinationOrderQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 277 of file QosSettings.cpp.

References DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS, DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS, and DDS::DestinationOrderQosPolicy::kind.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00279 {
00280   bool matched = false;
00281   if (!std::strcmp(name, "destination_order.kind")) {
00282     if (!std::strcmp(value, "BY_RECEPTION_TIMESTAMP")) {
00283       target.kind = DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS;
00284       matched = true;
00285     } else if (!std::strcmp(value, "BY_SOURCE_TIMESTAMP")) {
00286       target.kind = DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS;
00287       matched = true;
00288     }
00289   }
00290   return matched;
00291 }

bool OpenDDS::FaceTSS::config::set_history_kind_qos ( DDS::HistoryQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 293 of file QosSettings.cpp.

References DDS::KEEP_ALL_HISTORY_QOS, DDS::KEEP_LAST_HISTORY_QOS, and DDS::HistoryQosPolicy::kind.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00295 {
00296   bool matched = false;
00297   if (!std::strcmp(name, "history.kind")) {
00298     if (!std::strcmp(value, "KEEP_ALL")) {
00299       target.kind = DDS::KEEP_ALL_HISTORY_QOS;
00300       matched = true;
00301     } else if (!std::strcmp(value, "KEEP_LAST")) {
00302       target.kind = DDS::KEEP_LAST_HISTORY_QOS;
00303       matched = true;
00304     }
00305   }
00306   return matched;
00307 }

bool OpenDDS::FaceTSS::config::set_history_depth_qos ( DDS::HistoryQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 309 of file QosSettings.cpp.

References DDS::HistoryQosPolicy::depth.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00311 {
00312   bool matched = false;
00313   if (!std::strcmp(name, "history.depth")) {
00314     target.depth = atoi(value);
00315     matched = true;
00316   }
00317   return matched;
00318 }

bool OpenDDS::FaceTSS::config::set_resource_limits_max_samples_qos ( DDS::ResourceLimitsQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 320 of file QosSettings.cpp.

References DDS::ResourceLimitsQosPolicy::max_samples.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00322 {
00323   bool matched = false;
00324   if (!std::strcmp(name, "resource_limits.max_samples")) {
00325     target.max_samples = atoi(value);
00326     matched = true;
00327   }
00328   return matched;
00329 }

bool OpenDDS::FaceTSS::config::set_resource_limits_max_instances_qos ( DDS::ResourceLimitsQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 331 of file QosSettings.cpp.

References DDS::ResourceLimitsQosPolicy::max_instances.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00333 {
00334   bool matched = false;
00335   if (!std::strcmp(name, "resource_limits.max_instances")) {
00336     target.max_instances = atoi(value);
00337     matched = true;
00338   }
00339   return matched;
00340 }

bool OpenDDS::FaceTSS::config::set_resource_limits_max_samples_per_instance_qos ( DDS::ResourceLimitsQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 342 of file QosSettings.cpp.

References DDS::ResourceLimitsQosPolicy::max_samples_per_instance.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00344 {
00345   bool matched = false;
00346   if (!std::strcmp(name, "resource_limits.max_samples_per_instance")) {
00347     target.max_samples_per_instance = atoi(value);
00348     matched = true;
00349   }
00350   return matched;
00351 }

bool OpenDDS::FaceTSS::config::set_transport_priority_qos ( DDS::TransportPriorityQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 353 of file QosSettings.cpp.

References DDS::TransportPriorityQosPolicy::value.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00355 {
00356   bool matched = false;
00357   if (!std::strcmp(name, "transport_priority.value")) {
00358     target.value = atoi(value);
00359     matched = true;
00360   }
00361   return matched;
00362 }

bool OpenDDS::FaceTSS::config::set_lifespan_duration_qos ( DDS::LifespanQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 364 of file QosSettings.cpp.

References DDS::LifespanQosPolicy::duration, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00366 {
00367   return set_duration_qos_value(
00368     target.duration, "lifespan.duration", name, value);
00369 }

bool OpenDDS::FaceTSS::config::set_ownership_kind_qos ( DDS::OwnershipQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 371 of file QosSettings.cpp.

References DDS::EXCLUSIVE_OWNERSHIP_QOS, DDS::OwnershipQosPolicy::kind, and DDS::SHARED_OWNERSHIP_QOS.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00373 {
00374   bool matched = false;
00375   if (!std::strcmp(name, "ownership.kind")) {
00376     if (!std::strcmp(value, "SHARED")) {
00377       target.kind = DDS::SHARED_OWNERSHIP_QOS;
00378       matched = true;
00379     } else if (!std::strcmp(value, "EXCLUSIVE")) {
00380       target.kind = DDS::EXCLUSIVE_OWNERSHIP_QOS;
00381       matched = true;
00382     }
00383   }
00384   return matched;
00385 }

bool OpenDDS::FaceTSS::config::set_ownership_strength_value_qos ( DDS::OwnershipStrengthQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 387 of file QosSettings.cpp.

References DDS::OwnershipStrengthQosPolicy::value.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00389 {
00390   bool matched = false;
00391   if (!std::strcmp(name, "ownership_strength.value")) {
00392     target.value = atoi(value);
00393     matched = true;
00394   }
00395   return matched;
00396 }

bool OpenDDS::FaceTSS::config::set_time_based_filter_minimum_separation ( DDS::TimeBasedFilterQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 398 of file QosSettings.cpp.

References DDS::TimeBasedFilterQosPolicy::minimum_separation, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00400 {
00401   return set_duration_qos_value(
00402     target.minimum_separation, "time_based_filter.minimum_separation", name, value);
00403 }

bool OpenDDS::FaceTSS::config::set_reader_data_lifecycle_autopurge_nowriter_samples_delay ( DDS::ReaderDataLifecycleQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 405 of file QosSettings.cpp.

References DDS::ReaderDataLifecycleQosPolicy::autopurge_nowriter_samples_delay, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00407 {
00408   return set_duration_qos_value(
00409     target.autopurge_nowriter_samples_delay,
00410     "reader_data_lifecycle.autopurge_nowriter_samples_delay", name, value);
00411 }

bool OpenDDS::FaceTSS::config::set_reader_data_lifecycle_autopurge_disposed_samples_delay ( DDS::ReaderDataLifecycleQosPolicy target,
const char *  name,
const char *  value 
)

Definition at line 413 of file QosSettings.cpp.

References DDS::ReaderDataLifecycleQosPolicy::autopurge_disposed_samples_delay, and set_duration_qos_value().

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00415 {
00416   return set_duration_qos_value(
00417     target.autopurge_disposed_samples_delay,
00418     "reader_data_lifecycle.autopurge_disposed_samples_delay", name, value);
00419 }

void OpenDDS::FaceTSS::config::log_parser_error ( const char *  section,
const char *  name,
const char *  value 
)

Definition at line 422 of file QosSettings.cpp.

Referenced by OpenDDS::FaceTSS::config::QosSettings::set_qos().

00423 {
00424   ACE_DEBUG((LM_ERROR, "Could not set %s QOS setting %s to value %s\n",
00425     section, name, value));
00426 }

typedef OpenDDS::FaceTSS::config::OPENDDS_MAP ( OPENDDS_STRING  ,
QosSettings   
)

typedef OpenDDS::FaceTSS::config::OPENDDS_MAP ( OPENDDS_STRING  ,
TopicSettings   
)


Variable Documentation

const char* OpenDDS::FaceTSS::config::TOPIC_SECTION = "topic" [static]

Definition at line 16 of file Parser.cpp.

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

const char* OpenDDS::FaceTSS::config::CONNECTION_SECTION = "connection" [static]

Definition at line 17 of file Parser.cpp.

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

const char* OpenDDS::FaceTSS::config::DATAWRITER_QOS_SECTION = "datawriterqos" [static]

Definition at line 18 of file Parser.cpp.

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

const char* OpenDDS::FaceTSS::config::DATAREADER_QOS_SECTION = "datareaderqos" [static]

Definition at line 19 of file Parser.cpp.

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

const char* OpenDDS::FaceTSS::config::PUBLISHER_QOS_SECTION = "publisherqos" [static]

Definition at line 20 of file Parser.cpp.

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

const char* OpenDDS::FaceTSS::config::SUBSCRIBER_QOS_SECTION = "subscriberqos" [static]

Definition at line 21 of file Parser.cpp.

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


Generated on Fri Feb 12 20:06:46 2016 for OpenDDS by  doxygen 1.4.7