Implements the DDS::Topic interface. More...

#include <TopicImpl.h>

Inheritance diagram for OpenDDS::DCPS::TopicImpl:

[legend]

Collaboration diagram for OpenDDS::DCPS::TopicImpl:

[legend]

Public Member Functions
	TopicImpl (const char topic_name, const char type_name, OpenDDS::DCPS::TypeSupport_ptr type_support, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener, const DDS::StatusMask &mask, DomainParticipantImpl *participant)

virtual	~TopicImpl ()

virtual DDS::InstanceHandle_t	get_instance_handle ()

virtual DDS::ReturnCode_t	set_qos (const DDS::TopicQos &qos)

virtual DDS::ReturnCode_t	get_qos (DDS::TopicQos &qos)

virtual DDS::ReturnCode_t	set_listener (DDS::TopicListener_ptr a_listener, DDS::StatusMask mask)

virtual DDS::TopicListener_ptr	get_listener ()

virtual DDS::ReturnCode_t	get_inconsistent_topic_status (DDS::InconsistentTopicStatus &a_status)

virtual DDS::ReturnCode_t	enable ()

GUID_t	get_id () const

const char *	type_name () const

const char *	topic_name () const

virtual void	transport_config (const TransportConfig_rch &cfg)

void	inconsistent_topic (int count)

bool	check_data_representation (const DDS::DataRepresentationIdSeq &qos_ids, bool is_data_writer)

Public Member Functions inherited from DDS::Topic
ReturnCode_t	set_qos (in TopicQos qos)

ReturnCode_t	get_qos (inout TopicQos qos)

ReturnCode_t	set_listener (in TopicListener a_listener, in StatusMask mask)

ReturnCode_t	get_inconsistent_topic_status (inout InconsistentTopicStatus a_status)

Public Member Functions inherited from OpenDDS::DCPS::LocalObjectBase
virtual void	_add_ref ()

virtual void	_remove_ref ()

virtual CORBA::ULong	_refcount_value () const

Public Member Functions inherited from CORBA::LocalObject
virtual	~LocalObject (void)

virtual CORBA::Boolean	_non_existent (void)

virtual char *	_repository_id (void)

virtual CORBA::InterfaceDef_ptr	_get_interface (void)

virtual CORBA::Object_ptr	_get_component (void)

virtual void	_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags)

virtual void	_create_request (CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exclist, CORBA::ContextList_ptr ctxtlist, CORBA::Request_ptr &request, CORBA::Flags req_flags)

virtual CORBA::Request_ptr	_request (const char *operation)

CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)

CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)

CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)

CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)

CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)

virtual CORBA::ULong	_hash (CORBA::ULong maximum)

virtual CORBA::Boolean	_is_equivalent (CORBA::Object_ptr other_obj)

virtual CORBA::ORB_ptr	_get_orb (void)

virtual TAO::ObjectKey *	_key (void)

Public Member Functions inherited from CORBA::Object
virtual	~Object (void)

virtual TAO_Abstract_ServantBase *	_servant (void) const

virtual CORBA::Boolean	_is_collocated (void) const

virtual CORBA::Boolean	_is_local (void) const

	Object (TAO_Stub p, CORBA::Boolean collocated=false, TAO_Abstract_ServantBase servant=0, TAO_ORB_Core *orb_core=0)

	Object (IOP::IOR ior, TAO_ORB_Core orb_core)

virtual TAO_Stub *	_stubobj (void) const

virtual TAO_Stub *	_stubobj (void)

virtual void	_proxy_broker (TAO::Object_Proxy_Broker *proxy_broker)

virtual CORBA::Boolean	marshal (TAO_OutputCDR &cdr)

CORBA::Boolean	is_evaluated (void) const

TAO_ORB_Core *	orb_core (void) const

IOP::IOR *	steal_ior (void)

const IOP::IOR &	ior (void) const

virtual bool	can_convert_to_ior (void) const

