OpenDDS::DCPS::EntityImpl Class Reference

Implements the OpenDDS::DCPS::Entity interfaces. More...

#include <EntityImpl.h>

Inheritance diagram for OpenDDS::DCPS::EntityImpl:

Collaboration diagram for OpenDDS::DCPS::EntityImpl:

Public Member Functions
	EntityImpl ()
virtual	~EntityImpl ()
bool	is_enabled () const
virtual DDS::StatusCondition_ptr	get_statuscondition ()
virtual DDS::StatusMask	get_status_changes ()
virtual DDS::InstanceHandle_t	get_instance_handle ()=0
virtual DDS::DomainId_t	get_domain_id ()
virtual GUID_t	get_id () const
void	set_status_changed_flag (DDS::StatusKind status, bool status_changed_flag)
void	notify_status_condition ()
virtual void	transport_config (const TransportConfig_rch &cfg)
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 DDS::Entity
ReturnCode_t	enable ()
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

Protected Member Functions
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 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 Attributes
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 CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Private Attributes
DDS::StatusMask	status_changes_
DDS::StatusCondition_var	status_condition_
TransportConfig_rch	transport_config_
Observer_rch	observer_
Observer::Event	events_
ACE_Thread_Mutex	lock_
DDS::InstanceHandle_t	instance_handle_
WeakRcHandle< DomainParticipantImpl >	participant_for_instance_handle_

Additional Inherited Members
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 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
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 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)

Detailed Description

Implements the OpenDDS::DCPS::Entity interfaces.

This class is the base class of other servant classes. e.g. DomainParticipantImpl, PublisherImpl ...

Definition at line 37 of file EntityImpl.h.

Constructor & Destructor Documentation

EntityImpl()

OpenDDS::DCPS::EntityImpl::EntityImpl

(

)

Definition at line 20 of file EntityImpl.cpp.

  : enabled_(false)
  , entity_deleted_(false)
  , status_changes_(0)
  , status_condition_(new StatusConditionImpl(this))
  , observer_()
  , events_(Observer::e_NONE)
  , instance_handle_(DDS::HANDLE_NIL)
{
}

~EntityImpl()

OpenDDS::DCPS::EntityImpl::~EntityImpl ( )

virtual

Definition at line 31 of file EntityImpl.cpp.

References instance_handle_, and participant_for_instance_handle_.

{
  const RcHandle<DomainParticipantImpl> participant = participant_for_instance_handle_.lock();
  if (participant) {
    participant->return_handle(instance_handle_);
  }
}

Member Function Documentation

get_deleted()

bool OpenDDS::DCPS::EntityImpl::get_deleted ( ) const

protected

Definition at line 89 of file EntityImpl.cpp.

References entity_deleted_.

Referenced by OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::PublisherImpl::delete_contained_entities(), OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities(), OpenDDS::DCPS::PublisherImpl::delete_datawriter(), OpenDDS::DCPS::PublisherImpl::prepare_to_delete_datawriters(), OpenDDS::DCPS::RecorderImpl::remove_associations(), OpenDDS::DCPS::DataReaderImpl::remove_associations(), and OpenDDS::DCPS::DomainParticipantImpl::update_ownership_strength().

{
  return entity_deleted_;
}

get_domain_id()

virtual DDS::DomainId_t OpenDDS::DCPS::EntityImpl::get_domain_id ( )

inlinevirtual

Reimplemented in OpenDDS::DCPS::DomainParticipantImpl.

Definition at line 52 of file EntityImpl.h.

References OpenDDS::DOMAIN_UNKNOWN.

Referenced by OpenDDS::DCPS::TransportRegistry::bind_config().

{ return DOMAIN_UNKNOWN; }

get_entity_instance_handle()

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

protected

Definition at line 142 of file EntityImpl.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, instance_handle_, lock_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and participant_for_instance_handle_.

