OpenDDS::DCPS::DataReaderQosBuilder Class Reference

#include <Qos_Helper.h>

Collaboration diagram for OpenDDS::DCPS::DataReaderQosBuilder:

Public Member Functions
	DataReaderQosBuilder ()
	DataReaderQosBuilder (DDS::Subscriber_var subscriber)
	DataReaderQosBuilder (DDS::Topic_var topic, DDS::Subscriber_var subscriber)
const DDS::DataReaderQos &	qos () const
DDS::DataReaderQos &	qos ()
	operator const DDS::DataReaderQos & () const
	operator DDS::DataReaderQos & ()
bool	operator== (const DataReaderQosBuilder &other) const
bool	operator!= (const DataReaderQosBuilder &other) const
DataReaderQosBuilder &	durability_kind (DDS::DurabilityQosPolicyKind kind)
DataReaderQosBuilder &	durability_volatile ()
DataReaderQosBuilder &	durability_transient_local ()
DataReaderQosBuilder &	durability_transient ()
DataReaderQosBuilder &	durability_persistent ()
DataReaderQosBuilder &	deadline_period (const DDS::Duration_t &duration)
DataReaderQosBuilder &	latency_budget_duration (const DDS::Duration_t &duration)
DataReaderQosBuilder &	liveliness_kind (DDS::LivelinessQosPolicyKind kind)
DataReaderQosBuilder &	liveliness_automatic ()
DataReaderQosBuilder &	liveliness_manual_by_participant ()
DataReaderQosBuilder &	liveliness_manual_by_topic ()
DataReaderQosBuilder &	liveliness_lease_duration (const DDS::Duration_t &duration)
DataReaderQosBuilder &	reliability_kind (DDS::ReliabilityQosPolicyKind kind)
DataReaderQosBuilder &	reliability_best_effort ()
DataReaderQosBuilder &	reliability_reliable ()
DataReaderQosBuilder &	reliability_max_blocking_time (const DDS::Duration_t &duration)
DataReaderQosBuilder &	destination_order_kind (DDS::DestinationOrderQosPolicyKind kind)
DataReaderQosBuilder &	destination_order_by_reception_timestamp ()
DataReaderQosBuilder &	destination_order_by_source_timestamp ()
DataReaderQosBuilder &	history_kind (DDS::HistoryQosPolicyKind kind)
DataReaderQosBuilder &	history_keep_last (int depth)
DataReaderQosBuilder &	history_keep_all ()
DataReaderQosBuilder &	history_depth (int depth)
DataReaderQosBuilder &	resource_limits_max_samples (int value)
DataReaderQosBuilder &	resource_limits_max_instances (int value)
DataReaderQosBuilder &	resource_limits_max_samples_per_instance (int value)
DataReaderQosBuilder &	user_data_value (const DDS::OctetSeq &value)
DataReaderQosBuilder &	ownership_kind (DDS::OwnershipQosPolicyKind kind)
DataReaderQosBuilder &	ownership_shared ()
DataReaderQosBuilder &	ownership_exclusive ()
DataReaderQosBuilder &	time_based_filter_minimum_separation (const DDS::Duration_t &duration)
DataReaderQosBuilder &	reader_data_lifecycle_autopurge_nowriter_samples_delay (const DDS::Duration_t &duration)
DataReaderQosBuilder &	reader_data_lifecycle_autopurge_disposed_samples_delay (const DDS::Duration_t &duration)
DataReaderQosBuilder &	type_consistency_kind (DDS::TypeConsistencyEnforcementQosPolicyKind_t kind)
DataReaderQosBuilder &	type_consistency_disallow_type_coercion ()
DataReaderQosBuilder &	type_consistency_allow_type_coercion ()
DataReaderQosBuilder &	type_consistency_ignore_sequence_bounds (bool value)
DataReaderQosBuilder &	type_consistency_ignore_string_bounds (bool value)
DataReaderQosBuilder &	type_consistency_ignore_member_names (bool value)
DataReaderQosBuilder &	type_consistency_prevent_type_widening (bool value)
DataReaderQosBuilder &	type_consistency_force_type_validation (bool value)