virtual char *	convert_to_ior (bool use_omg_ior_format, const char *ior_prefix) const

void	_decr_refcount (void)

virtual CORBA::Boolean	_is_a (const char *logical_type_id)

virtual const char *	_interface_repository_id (void) const

CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)

CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)

CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)

CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)

CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Public Member Functions inherited from OpenDDS::DCPS::EntityImpl
	EntityImpl ()

virtual	~EntityImpl ()

bool	is_enabled () const

virtual DDS::StatusCondition_ptr	get_statuscondition ()

virtual DDS::StatusMask	get_status_changes ()

virtual DDS::DomainId_t	get_domain_id ()

void	set_status_changed_flag (DDS::StatusKind status, bool status_changed_flag)

void	notify_status_condition ()

TransportConfig_rch	transport_config () const

virtual RcHandle< EntityImpl >	parent () const

void	set_observer (Observer_rch observer, Observer::Event e)

Observer_rch	get_observer (Observer::Event e)

Public Member Functions inherited from OpenDDS::DCPS::TopicCallbacks
	TopicCallbacks ()

virtual	~TopicCallbacks ()

Public Member Functions inherited from OpenDDS::DCPS::TopicDescriptionImpl
	TopicDescriptionImpl (const char topic_name, const char type_name, TypeSupport_ptr type_support, DomainParticipantImpl *participant)

virtual	~TopicDescriptionImpl ()

virtual char *	get_type_name ()

virtual char *	get_name ()

virtual DDS::DomainParticipant_ptr	get_participant ()

OpenDDS::DCPS::TypeSupport_ptr	get_type_support ()

bool	has_entity_refs () const

void	add_entity_ref ()

void	remove_entity_ref ()

Private Attributes
DDS::TopicQos	qos_
	The topic qos. More...

ACE_Thread_Mutex	listener_mutex_
	Mutex to protect listener info. More...

DDS::StatusMask	listener_mask_

DDS::TopicListener_var	listener_
	The topic listener. More...

GUID_t	id_
	The id given by discovery. More...

ACE_Thread_Mutex	status_mutex_
	Mutex to protect status info. More...

DDS::InconsistentTopicStatus	inconsistent_topic_status_

unique_ptr< Monitor >	monitor_
	Pointer to the monitor object for this entity. More...

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::Topic >
typedef DDS::Topic ::_ptr_type	_ptr_type

typedef DDS::Topic ::_var_type	_var_type

Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr	_ptr_type

typedef LocalObject_var	_var_type

typedef LocalObject_out	_out_type

Public Types inherited from CORBA::Object
typedef Object_ptr	_ptr_type

typedef Object_var	_var_type

typedef Object_out	_out_type

Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::Entity >
typedef DDS::Entity ::_ptr_type	_ptr_type

typedef DDS::Entity ::_var_type	_var_type

Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::TopicDescription >
typedef DDS::TopicDescription ::_ptr_type	_ptr_type

typedef DDS::TopicDescription ::_var_type	_var_type

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::Topic >
static _ptr_type	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from CORBA::LocalObject
static LocalObject_ptr	_duplicate (LocalObject_ptr obj)

static LocalObject_ptr	_nil (void)

static LocalObject_ptr	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from CORBA::Object
static CORBA::Boolean	marshal (const Object_ptr x, TAO_OutputCDR &cdr)

static void	_tao_any_destructor (void *)

static CORBA::Boolean	is_nil_i (CORBA::Object_ptr obj)

static void	tao_object_initialize (Object *)

static CORBA::Object_ptr	_duplicate (CORBA::Object_ptr obj)

static CORBA::Object_ptr	_nil (void)

static CORBA::Object_ptr	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::Entity >
static _ptr_type	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::TopicDescription >
static _ptr_type	_narrow (CORBA::Object_ptr obj)

Protected Member Functions inherited from CORBA::LocalObject
	LocalObject (void)