Referenced by OpenDDS::DCPS::TopicImpl::get_instance_handle(), OpenDDS::DCPS::RecorderImpl::get_instance_handle(), OpenDDS::DCPS::DomainParticipantImpl::get_instance_handle(), OpenDDS::DCPS::DataWriterImpl::get_instance_handle(), OpenDDS::DCPS::ReplayerImpl::get_instance_handle(), and OpenDDS::DCPS::DataReaderImpl::get_instance_handle().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, DDS::HANDLE_NIL);

  if (instance_handle_ != DDS::HANDLE_NIL) {
    return instance_handle_;
  }

  if (!participant) {
    return DDS::HANDLE_NIL;
  }

  participant_for_instance_handle_ = participant;
  return instance_handle_ = participant->assign_handle(id);
}

get_id()

virtual GUID_t OpenDDS::DCPS::EntityImpl::get_id ( void  ) const

inlinevirtual

Reimplemented in OpenDDS::DCPS::DomainParticipantImpl, and OpenDDS::DCPS::TopicImpl.

Definition at line 54 of file EntityImpl.h.

References OpenDDS::DCPS::GUID_UNKNOWN.

Referenced by OpenDDS::DCPS::TransportRegistry::bind_config().

{ return GUID_UNKNOWN; }

get_instance_handle()

virtual DDS::InstanceHandle_t OpenDDS::DCPS::EntityImpl::get_instance_handle ( )

pure virtual

Implements DDS::Entity.

Implemented in OpenDDS::DCPS::DataReaderImpl, OpenDDS::DCPS::ReplayerImpl, OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::DomainParticipantImpl, OpenDDS::DCPS::RecorderImpl, OpenDDS::DCPS::PublisherImpl, OpenDDS::DCPS::TopicImpl, and OpenDDS::DCPS::SubscriberImpl.

get_observer()

Observer_rch OpenDDS::DCPS::EntityImpl::get_observer

(

Observer::Event

e

)

Definition at line 94 of file EntityImpl.cpp.

References ACE_GUARD_RETURN, events_, lock_, observer_, and parent().

Referenced by OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), OpenDDS::DCPS::DataWriterImpl::prepare_to_delete(), OpenDDS::DCPS::DataWriterImpl::remove_associations(), OpenDDS::DCPS::DataReaderImpl::remove_associations(), OpenDDS::DCPS::DataWriterImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::set_qos(), and OpenDDS::DCPS::DataWriterImpl::write().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, Observer_rch());
  return (observer_ && (events_ & e)) ? observer_ :
         parent() ? parent()->get_observer(e) : Observer_rch();
}

get_status_changes()

DDS::StatusMask OpenDDS::DCPS::EntityImpl::get_status_changes ( )

virtual

Implements DDS::Entity.

Definition at line 61 of file EntityImpl.cpp.

References ACE_GUARD_RETURN, lock_, and status_changes_.

Referenced by OpenDDS::DCPS::StatusConditionImpl::get_trigger_value().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, 0);
  return status_changes_;
}

get_statuscondition()

DDS::StatusCondition_ptr OpenDDS::DCPS::EntityImpl::get_statuscondition ( )

virtual

Implements DDS::Entity.

Definition at line 54 of file EntityImpl.cpp.

References ACE_GUARD_RETURN, lock_, and status_condition_.

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, 0);
  return DDS::StatusCondition::_duplicate(status_condition_);
}

is_enabled()

bool OpenDDS::DCPS::EntityImpl::is_enabled

(

)

const

Definition at line 48 of file EntityImpl.cpp.

References enabled_.

Referenced by OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::SubscriberImpl::enable(), OpenDDS::DCPS::PublisherImpl::enable(), OpenDDS::DCPS::ReplayerImpl::enable(), OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DomainParticipantImpl::enable(), OpenDDS::DCPS::DataReaderImpl::enable(), and OpenDDS::DCPS::RecorderImpl::set_qos().