Private Attributes
DDS::DataReaderQos	qos_

Detailed Description

Definition at line 1695 of file Qos_Helper.h.

Constructor & Destructor Documentation

DataReaderQosBuilder() [1/3]

OpenDDS::DCPS::DataReaderQosBuilder::DataReaderQosBuilder ( )

inline

Definition at line 1697 of file Qos_Helper.h.

  {
    qos_.durability = DurabilityQosPolicyBuilder();
    qos_.deadline = DeadlineQosPolicyBuilder();
    qos_.latency_budget = LatencyBudgetQosPolicyBuilder();
    qos_.liveliness = LivelinessQosPolicyBuilder();
    qos_.reliability = ReliabilityQosPolicyBuilder();
    qos_.destination_order = DestinationOrderQosPolicyBuilder();
    qos_.history = HistoryQosPolicyBuilder();
    qos_.resource_limits = ResourceLimitsQosPolicyBuilder();
    // userdata
    qos_.ownership = OwnershipQosPolicyBuilder();
    qos_.time_based_filter = TimeBasedFilterQosPolicyBuilder();
    qos_.reader_data_lifecycle = ReaderDataLifecycleQosPolicyBuilder();
    // representation
    qos_.type_consistency = TypeConsistencyEnforcementQosPolicyBuilder();
  }

DataReaderQosBuilder() [2/3]

OpenDDS::DCPS::DataReaderQosBuilder::DataReaderQosBuilder ( DDS::Subscriber_var  subscriber )

explicit

Definition at line 527 of file Qos_Helper.cpp.

References ACE_ERROR, ACE_TEXT(), LM_WARNING, OpenDDS::DCPS::log_level, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), and OpenDDS::DCPS::LogLevel::Warning.

{
  const DDS::ReturnCode_t ret = subscriber->get_default_datareader_qos(qos_);
  if (ret != DDS::RETCODE_OK && log_level >= LogLevel::Warning) {
    ACE_ERROR((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: DataReaderQosBuilder: ")
               ACE_TEXT("could not get_default_datareader_qos: %C\n"),
               retcode_to_string(ret)));
  }
}

DataReaderQosBuilder() [3/3]

OpenDDS::DCPS::DataReaderQosBuilder::DataReaderQosBuilder	(	DDS::Topic_var	topic,
		DDS::Subscriber_var	subscriber
	)

Definition at line 538 of file Qos_Helper.cpp.

References ACE_ERROR, ACE_TEXT(), LM_WARNING, OpenDDS::DCPS::log_level, OPENDDS_END_VERSIONED_NAMESPACE_DECL, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), and OpenDDS::DCPS::LogLevel::Warning.

{
  DDS::TopicQos tqos;
  DDS::ReturnCode_t ret = topic->get_qos(tqos);
  if (ret != DDS::RETCODE_OK && log_level >= LogLevel::Warning) {
    ACE_ERROR((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: DataReaderQosBuilder: ")
               ACE_TEXT("could not get_qos on topic: %C\n"),
               retcode_to_string(ret)));
  }
  ret = subscriber->get_default_datareader_qos(qos_);
  if (ret != DDS::RETCODE_OK && log_level >= LogLevel::Warning) {
    ACE_ERROR((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: DataReaderQosBuilder: ")
               ACE_TEXT("could not get_default_datareader_qos: %C\n"),
               retcode_to_string(ret)));
  }
  ret = subscriber->copy_from_topic_qos(qos_, tqos);
  if (ret != DDS::RETCODE_OK && log_level >= LogLevel::Warning) {
    ACE_ERROR((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: DataReaderQosBuilder: ")
               ACE_TEXT("could not copy_from_topic: %C\n"),
               retcode_to_string(ret)));
  }
}

Member Function Documentation

deadline_period()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::deadline_period ( const DDS::Duration_t &  duration )

inline

Definition at line 1765 of file Qos_Helper.h.

  {
    qos_.deadline.period = duration;
    return *this;
  }

destination_order_by_reception_timestamp()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::destination_order_by_reception_timestamp ( )

inline

Definition at line 1837 of file Qos_Helper.h.

References DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS.

  {
    qos_.destination_order.kind = DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS;
    return *this;
  }