Protected Member Functions inherited from CORBA::Object
	Object (int dummy=0)

TAO::Object_Proxy_Broker *	proxy_broker () const

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Member Functions inherited from OpenDDS::DCPS::EntityImpl
DDS::ReturnCode_t	set_enabled ()

void	set_deleted (bool state)

bool	get_deleted () const

DDS::InstanceHandle_t	get_entity_instance_handle (const GUID_t &id, const RcHandle< DomainParticipantImpl > &participant)

Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Protected Attributes inherited from OpenDDS::DCPS::EntityImpl
AtomicBool	enabled_
	The flag indicates the entity is enabled. More...

AtomicBool	entity_deleted_
	The flag indicates the entity is being deleted. More...

Protected Attributes inherited from OpenDDS::DCPS::TopicDescriptionImpl
ACE_CString	topic_name_
	The name of the topic. More...

ACE_CString	type_name_
	The datatype of the topic. More...

DomainParticipantImpl *	participant_
	The participant that creates this topic. More...

OpenDDS::DCPS::TypeSupport_var	type_support_
	The type_support for this topic. More...

Atomic< ACE_UINT32 >	entity_refs_
	The number of entities using this topic. More...

Detailed Description

Implements the DDS::Topic interface.

See the DDS specification, OMG formal/2015-04-10, for a description of the interface this class is implementing.

Definition at line 37 of file TopicImpl.h.

Constructor & Destructor Documentation

◆ TopicImpl()

OpenDDS::DCPS::TopicImpl::TopicImpl	(	const char *	topic_name,
		const char *	type_name,
		OpenDDS::DCPS::TypeSupport_ptr	type_support,
		const DDS::TopicQos &	qos,
		DDS::TopicListener_ptr	a_listener,
		const DDS::StatusMask &	mask,
		DomainParticipantImpl *	participant
	)

Definition at line 26 of file TopicImpl.cpp.

References _duplicate(), inconsistent_topic_status_, monitor_, TheServiceParticipant, DDS::InconsistentTopicStatus::total_count, and DDS::InconsistentTopicStatus::total_count_change.

   : TopicDescriptionImpl(topic_name,
                          type_name,
                          type_support,
                          participant),
     qos_(qos),
     listener_mask_(mask),
     listener_(DDS::TopicListener::_duplicate(a_listener)),
     id_(GUID_UNKNOWN)
 {
   inconsistent_topic_status_.total_count = 0;
   inconsistent_topic_status_.total_count_change = 0;
   monitor_.reset(TheServiceParticipant->monitor_factory_->create_topic_monitor(this));
 }

◆ ~TopicImpl()

OpenDDS::DCPS::TopicImpl::~TopicImpl ( )

virtual

Definition at line 47 of file TopicImpl.cpp.

48 {

49 }

Member Function Documentation

◆ check_data_representation()

bool OpenDDS::DCPS::TopicImpl::check_data_representation	(	const DDS::DataRepresentationIdSeq &	qos_ids,
		bool	is_data_writer
	)

Compare the QoS of the IDL Type and the Topic/DataWriter/DataReader to see whether the type matches all values in the QoS.

Definition at line 232 of file TopicImpl.cpp.