{
  return enabled_;
}

notify_status_condition()

void OpenDDS::DCPS::EntityImpl::notify_status_condition

(

)

Call this after dispatching to listeners when the "changed status flag" is enabled so that any waiting waitsets can be unblocked.

Definition at line 102 of file EntityImpl.cpp.

References ACE_ERROR, ACE_GUARD, ACE_TEXT(), LM_ERROR, lock_, OpenDDS::DCPS::ConditionImpl::signal_all(), and status_condition_.

Referenced by OpenDDS::DCPS::DataWriterImpl::association_complete_i(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data(), OpenDDS::DCPS::TopicImpl::inconsistent_topic(), OpenDDS::DCPS::WriteDataContainer::process_deadlines(), OpenDDS::DCPS::DataWriterImpl::remove_associations(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::DataReaderImpl::transport_assoc_done(), OpenDDS::DCPS::DataWriterImpl::update_incompatible_qos(), and OpenDDS::DCPS::DataReaderImpl::update_incompatible_qos().

{
  DDS::StatusCondition_var sc_var;
  {
    ACE_GUARD(ACE_Thread_Mutex, g, lock_);

    sc_var = DDS::StatusCondition::_duplicate(status_condition_);
  }

  StatusConditionImpl* sci = dynamic_cast<StatusConditionImpl*>(sc_var.in());
  if (sci) {
    sci->signal_all();
  } else {
    ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
      ACE_TEXT("EntityImpl::notify_status_condition: ")
      ACE_TEXT("failed to obtain the StatusConditionImpl.\n")));
  }
}

parent()

virtual RcHandle<EntityImpl> OpenDDS::DCPS::EntityImpl::parent ( void  ) const

inlinevirtual

Reimplemented in OpenDDS::DCPS::DataReaderImpl, OpenDDS::DCPS::DataWriterImpl, OpenDDS::DCPS::SubscriberImpl, and OpenDDS::DCPS::PublisherImpl.

Definition at line 66 of file EntityImpl.h.

References state.

Referenced by get_observer().

{ return RcHandle<EntityImpl>(); }

set_deleted()

void OpenDDS::DCPS::EntityImpl::set_deleted ( bool  state )

protected

Definition at line 83 of file EntityImpl.cpp.

References entity_deleted_, and state.

Referenced by OpenDDS::DCPS::SubscriberImpl::delete_contained_entities(), OpenDDS::DCPS::PublisherImpl::delete_contained_entities(), OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities(), and OpenDDS::DCPS::DataWriterImpl::prepare_to_delete().

{
  entity_deleted_ = state;
}

set_enabled()

DDS::ReturnCode_t OpenDDS::DCPS::EntityImpl::set_enabled ( )

protected

Definition at line 40 of file EntityImpl.cpp.

References enabled_, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::SubscriberImpl::enable(), OpenDDS::DCPS::PublisherImpl::enable(), OpenDDS::DCPS::ReplayerImpl::enable(), OpenDDS::DCPS::DataWriterImpl::enable(), OpenDDS::DCPS::DomainParticipantImpl::enable(), and OpenDDS::DCPS::DataReaderImpl::enable().

{
  enabled_ = true;

  return DDS::RETCODE_OK;
}

set_observer()

void OpenDDS::DCPS::EntityImpl::set_observer	(	Observer_rch	observer,
		Observer::Event	e
	)

Definition at line 135 of file EntityImpl.cpp.

References ACE_GUARD, events_, lock_, and observer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, lock_);
  observer_ = observer;
  events_ = e;
}

set_status_changed_flag()

void OpenDDS::DCPS::EntityImpl::set_status_changed_flag	(	DDS::StatusKind	status,
		bool	status_changed_flag
	)

Definition at line 68 of file EntityImpl.cpp.

References ACE_GUARD, lock_, and status_changes_.