destination_order_by_source_timestamp()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::destination_order_by_source_timestamp ( )

inline

Definition at line 1843 of file Qos_Helper.h.

References DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS.

  {
    qos_.destination_order.kind = DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS;
    return *this;
  }

destination_order_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::destination_order_kind ( DDS::DestinationOrderQosPolicyKind  kind )

inline

Definition at line 1831 of file Qos_Helper.h.

  {
    qos_.destination_order.kind = kind;
    return *this;
  }

durability_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::durability_kind ( DDS::DurabilityQosPolicyKind  kind )

inline

Definition at line 1735 of file Qos_Helper.h.

  {
    qos_.durability.kind = kind;
    return *this;
  }

durability_persistent()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::durability_persistent ( )

inline

Definition at line 1759 of file Qos_Helper.h.

References DDS::PERSISTENT_DURABILITY_QOS.

  {
    qos_.durability.kind = DDS::PERSISTENT_DURABILITY_QOS;
    return *this;
  }

durability_transient()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::durability_transient ( )

inline

Definition at line 1753 of file Qos_Helper.h.

References DDS::TRANSIENT_DURABILITY_QOS.

  {
    qos_.durability.kind = DDS::TRANSIENT_DURABILITY_QOS;
    return *this;
  }

durability_transient_local()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::durability_transient_local ( )

inline

Definition at line 1747 of file Qos_Helper.h.

References DDS::TRANSIENT_LOCAL_DURABILITY_QOS.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::open().

  {
    qos_.durability.kind = DDS::TRANSIENT_LOCAL_DURABILITY_QOS;
    return *this;
  }

durability_volatile()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::durability_volatile ( )

inline

Definition at line 1741 of file Qos_Helper.h.

References DDS::VOLATILE_DURABILITY_QOS.

  {
    qos_.durability.kind = DDS::VOLATILE_DURABILITY_QOS;
    return *this;
  }

history_depth()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::history_depth ( int  depth )

inline

Definition at line 1868 of file Qos_Helper.h.

  {
    qos_.history.depth = depth;
    return *this;
  }

history_keep_all()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::history_keep_all ( )

inline

Definition at line 1862 of file Qos_Helper.h.

References DDS::KEEP_ALL_HISTORY_QOS.

  {
    qos_.history.kind = DDS::KEEP_ALL_HISTORY_QOS;
    return *this;
  }

history_keep_last()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::history_keep_last ( int  depth )

inline

Definition at line 1855 of file Qos_Helper.h.

References DDS::KEEP_LAST_HISTORY_QOS.

  {
    qos_.history.kind = DDS::KEEP_LAST_HISTORY_QOS;
    qos_.history.depth = depth;
    return *this;
  }

history_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::history_kind ( DDS::HistoryQosPolicyKind  kind )

inline

Definition at line 1849 of file Qos_Helper.h.

  {
    qos_.history.kind = kind;
    return *this;
  }

latency_budget_duration()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::latency_budget_duration ( const DDS::Duration_t &  duration )

inline

Definition at line 1771 of file Qos_Helper.h.

  {
    qos_.latency_budget.duration = duration;
    return *this;
  }

liveliness_automatic()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::liveliness_automatic ( )

inline

Definition at line 1783 of file Qos_Helper.h.

References DDS::AUTOMATIC_LIVELINESS_QOS.

  {
    qos_.liveliness.kind = DDS::AUTOMATIC_LIVELINESS_QOS;
    return *this;
  }

liveliness_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::liveliness_kind ( DDS::LivelinessQosPolicyKind  kind )

inline

Definition at line 1777 of file Qos_Helper.h.

  {
    qos_.liveliness.kind = kind;
    return *this;
  }

liveliness_lease_duration()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::liveliness_lease_duration ( const DDS::Duration_t &  duration )

inline

Definition at line 1801 of file Qos_Helper.h.

  {
    qos_.liveliness.lease_duration = duration;
    return *this;
  }

liveliness_manual_by_participant()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::liveliness_manual_by_participant ( )

inline

Definition at line 1789 of file Qos_Helper.h.

References DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS.

  {
    qos_.liveliness.kind = DDS::MANUAL_BY_PARTICIPANT_LIVELINESS_QOS;
    return *this;
  }

liveliness_manual_by_topic()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::liveliness_manual_by_topic ( )

inline

Definition at line 1795 of file Qos_Helper.h.

References DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS.

  {
    qos_.liveliness.kind = DDS::MANUAL_BY_TOPIC_LIVELINESS_QOS;
    return *this;
  }

operator const DDS::DataReaderQos &()

OpenDDS::DCPS::DataReaderQosBuilder::operator const DDS::DataReaderQos & ( ) const

inline

Definition at line 1722 of file Qos_Helper.h.

{ return qos_; }

operator DDS::DataReaderQos &()

OpenDDS::DCPS::DataReaderQosBuilder::operator DDS::DataReaderQos & ( )

inline

Definition at line 1723 of file Qos_Helper.h.

{ return qos_; }

operator!=()

bool OpenDDS::DCPS::DataReaderQosBuilder::operator!= ( const DataReaderQosBuilder &  other ) const

inline

Definition at line 1730 of file Qos_Helper.h.

  {
    return !(*this == other);
  }

operator==()

bool OpenDDS::DCPS::DataReaderQosBuilder::operator== ( const DataReaderQosBuilder &  other ) const

inline

Definition at line 1725 of file Qos_Helper.h.

References qos_.

  {
    return qos_ == other.qos_;
  }

ownership_exclusive()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::ownership_exclusive ( )

inline

Definition at line 1910 of file Qos_Helper.h.

References DDS::EXCLUSIVE_OWNERSHIP_QOS.

  {
    qos_.ownership.kind = DDS::EXCLUSIVE_OWNERSHIP_QOS;
    return *this;
  }

ownership_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::ownership_kind ( DDS::OwnershipQosPolicyKind  kind )

inline

Definition at line 1898 of file Qos_Helper.h.

  {
    qos_.ownership.kind = kind;
    return *this;
  }

ownership_shared()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::ownership_shared ( )

inline

Definition at line 1904 of file Qos_Helper.h.

References DDS::SHARED_OWNERSHIP_QOS.

  {
    qos_.ownership.kind = DDS::SHARED_OWNERSHIP_QOS;
    return *this;
  }

qos() [1/2]

const DDS::DataReaderQos& OpenDDS::DCPS::DataReaderQosBuilder::qos ( void  ) const

inline

Definition at line 1720 of file Qos_Helper.h.

{ return qos_; }

qos() [2/2]

DDS::DataReaderQos& OpenDDS::DCPS::DataReaderQosBuilder::qos ( void  )

inline

Definition at line 1721 of file Qos_Helper.h.

{ return qos_; }

reader_data_lifecycle_autopurge_disposed_samples_delay()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reader_data_lifecycle_autopurge_disposed_samples_delay ( const DDS::Duration_t &  duration )

inline

Definition at line 1928 of file Qos_Helper.h.

  {
    qos_.reader_data_lifecycle.autopurge_disposed_samples_delay = duration;
    return *this;
  }

reader_data_lifecycle_autopurge_nowriter_samples_delay()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reader_data_lifecycle_autopurge_nowriter_samples_delay ( const DDS::Duration_t &  duration )

inline

Definition at line 1922 of file Qos_Helper.h.

  {
    qos_.reader_data_lifecycle.autopurge_nowriter_samples_delay = duration;
    return *this;
  }

reliability_best_effort()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reliability_best_effort ( )

inline

Definition at line 1813 of file Qos_Helper.h.

References DDS::BEST_EFFORT_RELIABILITY_QOS.

  {
    qos_.reliability.kind = DDS::BEST_EFFORT_RELIABILITY_QOS;
    return *this;
  }

reliability_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reliability_kind ( DDS::ReliabilityQosPolicyKind  kind )

inline

Definition at line 1807 of file Qos_Helper.h.

  {
    qos_.reliability.kind = kind;
    return *this;
  }

reliability_max_blocking_time()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reliability_max_blocking_time ( const DDS::Duration_t &  duration )

inline

Definition at line 1825 of file Qos_Helper.h.

  {
    qos_.reliability.max_blocking_time = duration;
    return *this;
  }