References ACE_ERROR, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::repr_seq_to_string(), and OpenDDS::DCPS::TopicDescriptionImpl::type_support_.

 {
   if (!type_support_) {
     return true;
   }
   DDS::DataRepresentationIdSeq type_allowed_reprs;
   type_support_->representations_allowed_by_type(type_allowed_reprs);
   //default for blank annotation is to allow all types of data representation
   if (type_allowed_reprs.length() == 0) {
     return true;
   }
   if (qos_ids.length() == 0) {
     if (log_level >= LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: TopicImpl::check_data_representation: "
         "representation qos is blank.\n"));
     }
     return false;
   }
   //Data Writer will only use the 1st QoS declared
   if (is_data_writer) {
     DDS::DataRepresentationId_t id = qos_ids[0];
     for (CORBA::ULong j = 0; j < type_allowed_reprs.length(); ++j) {
       if (id == type_allowed_reprs[j]) {
         return true;
       }
     }
   } else { // if data reader compare both lists for a compatible QoS
     for (CORBA::ULong i = 0; i < qos_ids.length(); ++i) {
       for (CORBA::ULong j = 0; j < type_allowed_reprs.length(); ++j) {
         if (qos_ids[i] == type_allowed_reprs[j]) {
           return true;
         }
       }
     }
   }
   if (log_level >= LogLevel::Notice) {
     ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: TopicImpl::check_data_representation: "
       "none of the data representation QoS: %C is allowed by the "
       "topic type IDL annotations: %C\n", repr_seq_to_string(qos_ids, is_data_writer).c_str(), repr_seq_to_string(type_allowed_reprs).c_str()));
   }
   return false;
 }

◆ enable()

DDS::ReturnCode_t OpenDDS::DCPS::TopicImpl::enable ( )

virtual

Implements DDS::Entity.

Definition at line 127 of file TopicImpl.cpp.

References ACE_ERROR, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::CREATED, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::FOUND, OpenDDS::DCPS::DomainParticipantImpl::get_domain_id(), OpenDDS::DCPS::DomainParticipantImpl::get_id(), OpenDDS::DCPS::GUID_UNKNOWN, id_, OpenDDS::DCPS::EntityImpl::is_enabled(), LM_ERROR, monitor_, OpenDDS::DCPS::TopicDescriptionImpl::participant_, qos_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::DCPS::EntityImpl::set_enabled(), TheServiceParticipant, OpenDDS::DCPS::TopicDescriptionImpl::topic_name_, OpenDDS::DCPS::topicstatus_to_string(), OpenDDS::DCPS::TopicDescriptionImpl::type_name_, and OpenDDS::DCPS::TopicDescriptionImpl::type_support_.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::create_new_topic().

 {
   //According spec:
   // - Calling enable on an already enabled Entity returns OK and has no
   // effect.
   // - Calling enable on an Entity whose factory is not enabled will fail
   // and return PRECONDITION_NOT_MET.
 
   if (this->is_enabled()) {
     return DDS::RETCODE_OK;
   }
 
   if (!this->participant_->is_enabled()) {
     return DDS::RETCODE_PRECONDITION_NOT_MET;
   }
 
   if (id_ == GUID_UNKNOWN) {
     const DDS::DomainId_t dom_id = participant_->get_domain_id();
     Discovery_rch disco = TheServiceParticipant->get_discovery(dom_id);
     TopicStatus status = disco->assert_topic(id_,
                                              dom_id,
                                              participant_->get_id(),
                                              topic_name_.c_str(),
                                              type_name_.c_str(),
                                              qos_,
                                              type_support_ ? type_support_->has_dcps_key() : false,
                                              this);
     if (status != CREATED && status != FOUND) {
       if (DCPS_debug_level >= 1) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: TopicImpl::enable, ")
                    ACE_TEXT("assert_topic failed with return value <%C>.\n"),
                    topicstatus_to_string(status)));
       }
       return DDS::RETCODE_ERROR;
     }
   }
 
   if (this->monitor_) {
     monitor_->report();
   }
   return this->set_enabled();
 }

◆ get_id()

GUID_t OpenDDS::DCPS::TopicImpl::get_id ( void ) const

virtual

This method is not defined in the IDL and is defined for internal use. Return the id given by discovery.

Reimplemented from OpenDDS::DCPS::EntityImpl.

Definition at line 172 of file TopicImpl.cpp.

References id_.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::delete_topic_i(), OpenDDS::DCPS::TopicMonitorImpl::report(), and OpenDDS::DCPS::DWMonitorImpl::report().

 {
   return id_;
 }

◆ get_inconsistent_topic_status()