Referenced by OpenDDS::DCPS::DataWriterImpl::association_complete_i(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data(), OpenDDS::DCPS::TopicImpl::get_inconsistent_topic_status(), OpenDDS::DCPS::DataReaderImpl::get_liveliness_changed_status(), OpenDDS::DCPS::DataWriterImpl::get_liveliness_lost_status(), OpenDDS::DCPS::DataWriterImpl::get_offered_deadline_missed_status(), OpenDDS::DCPS::DataWriterImpl::get_offered_incompatible_qos_status(), OpenDDS::DCPS::DataWriterImpl::get_publication_matched_status(), OpenDDS::DCPS::DataReaderImpl::get_requested_deadline_missed_status(), OpenDDS::DCPS::DataReaderImpl::get_requested_incompatible_qos_status(), OpenDDS::DCPS::DataReaderImpl::get_sample_lost_status(), OpenDDS::DCPS::DataReaderImpl::get_sample_rejected_status(), OpenDDS::DCPS::DataReaderImpl::get_subscription_matched_status(), OpenDDS::DCPS::TopicImpl::inconsistent_topic(), OpenDDS::DCPS::WriteDataContainer::process_deadlines(), OpenDDS::DCPS::DataWriterImpl::remove_associations(), OpenDDS::DCPS::DataReaderImpl::remove_associations_i(), OpenDDS::DCPS::MultiTopicDataReaderBase::set_status_changed_flag(), OpenDDS::DCPS::DataReaderImpl::transport_assoc_done(), OpenDDS::DCPS::DataWriterImpl::update_incompatible_qos(), and OpenDDS::DCPS::DataReaderImpl::update_incompatible_qos().

{
  ACE_GUARD(ACE_Thread_Mutex, g, lock_);

  if (status_changed_flag) {
    status_changes_ |= status;

  } else {
    status_changes_ &= ~status;
  }
}

transport_config() [1/2]

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

virtual

Reimplemented in OpenDDS::DCPS::TopicImpl.

Definition at line 122 of file EntityImpl.cpp.

References ACE_GUARD, lock_, and transport_config_.

Referenced by OpenDDS::DCPS::TransportRegistry::bind_config().

{
  ACE_GUARD(ACE_Thread_Mutex, g, lock_);
  transport_config_ = cfg;
}

transport_config() [2/2]

TransportConfig_rch OpenDDS::DCPS::EntityImpl::transport_config

(

)

const

Definition at line 129 of file EntityImpl.cpp.

References ACE_GUARD_RETURN, lock_, and transport_config_.

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, TransportConfig_rch());
  return transport_config_;
}

Member Data Documentation

enabled_

AtomicBool OpenDDS::DCPS::EntityImpl::enabled_

protected

The flag indicates the entity is enabled.

Definition at line 82 of file EntityImpl.h.