reliability_reliable()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::reliability_reliable ( )

inline

Definition at line 1819 of file Qos_Helper.h.

References DDS::RELIABLE_RELIABILITY_QOS.

Referenced by OpenDDS::RTPS::Spdp::SpdpTransport::open().

  {
    qos_.reliability.kind = DDS::RELIABLE_RELIABILITY_QOS;
    return *this;
  }

resource_limits_max_instances()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::resource_limits_max_instances ( int  value )

inline

Definition at line 1880 of file Qos_Helper.h.

References value.

  {
    qos_.resource_limits.max_instances = value;
    return *this;
  }

resource_limits_max_samples()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::resource_limits_max_samples ( int  value )

inline

Definition at line 1874 of file Qos_Helper.h.

References value.

  {
    qos_.resource_limits.max_samples = value;
    return *this;
  }

resource_limits_max_samples_per_instance()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::resource_limits_max_samples_per_instance ( int  value )

inline

Definition at line 1886 of file Qos_Helper.h.

References value.

  {
    qos_.resource_limits.max_samples_per_instance = value;
    return *this;
  }

time_based_filter_minimum_separation()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::time_based_filter_minimum_separation ( const DDS::Duration_t &  duration )

inline

Definition at line 1916 of file Qos_Helper.h.

  {
    qos_.time_based_filter.minimum_separation = duration;
    return *this;
  }

type_consistency_allow_type_coercion()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_allow_type_coercion ( )

inline

Definition at line 1946 of file Qos_Helper.h.

References DDS::ALLOW_TYPE_COERCION.

  {
    qos_.type_consistency.kind = DDS::ALLOW_TYPE_COERCION;
    return *this;
  }

type_consistency_disallow_type_coercion()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_disallow_type_coercion ( )

inline

Definition at line 1940 of file Qos_Helper.h.

References DDS::DISALLOW_TYPE_COERCION.

  {
    qos_.type_consistency.kind = DDS::DISALLOW_TYPE_COERCION;
    return *this;
  }

type_consistency_force_type_validation()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_force_type_validation ( bool  value )

inline

Definition at line 1976 of file Qos_Helper.h.

References value.

  {
    qos_.type_consistency.force_type_validation = value;
    return *this;
  }

type_consistency_ignore_member_names()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_ignore_member_names ( bool  value )

inline

Definition at line 1964 of file Qos_Helper.h.

References value.

  {
    qos_.type_consistency.ignore_member_names = value;
    return *this;
  }

type_consistency_ignore_sequence_bounds()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_ignore_sequence_bounds ( bool  value )

inline

Definition at line 1952 of file Qos_Helper.h.

References value.

  {
    qos_.type_consistency.ignore_sequence_bounds = value;
    return *this;
  }

type_consistency_ignore_string_bounds()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_ignore_string_bounds ( bool  value )

inline

Definition at line 1958 of file Qos_Helper.h.

References value.

  {
    qos_.type_consistency.ignore_string_bounds = value;
    return *this;
  }

type_consistency_kind()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_kind ( DDS::TypeConsistencyEnforcementQosPolicyKind_t  kind )

inline

Definition at line 1934 of file Qos_Helper.h.

  {
    qos_.type_consistency.kind = kind;
    return *this;
  }

type_consistency_prevent_type_widening()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::type_consistency_prevent_type_widening ( bool  value )

inline

Definition at line 1970 of file Qos_Helper.h.

References value.

  {
    qos_.type_consistency.prevent_type_widening = value;
    return *this;
  }

user_data_value()

DataReaderQosBuilder& OpenDDS::DCPS::DataReaderQosBuilder::user_data_value ( const DDS::OctetSeq &  value )

inline

Definition at line 1892 of file Qos_Helper.h.

References value.

  {
    qos_.user_data.value = value;
    return *this;
  }

Member Data Documentation

qos_

DDS::DataReaderQos OpenDDS::DCPS::DataReaderQosBuilder::qos_

private

Definition at line 1983 of file Qos_Helper.h.

Referenced by operator==().

---

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

• Qos_Helper.h
• Qos_Helper.cpp