DDS::ReturnCode_t OpenDDS::DCPS::TopicImpl::get_inconsistent_topic_status ( DDS::InconsistentTopicStatus & a_status )

virtual

Definition at line 117 of file TopicImpl.cpp.

References DDS::INCONSISTENT_TOPIC_STATUS, inconsistent_topic_status_, DDS::RETCODE_OK, OpenDDS::DCPS::EntityImpl::set_status_changed_flag(), status_mutex_, and DDS::InconsistentTopicStatus::total_count_change.

 {
   ACE_Guard<ACE_Thread_Mutex> g(status_mutex_);
   set_status_changed_flag(DDS::INCONSISTENT_TOPIC_STATUS, false);
   a_status = inconsistent_topic_status_;
   inconsistent_topic_status_.total_count_change = 0;
   return DDS::RETCODE_OK;
 }

◆ get_instance_handle()

DDS::InstanceHandle_t OpenDDS::DCPS::TopicImpl::get_instance_handle ( )

virtual

Implements OpenDDS::DCPS::EntityImpl.

Definition at line 178 of file TopicImpl.cpp.

References OpenDDS::DCPS::EntityImpl::get_entity_instance_handle(), id_, OpenDDS::DCPS::TopicDescriptionImpl::participant_, and OpenDDS::DCPS::rchandle_from().

 {
   return get_entity_instance_handle(id_, rchandle_from(participant_));
 }

◆ get_listener()

DDS::TopicListener_ptr OpenDDS::DCPS::TopicImpl::get_listener ( )

virtual

Implements DDS::Topic.

Definition at line 110 of file TopicImpl.cpp.

References listener_, and listener_mutex_.

 {
   ACE_Guard<ACE_Thread_Mutex> g(listener_mutex_);
   return DDS::TopicListener::_duplicate(listener_.in());
 }

◆ get_qos()

DDS::ReturnCode_t OpenDDS::DCPS::TopicImpl::get_qos ( DDS::TopicQos & qos )

virtual

Definition at line 93 of file TopicImpl.cpp.

References qos_, and DDS::RETCODE_OK.

 {
   qos = qos_;
   return DDS::RETCODE_OK;
 }

◆ inconsistent_topic()

void OpenDDS::DCPS::TopicImpl::inconsistent_topic ( int count )

virtual

Implements OpenDDS::DCPS::TopicCallbacks.

Definition at line 203 of file TopicImpl.cpp.

References DDS::INCONSISTENT_TOPIC_STATUS, inconsistent_topic_status_, listener_, OpenDDS::DCPS::DomainParticipantImpl::listener_for(), listener_mask_, listener_mutex_, OpenDDS::DCPS::EntityImpl::notify_status_condition(), OpenDDS::DCPS::TopicDescriptionImpl::participant_, ACE_Guard< ACE_LOCK >::release(), OpenDDS::DCPS::EntityImpl::set_status_changed_flag(), status_mutex_, DDS::InconsistentTopicStatus::total_count, and DDS::InconsistentTopicStatus::total_count_change.

 {
   ACE_Guard<ACE_Thread_Mutex> status_guard(status_mutex_);
   inconsistent_topic_status_.total_count_change += count - inconsistent_topic_status_.total_count;
   inconsistent_topic_status_.total_count = count;
 
   set_status_changed_flag(DDS::INCONSISTENT_TOPIC_STATUS, true);
 
   DDS::TopicListener_var listener;
   {
     ACE_Guard<ACE_Thread_Mutex> g(listener_mutex_);
     listener = listener_;
     if (!listener || !(listener_mask_ & DDS::INCONSISTENT_TOPIC_STATUS)) {
       g.release();
       listener = participant_->listener_for(DDS::INCONSISTENT_TOPIC_STATUS);
     }
   }
   if (listener) {
     const DDS::InconsistentTopicStatus status = inconsistent_topic_status_;
     inconsistent_topic_status_.total_count_change = 0;
     status_guard.release();
     listener->on_inconsistent_topic(this, status);
   } else {
     status_guard.release();
   }
 
   notify_status_condition();
 }