Referenced by OpenDDS::DCPS::SubscriberImpl::begin_access(), OpenDDS::DCPS::PublisherImpl::begin_coherent_changes(), OpenDDS::DCPS::SubscriberImpl::create_datareader(), OpenDDS::DCPS::PublisherImpl::create_datawriter(), OpenDDS::DCPS::DomainParticipantImpl::create_new_topic(), OpenDDS::DCPS::DomainParticipantImpl::create_publisher(), OpenDDS::DCPS::DomainParticipantImpl::create_recorder(), OpenDDS::DCPS::DomainParticipantImpl::create_replayer(), OpenDDS::DCPS::DomainParticipantImpl::create_subscriber(), OpenDDS::DCPS::DomainParticipantImpl::create_topic_i(), OpenDDS::DCPS::DataWriterImpl::dispose(), OpenDDS::DCPS::SubscriberImpl::end_access(), OpenDDS::DCPS::PublisherImpl::end_coherent_changes(), OpenDDS::DCPS::DataReaderImpl::get_matched_publication_data(), OpenDDS::DCPS::DataReaderImpl::get_matched_publications(), OpenDDS::DCPS::DataWriterImpl::get_matched_subscription_data(), OpenDDS::DCPS::DataWriterImpl::get_matched_subscriptions(), OpenDDS::DCPS::DomainParticipantImpl::ignore_participant(), OpenDDS::DCPS::DomainParticipantImpl::ignore_publication(), OpenDDS::DCPS::DomainParticipantImpl::ignore_subscription(), OpenDDS::DCPS::DomainParticipantImpl::ignore_topic(), is_enabled(), OpenDDS::DCPS::DataWriterImpl::register_instance_i(), OpenDDS::DCPS::PublisherImpl::resume_publications(), set_enabled(), OpenDDS::DCPS::TopicImpl::set_qos(), OpenDDS::DCPS::PublisherImpl::set_qos(), OpenDDS::DCPS::SubscriberImpl::set_qos(), OpenDDS::DCPS::ReplayerImpl::set_qos(), OpenDDS::DCPS::RecorderImpl::set_qos(), OpenDDS::DCPS::DataWriterImpl::set_qos(), OpenDDS::DCPS::DomainParticipantImpl::set_qos(), OpenDDS::DCPS::DataReaderImpl::set_qos(), OpenDDS::DCPS::PublisherImpl::suspend_publications(), OpenDDS::DCPS::DataWriterImpl::unregister_instance_i(), OpenDDS::DCPS::PublisherImpl::wait_for_acknowledgments(), and OpenDDS::DCPS::DataWriterImpl::write().

entity_deleted_

AtomicBool OpenDDS::DCPS::EntityImpl::entity_deleted_

protected

The flag indicates the entity is being deleted.

Definition at line 85 of file EntityImpl.h.

Referenced by get_deleted(), and set_deleted().

events_

Observer::Event OpenDDS::DCPS::EntityImpl::events_

private

Definition at line 99 of file EntityImpl.h.

Referenced by get_observer(), and set_observer().

instance_handle_

DDS::InstanceHandle_t OpenDDS::DCPS::EntityImpl::instance_handle_

private

Definition at line 103 of file EntityImpl.h.

Referenced by get_entity_instance_handle(), and ~EntityImpl().

lock_

ACE_Thread_Mutex OpenDDS::DCPS::EntityImpl::lock_

mutableprivate

Definition at line 101 of file EntityImpl.h.

Referenced by get_entity_instance_handle(), get_observer(), get_status_changes(), get_statuscondition(), notify_status_condition(), set_observer(), set_status_changed_flag(), and transport_config().

observer_

Observer_rch OpenDDS::DCPS::EntityImpl::observer_

private

Definition at line 98 of file EntityImpl.h.

Referenced by get_observer(), and set_observer().

participant_for_instance_handle_

WeakRcHandle<DomainParticipantImpl> OpenDDS::DCPS::EntityImpl::participant_for_instance_handle_

private

Definition at line 104 of file EntityImpl.h.

Referenced by get_entity_instance_handle(), and ~EntityImpl().

status_changes_

DDS::StatusMask OpenDDS::DCPS::EntityImpl::status_changes_

private

The status_changes_ variable lists all status changed flag. The StatusChangedFlag becomes TRUE whenever the plain communication status changes and it is reset to FALSE each time the application accesses the plain communication status via the proper get_<plain communication status> operation on the Entity.

Definition at line 93 of file EntityImpl.h.

Referenced by get_status_changes(), and set_status_changed_flag().

status_condition_

DDS::StatusCondition_var OpenDDS::DCPS::EntityImpl::status_condition_

private

Definition at line 94 of file EntityImpl.h.

Referenced by get_statuscondition(), and notify_status_condition().

transport_config_

TransportConfig_rch OpenDDS::DCPS::EntityImpl::transport_config_

private

Definition at line 96 of file EntityImpl.h.

Referenced by transport_config().

---

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

• EntityImpl.h
• EntityImpl.cpp