◆ set_listener()

DDS::ReturnCode_t OpenDDS::DCPS::TopicImpl::set_listener	(	DDS::TopicListener_ptr	a_listener,
		DDS::StatusMask	mask
	)

virtual

Definition at line 100 of file TopicImpl.cpp.

References listener_, listener_mask_, listener_mutex_, and DDS::RETCODE_OK.

 {
   ACE_Guard<ACE_Thread_Mutex> g(listener_mutex_);
   listener_mask_ = mask;
   //note: OK to duplicate  a nil object ref
   listener_ = DDS::TopicListener::_duplicate(a_listener);
   return DDS::RETCODE_OK;
 }

◆ set_qos()

DDS::ReturnCode_t OpenDDS::DCPS::TopicImpl::set_qos ( const DDS::TopicQos & qos )

virtual

Definition at line 51 of file TopicImpl.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::Qos_Helper::changeable(), OpenDDS::DCPS::Qos_Helper::consistent(), OpenDDS::DCPS::EntityImpl::enabled_, OpenDDS::DCPS::DomainParticipantImpl::get_domain_id(), OpenDDS::DCPS::DomainParticipantImpl::get_id(), id_, LM_ERROR, OPENDDS_NO_DURABILITY_KIND_TRANSIENT_PERSISTENT_COMPATIBILITY_CHECK, OPENDDS_NO_DURABILITY_SERVICE_COMPATIBILITY_CHECK, OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE_COMPATIBILITY_CHECK, OPENDDS_NO_OWNERSHIP_PROFILE_COMPATIBILITY_CHECK, OpenDDS::DCPS::TopicDescriptionImpl::participant_, qos_, DDS::RETCODE_ERROR, DDS::RETCODE_IMMUTABLE_POLICY, DDS::RETCODE_INCONSISTENT_POLICY, DDS::RETCODE_OK, DDS::RETCODE_UNSUPPORTED, TheServiceParticipant, and OpenDDS::DCPS::Qos_Helper::valid().

 {
   DDS::TopicQos qos = qos_arg;
 
   OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE_COMPATIBILITY_CHECK(qos, DDS::RETCODE_UNSUPPORTED);
   OPENDDS_NO_OWNERSHIP_PROFILE_COMPATIBILITY_CHECK(qos, DDS::RETCODE_UNSUPPORTED);
   OPENDDS_NO_DURABILITY_SERVICE_COMPATIBILITY_CHECK(qos, DDS::RETCODE_UNSUPPORTED);
   OPENDDS_NO_DURABILITY_KIND_TRANSIENT_PERSISTENT_COMPATIBILITY_CHECK(qos, DDS::RETCODE_UNSUPPORTED);
 
   if (Qos_Helper::valid(qos) && Qos_Helper::consistent(qos)) {
     if (qos_ == qos)
       return DDS::RETCODE_OK;
 
     // for the not changeable qos, it can be changed before enable
     if (!Qos_Helper::changeable(qos_, qos) && enabled_) {
       return DDS::RETCODE_IMMUTABLE_POLICY;
 
     } else {
       qos_ = qos;
 
       Discovery_rch disco =
         TheServiceParticipant->get_discovery(participant_->get_domain_id());
       const bool status =
         disco->update_topic_qos(this->id_, participant_->get_domain_id(),
                                participant_->get_id(), qos_);
 
       if (!status) {
         ACE_ERROR_RETURN((LM_ERROR,
                           ACE_TEXT("(%P|%t) TopicImpl::set_qos, ")
                           ACE_TEXT("failed on compatibility check.\n")),
                          DDS::RETCODE_ERROR);
       }
     }
 
     return DDS::RETCODE_OK;
 
   } else {
     return DDS::RETCODE_INCONSISTENT_POLICY;
   }
 }

◆ topic_name()

const char * OpenDDS::DCPS::TopicImpl::topic_name ( ) const

Definition at line 190 of file TopicImpl.cpp.

References ACE_String_Base< char >::c_str(), and OpenDDS::DCPS::TopicDescriptionImpl::topic_name_.

 {
   return this->topic_name_.c_str();
 }

◆ transport_config()

void OpenDDS::DCPS::TopicImpl::transport_config ( const TransportConfig_rch & cfg )

virtual

Reimplemented from OpenDDS::DCPS::EntityImpl.

Definition at line 197 of file TopicImpl.cpp.

 {
   throw Transport::MiscProblem();
 }

◆ type_name()

const char * OpenDDS::DCPS::TopicImpl::type_name ( ) const

Definition at line 184 of file TopicImpl.cpp.

References ACE_String_Base< char >::c_str(), and OpenDDS::DCPS::TopicDescriptionImpl::type_name_.

 {
   return this->type_name_.c_str();
 }

Member Data Documentation

◆ id_

GUID_t OpenDDS::DCPS::TopicImpl::id_

private

The id given by discovery.

Definition at line 106 of file TopicImpl.h.

Referenced by enable(), get_id(), get_instance_handle(), and set_qos().

◆ inconsistent_topic_status_

DDS::InconsistentTopicStatus OpenDDS::DCPS::TopicImpl::inconsistent_topic_status_

private

Count of discovered (readers/writers using) topics with the same topic name but different characteristics (typename)

Definition at line 112 of file TopicImpl.h.

Referenced by get_inconsistent_topic_status(), inconsistent_topic(), and TopicImpl().

◆ listener_

DDS::TopicListener_var OpenDDS::DCPS::TopicImpl::listener_

private

The topic listener.

Definition at line 103 of file TopicImpl.h.

Referenced by get_listener(), inconsistent_topic(), and set_listener().

◆ listener_mask_

DDS::StatusMask OpenDDS::DCPS::TopicImpl::listener_mask_

private

The mask for which kind of events the listener will be notified about.

Definition at line 101 of file TopicImpl.h.

Referenced by inconsistent_topic(), and set_listener().

◆ listener_mutex_

ACE_Thread_Mutex OpenDDS::DCPS::TopicImpl::listener_mutex_

private

Mutex to protect listener info.

Definition at line 98 of file TopicImpl.h.

Referenced by get_listener(), inconsistent_topic(), and set_listener().

◆ monitor_

unique_ptr<Monitor> OpenDDS::DCPS::TopicImpl::monitor_

private

Pointer to the monitor object for this entity.

Definition at line 115 of file TopicImpl.h.

Referenced by enable(), and TopicImpl().

◆ qos_

DDS::TopicQos OpenDDS::DCPS::TopicImpl::qos_

private

The topic qos.

Definition at line 95 of file TopicImpl.h.

Referenced by enable(), get_qos(), and set_qos().

◆ status_mutex_

ACE_Thread_Mutex OpenDDS::DCPS::TopicImpl::status_mutex_

private

Mutex to protect status info.

Definition at line 109 of file TopicImpl.h.

Referenced by get_inconsistent_topic_status(), and inconsistent_topic().

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

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ TopicImpl()

◆ ~TopicImpl()

Member Function Documentation

◆ check_data_representation()

◆ enable()

◆ get_id()

◆ get_inconsistent_topic_status()

◆ get_instance_handle()

◆ get_listener()

◆ get_qos()

◆ inconsistent_topic()

◆ set_listener()

◆ set_qos()

◆ topic_name()

◆ transport_config()

◆ type_name()

Member Data Documentation

◆ id_

◆ inconsistent_topic_status_

◆ listener_

◆ listener_mask_

◆ listener_mutex_

◆ monitor_

◆ qos_

◆ status_mutex_