OpenDDS::DCPS::DomainParticipantImpl Class Reference

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

#include <DomainParticipantImpl.h>

Inheritance diagram for OpenDDS::DCPS::DomainParticipantImpl:

Collaboration diagram for OpenDDS::DCPS::DomainParticipantImpl:

Classes
class	AutomaticLivelinessTimer
class	LivelinessTimer
class	ParticipantLivelinessTimer
struct	RefCounted_Topic
class	RepoIdSequence

Public Types
typedef Objref_Servant_Pair< SubscriberImpl, DDS::Subscriber, DDS::Subscriber_ptr, DDS::Subscriber_var >	Subscriber_Pair
typedef Objref_Servant_Pair< PublisherImpl, DDS::Publisher, DDS::Publisher_ptr, DDS::Publisher_var >	Publisher_Pair
typedef Objref_Servant_Pair< TopicImpl, DDS::Topic, DDS::Topic_ptr, DDS::Topic_var >	Topic_Pair
typedef TopicMap::iterator	TopicMapIterator
typedef std::pair< TopicMapIterator, TopicMapIterator >	TopicMapIteratorPair
Public Types inherited from OpenDDS::DCPS::LocalObject< DDS::DomainParticipant >
typedef DDS::DomainParticipant ::_ptr_type	_ptr_type
typedef DDS::DomainParticipant ::_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 ACE_Event_Handler
typedef long	Reference_Count

Public Member Functions
typedef	OPENDDS_SET (Subscriber_Pair) SubscriberSet
typedef	OPENDDS_SET (Publisher_Pair) PublisherSet
typedef	OPENDDS_MULTIMAP (OPENDDS_STRING, RefCounted_Topic) TopicMap
typedef	OPENDDS_MAP (OPENDDS_STRING, DDS::TopicDescription_var) TopicDescriptionMap
	DomainParticipantImpl (InstanceHandleGenerator &handle_generator, const DDS::DomainId_t &domain_id, const DDS::DomainParticipantQos &qos, DDS::DomainParticipantListener_ptr a_listener, const DDS::StatusMask &mask)
virtual	~DomainParticipantImpl ()
virtual DDS::InstanceHandle_t	get_instance_handle ()
virtual DDS::Publisher_ptr	create_publisher (const DDS::PublisherQos &qos, DDS::PublisherListener_ptr a_listener, DDS::StatusMask mask)
virtual DDS::ReturnCode_t	delete_publisher (DDS::Publisher_ptr p)
virtual DDS::Subscriber_ptr	create_subscriber (const DDS::SubscriberQos &qos, DDS::SubscriberListener_ptr a_listener, DDS::StatusMask mask)
virtual DDS::ReturnCode_t	delete_subscriber (DDS::Subscriber_ptr s)
virtual DDS::Subscriber_ptr	get_builtin_subscriber ()
RcHandle< DCPS::BitSubscriber >	get_builtin_subscriber_proxy ()
virtual DDS::Topic_ptr	create_topic (const char *topic_name, const char *type_name, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener, DDS::StatusMask mask)
virtual DDS::ReturnCode_t	delete_topic (DDS::Topic_ptr a_topic)
virtual DDS::Topic_ptr	find_topic (const char *topic_name, const DDS::Duration_t &timeout)
virtual DDS::TopicDescription_ptr	lookup_topicdescription (const char *name)
virtual DDS::ContentFilteredTopic_ptr	create_contentfilteredtopic (const char *name, DDS::Topic_ptr related_topic, const char *filter_expression, const DDS::StringSeq &expression_parameters)
virtual DDS::ReturnCode_t	delete_contentfilteredtopic (DDS::ContentFilteredTopic_ptr a_contentfilteredtopic)
virtual DDS::MultiTopic_ptr	create_multitopic (const char *name, const char *type_name, const char *subscription_expression, const DDS::StringSeq &expression_parameters)
virtual DDS::ReturnCode_t	delete_multitopic (DDS::MultiTopic_ptr a_multitopic)
RcHandle< FilterEvaluator >	get_filter_eval (const char *filter)
void	deref_filter_eval (const char *filter)
virtual DDS::ReturnCode_t	delete_contained_entities ()
virtual CORBA::Boolean	contains_entity (DDS::InstanceHandle_t a_handle)
virtual DDS::ReturnCode_t	set_qos (const DDS::DomainParticipantQos &qos)
virtual DDS::ReturnCode_t	get_qos (DDS::DomainParticipantQos &qos)
virtual DDS::ReturnCode_t	set_listener (DDS::DomainParticipantListener_ptr a_listener, DDS::StatusMask mask)
virtual DDS::DomainParticipantListener_ptr	get_listener ()
virtual DDS::ReturnCode_t	ignore_participant (DDS::InstanceHandle_t handle)
virtual DDS::ReturnCode_t	ignore_topic (DDS::InstanceHandle_t handle)
virtual DDS::ReturnCode_t	ignore_publication (DDS::InstanceHandle_t handle)
virtual DDS::ReturnCode_t	ignore_subscription (DDS::InstanceHandle_t handle)
virtual DDS::DomainId_t	get_domain_id ()
virtual DDS::ReturnCode_t	assert_liveliness ()
virtual DDS::ReturnCode_t	set_default_publisher_qos (const DDS::PublisherQos &qos)
virtual DDS::ReturnCode_t	get_default_publisher_qos (DDS::PublisherQos &qos)
virtual DDS::ReturnCode_t	set_default_subscriber_qos (const DDS::SubscriberQos &qos)
virtual DDS::ReturnCode_t	get_default_subscriber_qos (DDS::SubscriberQos &qos)
virtual DDS::ReturnCode_t	set_default_topic_qos (const DDS::TopicQos &qos)
virtual DDS::ReturnCode_t	get_default_topic_qos (DDS::TopicQos &qos)
virtual DDS::ReturnCode_t	get_current_time (DDS::Time_t &current_time)
virtual DDS::ReturnCode_t	get_discovered_participants (DDS::InstanceHandleSeq &participant_handles)
virtual DDS::ReturnCode_t	get_discovered_participant_data (DDS::ParticipantBuiltinTopicData &participant_data, DDS::InstanceHandle_t participant_handle)
virtual DDS::ReturnCode_t	get_discovered_topics (DDS::InstanceHandleSeq &topic_handles)
virtual DDS::ReturnCode_t	get_discovered_topic_data (DDS::TopicBuiltinTopicData &topic_data, DDS::InstanceHandle_t topic_handle)
virtual DDS::ReturnCode_t	enable ()
GUID_t	get_id () const
OPENDDS_STRING	get_unique_id ()
DDS::InstanceHandle_t	assign_handle (const GUID_t &id=GUID_UNKNOWN)
DDS::InstanceHandle_t	lookup_handle (const GUID_t &id) const
DDS::InstanceHandle_t	await_handle (const GUID_t &id, TimeDuration max_wait=TimeDuration::zero_value) const
void	return_handle (DDS::InstanceHandle_t handle)
GUID_t	get_repoid (DDS::InstanceHandle_t id) const
bool	is_clean (String *leftover_entities=0) const
DDS::DomainParticipantListener_ptr	listener_for (DDS::StatusKind kind)
typedef	OPENDDS_VECTOR (GUID_t) TopicIdVec
void	get_topic_ids (TopicIdVec &topics)
OwnershipManager *	ownership_manager ()
void	update_ownership_strength (const GUID_t &pub_id, const CORBA::Long &ownership_strength)
bool	federated () const
Recorder_ptr	create_recorder (DDS::Topic_ptr a_topic, const DDS::SubscriberQos &subscriber_qos, const DDS::DataReaderQos &datareader_qos, const RecorderListener_rch &a_listener, DDS::StatusMask mask)
Replayer_ptr	create_replayer (DDS::Topic_ptr a_topic, const DDS::PublisherQos &publisher_qos, const DDS::DataWriterQos &datawriter_qos, const ReplayerListener_rch &a_listener, DDS::StatusMask mask)
DDS::Topic_ptr	create_typeless_topic (const char *topic_name, const char *type_name, bool type_has_keys, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener, DDS::StatusMask mask)
void	delete_recorder (Recorder_ptr recorder)
void	delete_replayer (Replayer_ptr replayer)
void	add_adjust_liveliness_timers (DataWriterImpl *writer)
void	remove_adjust_liveliness_timers ()
XTypes::TypeLookupService_rch	get_type_lookup_service ()
Security::SecurityConfig_rch	get_security_config () const
DDS::Security::PermissionsHandle	permissions_handle () const
DDS::Security::ParticipantCryptoHandle	crypto_handle () const
bool	prepare_to_delete_datawriters ()
bool	set_wait_pending_deadline (const MonotonicTimePoint &deadline)
DDS::ReturnCode_t	get_dynamic_type (DDS::DynamicType_var &type, const DDS::BuiltinTopicKey_t &key)
Public Member Functions inherited from DDS::DomainParticipant
Publisher	create_publisher (in PublisherQos qos, in PublisherListener a_listener, in StatusMask mask)
ReturnCode_t	delete_publisher (in Publisher p)
Subscriber	create_subscriber (in SubscriberQos qos, in SubscriberListener a_listener, in StatusMask mask)
ReturnCode_t	delete_subscriber (in Subscriber s)
Topic	create_topic (in string topic_name, in string type_name, in TopicQos qos, in TopicListener a_listener, in StatusMask mask)
ReturnCode_t	delete_topic (in Topic a_topic)
Topic	find_topic (in string topic_name, in Duration_t timeout)
TopicDescription	lookup_topicdescription (in string name)
ContentFilteredTopic	create_contentfilteredtopic (in string name, in Topic related_topic, in string filter_expression, in StringSeq expression_parameters)
ReturnCode_t	delete_contentfilteredtopic (in ContentFilteredTopic a_contentfilteredtopic)
MultiTopic	create_multitopic (in string name, in string type_name, in string subscription_expression, in StringSeq expression_parameters)
ReturnCode_t	delete_multitopic (in MultiTopic a_multitopic)
boolean	contains_entity (in InstanceHandle_t a_handle)
ReturnCode_t	set_qos (in DomainParticipantQos qos)
ReturnCode_t	get_qos (inout DomainParticipantQos qos)
ReturnCode_t	set_listener (in DomainParticipantListener a_listener, in StatusMask mask)
ReturnCode_t	ignore_participant (in InstanceHandle_t handle)
ReturnCode_t	ignore_topic (in InstanceHandle_t handle)
ReturnCode_t	ignore_publication (in InstanceHandle_t handle)
ReturnCode_t	ignore_subscription (in InstanceHandle_t handle)
ReturnCode_t	set_default_publisher_qos (in PublisherQos qos)
ReturnCode_t	get_default_publisher_qos (inout PublisherQos qos)
ReturnCode_t	set_default_subscriber_qos (in SubscriberQos qos)
ReturnCode_t	get_default_subscriber_qos (inout SubscriberQos qos)
ReturnCode_t	set_default_topic_qos (in TopicQos qos)
ReturnCode_t	get_default_topic_qos (inout TopicQos qos)
ReturnCode_t	get_current_time (inout Time_t current_time)
ReturnCode_t	get_discovered_participants (inout InstanceHandleSeq participant_handles)
ReturnCode_t	get_discovered_participant_data (inout ParticipantBuiltinTopicData participant_data, in InstanceHandle_t participant_handle)
ReturnCode_t	get_discovered_topics (inout InstanceHandleSeq topic_handles)
ReturnCode_t	get_discovered_topic_data (inout TopicBuiltinTopicData topic_data, in InstanceHandle_t topic_handle)
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 ()
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 ACE_Event_Handler
virtual	~ACE_Event_Handler (void)
virtual ACE_HANDLE	get_handle (void) const
virtual void	set_handle (ACE_HANDLE)
virtual int	priority (void) const
virtual void	priority (int priority)
virtual int	handle_input (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_output (ACE_HANDLE fd=ACE_INVALID_HANDLE)
virtual int	handle_timeout (const ACE_Time_Value &current_time, const void *act=0)
virtual int	handle_exit (ACE_Process *)
virtual int	handle_close (ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
virtual int	handle_signal (int signum, siginfo_t *=0, ucontext_t *=0)
virtual int	resume_handler (void)
virtual int	handle_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual int	handle_group_qos (ACE_HANDLE=ACE_INVALID_HANDLE)
virtual void	reactor (ACE_Reactor *reactor)
virtual ACE_Reactor *	reactor (void) const
virtual ACE_Reactor_Timer_Interface *	reactor_timer_interface (void) const
virtual Reference_Count	add_reference (void)
virtual Reference_Count	remove_reference (void)
Reference_Counting_Policy &	reference_counting_policy (void)

Private Types
typedef std::pair< DDS::InstanceHandle_t, unsigned int >	HandleWithCounter
typedef PmfSporadicTask< AutomaticLivelinessTimer >	AutomaticLivelinessTask
typedef PmfSporadicTask< ParticipantLivelinessTimer >	ParticipantLivelinessTask

Private Member Functions
bool	validate_publisher_qos (DDS::PublisherQos &publisher_qos)
bool	validate_subscriber_qos (DDS::SubscriberQos &subscriber_qos)
DDS::Topic_ptr	create_topic_i (const char *topic_name, const char *type_name, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener, DDS::StatusMask mask, int topic_mask)
DDS::Topic_ptr	create_new_topic (const char *topic_name, const char *type_name, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener, const DDS::StatusMask &mask, OpenDDS::DCPS::TypeSupport_ptr type_support)
DDS::ReturnCode_t	delete_topic_i (DDS::Topic_ptr a_topic, bool remove_objref)
typedef	OPENDDS_MAP_CMP (GUID_t, HandleWithCounter, GUID_tKeyLessThan) CountedHandleMap
typedef	OPENDDS_MAP (DDS::InstanceHandle_t, GUID_t) RepoIdMap
typedef	OPENDDS_MAP_CMP (GUID_t, DDS::InstanceHandle_t, GUID_tKeyLessThan) HandleMap
	OPENDDS_MAP (OPENDDS_STRING, RcHandle< FilterEvaluator >) filter_cache_
typedef	OPENDDS_SET_CMP (Recorder_var, VarLess< Recorder >) RecorderSet
typedef	OPENDDS_SET_CMP (Replayer_var, VarLess< Replayer >) ReplayerSet
TimeDuration	liveliness_check_interval (DDS::LivelinessQosPolicyKind kind)
bool	participant_liveliness_activity_after (const MonotonicTimePoint &tv)
void	signal_liveliness (DDS::LivelinessQosPolicyKind kind)
virtual int	handle_exception (ACE_HANDLE fd)

Private Attributes
DDS::TopicQos	default_topic_qos_
	The default topic qos. More...
DDS::PublisherQos	default_publisher_qos_
	The default publisher qos. More...
DDS::SubscriberQos	default_subscriber_qos_
	The default subscriber qos. More...
DDS::DomainParticipantQos	qos_
	The qos of this DomainParticipant. More...
ACE_Thread_Mutex	listener_mutex_
	Mutex to protect listener info. More...
DDS::DomainParticipantListener_var	listener_
	Used to notify the entity for relevant events. More...
DDS::StatusMask	listener_mask_
DDS::Security::IdentityHandle	id_handle_
	This participant id handle given by authentication. More...
DDS::Security::PermissionsHandle	perm_handle_
	This participant permissions handle given by access constrol. More...
DDS::Security::ParticipantCryptoHandle	part_crypto_handle_
	This participant crypto handle given by crypto. More...
const DDS::DomainId_t	domain_id_
	The id of the domain that creates this participant. More...
GUID_t	dp_id_
	This participant id given by discovery. More...
bool	federated_
PublisherSet	publishers_
	Collection of publishers. More...
SubscriberSet	subscribers_
	Collection of subscribers. More...
TopicMap	topics_
	Collection of topics. More...
TopicDescriptionMap	topic_descrs_
	Collection of TopicDescriptions which are not also Topics. More...
CountedHandleMap	handles_
	Instance handles assigned which are mapped to GUIDs (use handle_protector_) More...
RepoIdMap	repoIds_
	By-handle lookup of instance handles assigned to GUIDs (use handle_protector_) More...
HandleMap	ignored_participants_
	Collection of ignored participants. More...
HandleMap	ignored_topics_
	Collection of ignored topics. More...
ACE_Recursive_Thread_Mutex	publishers_protector_
	Protect the publisher collection. More...
ACE_Recursive_Thread_Mutex	subscribers_protector_
	Protect the subscriber collection. More...
ACE_Recursive_Thread_Mutex	topics_protector_
	Protect the topic collection. More...
ACE_Thread_Mutex	handle_protector_
	Protect the handle collection. More...
ConditionVariable< ACE_Thread_Mutex >	handle_waiters_
ACE_Thread_Mutex	shutdown_mutex_
	Protect the shutdown. More...
ConditionVariable< ACE_Thread_Mutex >	shutdown_condition_
DDS::ReturnCode_t	shutdown_result_
bool	shutdown_complete_
RcHandle< BitSubscriber >	bit_subscriber_
	The built in topic subscriber. More...
InstanceHandleGenerator &	participant_handles_
	Get instances handles from DomainParticipantFactory (use handle_protector_) More...
DisjointSequence::OrderedRanges< DDS::InstanceHandle_t >	reusable_handles_
	Keep track of handles that can be reused (use handle_protector_) More...
unique_ptr< Monitor >	monitor_
OwnershipManager	owner_man_
RepoIdSequence	pub_id_gen_
	Publisher ID generator. More...
ACE_Thread_Mutex	filter_cache_lock_
RecorderSet	recorders_
ReplayerSet	replayers_
Security::SecurityConfig_rch	security_config_
ACE_Recursive_Thread_Mutex	recorders_protector_
	Protect the recorders collection. More...
ACE_Recursive_Thread_Mutex	replayers_protector_
	Protect the replayers collection. More...
RcHandle< AutomaticLivelinessTimer >	automatic_liveliness_timer_
RcHandle< AutomaticLivelinessTask >	automatic_liveliness_task_
RcHandle< ParticipantLivelinessTimer >	participant_liveliness_timer_
RcHandle< ParticipantLivelinessTask >	participant_liveliness_task_
MonotonicTimePoint	last_liveliness_activity_
XTypes::TypeLookupService_rch	type_lookup_service_

Static Private Attributes
static const int	TOPIC_TYPE_HAS_KEYS = 1
static const int	TOPIC_TYPELESS = 2

Additional Inherited Members
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::DomainParticipant >
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 ACE_Event_Handler
static ACE_THR_FUNC_RETURN	read_adapter (void *event_handler)
static int	register_stdin_handler (ACE_Event_Handler *eh, ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr, int flags=THR_DETACHED)
static int	remove_stdin_handler (ACE_Reactor *reactor, ACE_Thread_Manager *thr_mgr)
Public Attributes inherited from ACE_Event_Handler
	LO_PRIORITY
	HI_PRIORITY
	NULL_MASK
	READ_MASK
	WRITE_MASK
	EXCEPT_MASK
	ACCEPT_MASK
	CONNECT_MASK
	TIMER_MASK
	QOS_MASK
	GROUP_QOS_MASK
	SIGNAL_MASK
	ALL_EVENTS_MASK
	RWE_MASK
	DONT_CALL
	ACE_EVENT_HANDLER_NOT_RESUMED
	ACE_REACTOR_RESUMES_HANDLER
	ACE_APPLICATION_RESUMES_HANDLER
Protected Types inherited from ACE_Event_Handler
typedef ACE_Atomic_Op< ACE_SYNCH_MUTEX, Reference_Count >	Atomic_Reference_Count
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 Member Functions inherited from ACE_Event_Handler
	ACE_Event_Handler (ACE_Reactor *=0, int priority=ACE_Event_Handler::LO_PRIORITY)
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 ACE_Event_Handler
Atomic_Reference_Count	reference_count_

Detailed Description

Implements the OpenDDS::DCPS::DomainParticipant interfaces.

This class acts as an entrypoint of the service and a factory for publisher, subscriber and topic. It also acts as a container for the publisher, subscriber and topic objects.

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

Definition at line 77 of file DomainParticipantImpl.h.

Member Typedef Documentation

AutomaticLivelinessTask

typedef PmfSporadicTask<AutomaticLivelinessTimer> OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTask

private

Definition at line 622 of file DomainParticipantImpl.h.

HandleWithCounter

typedef std::pair<DDS::InstanceHandle_t, unsigned int> OpenDDS::DCPS::DomainParticipantImpl::HandleWithCounter

private

Definition at line 509 of file DomainParticipantImpl.h.

ParticipantLivelinessTask

typedef PmfSporadicTask<ParticipantLivelinessTimer> OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTask

private

Definition at line 642 of file DomainParticipantImpl.h.

Publisher_Pair

typedef Objref_Servant_Pair<PublisherImpl, DDS::Publisher, DDS::Publisher_ptr, DDS::Publisher_var> OpenDDS::DCPS::DomainParticipantImpl::Publisher_Pair

Definition at line 87 of file DomainParticipantImpl.h.

Subscriber_Pair

typedef Objref_Servant_Pair<SubscriberImpl, DDS::Subscriber, DDS::Subscriber_ptr, DDS::Subscriber_var> OpenDDS::DCPS::DomainParticipantImpl::Subscriber_Pair

Definition at line 84 of file DomainParticipantImpl.h.

Topic_Pair

typedef Objref_Servant_Pair<TopicImpl, DDS::Topic, DDS::Topic_ptr, DDS::Topic_var> OpenDDS::DCPS::DomainParticipantImpl::Topic_Pair

Definition at line 90 of file DomainParticipantImpl.h.

TopicMapIterator

typedef TopicMap::iterator OpenDDS::DCPS::DomainParticipantImpl::TopicMapIterator

Definition at line 124 of file DomainParticipantImpl.h.

TopicMapIteratorPair

typedef std::pair<TopicMapIterator, TopicMapIterator> OpenDDS::DCPS::DomainParticipantImpl::TopicMapIteratorPair

Definition at line 125 of file DomainParticipantImpl.h.

Constructor & Destructor Documentation

DomainParticipantImpl()

OpenDDS::DCPS::DomainParticipantImpl::DomainParticipantImpl	(	InstanceHandleGenerator &	handle_generator,
		const DDS::DomainId_t &	domain_id,
		const DDS::DomainParticipantQos &	qos,
		DDS::DomainParticipantListener_ptr	a_listener,
		const DDS::StatusMask &	mask
	)

Definition at line 92 of file DomainParticipantImpl.cpp.

References monitor_, set_listener(), TheServiceParticipant, and type_lookup_service_.

  : default_topic_qos_(TheServiceParticipant->initial_TopicQos())
  , default_publisher_qos_(TheServiceParticipant->initial_PublisherQos())
  , default_subscriber_qos_(TheServiceParticipant->initial_SubscriberQos())
  , qos_(qos)
#ifdef OPENDDS_SECURITY
  , id_handle_(DDS::HANDLE_NIL)
  , perm_handle_(DDS::HANDLE_NIL)
  , part_crypto_handle_(DDS::HANDLE_NIL)
#endif
  , domain_id_(domain_id)
  , dp_id_(GUID_UNKNOWN)
  , federated_(false)
  , handle_waiters_(handle_protector_)
  , shutdown_condition_(shutdown_mutex_)
  , shutdown_complete_(false)
  , participant_handles_(handle_generator)
  , pub_id_gen_(dp_id_)
  , automatic_liveliness_timer_(make_rch<AutomaticLivelinessTimer>(ref(*this)))
  , automatic_liveliness_task_(make_rch<AutomaticLivelinessTask>(
    TheServiceParticipant->time_source(),
    TheServiceParticipant->interceptor(),
    automatic_liveliness_timer_,
    &LivelinessTimer::execute))
  , participant_liveliness_timer_(make_rch<ParticipantLivelinessTimer>(ref(*this)))
  , participant_liveliness_task_(make_rch<ParticipantLivelinessTask>(
    TheServiceParticipant->time_source(),
    TheServiceParticipant->interceptor(),
    participant_liveliness_timer_,
    &LivelinessTimer::execute))
{
  (void) this->set_listener(a_listener, mask);
  monitor_.reset(TheServiceParticipant->monitor_factory_->create_dp_monitor(this));
  type_lookup_service_ = make_rch<XTypes::TypeLookupService>();
}

~DomainParticipantImpl()

OpenDDS::DCPS::DomainParticipantImpl::~DomainParticipantImpl ( )

virtual

Definition at line 133 of file DomainParticipantImpl.cpp.

References access(), ACE_ERROR, ACE_TEXT(), DDS::Security::SecurityException::code, DDS::HANDLE_NIL, LM_ERROR, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, perm_handle_, security_config_, and OpenDDS::DCPS::security_debug.

{
#ifdef OPENDDS_SECURITY
  if (security_config_ && perm_handle_ != DDS::HANDLE_NIL) {
    Security::AccessControl_var access = security_config_->get_access_control();
    DDS::Security::SecurityException se;
    if (!access->return_permissions_handle(perm_handle_, se)) {
      if (DCPS::security_debug.auth_warn) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::~DomainParticipantImpl: ")
                   ACE_TEXT("Unable to return permissions handle. SecurityException[%d.%d]: %C\n"),
                   se.code, se.minor_code, se.message.in()));
      }
    }
  }
#endif

}

Member Function Documentation

add_adjust_liveliness_timers()

void OpenDDS::DCPS::DomainParticipantImpl::add_adjust_liveliness_timers

(

DataWriterImpl *

writer

)

Definition at line 2307 of file DomainParticipantImpl.cpp.

References automatic_liveliness_timer_, and participant_liveliness_timer_.

{
  automatic_liveliness_timer_->add_adjust(writer);
  participant_liveliness_timer_->add_adjust(writer);
}

assert_liveliness()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::assert_liveliness ( )

virtual

Implements DDS::DomainParticipant.

Definition at line 1425 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, last_liveliness_activity_, publishers_, publishers_protector_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, and OpenDDS::DCPS::TimePoint_T< AceClock >::set_to_now().

{
  // This operation needs to only be used if the DomainParticipant contains
  // DataWriter entities with the LIVELINESS set to MANUAL_BY_PARTICIPANT and
  // it only affects the liveliness of those DataWriter entities. Otherwise,
  // it has no effect.
  // This will do nothing in current implementation since we only
  // support the AUTOMATIC liveliness qos for datawriter.
  // Add implementation here.

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   this->publishers_protector_,
                   DDS::RETCODE_ERROR);

  for (PublisherSet::iterator it(publishers_.begin());
       it != publishers_.end(); ++it) {
    it->svt_->assert_liveliness_by_participant();
  }

  last_liveliness_activity_.set_to_now();

  return DDS::RETCODE_OK;
}

assign_handle()

DDS::InstanceHandle_t OpenDDS::DCPS::DomainParticipantImpl::assign_handle

(

const GUID_t &

id = GUID_UNKNOWN

)

Assign an instance handle, optionally representing a GUID. If a GUID is provided (not GUID_UNKNOWN), other calls to assign_handle for this GUID will return the same handle, as will subsequent calls to lookup_handle.

If this method returns a valid (non-HANDLE_NIL) handle, it must be returned by calling return_handle.

Definition at line 1842 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_GUARD_RETURN, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DisjointSequence::OrderedRanges< T >::empty(), OpenDDS::DCPS::GUID_UNKNOWN, DDS::HANDLE_NIL, handle_protector_, handle_waiters_, handles_, LM_DEBUG, OpenDDS::DCPS::InstanceHandleGenerator::next(), OpenDDS::DCPS::ConditionVariable< Mutex >::notify_all(), participant_handles_, OpenDDS::DCPS::DisjointSequence::OrderedRanges< T >::pop_front(), repoIds_, and reusable_handles_.

Referenced by OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::ReplayerImpl::association_complete_i(), create_publisher(), and create_subscriber().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::HANDLE_NIL);
  if (id == GUID_UNKNOWN) {
    const DDS::InstanceHandle_t ih =
      reusable_handles_.empty() ? participant_handles_.next() : reusable_handles_.pop_front();
    if (DCPS_debug_level > 5) {
      ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::assign_handle: "
                 "New unmapped InstanceHandle %d\n", ih));
    }
    return ih;
  }

  const CountedHandleMap::iterator location = handles_.find(id);
  if (location == handles_.end()) {
    const DDS::InstanceHandle_t handle =
      reusable_handles_.empty() ? participant_handles_.next() : reusable_handles_.pop_front();
    if (DCPS_debug_level > 5) {
      ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::assign_handle: "
                 "New mapped InstanceHandle %d for %C\n",
                 handle, LogGuid(id).c_str()));
    }
    handles_[id] = std::make_pair(handle, 1);
    repoIds_[handle] = id;
    handle_waiters_.notify_all();
    return handle;
  }

  HandleWithCounter& mapped = location->second;
  ++mapped.second;
  if (DCPS_debug_level > 5) {
    ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::assign_handle: "
               "Incremented refcount for InstanceHandle %d to %d\n",
               mapped.first, mapped.second));
  }
  return mapped.first;
}

await_handle()

DDS::InstanceHandle_t OpenDDS::DCPS::DomainParticipantImpl::await_handle	(	const GUID_t &	id,
		TimeDuration	max_wait = TimeDuration::zero_value
	)		const

Similar to lookup_handle in that it will return a previously mapped handle, but will coorindate with assign_handle when a desired handle has not yet been mapped, but is expected to be. The optional max_wait argument can be supplied to limit the time spent waiting for a handle. If the wait times out, a value of HANDLE_NIL is returned.

Definition at line 1880 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::CvStatus_NoTimeout, DDS::HANDLE_NIL, handle_protector_, handle_waiters_, handles_, OpenDDS::DCPS::TimeDuration::is_zero(), OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), TheServiceParticipant, OpenDDS::DCPS::ConditionVariable< Mutex >::wait(), and OpenDDS::DCPS::ConditionVariable< Mutex >::wait_until().

{
  MonotonicTimePoint expire_at = MonotonicTimePoint::now() + max_wait;
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::HANDLE_NIL);
  CountedHandleMap::const_iterator iter = handles_.find(id);
  CvStatus res = CvStatus_NoTimeout;
  ThreadStatusManager& thread_status_manager = TheServiceParticipant->get_thread_status_manager();
  while (res == CvStatus_NoTimeout && iter == handles_.end()) {
    res = max_wait.is_zero() ? handle_waiters_.wait(thread_status_manager) : handle_waiters_.wait_until(expire_at, thread_status_manager);
    iter = handles_.find(id);
  }
  return iter == handles_.end() ? DDS::HANDLE_NIL : iter->second.first;
}

contains_entity()

CORBA::Boolean OpenDDS::DCPS::DomainParticipantImpl::contains_entity ( DDS::InstanceHandle_t  a_handle )

virtual

Check top-level containers for Topic, Subscriber, and Publisher instances.

Recurse into SubscriberImpl and PublisherImpl for DataReader and DataWriter instances respectively.

Definition at line 1100 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, publishers_, publishers_protector_, subscribers_, subscribers_protector_, topics_, and topics_protector_.

{
  /// Check top-level containers for Topic, Subscriber,
  /// and Publisher instances.
  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     guard,
                     this->topics_protector_,
                     false);

    for (TopicMap::iterator it(topics_.begin());
         it != topics_.end(); ++it) {
      if (a_handle == it->second.pair_.svt_->get_instance_handle())
        return true;
    }
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     guard,
                     this->subscribers_protector_,
                     false);

    for (SubscriberSet::iterator it(subscribers_.begin());
         it != subscribers_.end(); ++it) {
      if (a_handle == it->svt_->get_instance_handle())
        return true;
    }
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     guard,
                     this->publishers_protector_,
                     false);

    for (PublisherSet::iterator it(publishers_.begin());
         it != publishers_.end(); ++it) {
      if (a_handle == it->svt_->get_instance_handle())
        return true;
    }
  }

  /// Recurse into SubscriberImpl and PublisherImpl for
  /// DataReader and DataWriter instances respectively.
  for (SubscriberSet::iterator it(subscribers_.begin());
       it != subscribers_.end(); ++it) {
    if (it->svt_->contains_reader(a_handle))
      return true;
  }

  for (PublisherSet::iterator it(publishers_.begin());
       it != publishers_.end(); ++it) {
    if (it->svt_->contains_writer(a_handle))
      return true;
  }

  return false;
}

create_contentfilteredtopic()

DDS::ContentFilteredTopic_ptr OpenDDS::DCPS::DomainParticipantImpl::create_contentfilteredtopic ( const char *  name, DDS::Topic_ptr  related_topic, const char *  filter_expression, const DDS::StringSeq &  expression_parameters  )

virtual

Definition at line 813 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, CORBA::is_nil(), LM_ERROR, name, DDS::RETCODE_OK, topic_descrs_, topics_, and topics_protector_.

{
  if (CORBA::is_nil(related_topic)) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_contentfilteredtopic, ")
                 ACE_TEXT("can't create a content-filtered topic due to null related ")
                 ACE_TEXT("topic.\n")));
    }
    return 0;
  }

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, topics_protector_, 0);

  if (topics_.count(name)) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_contentfilteredtopic, ")
                 ACE_TEXT("can't create a content-filtered topic due to name \"%C\" ")
                 ACE_TEXT("already in use by a Topic.\n"), name));
    }
    return 0;
  }

  if (topic_descrs_.count(name)) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_contentfilteredtopic, ")
                 ACE_TEXT("can't create a content-filtered topic due to name \"%C\" ")
                 ACE_TEXT("already in use by a TopicDescription.\n"), name));
    }
    return 0;
  }

  DDS::ContentFilteredTopic_var cft;
  try {
    // Create the cft in two steps so that we only have one place to
    // check the expression parameters
    cft = new ContentFilteredTopicImpl(name, related_topic, filter_expression, this);
    if (cft->set_expression_parameters(expression_parameters) != DDS::RETCODE_OK) {
      return 0;
    }
  } catch (const std::exception& e) {
    if (DCPS_debug_level) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_contentfilteredtopic, ")
                 ACE_TEXT("can't create a content-filtered topic due to runtime error: ")
                 ACE_TEXT("%C.\n"), e.what()));
    }
    return 0;
  }
  DDS::TopicDescription_var td = DDS::TopicDescription::_duplicate(cft);
  topic_descrs_[name] = td;
  return cft._retn();
}

create_multitopic()

DDS::MultiTopic_ptr OpenDDS::DCPS::DomainParticipantImpl::create_multitopic ( const char *  name, const char *  type_name, const char *  subscription_expression, const DDS::StringSeq &  expression_parameters  )

virtual

Definition at line 921 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, name, topic_descrs_, topics_, and topics_protector_.

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, topics_protector_, 0);

  if (topics_.count(name)) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_multitopic, ")
                 ACE_TEXT("can't create a multi topic due to name \"%C\" ")
                 ACE_TEXT("already in use by a Topic.\n"), name));
    }
    return 0;
  }

  if (topic_descrs_.count(name)) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_multitopic, ")
                 ACE_TEXT("can't create a multi topic due to name \"%C\" ")
                 ACE_TEXT("already in use by a TopicDescription.\n"), name));
    }
    return 0;
  }

  DDS::MultiTopic_var mt;
  try {
    mt = new MultiTopicImpl(name, type_name, subscription_expression,
      expression_parameters, this);
  } catch (const std::exception& e) {
    if (DCPS_debug_level) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_multitopic, ")
                 ACE_TEXT("can't create a multi topic due to runtime error: ")
                 ACE_TEXT("%C.\n"), e.what()));
    }
    return 0;
  }
  DDS::TopicDescription_var td = DDS::TopicDescription::_duplicate(mt);
  topic_descrs_[name] = td;
  return mt._retn();
}

create_new_topic()

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

private

Definition at line 1942 of file DomainParticipantImpl.cpp.

References access(), ACE_ERROR, ACE_GUARD_RETURN, ACE_NEW_RETURN, ACE_TEXT(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, DDS::Security::SecurityException::code, domain_id_, OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, DDS::Security::TopicSecurityAttributes::is_read_protected, DDS::Security::TopicSecurityAttributes::is_write_protected, LM_WARNING, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, monitor_, OpenDDS::DCPS::Objref_Servant_Pair< T_impl, T, T_ptr, T_var >::obj_, OpenDDS::DCPS::DomainParticipantImpl::RefCounted_Topic::pair_, perm_handle_, qos_, DDS::RETCODE_OK, security_config_, OpenDDS::DCPS::security_debug, OpenDDS::DCPS::topicIsBIT(), topics_, and topics_protector_.

Referenced by create_topic_i(), and find_topic().

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   this->topics_protector_,
                   DDS::Topic::_nil());

#ifdef OPENDDS_SECURITY
  if (perm_handle_ && !topicIsBIT(topic_name, type_name)) {
    Security::AccessControl_var access = security_config_->get_access_control();

    DDS::Security::SecurityException se;

    DDS::Security::TopicSecurityAttributes sec_attr;
    if (!access->get_topic_sec_attributes(perm_handle_, topic_name, sec_attr, se)) {
      if (DCPS::security_debug.new_entity_warn) {
        ACE_ERROR((LM_WARNING,
                   ACE_TEXT("(%P|%t) WARNING: ")
                   ACE_TEXT("DomainParticipantImpl::create_new_topic, ")
                   ACE_TEXT("Unable to get security attributes for topic '%C'. SecurityException[%d.%d]: %C\n"),
                   topic_name, se.code, se.minor_code, se.message.in()));
        }
      return DDS::Topic::_nil();
    }

    if ((sec_attr.is_write_protected || sec_attr.is_read_protected) &&
        !access->check_create_topic(perm_handle_, domain_id_, topic_name, qos, se)) {
      if (DCPS::security_debug.new_entity_warn) {
        ACE_ERROR((LM_WARNING,
                   ACE_TEXT("(%P|%t) WARNING: ")
                   ACE_TEXT("DomainParticipantImpl::create_new_topic, ")
                   ACE_TEXT("Permissions check failed to create new topic '%C'. SecurityException[%d.%d]: %C\n"),
                   topic_name, se.code, se.minor_code, se.message.in()));
      }
      return DDS::Topic::_nil();
    }
  }
#endif

  TopicImpl* topic_servant = 0;

  ACE_NEW_RETURN(topic_servant,
                 TopicImpl(topic_name,
                           type_name,
                           type_support,
                           qos,
                           a_listener,
                           mask,
                           this),
                 DDS::Topic::_nil());

  if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
    const DDS::ReturnCode_t ret = topic_servant->enable();

    if (ret != DDS::RETCODE_OK) {
      ACE_ERROR((LM_WARNING,
          ACE_TEXT("(%P|%t) WARNING: ")
          ACE_TEXT("DomainParticipantImpl::create_new_topic, ")
          ACE_TEXT("enable failed.\n")));
      return DDS::Topic::_nil();
    }
  }

  DDS::Topic_ptr obj(topic_servant);

  // this object will also act as a guard against leaking the new TopicImpl
  RefCounted_Topic refCounted_topic(Topic_Pair(topic_servant, obj, false));
  topics_.insert(std::make_pair(topic_name, refCounted_topic));

  if (this->monitor_) {
    this->monitor_->report();
  }

  // the topics_ map has one reference and we duplicate to give
  // the caller another reference.
  return DDS::Topic::_duplicate(refCounted_topic.pair_.obj_.in());
}

create_publisher()

DDS::Publisher_ptr OpenDDS::DCPS::DomainParticipantImpl::create_publisher ( const DDS::PublisherQos &  qos, DDS::PublisherListener_ptr  a_listener, DDS::StatusMask  mask  )

virtual

Definition at line 153 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_NEW_RETURN, ACE_TEXT(), assign_handle(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::PublisherImpl::enable(), OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, OpenDDS::DCPS::insert(), LM_ERROR, OpenDDS::DCPS::DomainParticipantImpl::RepoIdSequence::next(), pub_id_gen_, publishers_, publishers_protector_, qos_, and validate_publisher_qos().

{
  DDS::PublisherQos pub_qos = qos;

  if (! this->validate_publisher_qos(pub_qos))
    return DDS::Publisher::_nil();

  // Although Publisher entities have GUIDs assigned (see pub_id_gen_),
  // these are not GUIDs from the RTPS spec and
  // so the handle doesn't need to correlate to the GUID.
  const DDS::InstanceHandle_t handle = assign_handle();

  PublisherImpl* pub = 0;
  ACE_NEW_RETURN(pub,
                 PublisherImpl(handle,
                               pub_id_gen_.next(),
                               pub_qos,
                               a_listener,
                               mask,
                               this),
                 DDS::Publisher::_nil());

  if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
    pub->enable();
  }

  DDS::Publisher_ptr pub_obj(pub);

  // this object will also act as the guard for leaking Publisher Impl
  Publisher_Pair pair(pub, pub_obj, false);

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   this->publishers_protector_,
                   DDS::Publisher::_nil());

  if (OpenDDS::DCPS::insert(publishers_, pair) == -1) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::create_publisher, ")
                 ACE_TEXT("%p\n"),
                 ACE_TEXT("insert")));
    }
    return DDS::Publisher::_nil();
  }

  return DDS::Publisher::_duplicate(pub_obj);
}

create_recorder()

Recorder_ptr OpenDDS::DCPS::DomainParticipantImpl::create_recorder	(	DDS::Topic_ptr	a_topic,
		const DDS::SubscriberQos &	subscriber_qos,
		const DDS::DataReaderQos &	datareader_qos,
		const RecorderListener_rch &	a_listener,
		DDS::StatusMask	mask
	)

Definition at line 2192 of file DomainParticipantImpl.cpp.

References TAO_Objref_Var_T< T >::_retn(), ACE_ERROR, ACE_TEXT(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, OpenDDS::DCPS::RecorderImpl::init(), CORBA::is_nil(), LM_ERROR, qos_, recorders_, recorders_protector_, TheServiceParticipant, OpenDDS::DCPS::SubscriberImpl::validate_datareader_qos(), and validate_subscriber_qos().

Referenced by OpenDDS::DCPS::Service_Participant::create_recorder().

{
  if (CORBA::is_nil(a_topic)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_recorder, ")
                 ACE_TEXT("topic desc is nil.\n")));
    }
    return 0;
  }

  DDS::SubscriberQos sub_qos = subscriber_qos;
  DDS::DataReaderQos dr_qos;

  if (! this->validate_subscriber_qos(sub_qos) ||
      ! SubscriberImpl::validate_datareader_qos(datareader_qos,
                                                TheServiceParticipant->initial_DataReaderQos(),
                                                a_topic,
                                                dr_qos, false) ) {
    return 0;
  }

  RecorderImpl* recorder(new RecorderImpl);
  Recorder_var result(recorder);

  recorder->init(dynamic_cast<TopicDescriptionImpl*>(a_topic),
    dr_qos, a_listener,
    mask, this, sub_qos);

  if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
    recorder->enable();
  }

  ACE_Guard<ACE_Recursive_Thread_Mutex> guard(recorders_protector_);
  recorders_.insert(result);

  return result._retn();
}

create_replayer()

Replayer_ptr OpenDDS::DCPS::DomainParticipantImpl::create_replayer	(	DDS::Topic_ptr	a_topic,
		const DDS::PublisherQos &	publisher_qos,
		const DDS::DataWriterQos &	datawriter_qos,
		const ReplayerListener_rch &	a_listener,
		DDS::StatusMask	mask
	)

Definition at line 2237 of file DomainParticipantImpl.cpp.

References TAO_Objref_Var_T< T >::_retn(), ACE_ERROR, ACE_TEXT(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::ReplayerImpl::enable(), OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, OpenDDS::DCPS::ReplayerImpl::init(), CORBA::is_nil(), LM_ERROR, qos_, replayers_, replayers_protector_, DDS::RETCODE_OK, TheServiceParticipant, OpenDDS::DCPS::PublisherImpl::validate_datawriter_qos(), and validate_publisher_qos().

Referenced by OpenDDS::DCPS::Service_Participant::create_replayer().

{
  if (CORBA::is_nil(a_topic)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_replayer, ")
                 ACE_TEXT("topic desc is nil.\n")));
    }
    return 0;
  }

  DDS::PublisherQos pub_qos = publisher_qos;
  DDS::DataWriterQos dw_qos;

  if (! this->validate_publisher_qos(pub_qos) ||
      ! PublisherImpl::validate_datawriter_qos(datawriter_qos,
                                               TheServiceParticipant->initial_DataWriterQos(),
                                               a_topic,
                                               dw_qos)) {
    return 0;
  }

  TopicImpl* topic_servant = dynamic_cast<TopicImpl*>(a_topic);

  ReplayerImpl* replayer(new ReplayerImpl);
  Replayer_var result(replayer);

  replayer->init(a_topic, topic_servant, dw_qos, a_listener, mask, this, pub_qos);

  if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
    const DDS::ReturnCode_t ret = replayer->enable();

    if (ret != DDS::RETCODE_OK) {
      if (DCPS_debug_level > 0) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: ")
                   ACE_TEXT("DomainParticipantImpl::create_replayer, ")
                   ACE_TEXT("enable failed.\n")));
      }
      return 0;
    }
  }

  ACE_Guard<ACE_Recursive_Thread_Mutex> guard(replayers_protector_);
  replayers_.insert(result);
  return result._retn();
}

create_subscriber()

DDS::Subscriber_ptr OpenDDS::DCPS::DomainParticipantImpl::create_subscriber ( const DDS::SubscriberQos &  qos, DDS::SubscriberListener_ptr  a_listener, DDS::StatusMask  mask  )

virtual

Definition at line 270 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_NEW_RETURN, ACE_TEXT(), assign_handle(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::SubscriberImpl::enable(), OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, OpenDDS::DCPS::insert(), LM_ERROR, qos_, subscribers_, subscribers_protector_, and validate_subscriber_qos().

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), and OpenDDS::DCPS::StaticDiscovery::init_bit().

{
  DDS::SubscriberQos sub_qos = qos;

  if (! this->validate_subscriber_qos(sub_qos)) {
    return DDS::Subscriber::_nil();
  }

  const DDS::InstanceHandle_t handle = assign_handle();

  SubscriberImpl* sub = 0;
  ACE_NEW_RETURN(sub,
                 SubscriberImpl(handle,
                                sub_qos,
                                a_listener,
                                mask,
                                this),
                 DDS::Subscriber::_nil());

  if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
    sub->enable();
  }

  DDS::Subscriber_ptr sub_obj(sub);

  Subscriber_Pair pair(sub, sub_obj, false);

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   this->subscribers_protector_,
                   DDS::Subscriber::_nil());

  if (OpenDDS::DCPS::insert(subscribers_, pair) == -1) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::create_subscriber, ")
                 ACE_TEXT("%p\n"),
                 ACE_TEXT("insert")));
    }
    return DDS::Subscriber::_nil();
  }

  return DDS::Subscriber::_duplicate(sub_obj);
}

create_topic()

DDS::Topic_ptr OpenDDS::DCPS::DomainParticipantImpl::create_topic ( const char *  topic_name, const char *  type_name, const DDS::TopicQos &  qos, DDS::TopicListener_ptr  a_listener, DDS::StatusMask  mask  )

virtual

Definition at line 395 of file DomainParticipantImpl.cpp.

References create_topic_i().

Referenced by OpenDDS::DCPS::Discovery::create_bit_topics().

{
  return create_topic_i(topic_name,
                        type_name,
                        qos,
                        a_listener,
                        mask,
                        0);
}

create_topic_i()

DDS::Topic_ptr OpenDDS::DCPS::DomainParticipantImpl::create_topic_i ( const char *  topic_name, const char *  type_name, const DDS::TopicQos &  qos, DDS::TopicListener_ptr  a_listener, DDS::StatusMask  mask, int  topic_mask  )

private

Definition at line 431 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), DDS::EntityFactoryQosPolicy::autoenable_created_entities, OpenDDS::DCPS::Qos_Helper::consistent(), create_new_topic(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::EntityImpl::enabled_, DDS::DomainParticipantQos::entity_factory, Util::find(), get_default_topic_qos(), TAO::String_var< charT >::in(), CORBA::is_nil(), LM_ERROR, LM_WARNING, 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, qos_, Registered_Data_Types, DDS::RETCODE_OK, ACE_OS::strcmp(), topic_descrs_, TOPIC_QOS_DEFAULT, topics_, topics_protector_, and OpenDDS::DCPS::Qos_Helper::valid().

Referenced by create_topic(), and create_typeless_topic().

{
  DDS::TopicQos topic_qos;

  if (qos == TOPIC_QOS_DEFAULT) {
    this->get_default_topic_qos(topic_qos);

  } else {
    topic_qos = qos;
  }

  OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE_COMPATIBILITY_CHECK(qos, DDS::Topic::_nil());
  OPENDDS_NO_OWNERSHIP_PROFILE_COMPATIBILITY_CHECK(qos, DDS::Topic::_nil());
  OPENDDS_NO_DURABILITY_SERVICE_COMPATIBILITY_CHECK(qos, DDS::Topic::_nil());
  OPENDDS_NO_DURABILITY_KIND_TRANSIENT_PERSISTENT_COMPATIBILITY_CHECK(qos, DDS::Topic::_nil());

  if (!Qos_Helper::valid(topic_qos)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_topic, ")
                 ACE_TEXT("invalid qos.\n")));
    }
    return DDS::Topic::_nil();
  }

  if (!Qos_Helper::consistent(topic_qos)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::create_topic, ")
                 ACE_TEXT("inconsistent qos.\n")));
    }
    return DDS::Topic::_nil();
  }

  // See if there is a Topic with the same name.
  TopicMap::mapped_type* entry = 0;
  bool found = false;
  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->topics_protector_,
                     DDS::Topic::_nil());

#if !defined(OPENDDS_NO_CONTENT_FILTERED_TOPIC) || !defined(OPENDDS_NO_MULTI_TOPIC)
    if (topic_descrs_.count(topic_name)) {
      if (DCPS_debug_level > 3) {
        ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                   ACE_TEXT("DomainParticipantImpl::create_topic, ")
                   ACE_TEXT("can't create a Topic due to name \"%C\" already in use ")
                   ACE_TEXT("by a TopicDescription.\n"), topic_name));
      }
      return 0;
    }
#endif

    if (Util::find(topics_, topic_name, entry) == 0) {
      found = true;
    }
  }

  /*
   * If there is a topic with the same name, return the topic if it has the
   * same type name and QoS, else it is an error.
   */
  if (found) {
    CORBA::String_var found_type = entry->pair_.svt_->get_type_name();
    if (ACE_OS::strcmp(type_name, found_type) == 0) {
      DDS::TopicQos found_qos;
      entry->pair_.svt_->get_qos(found_qos);

      if (topic_qos == found_qos) { // match type name, qos
        {
          ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                           tao_mon,
                           this->topics_protector_,
                           DDS::Topic::_nil());
          ++entry->client_refs_;
        }
        return DDS::Topic::_duplicate(entry->pair_.obj_.in());

      } else { // Same Name and Type, Different QoS
        if (DCPS_debug_level >= 1) {
          ACE_ERROR((LM_ERROR,
            ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::create_topic: ")
            ACE_TEXT("topic with name \"%C\" and type %C already exists, ")
            ACE_TEXT("but the QoS doesn't match.\n"),
            topic_name, type_name));
        }

        return DDS::Topic::_nil();
      }

    } else { // Same Name, Different Type
      if (DCPS_debug_level >= 1) {
        ACE_ERROR((LM_ERROR,
          ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::create_topic: ")
          ACE_TEXT("topic with name \"%C\" already exists, but its type, %C ")
          ACE_TEXT("is not the same as %C.\n"),
          topic_name, found_type.in(), type_name));
      }

      return DDS::Topic::_nil();
    }

  } else {

    OpenDDS::DCPS::TypeSupport_var type_support;

    if (0 == topic_mask) {
      // creating a topic with compile time type
      type_support = Registered_Data_Types->lookup(this, type_name);
      if (CORBA::is_nil(type_support)) {
        if (DCPS_debug_level >= 1) {
           ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                      ACE_TEXT("DomainParticipantImpl::create_topic, ")
                      ACE_TEXT("can't create a topic=%C type_name=%C ")
                      ACE_TEXT("is not registered.\n"),
                      topic_name, type_name));
        }
        return DDS::Topic::_nil();
      }
    }

    DDS::Topic_var new_topic = create_new_topic(topic_name,
                                                type_name,
                                                topic_qos,
                                                a_listener,
                                                mask,
                                                type_support);

    if (!new_topic) {
      if (DCPS_debug_level > 0) {
        ACE_ERROR((LM_WARNING,
                   ACE_TEXT("(%P|%t) WARNING: ")
                   ACE_TEXT("DomainParticipantImpl::create_topic, ")
                   ACE_TEXT("create_new_topic failed.\n")));
      }
      return DDS::Topic::_nil();
    }

    if (enabled_ && qos_.entity_factory.autoenable_created_entities) {
      if (new_topic->enable() != DDS::RETCODE_OK) {
        if (DCPS_debug_level > 0) {
          ACE_ERROR((LM_WARNING,
                     ACE_TEXT("(%P|%t) WARNING: ")
                     ACE_TEXT("DomainParticipantImpl::create_topic, ")
                     ACE_TEXT("enable failed.\n")));
        }
        return DDS::Topic::_nil();
      }
    }
    return new_topic._retn();
  }
}

create_typeless_topic()

DDS::Topic_ptr OpenDDS::DCPS::DomainParticipantImpl::create_typeless_topic	(	const char *	topic_name,
		const char *	type_name,
		bool	type_has_keys,
		const DDS::TopicQos &	qos,
		DDS::TopicListener_ptr	a_listener,
		DDS::StatusMask	mask
	)

Definition at line 411 of file DomainParticipantImpl.cpp.

References create_topic_i(), TOPIC_TYPE_HAS_KEYS, and TOPIC_TYPELESS.

Referenced by OpenDDS::DCPS::Service_Participant::create_typeless_topic().

{
  int topic_mask = (type_has_keys ? TOPIC_TYPE_HAS_KEYS : 0 ) | TOPIC_TYPELESS;

  return create_topic_i(topic_name,
                        type_name,
                        qos,
                        a_listener,
                        mask,
                        topic_mask);
}

crypto_handle()

DDS::Security::ParticipantCryptoHandle OpenDDS::DCPS::DomainParticipantImpl::crypto_handle ( ) const

inline

Definition at line 413 of file DomainParticipantImpl.h.

  {
    return part_crypto_handle_;
  }

delete_contained_entities()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities ( )

virtual

Implements DDS::DomainParticipant.

Definition at line 1053 of file DomainParticipantImpl.cpp.

References ACE_Thread_Mutex::acquire(), bit_subscriber_, domain_id_, OpenDDS::DCPS::EntityImpl::get_deleted(), handle_exception(), prepare_to_delete_datawriters(), Registered_Data_Types, ACE_Thread_Mutex::release(), DDS::RETCODE_ERROR, ACE_Thread::self(), OpenDDS::DCPS::EntityImpl::set_deleted(), set_wait_pending_deadline(), shutdown_complete_, shutdown_condition_, shutdown_mutex_, shutdown_result_, TheServiceParticipant, ACE_OS::thr_equal(), and OpenDDS::DCPS::ConditionVariable< Mutex >::wait().

Referenced by OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_all_participants(), and OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant().

{
  if (!get_deleted()) {
    // mark that the entity is being deleted
    set_deleted(true);

    if (!prepare_to_delete_datawriters()) {
      return DDS::RETCODE_ERROR;
    }
    if (!set_wait_pending_deadline(TheServiceParticipant->new_pending_timeout_deadline())) {
      return DDS::RETCODE_ERROR;
    }
  }

  // BIT subscriber and data readers will be deleted with the
  // rest of the entities, so need to report to discovery that
  // BIT is no longer available
  Discovery_rch disc = TheServiceParticipant->get_discovery(this->domain_id_);
  if (disc)
    disc->fini_bit(this);

  if (ACE_OS::thr_equal(TheServiceParticipant->reactor_owner(),
                        ACE_Thread::self())) {
    handle_exception(0);

  } else {
    TheServiceParticipant->reactor()->notify(this);

    shutdown_mutex_.acquire();
    ThreadStatusManager& thread_status_manager = TheServiceParticipant->get_thread_status_manager();
    while (!shutdown_complete_) {
      shutdown_condition_.wait(thread_status_manager);
    }
    shutdown_complete_ = false;
    shutdown_mutex_.release();
  }

  bit_subscriber_.reset();

  Registered_Data_Types->unregister_participant(this);

  // the participant can now start creating new contained entities
  set_deleted(false);
  return shutdown_result_;
}

delete_contentfilteredtopic()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_contentfilteredtopic ( DDS::ContentFilteredTopic_ptr  a_contentfilteredtopic )

virtual

Definition at line 873 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TopicDescriptionImpl::has_entity_refs(), TAO::String_var< charT >::in(), LM_ERROR, name, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_OUT_OF_RESOURCES, DDS::RETCODE_PRECONDITION_NOT_MET, topic_descrs_, and topics_protector_.

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, topics_protector_,
                   DDS::RETCODE_OUT_OF_RESOURCES);
  DDS::ContentFilteredTopic_var cft =
    DDS::ContentFilteredTopic::_duplicate(a_contentfilteredtopic);
  CORBA::String_var name = cft->get_name();
  TopicDescriptionMap::iterator iter = topic_descrs_.find(name.in());
  if (iter == topic_descrs_.end()) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_contentfilteredtopic, ")
                 ACE_TEXT("can't delete a content-filtered topic \"%C\" ")
                 ACE_TEXT("because it is not in the set.\n"), name.in ()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  TopicDescriptionImpl* tdi = dynamic_cast<TopicDescriptionImpl*>(iter->second.in());

  if (!tdi) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_contentfilteredtopic, ")
                 ACE_TEXT("can't delete a content-filtered topic \"%C\" ")
                 ACE_TEXT("failed to obtain TopicDescriptionImpl\n"), name.in()));
    }
    return DDS::RETCODE_ERROR;
  }

  if (tdi->has_entity_refs()) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_contentfilteredtopic, ")
                 ACE_TEXT("can't delete a content-filtered topic \"%C\" ")
                 ACE_TEXT("because it is used by a datareader\n"), name.in ()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }
  topic_descrs_.erase(iter);
  return DDS::RETCODE_OK;
}

delete_multitopic()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_multitopic ( DDS::MultiTopic_ptr  a_multitopic )

virtual

Definition at line 966 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TopicDescriptionImpl::has_entity_refs(), TAO::String_var< charT >::in(), LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_OUT_OF_RESOURCES, DDS::RETCODE_PRECONDITION_NOT_MET, topic_descrs_, and topics_protector_.

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, topics_protector_,
                   DDS::RETCODE_OUT_OF_RESOURCES);
  DDS::MultiTopic_var mt = DDS::MultiTopic::_duplicate(a_multitopic);
  CORBA::String_var mt_name = mt->get_name();
  TopicDescriptionMap::iterator iter = topic_descrs_.find(mt_name.in());
  if (iter == topic_descrs_.end()) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_multitopic, ")
                 ACE_TEXT("can't delete a multitopic \"%C\" ")
                 ACE_TEXT("because it is not in the set.\n"), mt_name.in ()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  TopicDescriptionImpl* tdi = dynamic_cast<TopicDescriptionImpl*>(iter->second.in());

  if (!tdi) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_multitopic, ")
                 ACE_TEXT("can't delete a multitopic topic \"%C\" ")
                 ACE_TEXT("failed to obtain TopicDescriptionImpl.\n"),
                 mt_name.in()));
    }
    return DDS::RETCODE_ERROR;
  }

  if (tdi->has_entity_refs()) {
    if (DCPS_debug_level > 3) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::delete_multitopic, ")
                 ACE_TEXT("can't delete a multitopic topic \"%C\" ")
                 ACE_TEXT("because it is used by a datareader.\n"), mt_name.in ()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }
  topic_descrs_.erase(iter);
  return DDS::RETCODE_OK;
}

delete_publisher()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_publisher ( DDS::Publisher_ptr  p )

virtual

Definition at line 206 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, OpenDDS::DCPS::PublisherImpl::delete_contained_entities(), OpenDDS::DCPS::PublisherImpl::is_clean(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, publishers_, publishers_protector_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, and OpenDDS::DCPS::retcode_to_string().

Referenced by handle_exception().

{
  // The servant's ref count should be 2 at this point,
  // one referenced by poa, one referenced by the publisher
  // set.
  PublisherImpl* the_servant = dynamic_cast<PublisherImpl*>(p);
  if (!the_servant) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_publisher: "
                 "Failed to obtain PublisherImpl\n"));
    }
    return DDS::RETCODE_ERROR;
  }

  const Publisher_Pair pub_pair(the_servant, p, true);

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, g,
      publishers_protector_, DDS::RETCODE_ERROR);
    if (publishers_.count(pub_pair) == 0) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_publisher: "
                   "This publisher doesn't belong to this participant\n"));
      }
      return DDS::RETCODE_PRECONDITION_NOT_MET;
    }
  }

  String leftover_entities;
  if (!the_servant->is_clean(&leftover_entities)) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_publisher: "
                 "The publisher is not empty. %C leftover\n",
                 leftover_entities.c_str()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  const DDS::ReturnCode_t ret = the_servant->delete_contained_entities();
  if (ret != DDS::RETCODE_OK) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_publisher: "
                 "Failed to delete contained entities: %C\n", retcode_to_string(ret)));
    }
    return ret;
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, g,
      publishers_protector_, DDS::RETCODE_ERROR);
    if (remove(publishers_, pub_pair) == -1) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_publisher: "
          "publisher not found\n"));
      }
      return DDS::RETCODE_ERROR;
    }
  }

  return DDS::RETCODE_OK;
}

delete_recorder()

void OpenDDS::DCPS::DomainParticipantImpl::delete_recorder

(

Recorder_ptr

recorder

)

Definition at line 2291 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::Recorder::_duplicate(), recorders_, and recorders_protector_.

Referenced by OpenDDS::DCPS::Service_Participant::delete_recorder().

{
  const Recorder_var recvar(Recorder::_duplicate(recorder));
  ACE_Guard<ACE_Recursive_Thread_Mutex> guard(recorders_protector_);
  recorders_.erase(recvar);
}

delete_replayer()

void OpenDDS::DCPS::DomainParticipantImpl::delete_replayer

(

Replayer_ptr

replayer

)

Definition at line 2299 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::Replayer::_duplicate(), replayers_, and replayers_protector_.

Referenced by OpenDDS::DCPS::Service_Participant::delete_replayer().

{
  const Replayer_var repvar(Replayer::_duplicate(replayer));
  ACE_Guard<ACE_Recursive_Thread_Mutex> guard(replayers_protector_);
  replayers_.erase(repvar);
}

delete_subscriber()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_subscriber ( DDS::Subscriber_ptr  s )

virtual

Definition at line 319 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, OpenDDS::DCPS::SubscriberImpl::delete_contained_entities(), OpenDDS::DCPS::SubscriberImpl::is_clean(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, OpenDDS::DCPS::retcode_to_string(), subscribers_, and subscribers_protector_.

Referenced by handle_exception().

{
  // The servant's ref count should be 2 at this point,
  // one referenced by poa, one referenced by the subscriber
  // set.
  SubscriberImpl* const the_servant = dynamic_cast<SubscriberImpl*>(s);
  if (!the_servant) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_subscriber: "
                 "Failed to obtain SubscriberImpl\n"));
    }
    return DDS::RETCODE_ERROR;
  }

  const Subscriber_Pair sub_pair(the_servant, s, true);

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, g,
      subscribers_protector_, DDS::RETCODE_ERROR);
    if (subscribers_.count(sub_pair) == 0) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_subscriber: "
                   "This subscriber doesn't belong to this participant\n"));
      }
      return DDS::RETCODE_PRECONDITION_NOT_MET;
    }
  }

  String leftover_entities;
  if (!the_servant->is_clean(&leftover_entities)) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_subscriber: "
                 "The subscriber is not empty. %C leftover\n",
                 leftover_entities.c_str()));
    }
    return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  const DDS::ReturnCode_t ret = the_servant->delete_contained_entities();
  if (ret != DDS::RETCODE_OK) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_subscriber: "
                 "Failed to delete contained entities: %C\n", retcode_to_string(ret)));
    }
    return ret;
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, g,
      subscribers_protector_, DDS::RETCODE_ERROR);
    if (remove(subscribers_, sub_pair) == -1) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_subscriber: "
          "subscriber not found\n"));
      }
      return DDS::RETCODE_ERROR;
    }
  }

  return DDS::RETCODE_OK;
}

delete_topic()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_topic ( DDS::Topic_ptr  a_topic )

virtual

Definition at line 595 of file DomainParticipantImpl.cpp.

References delete_topic_i().

{
  return delete_topic_i(a_topic, false);
}

delete_topic_i()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::delete_topic_i ( DDS::Topic_ptr  a_topic, bool  remove_objref  )

private

Delete the topic with option of whether the topic object reference should be removed.

Definition at line 601 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, OpenDDS::DCPS::DCPS_debug_level, domain_id_, get_domain_id(), OpenDDS::DCPS::TopicImpl::get_id(), get_id(), OpenDDS::DCPS::TopicDescriptionImpl::get_name(), OpenDDS::DCPS::TopicDescriptionImpl::get_participant(), OpenDDS::DCPS::TopicDescriptionImpl::has_entity_refs(), TAO::String_var< charT >::in(), LM_DEBUG, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::REMOVED, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, TheServiceParticipant, topics_, topics_protector_, and OpenDDS::DCPS::topicstatus_to_string().

Referenced by delete_topic(), and handle_exception().

{
  DDS::ReturnCode_t ret = DDS::RETCODE_OK;

  try {
    // The servant's ref count should be greater than 2 at this point,
    // one referenced by poa, one referenced by the topic map and
    // others referenced by the datareader/datawriter.
    TopicImpl* the_topic_servant = dynamic_cast<TopicImpl*>(a_topic);

    if (!the_topic_servant) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i: %p\n"
                   "failed to obtain TopicImpl."));
      }
      return DDS::RETCODE_ERROR;
    }

    DDS::DomainParticipant_var dp = the_topic_servant->get_participant();

    DomainParticipantImpl* the_dp_servant =
      dynamic_cast<DomainParticipantImpl*>(dp.in());

    if (the_dp_servant != this) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i: "
                   "will return PRECONDITION_NOT_MET because this is not the "
                   "participant that owns this topic\n"));
      }
      return DDS::RETCODE_PRECONDITION_NOT_MET;
    }
    if (!remove_objref && the_topic_servant->has_entity_refs()) {
      // If entity_refs is true (nonzero), then some reader or writer is using
      // this topic and the spec requires delete_topic() to fail with the error:
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i: "
                   "will return PRECONDITION_NOT_MET because there are still "
                   "outstanding references to this topic\n"));
      }
      return DDS::RETCODE_PRECONDITION_NOT_MET;
    }

    {
      ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                       tao_mon,
                       this->topics_protector_,
                       DDS::RETCODE_ERROR);

      CORBA::String_var topic_name = the_topic_servant->get_name();
      TopicMap::mapped_type* entry = 0;

      TopicMapIteratorPair iters = topics_.equal_range(topic_name.in());
      TopicMapIterator iter;
      for (iter = iters.first; iter != iters.second; ++iter) {
        if (iter->second.pair_.svt_ == the_topic_servant) {
          entry = &iter->second;
          break;
        }
      }
      if (entry == 0) {
        if (log_level >= LogLevel::Notice) {
          ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i: not found\n"));
        }
        return DDS::RETCODE_ERROR;
      }

      const CORBA::ULong client_refs = --entry->client_refs_;

      if (remove_objref || 0 == client_refs) {
        const GUID_t topicId = the_topic_servant->get_id();
        topics_.erase(iter);

        Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
        TopicStatus status = disco->remove_topic(
          the_dp_servant->get_domain_id(), the_dp_servant->get_id(), topicId);

        if (status != REMOVED) {
          if (log_level >= LogLevel::Notice) {
            ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i, "
                       "remove_topic failed with return value <%C>\n", topicstatus_to_string(status)));
           }
          return DDS::RETCODE_ERROR;
        }

        return DDS::RETCODE_OK;

      } else {
        if (DCPS_debug_level > 4) {
          ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::delete_topic_i: "
                     "Didn't remove topic from the map, remove_objref %d client_refs %d\n",
                     remove_objref, client_refs));
        }
      }
    }

  } catch (...) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::delete_topic_i, "
                 " Caught Unknown Exception\n"));
    }
    ret = DDS::RETCODE_ERROR;
  }

  return ret;
}

deref_filter_eval()

void OpenDDS::DCPS::DomainParticipantImpl::deref_filter_eval

(

const char *

filter

)

Definition at line 1038 of file DomainParticipantImpl.cpp.

References ACE_GUARD, and filter_cache_lock_.

{
  ACE_GUARD(ACE_Thread_Mutex, guard, filter_cache_lock_);
  typedef std::map<OPENDDS_STRING, RcHandle<FilterEvaluator> > Map;
  Map::iterator iter = filter_cache_.find(filter);
  if (iter != filter_cache_.end()) {
    if (iter->second->ref_count() == 1) {
      filter_cache_.erase(iter);
    }
  }
}

enable()

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

virtual

Implements DDS::Entity.

Definition at line 1617 of file DomainParticipantImpl.cpp.

References access(), ACE_DEBUG, ACE_ERROR, ACE_TEXT(), DDS::Security::ParticipantSecurityAttributes::allow_unauthenticated_participants, DDS::EntityFactoryQosPolicy::autoenable_created_entities, bit_subscriber_, DDS::Security::SecurityException::code, OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, DDS::DomainParticipantQos::entity_factory, OpenDDS::DCPS::AddDomainStatus::federated, federated_, Util::filter_properties(), OpenDDS::DCPS::GUID_UNKNOWN, DDS::HANDLE_NIL, OpenDDS::DCPS::AddDomainStatus::id, id_handle_, OpenDDS::DCPS::EntityImpl::is_enabled(), OpenDDS::DCPS::RcHandle< T >::is_nil(), DDS::Security::ParticipantSecurityAttributes::is_rtps_protected, LM_DEBUG, LM_ERROR, DDS::Security::SecurityException::message, DDS::Security::SecurityException::minor_code, monitor_, part_crypto_handle_, perm_handle_, DDS::DomainParticipantQos::property, publishers_, qos_, DDS::RETCODE_ERROR, DDS::Security::RETCODE_NOT_ALLOWED_BY_SECURITY, DDS::RETCODE_OK, security_config_, OpenDDS::DCPS::security_debug, OpenDDS::DCPS::EntityImpl::set_enabled(), subscribers_, TheSecurityRegistry, TheServiceParticipant, TheTransientKludge, topics_, type_lookup_service_, DDS::Security::VALIDATION_OK, value, and DDS::PropertyQosPolicy::value.

{
  //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;
  }

#ifdef OPENDDS_SECURITY
  if (!security_config_ && TheServiceParticipant->get_security()) {
    security_config_ = TheSecurityRegistry->default_config();
    if (!security_config_) {
      security_config_ = TheSecurityRegistry->builtin_config();
      TheSecurityRegistry->default_config(security_config_);
    }
  }
#endif

  Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);

  if (disco.is_nil()) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                ACE_TEXT("no discovery found for domain id: %d.\n"), domain_id_));
    }
    return DDS::RETCODE_ERROR;
  }

#ifdef OPENDDS_SECURITY
  if (TheServiceParticipant->get_security() && !security_config_) {
    if (DCPS::security_debug.new_entity_error) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                 ACE_TEXT("DCPSSecurity flag is set, but unable to load security plugin configuration.\n")));
    }
    return DDS::RETCODE_ERROR;
  }
#endif

  AddDomainStatus value = {GUID_UNKNOWN, false};

#ifdef OPENDDS_SECURITY
  if (TheServiceParticipant->get_security() && security_config_->qos_implies_security(qos_)) {
    Security::Authentication_var auth = security_config_->get_authentication();

    DDS::Security::SecurityException se;
    DDS::Security::ValidationResult_t val_res =
      auth->validate_local_identity(id_handle_, dp_id_, domain_id_, qos_, disco->generate_participant_guid(), se);

    /* TODO - Handle VALIDATION_PENDING_RETRY */
    if (val_res != DDS::Security::VALIDATION_OK) {
      if (DCPS::security_debug.new_entity_error) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                   ACE_TEXT("Unable to validate local identity. SecurityException[%d.%d]: %C\n"),
                   se.code, se.minor_code, se.message.in()));
      }
      return DDS::Security::RETCODE_NOT_ALLOWED_BY_SECURITY;
    }

    Security::AccessControl_var access = security_config_->get_access_control();

    perm_handle_ = access->validate_local_permissions(auth, id_handle_, domain_id_, qos_, se);

    if (perm_handle_ == DDS::HANDLE_NIL) {
      if (DCPS::security_debug.new_entity_error) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                   ACE_TEXT("Unable to validate local permissions. SecurityException[%d.%d]: %C\n"),
                   se.code, se.minor_code, se.message.in()));
      }
      return DDS::Security::RETCODE_NOT_ALLOWED_BY_SECURITY;
    }

    const bool check_create = access->check_create_participant(perm_handle_, domain_id_, qos_, se);
    if (!check_create) {
      if (DCPS::security_debug.new_entity_error) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                   ACE_TEXT("Unable to create participant. SecurityException[%d.%d]: %C\n"),
                   se.code, se.minor_code, se.message.in()));
      }
      return DDS::Security::RETCODE_NOT_ALLOWED_BY_SECURITY;
    }

    DDS::Security::ParticipantSecurityAttributes part_sec_attr;
    const bool check_part_sec_attr = access->get_participant_sec_attributes(perm_handle_, part_sec_attr, se);

    if (!check_part_sec_attr) {
      if (DCPS::security_debug.new_entity_error) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable,")
                   ACE_TEXT("Unable to get participant security attributes. SecurityException[%d.%d]: %C\n"),
                   se.code, se.minor_code, se.message.in()));
      }
      return DDS::RETCODE_ERROR;
    }

    if (part_sec_attr.is_rtps_protected) { // DDS-Security v1.1 8.4.2.4 Table 27 is_rtps_protected
      if (part_sec_attr.allow_unauthenticated_participants) {
        if (DCPS::security_debug.new_entity_error) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                     ACE_TEXT("allow_unauthenticated_participants is not possible with is_rtps_protected\n")));
        }
        return DDS::Security::RETCODE_NOT_ALLOWED_BY_SECURITY;
      }

      const Security::CryptoKeyFactory_var crypto = security_config_->get_crypto_key_factory();
      part_crypto_handle_ = crypto->register_local_participant(id_handle_, perm_handle_,
        Util::filter_properties(qos_.property.value, "dds.sec.crypto."), part_sec_attr, se);
      if (part_crypto_handle_ == DDS::HANDLE_NIL) {
        if (DCPS::security_debug.new_entity_error) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                     ACE_TEXT("Unable to register local participant. SecurityException[%d.%d]: %C\n"),
                     se.code, se.minor_code, se.message.in()));
        }
        return DDS::RETCODE_ERROR;
      }

    } else {
      part_crypto_handle_ = DDS::HANDLE_NIL;
    }

    value = disco->add_domain_participant_secure(domain_id_, qos_, type_lookup_service_,
                                                 dp_id_, id_handle_, perm_handle_, part_crypto_handle_);

    if (value.id == GUID_UNKNOWN) {
      if (DCPS::security_debug.new_entity_error) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                   ACE_TEXT("add_domain_participant_secure returned invalid id.\n")));
      }
      return DDS::RETCODE_ERROR;
    }

  } else {
#endif

    value = disco->add_domain_participant(domain_id_, qos_, type_lookup_service_);

    if (value.id == GUID_UNKNOWN) {
      if (DCPS_debug_level > 0) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::enable, ")
                   ACE_TEXT("add_domain_participant returned invalid id.\n")));
      }
      return DDS::RETCODE_ERROR;
    }

#ifdef OPENDDS_SECURITY
  }
#endif

  dp_id_ = value.id;
  federated_ = value.federated;

  if (monitor_) {
    monitor_->report();
  }

  if (TheServiceParticipant->monitor_) {
    TheServiceParticipant->monitor_->report();
  }

  const DDS::ReturnCode_t ret = this->set_enabled();

  if (DCPS_debug_level > 1) {
    ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DomainParticipantImpl::enable: ")
               ACE_TEXT("enabled participant %C in domain %d\n"),
               LogGuid(dp_id_).c_str(), domain_id_));
  }

  if (ret == DDS::RETCODE_OK && !TheTransientKludge->is_enabled()) {
    Discovery_rch disc = TheServiceParticipant->get_discovery(this->domain_id_);
    this->bit_subscriber_ = disc->init_bit(this);
  }

  if (ret != DDS::RETCODE_OK) {
    return ret;
  }

  if (qos_.entity_factory.autoenable_created_entities) {

    for (TopicMap::iterator it = topics_.begin(); it != topics_.end(); ++it) {
      it->second.pair_.svt_->enable();
    }

    for (PublisherSet::iterator it = publishers_.begin(); it != publishers_.end(); ++it) {
      it->svt_->enable();
    }

    for (SubscriberSet::iterator it = subscribers_.begin(); it != subscribers_.end(); ++it) {
      it->svt_->enable();
    }
  }

  return DDS::RETCODE_OK;
}

federated()

bool OpenDDS::DCPS::DomainParticipantImpl::federated ( ) const

inline

Definition at line 371 of file DomainParticipantImpl.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::init_bit().

                         {
    return this->federated_;
  }

find_topic()

DDS::Topic_ptr OpenDDS::DCPS::DomainParticipantImpl::find_topic ( const char *  topic_name, const DDS::Duration_t &  timeout  )

virtual

Definition at line 710 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), create_new_topic(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DEFAULT_STATUS_MASK, domain_id_, OpenDDS::DCPS::FOUND, get_id(), TAO::String_var< charT >::in(), OpenDDS::DCPS::INTERNAL_ERROR, CORBA::is_nil(), LM_DEBUG, LM_ERROR, OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), TAO::String_var< charT >::out(), Registered_Data_Types, ACE_Time_Value::sec(), ACE_OS::sleep(), TheServiceParticipant, and OpenDDS::DCPS::TimeDuration::value().

{
  const MonotonicTimePoint timeout_at(MonotonicTimePoint::now() + TimeDuration(timeout));

  bool first_time = true;
  while (first_time || MonotonicTimePoint::now() < timeout_at) {
    if (first_time) {
      first_time = false;
    }

    GUID_t topic_id;
    CORBA::String_var type_name;
    DDS::TopicQos_var qos;

    Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
    TopicStatus status = disco->find_topic(domain_id_,
                                           get_id(),
                                           topic_name,
                                           type_name.out(),
                                           qos.out(),
                                           topic_id);

    const MonotonicTimePoint now = MonotonicTimePoint::now();
    if (status == FOUND) {
      OpenDDS::DCPS::TypeSupport_var type_support =
        Registered_Data_Types->lookup(this, type_name.in());
      if (CORBA::is_nil(type_support)) {
        if (DCPS_debug_level) {
            ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                       ACE_TEXT("DomainParticipantImpl::find_topic, ")
                       ACE_TEXT("can't create a Topic: type_name \"%C\" ")
                       ACE_TEXT("is not registered.\n"), type_name.in()));
        }

        return DDS::Topic::_nil();
      }

      DDS::Topic_ptr new_topic = create_new_topic(topic_name,
                                                  type_name,
                                                  qos,
                                                  DDS::TopicListener::_nil(),
                                                  OpenDDS::DCPS::DEFAULT_STATUS_MASK,
                                                  type_support);
      return new_topic;

    } else if (status == INTERNAL_ERROR) {
      if (DCPS_debug_level > 0) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::find_topic - ")
                   ACE_TEXT("topic not found, discovery returned INTERNAL_ERROR!\n")));
      }
      return DDS::Topic::_nil();
    } else if (now < timeout_at) {
      const TimeDuration remaining = timeout_at - now;

      if (remaining.value().sec() >= 1) {
        ACE_OS::sleep(1);

      } else {
        ACE_OS::sleep(remaining.value());
      }
    }
  }

  if (DCPS_debug_level >= 1) {
    // timed out
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::find_topic, ")
               ACE_TEXT("timed out.\n")));
  }

  return DDS::Topic::_nil();
}

get_builtin_subscriber()

DDS::Subscriber_ptr OpenDDS::DCPS::DomainParticipantImpl::get_builtin_subscriber ( )

virtual

Implements DDS::DomainParticipant.

Definition at line 383 of file DomainParticipantImpl.cpp.

References bit_subscriber_.

Referenced by OpenDDS::DCPS::instance_handle_to_bit_data().

{
  return bit_subscriber_->get();
}

get_builtin_subscriber_proxy()

RcHandle< BitSubscriber > OpenDDS::DCPS::DomainParticipantImpl::get_builtin_subscriber_proxy

(

)

Definition at line 389 of file DomainParticipantImpl.cpp.

References bit_subscriber_.

{
  return bit_subscriber_;
}

get_current_time()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_current_time ( DDS::Time_t &  current_time )

virtual

Set Argument to Current System Time

Definition at line 1514 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::TimePoint_T< SystemClock >::now(), DDS::RETCODE_OK, and OpenDDS::DCPS::TimePoint_T< AceClock >::to_dds_time().

{
  current_time = SystemTimePoint::now().to_dds_time();
  return DDS::RETCODE_OK;
}

get_default_publisher_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_default_publisher_qos ( DDS::PublisherQos &  qos )

virtual

Definition at line 1464 of file DomainParticipantImpl.cpp.

References default_publisher_qos_, and DDS::RETCODE_OK.

Referenced by validate_publisher_qos().

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

get_default_subscriber_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_default_subscriber_qos ( DDS::SubscriberQos &  qos )

virtual

Definition at line 1485 of file DomainParticipantImpl.cpp.

References default_subscriber_qos_, and DDS::RETCODE_OK.

Referenced by validate_subscriber_qos().

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

get_default_topic_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_default_topic_qos ( DDS::TopicQos &  qos )

virtual

Definition at line 1506 of file DomainParticipantImpl.cpp.

References default_topic_qos_, and DDS::RETCODE_OK.

Referenced by create_topic_i().

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

get_discovered_participant_data()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_discovered_participant_data ( DDS::ParticipantBuiltinTopicData &  participant_data, DDS::InstanceHandle_t  participant_handle  )

virtual

Definition at line 1545 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, bit_subscriber_, OpenDDS::DCPS::GuidConverter::entityKind(), handle_protector_, handles_, OpenDDS::DCPS::KIND_PARTICIPANT, DDS::RETCODE_ERROR, and DDS::RETCODE_PRECONDITION_NOT_MET.

{
  {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::RETCODE_ERROR);

    bool found = false;
    const CountedHandleMap::const_iterator itEnd = handles_.end();
    for (CountedHandleMap::const_iterator iter = handles_.begin(); iter != itEnd; ++iter) {
      GuidConverter converter(iter->first);

      if (participant_handle == iter->second.first
          && converter.entityKind() == KIND_PARTICIPANT) {
        found = true;
        break;
      }
    }

    if (!found)
      return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  return bit_subscriber_->get_discovered_participant_data(participant_data, participant_handle);
}

get_discovered_participants()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_discovered_participants ( DDS::InstanceHandleSeq &  participant_handles )

virtual

Definition at line 1523 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, dp_id_, OpenDDS::DCPS::GuidConverter::entityKind(), handle_protector_, handles_, ignored_participants_, OpenDDS::DCPS::KIND_PARTICIPANT, OpenDDS::DCPS::push_back(), DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::RETCODE_ERROR);

  const CountedHandleMap::const_iterator itEnd = handles_.end();
  for (CountedHandleMap::const_iterator iter = handles_.begin(); iter != itEnd; ++iter) {
    GuidConverter converter(iter->first);

    if (converter.entityKind() == KIND_PARTICIPANT) {
      // skip itself and the ignored participant
      if (iter->first == dp_id_ || ignored_participants_.count(iter->first)) {
        continue;
      }

      push_back(participant_handles, iter->second.first);
    }
  }

  return DDS::RETCODE_OK;
}

get_discovered_topic_data()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_discovered_topic_data ( DDS::TopicBuiltinTopicData &  topic_data, DDS::InstanceHandle_t  topic_handle  )

virtual

Definition at line 1591 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, bit_subscriber_, handle_protector_, handles_, OpenDDS::DCPS::GuidConverter::isTopic(), DDS::RETCODE_ERROR, and DDS::RETCODE_PRECONDITION_NOT_MET.

{
  {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::RETCODE_ERROR);

    bool found = false;
    const CountedHandleMap::const_iterator itEnd = handles_.end();
    for (CountedHandleMap::const_iterator iter = handles_.begin(); iter != itEnd; ++iter) {
      GuidConverter converter(iter->first);
      if (topic_handle == iter->second.first && converter.isTopic()) {
        found = true;
        break;
      }
    }

    if (!found)
      return DDS::RETCODE_PRECONDITION_NOT_MET;
  }

  return bit_subscriber_->get_discovered_topic_data(topic_data, topic_handle);
}

get_discovered_topics()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_discovered_topics ( DDS::InstanceHandleSeq &  topic_handles )

virtual

Definition at line 1571 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, handle_protector_, handles_, ignored_topics_, OpenDDS::DCPS::GuidConverter::isTopic(), OpenDDS::DCPS::push_back(), DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::RETCODE_ERROR);

  const CountedHandleMap::const_iterator itEnd = handles_.end();
  for (CountedHandleMap::const_iterator iter = handles_.begin(); iter != itEnd; ++iter) {
    GuidConverter converter(iter->first);
    if (converter.isTopic()) {
      if (ignored_topics_.count(iter->first)) {
        continue;
      }

      push_back(topic_handles, iter->second.first);
    }
  }

  return DDS::RETCODE_OK;
}

get_domain_id()

DDS::DomainId_t OpenDDS::DCPS::DomainParticipantImpl::get_domain_id ( )

virtual

Reimplemented from OpenDDS::DCPS::EntityImpl.

Definition at line 1419 of file DomainParticipantImpl.cpp.

References domain_id_.

Referenced by OpenDDS::DCPS::MonitorFactoryImpl::create_dp_monitor(), OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), delete_topic_i(), OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::RTPS::RtpsDiscovery::fini_bit(), OpenDDS::DCPS::StaticDiscovery::fini_bit(), OpenDDS::DCPS::RecorderImpl::init(), OpenDDS::DCPS::ReplayerImpl::init(), OpenDDS::DCPS::DataReaderImpl::init(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), OpenDDS::DCPS::StaticDiscovery::init_bit(), OpenDDS::DCPS::DPMonitorImpl::report(), OpenDDS::DCPS::TopicImpl::set_qos(), OpenDDS::DCPS::ReplayerImpl::set_qos(), and OpenDDS::DCPS::RecorderImpl::set_qos().

{
  return domain_id_;
}

get_dynamic_type()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_dynamic_type	(	DDS::DynamicType_var &	type,
		const DDS::BuiltinTopicKey_t &	key
	)

Definition at line 2617 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, OpenDDS::DCPS::bit_key_to_guid(), OpenDDS::XTypes::TypeInformation::complete, OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::XTypes::dynamic_type_is_valid(), LM_DEBUG, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::XTypes::TypeInformation::minimal, OpenDDS::DCPS::LogLevel::Notice, OPENDDS_END_VERSIONED_NAMESPACE_DECL, DDS::RETCODE_ERROR, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), DDS::RETCODE_UNSUPPORTED, OpenDDS::XTypes::DynamicTypeImpl::set_complete_type_identifier(), OpenDDS::XTypes::DynamicTypeImpl::set_minimal_type_identifier(), OpenDDS::XTypes::DynamicTypeImpl::set_preset_type_info(), TheServiceParticipant, OpenDDS::XTypes::TypeIdentifierWithSize::type_id, type_lookup_service_, OpenDDS::XTypes::TypeIdentifierWithDependencies::typeid_with_size, OpenDDS::XTypes::TypeIdentifierWithSize::typeobject_serialized_size, and OpenDDS::DCPS::TypeObjReqCond::wait().

{
  if (!type_lookup_service_) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::get_dynamic_type: "
        "Can't get a DynamicType, no type lookup service\n"));
    }
    return DDS::RETCODE_UNSUPPORTED;
  }

  XTypes::TypeInformation ti = type_lookup_service_->get_type_info(key);
  if (ti.complete.typeid_with_size.typeobject_serialized_size == 0) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::get_dynamic_type: "
        "Can't get a DynamicType, type info is missing complete\n"));
    }
    return DDS::RETCODE_NO_DATA;
  }

  const XTypes::TypeIdentifier& ctid = ti.complete.typeid_with_size.type_id;
  const GUID_t entity = bit_key_to_guid(key);
  if (!type_lookup_service_->has_complete(ctid)) {
    // We don't have it, try to asking the remote for the complete
    // TypeObjects.
    if (DCPS_debug_level >= 4) {
      ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::get_dynamic_type: "
        "requesting remote complete TypeObject from %C\n", LogGuid(entity).c_str()));
    }
    Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
    TypeObjReqCond cond;
    disco->request_remote_complete_type_objects(domain_id_, dp_id_, entity, ti, cond);
    const DDS::ReturnCode_t rc = cond.wait();
    if (rc != DDS::RETCODE_OK) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::get_dynamic_type: "
          "Couldn't get remote complete type object: %C\n", retcode_to_string(rc)));
      }
      return rc;
    }

    if (!type_lookup_service_->has_complete(ctid)) {
      if (log_level >= LogLevel::Notice) {
        ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::get_dynamic_type: "
          "request_remote_complete_type_objects succeeded, but type lookup service still says it "
          "doesn't have the complete TypeObject?\n"));
      }
      return DDS::RETCODE_ERROR;
    }
  }

  DDS::DynamicType_var got_type = type_lookup_service_->type_identifier_to_dynamic(ctid, entity);
  if (!XTypes::dynamic_type_is_valid(got_type)) {
    if (log_level >= LogLevel::Notice) {
      ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: DomainParticipantImpl::get_dynamic_type: "
        "Got an invalid DynamicType\n"));
    }
    return DDS::RETCODE_ERROR;
  }
  type = got_type;

  XTypes::DynamicTypeImpl* impl = dynamic_cast<XTypes::DynamicTypeImpl*>(type.in());
  impl->set_complete_type_identifier(ctid);
  impl->set_minimal_type_identifier(ti.minimal.typeid_with_size.type_id);
  impl->set_preset_type_info(ti);

  return DDS::RETCODE_OK;
}

get_filter_eval()

RcHandle< FilterEvaluator > OpenDDS::DCPS::DomainParticipantImpl::get_filter_eval

(

const char *

filter

)

Definition at line 1015 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, filter_cache_lock_, and LM_ERROR.

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, filter_cache_lock_,
                   RcHandle<FilterEvaluator>());

  RcHandle<FilterEvaluator>& result = filter_cache_[filter];
  if (!result) {
    try {
      result = make_rch<FilterEvaluator>(filter, false);
    } catch (const std::exception& e) {
      filter_cache_.erase(filter);
      if (DCPS_debug_level) {
        ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
                   ACE_TEXT("DomainParticipantImpl::get_filter_eval, ")
                   ACE_TEXT("can't create a writer-side content filter due to ")
                   ACE_TEXT("runtime error: %C.\n"), e.what()));
      }
    }
  }
  return result;
}

get_id()

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

virtual

Following methods are not the idl interfaces and are local operations. Return the id given by discovery.

Reimplemented from OpenDDS::DCPS::EntityImpl.

Definition at line 1824 of file DomainParticipantImpl.cpp.

References dp_id_, and OPENDDS_STRING.

Referenced by OpenDDS::DCPS::RecorderImpl::cleanup(), OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant(), delete_topic_i(), OpenDDS::DCPS::TopicImpl::enable(), OpenDDS::DCPS::RecorderImpl::enable(), OpenDDS::DCPS::ReplayerImpl::enable(), find_topic(), OpenDDS::RTPS::RtpsDiscovery::fini_bit(), OpenDDS::DCPS::StaticDiscovery::fini_bit(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), OpenDDS::DCPS::StaticDiscovery::init_bit(), OpenDDS::FaceTSS::populate_header_received(), OpenDDS::DCPS::SubscriberMonitorImpl::report(), OpenDDS::DCPS::TopicMonitorImpl::report(), OpenDDS::DCPS::DPMonitorImpl::report(), OpenDDS::DCPS::PublisherMonitorImpl::report(), OpenDDS::DCPS::TopicImpl::set_qos(), OpenDDS::DCPS::ReplayerImpl::set_qos(), OpenDDS::DCPS::RecorderImpl::set_qos(), and signal_liveliness().

{
  return dp_id_;
}

get_instance_handle()

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

virtual

Implements OpenDDS::DCPS::EntityImpl.

Definition at line 1837 of file DomainParticipantImpl.cpp.

References dp_id_, OpenDDS::DCPS::EntityImpl::get_entity_instance_handle(), and OpenDDS::DCPS::rchandle_from().

{
  return get_entity_instance_handle(dp_id_, rchandle_from(this));
}

get_listener()

DDS::DomainParticipantListener_ptr OpenDDS::DCPS::DomainParticipantImpl::get_listener ( )

virtual

Implements DDS::DomainParticipant.

Definition at line 1219 of file DomainParticipantImpl.cpp.

References listener_, and listener_mutex_.

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

get_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::get_qos ( DDS::DomainParticipantQos &  qos )

virtual

Definition at line 1199 of file DomainParticipantImpl.cpp.

References qos_, and DDS::RETCODE_OK.

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

get_repoid()

GUID_t OpenDDS::DCPS::DomainParticipantImpl::get_repoid

(

DDS::InstanceHandle_t

id

)

const

Obtain a GUID representing a local hande.

Returns

GUID_UNKNOWN if not found.

Definition at line 1934 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::GUID_UNKNOWN, handle_protector_, and repoIds_.

Referenced by ignore_participant(), ignore_publication(), ignore_subscription(), ignore_topic(), OpenDDS::FaceTSS::populate_header_received(), and OpenDDS::DCPS::ReplayerImpl::write().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, GUID_UNKNOWN);
  const RepoIdMap::const_iterator location = repoIds_.find(handle);
  return location == repoIds_.end() ? GUID_UNKNOWN : location->second;
}

get_security_config()

Security::SecurityConfig_rch OpenDDS::DCPS::DomainParticipantImpl::get_security_config ( ) const

inline

Definition at line 405 of file DomainParticipantImpl.h.

  {
    return security_config_;
  }

get_topic_ids()

void OpenDDS::DCPS::DomainParticipantImpl::get_topic_ids

(

TopicIdVec &

topics

)

Populates an std::vector with the GUID_t of the topics this participant has created/found.

Definition at line 2078 of file DomainParticipantImpl.cpp.

References ACE_GUARD, topics_, and topics_protector_.

Referenced by OpenDDS::DCPS::DPMonitorImpl::report().

{
  ACE_GUARD(ACE_Recursive_Thread_Mutex,
            guard,
            this->topics_protector_);

  topics.reserve(topics_.size());
  for (TopicMap::iterator it(topics_.begin());
       it != topics_.end(); ++it) {
    topics.push_back(it->second.pair_.svt_->get_id());
  }
}

get_type_lookup_service()

XTypes::TypeLookupService_rch OpenDDS::DCPS::DomainParticipantImpl::get_type_lookup_service ( )

inline

Definition at line 402 of file DomainParticipantImpl.h.

Referenced by OpenDDS::DCPS::RecorderImpl::add_to_dynamic_type_map(), OpenDDS::DCPS::Service_Participant::get_type_information(), and OpenDDS::DCPS::Service_Participant::get_type_object().

{ return type_lookup_service_; }

get_unique_id()

OPENDDS_STRING OpenDDS::DCPS::DomainParticipantImpl::get_unique_id

(

void

)

Return a unique string based on repo ID.

Definition at line 1830 of file DomainParticipantImpl.cpp.

References dp_id_, and OpenDDS::DCPS::GuidConverter::uniqueParticipantId().

{
  return GuidConverter(dp_id_).uniqueParticipantId();
}

handle_exception()

int OpenDDS::DCPS::DomainParticipantImpl::handle_exception ( ACE_HANDLE  fd )

privatevirtual

Reimplemented from ACE_Event_Handler.

Definition at line 2455 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, ACE_Thread_Mutex::acquire(), automatic_liveliness_timer_, OpenDDS::DCPS::RecorderImpl::cleanup(), OpenDDS::DCPS::ReplayerImpl::cleanup(), delete_publisher(), delete_subscriber(), delete_topic_i(), OpenDDS::DCPS::ConditionVariable< Mutex >::notify_all(), participant_liveliness_timer_, publishers_, publishers_protector_, recorders_, recorders_protector_, ACE_Thread_Mutex::release(), replayers_, replayers_protector_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, shutdown_complete_, shutdown_condition_, shutdown_mutex_, shutdown_result_, subscribers_, subscribers_protector_, TheServiceParticipant, topics_, and topics_protector_.

Referenced by delete_contained_entities().

{
  ThreadStatusManager::Event ev(TheServiceParticipant->get_thread_status_manager());

  DDS::ReturnCode_t ret = DDS::RETCODE_OK;

  automatic_liveliness_timer_->cancel();
  participant_liveliness_timer_->cancel();

  // delete publishers
  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->publishers_protector_,
                     DDS::RETCODE_ERROR);

    PublisherSet::iterator pubIter = publishers_.begin();
    DDS::Publisher_ptr pubPtr;
    size_t pubsize = publishers_.size();

    while (pubsize > 0) {
      pubPtr = (*pubIter).obj_.in();
      ++pubIter;

      DDS::ReturnCode_t result = pubPtr->delete_contained_entities();
      if (result != DDS::RETCODE_OK) {
        ret = result;
      }

      result = delete_publisher(pubPtr);

      if (result != DDS::RETCODE_OK) {
        ret = result;
      }

      --pubsize;
    }

  }

  // delete subscribers
  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->subscribers_protector_,
                     DDS::RETCODE_ERROR);

    SubscriberSet::iterator subIter = subscribers_.begin();
    DDS::Subscriber_ptr subPtr;
    size_t subsize = subscribers_.size();

    while (subsize > 0) {
      subPtr = (*subIter).obj_.in();
      ++subIter;

      DDS::ReturnCode_t result = subPtr->delete_contained_entities();

      if (result != DDS::RETCODE_OK) {
        ret = result;
      }

      result = delete_subscriber(subPtr);

      if (result != DDS::RETCODE_OK) {
        ret = result;
      }

      --subsize;
    }
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->recorders_protector_,
                     DDS::RETCODE_ERROR);

    RecorderSet::iterator it = recorders_.begin();
    for (; it != recorders_.end(); ++it ){
      RecorderImpl* impl = dynamic_cast<RecorderImpl* >(it->in());
      DDS::ReturnCode_t result = DDS::RETCODE_ERROR;
      if (impl) result = impl->cleanup();
      if (result != DDS::RETCODE_OK) ret = result;
    }
    recorders_.clear();
  }

  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->replayers_protector_,
                     DDS::RETCODE_ERROR);

    ReplayerSet::iterator it = replayers_.begin();
    for (; it != replayers_.end(); ++it ){
      ReplayerImpl* impl = static_cast<ReplayerImpl* >(it->in());
      DDS::ReturnCode_t result = DDS::RETCODE_ERROR;
      if (impl) result = impl->cleanup();
      if (result != DDS::RETCODE_OK) ret = result;

    }

    replayers_.clear();
  }

  // delete topics
  {
    ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                     tao_mon,
                     this->topics_protector_,
                     DDS::RETCODE_ERROR);

    TopicMap::iterator topicIter = topics_.begin();
    DDS::Topic_ptr topicPtr;
    size_t topicsize = topics_.size();

    while (topicsize > 0) {
      topicPtr = topicIter->second.pair_.obj_.in();
      ++topicIter;

      // Delete the topic the reference count.
      const DDS::ReturnCode_t result = this->delete_topic_i(topicPtr, true);

      if (result != DDS::RETCODE_OK) {
        ret = result;
      }
      --topicsize;
    }
  }

  shutdown_mutex_.acquire();
  shutdown_result_ = ret;
  shutdown_complete_ = true;
  shutdown_condition_.notify_all();
  shutdown_mutex_.release();

  return 0;
}

ignore_participant()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::ignore_participant ( DDS::InstanceHandle_t  handle )

virtual

Definition at line 1226 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::DCPS::EntityImpl::enabled_, get_repoid(), ignored_participants_, LM_DEBUG, LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_NOT_ENABLED, DDS::RETCODE_OK, DDS::RETCODE_UNSUPPORTED, and TheServiceParticipant.

{
#ifndef DDS_HAS_MINIMUM_BIT
  if (!enabled_) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_participant, ")
                 ACE_TEXT("Entity is not enabled.\n")));
    }
    return DDS::RETCODE_NOT_ENABLED;
  }

  GUID_t ignoreId = get_repoid(handle);
  HandleMap::const_iterator location = this->ignored_participants_.find(ignoreId);

  if (location == this->ignored_participants_.end()) {
    this->ignored_participants_[ ignoreId] = handle;
  }
  else {// ignore same participant again, just return ok.
    return DDS::RETCODE_OK;
  }

  if (DCPS_debug_level >= 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::ignore_participant: ")
               ACE_TEXT("%C ignoring handle %x.\n"),
               LogGuid(dp_id_).c_str(),
               handle));
  }

  Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
  if (!disco->ignore_domain_participant(domain_id_,
                                        dp_id_,
                                        ignoreId)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_participant, ")
                 ACE_TEXT("Could not ignore domain participant.\n")));
    }
    return DDS::RETCODE_ERROR;
  }


  if (DCPS_debug_level >= 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::ignore_participant: ")
               ACE_TEXT("%C repo call returned.\n"),
               LogGuid(dp_id_).c_str()));
  }

  return DDS::RETCODE_OK;
#else
  ACE_UNUSED_ARG(handle);
  return DDS::RETCODE_UNSUPPORTED;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

ignore_publication()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::ignore_publication ( DDS::InstanceHandle_t  handle )

virtual

Definition at line 1335 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::DCPS::EntityImpl::enabled_, get_repoid(), LM_DEBUG, LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_NOT_ENABLED, DDS::RETCODE_OK, DDS::RETCODE_UNSUPPORTED, and TheServiceParticipant.

{
#ifndef DDS_HAS_MINIMUM_BIT
  if (!enabled_) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_publication, ")
                 ACE_TEXT(" Entity is not enabled.\n")));
    }
    return DDS::RETCODE_NOT_ENABLED;
  }

  if (DCPS_debug_level >= 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::ignore_publication: ")
               ACE_TEXT("%C ignoring handle %x.\n"),
               LogGuid(dp_id_).c_str(),
               handle));
  }

  GUID_t ignoreId = get_repoid(handle);
  Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
  if (!disco->ignore_publication(domain_id_,
                                 dp_id_,
                                 ignoreId)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_publication, ")
                 ACE_TEXT(" could not ignore publication in discovery.\n")));
    }
    return DDS::RETCODE_ERROR;
  }

  return DDS::RETCODE_OK;
#else
  ACE_UNUSED_ARG(handle);
  return DDS::RETCODE_UNSUPPORTED;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

ignore_subscription()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::ignore_subscription ( DDS::InstanceHandle_t  handle )

virtual

Definition at line 1377 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::DCPS::EntityImpl::enabled_, get_repoid(), LM_DEBUG, LM_ERROR, DDS::RETCODE_ERROR, DDS::RETCODE_NOT_ENABLED, DDS::RETCODE_OK, DDS::RETCODE_UNSUPPORTED, and TheServiceParticipant.

{
#ifndef DDS_HAS_MINIMUM_BIT
  if (!enabled_) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_subscription, ")
                 ACE_TEXT(" Entity is not enabled.\n")));
    }
    return DDS::RETCODE_NOT_ENABLED;
  }

  if (DCPS_debug_level >= 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::ignore_subscription: ")
               ACE_TEXT("%C ignoring handle %d.\n"),
               LogGuid(dp_id_).c_str(),
               handle));
  }

  GUID_t ignoreId = get_repoid(handle);
  Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
  if (!disco->ignore_subscription(domain_id_,
                                  dp_id_,
                                  ignoreId)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_subscription, ")
                 ACE_TEXT(" could not ignore subscription in discovery.\n")));
    }
    return DDS::RETCODE_ERROR;
  }

  return DDS::RETCODE_OK;
#else
  ACE_UNUSED_ARG(handle);
  return DDS::RETCODE_UNSUPPORTED;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

ignore_topic()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::ignore_topic ( DDS::InstanceHandle_t  handle )

virtual

Definition at line 1285 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::DCPS::EntityImpl::enabled_, get_repoid(), ignored_topics_, LM_DEBUG, LM_ERROR, DDS::RETCODE_NOT_ENABLED, DDS::RETCODE_OK, DDS::RETCODE_UNSUPPORTED, and TheServiceParticipant.

{
#ifndef DDS_HAS_MINIMUM_BIT
  if (!enabled_) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_topic, ")
                 ACE_TEXT(" Entity is not enabled.\n")));
    }
    return DDS::RETCODE_NOT_ENABLED;
  }

  GUID_t ignoreId = get_repoid(handle);
  HandleMap::const_iterator location = this->ignored_topics_.find(ignoreId);

  if (location == this->ignored_topics_.end()) {
    this->ignored_topics_[ ignoreId] = handle;
  }
  else { // ignore same topic again, just return ok.
    return DDS::RETCODE_OK;
  }

  if (DCPS_debug_level >= 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) DomainParticipantImpl::ignore_topic: ")
               ACE_TEXT("%C ignoring handle %x.\n"),
               LogGuid(dp_id_).c_str(),
               handle));
  }

  Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id_);
  if (!disco->ignore_topic(domain_id_,
                           dp_id_,
                           ignoreId)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: DomainParticipantImpl::ignore_topic, ")
                 ACE_TEXT(" Could not ignore topic.\n")));
    }
  }

  return DDS::RETCODE_OK;
#else
  ACE_UNUSED_ARG(handle);
  return DDS::RETCODE_UNSUPPORTED;
#endif // !defined (DDS_HAS_MINIMUM_BIT)
}

is_clean()

bool OpenDDS::DCPS::DomainParticipantImpl::is_clean

(

String *

leftover_entities = 0

)

const

Check to see if the Participant has any entities left in it. leftover_entities will be set with a description of what is left.

Definition at line 2026 of file DomainParticipantImpl.cpp.

References publishers_, subscribers_, TheTransientKludge, OpenDDS::DCPS::to_dds_string(), OpenDDS::DCPS::topicIsBIT(), and topics_.

Referenced by OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant().

{
  if (leftover_entities) {
    leftover_entities->clear();
  }

  // check that the only remaining topics are built-in topics
  size_t topic_count = 0;
  for (TopicMap::const_iterator it = topics_.begin(); it != topics_.end(); ++it) {
    if (!topicIsBIT(it->second.pair_.svt_->topic_name(), it->second.pair_.svt_->type_name())) {
      ++topic_count;
    }
  }
  if (topic_count) {
    *leftover_entities += to_dds_string(topic_count) + " topic(s)";
  }

  size_t sub_count = subscribers_.size();
  if (!TheTransientKludge->is_enabled()) {
    // There are built-in topics and built-in topic subscribers left.
    sub_count = sub_count <= 1 ? 0 : sub_count;
  }
  if (leftover_entities && sub_count) {
    if (leftover_entities->size()) {
      *leftover_entities += ", ";
    }
    *leftover_entities += to_dds_string(sub_count) + " subscriber(s)";
  }

  const size_t pub_count = publishers_.size();
  if (leftover_entities && pub_count) {
    if (leftover_entities->size()) {
      *leftover_entities += ", ";
    }
    *leftover_entities += to_dds_string(pub_count) + " publisher(s)";
  }

  return topic_count == 0 && sub_count == 0 && pub_count == 0;
}

listener_for()

DDS::DomainParticipantListener_ptr OpenDDS::DCPS::DomainParticipantImpl::listener_for

(

DDS::StatusKind

kind

)

This is used to retrieve the listener for a certain status change. If this DomainParticipant has a registered listener and the status kind is in the listener mask then the listener is returned. Otherwise, return nil.

Definition at line 2067 of file DomainParticipantImpl.cpp.

References CORBA::is_nil(), listener_, listener_mask_, and listener_mutex_.

Referenced by OpenDDS::DCPS::TopicImpl::inconsistent_topic().

{
  ACE_Guard<ACE_Thread_Mutex> g(listener_mutex_);
  if (CORBA::is_nil(listener_.in()) || (listener_mask_ & kind) == 0) {
    return DDS::DomainParticipantListener::_nil ();
  } else {
    return DDS::DomainParticipantListener::_duplicate(listener_.in());
  }
}

liveliness_check_interval()

TimeDuration OpenDDS::DCPS::DomainParticipantImpl::liveliness_check_interval ( DDS::LivelinessQosPolicyKind  kind )

private

Definition at line 2413 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::TimeDuration::max_value, publishers_, and publishers_protector_.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::LivelinessTimer::execute().

{
  TimeDuration tv(TimeDuration::max_value);

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   publishers_protector_,
                   tv);

  for (PublisherSet::iterator it = publishers_.begin(); it != publishers_.end(); ++it) {
    tv = std::min(tv, it->svt_->liveliness_check_interval(kind));
  }

  return tv;
}

lookup_handle()

DDS::InstanceHandle_t OpenDDS::DCPS::DomainParticipantImpl::lookup_handle

(

const GUID_t &

id

)

const

Get a handle that was previously mapped to a GUID or HANDLE_NIL if none exists.

Handles returned from this method should not be passed to return_handle.

Definition at line 1895 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, DDS::HANDLE_NIL, handle_protector_, and handles_.

Referenced by OpenDDS::DCPS::RecorderImpl::lookup_instance_handles(), OpenDDS::DCPS::ReplayerImpl::lookup_instance_handles(), and OpenDDS::DCPS::RecorderImpl::repoid_to_bit_key().

{
  ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, handle_protector_, DDS::HANDLE_NIL);
  const CountedHandleMap::const_iterator iter = handles_.find(id);
  return iter == handles_.end() ? DDS::HANDLE_NIL : iter->second.first;
}

lookup_topicdescription()

DDS::TopicDescription_ptr OpenDDS::DCPS::DomainParticipantImpl::lookup_topicdescription ( const char *  name )

virtual

Definition at line 787 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, Util::find(), topic_descrs_, topics_, and topics_protector_.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::init_bit(), OpenDDS::RTPS::RtpsDiscovery::init_bit(), and OpenDDS::DCPS::StaticDiscovery::init_bit().

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                   tao_mon,
                   this->topics_protector_,
                   DDS::Topic::_nil());

  TopicMap::mapped_type* entry = 0;

  if (Util::find(topics_, name, entry) == -1) {
#if !defined(OPENDDS_NO_CONTENT_FILTERED_TOPIC) || !defined(OPENDDS_NO_MULTI_TOPIC)
    TopicDescriptionMap::iterator iter = topic_descrs_.find(name);
    if (iter != topic_descrs_.end()) {
      return DDS::TopicDescription::_duplicate(iter->second);
    }
#endif
    return DDS::TopicDescription::_nil();

  } else {
    return DDS::TopicDescription::_duplicate(entry->pair_.obj_.in());
  }
}

OPENDDS_MAP() [1/3]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MAP	(	OPENDDS_STRING	,
		DDS::TopicDescription_var
	)

OPENDDS_MAP() [2/3]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MAP ( DDS::InstanceHandle_t  , GUID_t    )

private

OPENDDS_MAP() [3/3]

OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MAP ( OPENDDS_STRING  , RcHandle< FilterEvaluator >    )

private

OPENDDS_MAP_CMP() [1/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MAP_CMP ( GUID_t  , HandleWithCounter  , GUID_tKeyLessThan    )

private

OPENDDS_MAP_CMP() [2/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MAP_CMP ( GUID_t  , DDS::InstanceHandle_t  , GUID_tKeyLessThan    )

private

OPENDDS_MULTIMAP()

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_MULTIMAP	(	OPENDDS_STRING	,
		RefCounted_Topic
	)

OPENDDS_SET() [1/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_SET

(

Subscriber_Pair

)

OPENDDS_SET() [2/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_SET

(

Publisher_Pair

)

OPENDDS_SET_CMP() [1/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_SET_CMP ( Recorder_var  , VarLess< Recorder >    )

private

OPENDDS_SET_CMP() [2/2]

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_SET_CMP ( Replayer_var  , VarLess< Replayer >    )

private

OPENDDS_VECTOR()

typedef OpenDDS::DCPS::DomainParticipantImpl::OPENDDS_VECTOR

(

GUID_t

)

ownership_manager()

OwnershipManager * OpenDDS::DCPS::DomainParticipantImpl::ownership_manager

(

)

Accessor for ownership manager.

Definition at line 2094 of file DomainParticipantImpl.cpp.

References ACE_ERROR, bit_subscriber_, LM_WARNING, OpenDDS::DCPS::log_level, owner_man_, and OpenDDS::DCPS::LogLevel::Warning.

Referenced by OpenDDS::DCPS::RecorderImpl::init().

{
#if !defined (DDS_HAS_MINIMUM_BIT)
  if (bit_subscriber_) {
    bit_subscriber_->bit_pub_listener_hack(this);
  } else {
    if (log_level >= LogLevel::Warning) {
      ACE_ERROR((LM_WARNING,
                 "(%P|%t) WARNING: DomainParticipantImpl::ownership_manager: bit_subscriber_ is null"));
    }
  }
#endif
  return &owner_man_;
}

participant_liveliness_activity_after()

bool OpenDDS::DCPS::DomainParticipantImpl::participant_liveliness_activity_after ( const MonotonicTimePoint &  tv )

private

Definition at line 2430 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::TimePoint_T< AceClock >::is_zero(), last_liveliness_activity_, publishers_, and publishers_protector_.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer::dispatch().

{
  if (last_liveliness_activity_ > tv) {
    return true;
  }

  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, tao_mon, this->publishers_protector_, !tv.is_zero());

  for (PublisherSet::iterator it(publishers_.begin());
       it != publishers_.end(); ++it) {
    if (it->svt_->participant_liveliness_activity_after(tv)) {
      return true;
    }
  }

  return false;
}

permissions_handle()

DDS::Security::PermissionsHandle OpenDDS::DCPS::DomainParticipantImpl::permissions_handle ( ) const

inline

Definition at line 409 of file DomainParticipantImpl.h.

  {
    return perm_handle_;
  }

prepare_to_delete_datawriters()

bool OpenDDS::DCPS::DomainParticipantImpl::prepare_to_delete_datawriters

(

)

Definition at line 2594 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, publishers_, and publishers_protector_.

Referenced by delete_contained_entities().

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, publishers_protector_, false);
  bool result = true;
  const PublisherSet::iterator end = publishers_.end();
  for (PublisherSet::iterator i = publishers_.begin(); i != end; ++i) {
    result &= i->svt_->prepare_to_delete_datawriters();
  }
  return result;
}

remove_adjust_liveliness_timers()

void OpenDDS::DCPS::DomainParticipantImpl::remove_adjust_liveliness_timers

(

)

Definition at line 2314 of file DomainParticipantImpl.cpp.

References automatic_liveliness_timer_, and participant_liveliness_timer_.

{
  automatic_liveliness_timer_->remove_adjust();
  participant_liveliness_timer_->remove_adjust();
}

return_handle()

void OpenDDS::DCPS::DomainParticipantImpl::return_handle

(

DDS::InstanceHandle_t

handle

)

Return a previously-assigned handle.

Definition at line 1902 of file DomainParticipantImpl.cpp.

References ACE_DEBUG, ACE_GUARD, OpenDDS::DCPS::DisjointSequence::OrderedRanges< T >::add(), OpenDDS::DCPS::DCPS_debug_level, handle_protector_, handles_, LM_DEBUG, repoIds_, and reusable_handles_.

Referenced by OpenDDS::DCPS::ReplayerImpl::remove_associations(), and OpenDDS::DCPS::RecorderImpl::remove_associations_i().

{
  ACE_GUARD(ACE_Thread_Mutex, guard, handle_protector_);
  const RepoIdMap::iterator r_iter = repoIds_.find(handle);
  if (r_iter == repoIds_.end()) {
    reusable_handles_.add(handle);
    if (DCPS_debug_level > 5) {
      ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::return_handle: "
                 "Returned unmapped InstanceHandle %d\n", handle));
    }
    return;
  }

  const CountedHandleMap::iterator h_iter = handles_.find(r_iter->second);
  if (h_iter == handles_.end()) {
    return;
  }

  if (DCPS_debug_level > 5) {
    ACE_DEBUG((LM_DEBUG, "(%P|%t) DomainParticipantImpl::return_handle: "
               "Returned mapped InstanceHandle %d refcount %d\n",
               handle, h_iter->second.second));
  }

  HandleWithCounter& mapped = h_iter->second;
  if (--mapped.second == 0) {
    handles_.erase(h_iter);
    repoIds_.erase(r_iter);
    reusable_handles_.add(handle);
  }
}

set_default_publisher_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::set_default_publisher_qos ( const DDS::PublisherQos &  qos )

virtual

Definition at line 1451 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::Qos_Helper::consistent(), default_publisher_qos_, DDS::RETCODE_INCONSISTENT_POLICY, DDS::RETCODE_OK, and OpenDDS::DCPS::Qos_Helper::valid().

{
  if (Qos_Helper::valid(qos) && Qos_Helper::consistent(qos)) {
    default_publisher_qos_ = qos;
    return DDS::RETCODE_OK;

  } else {
    return DDS::RETCODE_INCONSISTENT_POLICY;
  }
}

set_default_subscriber_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::set_default_subscriber_qos ( const DDS::SubscriberQos &  qos )

virtual

Definition at line 1472 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::Qos_Helper::consistent(), default_subscriber_qos_, DDS::RETCODE_INCONSISTENT_POLICY, DDS::RETCODE_OK, and OpenDDS::DCPS::Qos_Helper::valid().

{
  if (Qos_Helper::valid(qos) && Qos_Helper::consistent(qos)) {
    default_subscriber_qos_ = qos;
    return DDS::RETCODE_OK;

  } else {
    return DDS::RETCODE_INCONSISTENT_POLICY;
  }
}

set_default_topic_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::set_default_topic_qos ( const DDS::TopicQos &  qos )

virtual

Definition at line 1493 of file DomainParticipantImpl.cpp.

References OpenDDS::DCPS::Qos_Helper::consistent(), default_topic_qos_, DDS::RETCODE_INCONSISTENT_POLICY, DDS::RETCODE_OK, and OpenDDS::DCPS::Qos_Helper::valid().

{
  if (Qos_Helper::valid(qos) && Qos_Helper::consistent(qos)) {
    default_topic_qos_ = qos;
    return DDS::RETCODE_OK;

  } else {
    return DDS::RETCODE_INCONSISTENT_POLICY;
  }
}

set_listener()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::set_listener ( DDS::DomainParticipantListener_ptr  a_listener, DDS::StatusMask  mask  )

virtual

Definition at line 1207 of file DomainParticipantImpl.cpp.

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

Referenced by DomainParticipantImpl().

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

set_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::set_qos ( const DDS::DomainParticipantQos &  qos )

virtual

Definition at line 1161 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::Qos_Helper::changeable(), OpenDDS::DCPS::Qos_Helper::consistent(), OpenDDS::DCPS::DCPS_debug_level, domain_id_, dp_id_, OpenDDS::DCPS::EntityImpl::enabled_, LM_ERROR, qos_, DDS::RETCODE_ERROR, DDS::RETCODE_IMMUTABLE_POLICY, DDS::RETCODE_INCONSISTENT_POLICY, DDS::RETCODE_OK, TheServiceParticipant, and OpenDDS::DCPS::Qos_Helper::valid().

{
  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(domain_id_);
      const bool status =
        disco->update_domain_participant_qos(domain_id_,
                                             dp_id_,
                                             qos_);

      if (!status) {
        if (DCPS_debug_level > 0) {
          ACE_ERROR((LM_ERROR,
                     ACE_TEXT("(%P|%t) DomainParticipantImpl::set_qos, ")
                     ACE_TEXT("failed on compatibility check.\n")));
        }
        return DDS::RETCODE_ERROR;
      }
    }

    return DDS::RETCODE_OK;

  } else {
    return DDS::RETCODE_INCONSISTENT_POLICY;
  }
}

set_wait_pending_deadline()

bool OpenDDS::DCPS::DomainParticipantImpl::set_wait_pending_deadline

(

const MonotonicTimePoint &

deadline

)

Definition at line 2605 of file DomainParticipantImpl.cpp.

References ACE_GUARD_RETURN, publishers_, and publishers_protector_.

Referenced by delete_contained_entities().

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, publishers_protector_, false);
  bool result = true;
  const PublisherSet::iterator end = publishers_.end();
  for (PublisherSet::iterator i = publishers_.begin(); i != end; ++i) {
    result &= i->svt_->set_wait_pending_deadline(deadline);
  }
  return result;
}

signal_liveliness()

void OpenDDS::DCPS::DomainParticipantImpl::signal_liveliness ( DDS::LivelinessQosPolicyKind  kind )

private

Definition at line 2449 of file DomainParticipantImpl.cpp.

References domain_id_, get_id(), and TheServiceParticipant.

Referenced by OpenDDS::DCPS::DomainParticipantImpl::AutomaticLivelinessTimer::dispatch(), and OpenDDS::DCPS::DomainParticipantImpl::ParticipantLivelinessTimer::dispatch().

{
  TheServiceParticipant->get_discovery(domain_id_)->signal_liveliness (domain_id_, get_id(), kind);
}

update_ownership_strength()

void OpenDDS::DCPS::DomainParticipantImpl::update_ownership_strength	(	const GUID_t &	pub_id,
		const CORBA::Long &	ownership_strength
	)

Called upon receiving new BIT publication data to update the ownership strength of a publication.

Definition at line 2110 of file DomainParticipantImpl.cpp.

References ACE_GUARD, OpenDDS::DCPS::EntityImpl::get_deleted(), subscribers_, and subscribers_protector_.

Referenced by OpenDDS::DCPS::BitPubListenerImpl::on_data_available().

{
  ACE_GUARD(ACE_Recursive_Thread_Mutex,
            tao_mon,
            this->subscribers_protector_);

  if (this->get_deleted ())
    return;

  for (SubscriberSet::iterator it(this->subscribers_.begin());
      it != this->subscribers_.end(); ++it) {
    it->svt_->update_ownership_strength(pub_id, ownership_strength);
  }
}

validate_publisher_qos()

bool OpenDDS::DCPS::DomainParticipantImpl::validate_publisher_qos ( DDS::PublisherQos &  publisher_qos )

private

Definition at line 2147 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::Qos_Helper::consistent(), OpenDDS::DCPS::DCPS_debug_level, get_default_publisher_qos(), LM_ERROR, OPENDDS_NO_OBJECT_MODEL_PROFILE_COMPATIBILITY_CHECK, PUBLISHER_QOS_DEFAULT, and OpenDDS::DCPS::Qos_Helper::valid().

Referenced by create_publisher(), and create_replayer().

{
  if (pub_qos == PUBLISHER_QOS_DEFAULT) {
    this->get_default_publisher_qos(pub_qos);
  }

  OPENDDS_NO_OBJECT_MODEL_PROFILE_COMPATIBILITY_CHECK(pub_qos, false);

  if (!Qos_Helper::valid(pub_qos) || !Qos_Helper::consistent(pub_qos)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::validate_publisher_qos, ")
                 ACE_TEXT("invalid qos.\n")));
    }
    return false;
  }

  return true;
}

validate_subscriber_qos()

bool OpenDDS::DCPS::DomainParticipantImpl::validate_subscriber_qos ( DDS::SubscriberQos &  subscriber_qos )

private

Definition at line 2169 of file DomainParticipantImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::Qos_Helper::consistent(), OpenDDS::DCPS::DCPS_debug_level, get_default_subscriber_qos(), LM_ERROR, OPENDDS_NO_OBJECT_MODEL_PROFILE_COMPATIBILITY_CHECK, SUBSCRIBER_QOS_DEFAULT, and OpenDDS::DCPS::Qos_Helper::valid().

Referenced by create_recorder(), and create_subscriber().

{
  if (subscriber_qos == SUBSCRIBER_QOS_DEFAULT) {
    this->get_default_subscriber_qos(subscriber_qos);
  }

  OPENDDS_NO_OBJECT_MODEL_PROFILE_COMPATIBILITY_CHECK(subscriber_qos, false);

  if (!Qos_Helper::valid(subscriber_qos) || !Qos_Helper::consistent(subscriber_qos)) {
    if (DCPS_debug_level > 0) {
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantImpl::validate_subscriber_qos, ")
                 ACE_TEXT("invalid qos.\n")));
    }
    return false;
  }


  return true;
}

Member Data Documentation

automatic_liveliness_task_

RcHandle<AutomaticLivelinessTask> OpenDDS::DCPS::DomainParticipantImpl::automatic_liveliness_task_

private

Definition at line 623 of file DomainParticipantImpl.h.

automatic_liveliness_timer_

RcHandle<AutomaticLivelinessTimer> OpenDDS::DCPS::DomainParticipantImpl::automatic_liveliness_timer_

private

Definition at line 621 of file DomainParticipantImpl.h.

Referenced by add_adjust_liveliness_timers(), handle_exception(), and remove_adjust_liveliness_timers().

bit_subscriber_

RcHandle<BitSubscriber> OpenDDS::DCPS::DomainParticipantImpl::bit_subscriber_

private

The built in topic subscriber.

Definition at line 542 of file DomainParticipantImpl.h.

Referenced by delete_contained_entities(), enable(), get_builtin_subscriber(), get_builtin_subscriber_proxy(), get_discovered_participant_data(), get_discovered_topic_data(), and ownership_manager().

default_publisher_qos_

DDS::PublisherQos OpenDDS::DCPS::DomainParticipantImpl::default_publisher_qos_

private

The default publisher qos.

Definition at line 466 of file DomainParticipantImpl.h.

Referenced by get_default_publisher_qos(), and set_default_publisher_qos().

default_subscriber_qos_

DDS::SubscriberQos OpenDDS::DCPS::DomainParticipantImpl::default_subscriber_qos_

private

The default subscriber qos.

Definition at line 468 of file DomainParticipantImpl.h.

Referenced by get_default_subscriber_qos(), and set_default_subscriber_qos().

default_topic_qos_

DDS::TopicQos OpenDDS::DCPS::DomainParticipantImpl::default_topic_qos_

private

The default topic qos.

Definition at line 464 of file DomainParticipantImpl.h.

Referenced by get_default_topic_qos(), and set_default_topic_qos().

domain_id_

const DDS::DomainId_t OpenDDS::DCPS::DomainParticipantImpl::domain_id_

private

The id of the domain that creates this participant.

Definition at line 490 of file DomainParticipantImpl.h.

Referenced by create_new_topic(), delete_contained_entities(), delete_topic_i(), enable(), find_topic(), get_domain_id(), get_dynamic_type(), ignore_participant(), ignore_publication(), ignore_subscription(), ignore_topic(), set_qos(), and signal_liveliness().

dp_id_

GUID_t OpenDDS::DCPS::DomainParticipantImpl::dp_id_

private

This participant id given by discovery.

Definition at line 492 of file DomainParticipantImpl.h.

Referenced by enable(), get_discovered_participants(), get_dynamic_type(), get_id(), get_instance_handle(), get_unique_id(), ignore_participant(), ignore_publication(), ignore_subscription(), ignore_topic(), and set_qos().

federated_

bool OpenDDS::DCPS::DomainParticipantImpl::federated_

private

Whether this DomainParticipant is attached to a federated repository.

Definition at line 496 of file DomainParticipantImpl.h.

Referenced by enable().

filter_cache_lock_

ACE_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::filter_cache_lock_

private

Definition at line 560 of file DomainParticipantImpl.h.

Referenced by deref_filter_eval(), and get_filter_eval().

handle_protector_

ACE_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::handle_protector_

mutableprivate

Protect the handle collection.

Definition at line 531 of file DomainParticipantImpl.h.

Referenced by assign_handle(), await_handle(), get_discovered_participant_data(), get_discovered_participants(), get_discovered_topic_data(), get_discovered_topics(), get_repoid(), lookup_handle(), and return_handle().

handle_waiters_

ConditionVariable<ACE_Thread_Mutex> OpenDDS::DCPS::DomainParticipantImpl::handle_waiters_

mutableprivate

Definition at line 533 of file DomainParticipantImpl.h.

Referenced by assign_handle(), and await_handle().

handles_

CountedHandleMap OpenDDS::DCPS::DomainParticipantImpl::handles_

private

Instance handles assigned which are mapped to GUIDs (use handle_protector_)

Definition at line 514 of file DomainParticipantImpl.h.

Referenced by assign_handle(), await_handle(), get_discovered_participant_data(), get_discovered_participants(), get_discovered_topic_data(), get_discovered_topics(), lookup_handle(), and return_handle().

id_handle_

DDS::Security::IdentityHandle OpenDDS::DCPS::DomainParticipantImpl::id_handle_

private

This participant id handle given by authentication.

Definition at line 482 of file DomainParticipantImpl.h.

Referenced by enable().

ignored_participants_

HandleMap OpenDDS::DCPS::DomainParticipantImpl::ignored_participants_

private

Collection of ignored participants.

Definition at line 521 of file DomainParticipantImpl.h.

Referenced by get_discovered_participants(), and ignore_participant().

ignored_topics_

HandleMap OpenDDS::DCPS::DomainParticipantImpl::ignored_topics_

private

Collection of ignored topics.

Definition at line 523 of file DomainParticipantImpl.h.

Referenced by get_discovered_topics(), and ignore_topic().

last_liveliness_activity_

MonotonicTimePoint OpenDDS::DCPS::DomainParticipantImpl::last_liveliness_activity_

private

Definition at line 649 of file DomainParticipantImpl.h.

Referenced by assert_liveliness(), and participant_liveliness_activity_after().

listener_

DDS::DomainParticipantListener_var OpenDDS::DCPS::DomainParticipantImpl::listener_

private

Used to notify the entity for relevant events.

Definition at line 475 of file DomainParticipantImpl.h.

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

listener_mask_

DDS::StatusMask OpenDDS::DCPS::DomainParticipantImpl::listener_mask_

private

The StatusKind bit mask indicates which status condition change can be notified by the listener of this entity.

Definition at line 478 of file DomainParticipantImpl.h.

Referenced by listener_for(), and set_listener().

listener_mutex_

ACE_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::listener_mutex_

private

Mutex to protect listener info.

Definition at line 473 of file DomainParticipantImpl.h.

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

monitor_

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

private

Definition at line 550 of file DomainParticipantImpl.h.

Referenced by create_new_topic(), DomainParticipantImpl(), and enable().

owner_man_

OwnershipManager OpenDDS::DCPS::DomainParticipantImpl::owner_man_

private

Definition at line 553 of file DomainParticipantImpl.h.

Referenced by ownership_manager().

part_crypto_handle_

DDS::Security::ParticipantCryptoHandle OpenDDS::DCPS::DomainParticipantImpl::part_crypto_handle_

private

This participant crypto handle given by crypto.

Definition at line 486 of file DomainParticipantImpl.h.

Referenced by enable().

participant_handles_

InstanceHandleGenerator& OpenDDS::DCPS::DomainParticipantImpl::participant_handles_

private

Get instances handles from DomainParticipantFactory (use handle_protector_)

Definition at line 545 of file DomainParticipantImpl.h.

Referenced by assign_handle().

participant_liveliness_task_

RcHandle<ParticipantLivelinessTask> OpenDDS::DCPS::DomainParticipantImpl::participant_liveliness_task_

private

Definition at line 643 of file DomainParticipantImpl.h.

participant_liveliness_timer_

RcHandle<ParticipantLivelinessTimer> OpenDDS::DCPS::DomainParticipantImpl::participant_liveliness_timer_

private

Definition at line 641 of file DomainParticipantImpl.h.

Referenced by add_adjust_liveliness_timers(), handle_exception(), and remove_adjust_liveliness_timers().

perm_handle_

DDS::Security::PermissionsHandle OpenDDS::DCPS::DomainParticipantImpl::perm_handle_

private

This participant permissions handle given by access constrol.

Definition at line 484 of file DomainParticipantImpl.h.

Referenced by create_new_topic(), enable(), and ~DomainParticipantImpl().

pub_id_gen_

RepoIdSequence OpenDDS::DCPS::DomainParticipantImpl::pub_id_gen_

private

Publisher ID generator.

Definition at line 557 of file DomainParticipantImpl.h.

Referenced by create_publisher().

publishers_

PublisherSet OpenDDS::DCPS::DomainParticipantImpl::publishers_

private

Collection of publishers.

Definition at line 499 of file DomainParticipantImpl.h.

Referenced by assert_liveliness(), contains_entity(), create_publisher(), delete_publisher(), enable(), handle_exception(), is_clean(), liveliness_check_interval(), participant_liveliness_activity_after(), prepare_to_delete_datawriters(), and set_wait_pending_deadline().

publishers_protector_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::publishers_protector_

private

Protect the publisher collection.

Definition at line 525 of file DomainParticipantImpl.h.

Referenced by assert_liveliness(), contains_entity(), create_publisher(), delete_publisher(), handle_exception(), liveliness_check_interval(), participant_liveliness_activity_after(), prepare_to_delete_datawriters(), and set_wait_pending_deadline().

qos_

DDS::DomainParticipantQos OpenDDS::DCPS::DomainParticipantImpl::qos_

private

The qos of this DomainParticipant.

Definition at line 471 of file DomainParticipantImpl.h.

Referenced by create_new_topic(), create_publisher(), create_recorder(), create_replayer(), create_subscriber(), create_topic_i(), enable(), get_qos(), and set_qos().

recorders_

RecorderSet OpenDDS::DCPS::DomainParticipantImpl::recorders_

private

Definition at line 567 of file DomainParticipantImpl.h.

Referenced by create_recorder(), delete_recorder(), and handle_exception().

recorders_protector_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::recorders_protector_

private

Protect the recorders collection.

Definition at line 575 of file DomainParticipantImpl.h.

Referenced by create_recorder(), delete_recorder(), and handle_exception().

replayers_

ReplayerSet OpenDDS::DCPS::DomainParticipantImpl::replayers_

private

Definition at line 568 of file DomainParticipantImpl.h.

Referenced by create_replayer(), delete_replayer(), and handle_exception().

replayers_protector_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::replayers_protector_

private

Protect the replayers collection.

Definition at line 577 of file DomainParticipantImpl.h.

Referenced by create_replayer(), delete_replayer(), and handle_exception().

repoIds_

RepoIdMap OpenDDS::DCPS::DomainParticipantImpl::repoIds_

private

By-handle lookup of instance handles assigned to GUIDs (use handle_protector_)

Definition at line 516 of file DomainParticipantImpl.h.

Referenced by assign_handle(), get_repoid(), and return_handle().

reusable_handles_

DisjointSequence::OrderedRanges<DDS::InstanceHandle_t> OpenDDS::DCPS::DomainParticipantImpl::reusable_handles_

private

Keep track of handles that can be reused (use handle_protector_)

Definition at line 548 of file DomainParticipantImpl.h.

Referenced by assign_handle(), and return_handle().

security_config_

Security::SecurityConfig_rch OpenDDS::DCPS::DomainParticipantImpl::security_config_

private

Definition at line 571 of file DomainParticipantImpl.h.

Referenced by create_new_topic(), enable(), and ~DomainParticipantImpl().

shutdown_complete_

bool OpenDDS::DCPS::DomainParticipantImpl::shutdown_complete_

private

Definition at line 539 of file DomainParticipantImpl.h.

Referenced by delete_contained_entities(), and handle_exception().

shutdown_condition_

ConditionVariable<ACE_Thread_Mutex> OpenDDS::DCPS::DomainParticipantImpl::shutdown_condition_

private

Definition at line 537 of file DomainParticipantImpl.h.

Referenced by delete_contained_entities(), and handle_exception().

shutdown_mutex_

ACE_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::shutdown_mutex_

private

Protect the shutdown.

Definition at line 536 of file DomainParticipantImpl.h.

Referenced by delete_contained_entities(), and handle_exception().

shutdown_result_

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantImpl::shutdown_result_

private

Definition at line 538 of file DomainParticipantImpl.h.

Referenced by delete_contained_entities(), and handle_exception().

subscribers_

SubscriberSet OpenDDS::DCPS::DomainParticipantImpl::subscribers_

private

Collection of subscribers.

Definition at line 501 of file DomainParticipantImpl.h.

Referenced by contains_entity(), create_subscriber(), delete_subscriber(), enable(), handle_exception(), is_clean(), and update_ownership_strength().

subscribers_protector_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::subscribers_protector_

private

Protect the subscriber collection.

Definition at line 527 of file DomainParticipantImpl.h.

Referenced by contains_entity(), create_subscriber(), delete_subscriber(), handle_exception(), and update_ownership_strength().

topic_descrs_

TopicDescriptionMap OpenDDS::DCPS::DomainParticipantImpl::topic_descrs_

private

Collection of TopicDescriptions which are not also Topics.

Definition at line 506 of file DomainParticipantImpl.h.

Referenced by create_contentfilteredtopic(), create_multitopic(), create_topic_i(), delete_contentfilteredtopic(), delete_multitopic(), and lookup_topicdescription().

TOPIC_TYPE_HAS_KEYS

const int OpenDDS::DCPS::DomainParticipantImpl::TOPIC_TYPE_HAS_KEYS = 1

staticprivate

The implementation of create_topic.{@ constants for the topic_mask argument to create_topic_i

Definition at line 436 of file DomainParticipantImpl.h.

Referenced by create_typeless_topic().

TOPIC_TYPELESS

const int OpenDDS::DCPS::DomainParticipantImpl::TOPIC_TYPELESS = 2

staticprivate

Definition at line 437 of file DomainParticipantImpl.h.

Referenced by create_typeless_topic().

topics_

TopicMap OpenDDS::DCPS::DomainParticipantImpl::topics_

private

Collection of topics.

Definition at line 503 of file DomainParticipantImpl.h.

Referenced by contains_entity(), create_contentfilteredtopic(), create_multitopic(), create_new_topic(), create_topic_i(), delete_topic_i(), enable(), get_topic_ids(), handle_exception(), is_clean(), and lookup_topicdescription().

topics_protector_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::DomainParticipantImpl::topics_protector_

private

Protect the topic collection.

Definition at line 529 of file DomainParticipantImpl.h.

Referenced by contains_entity(), create_contentfilteredtopic(), create_multitopic(), create_new_topic(), create_topic_i(), delete_contentfilteredtopic(), delete_multitopic(), delete_topic_i(), get_topic_ids(), handle_exception(), and lookup_topicdescription().

type_lookup_service_

XTypes::TypeLookupService_rch OpenDDS::DCPS::DomainParticipantImpl::type_lookup_service_

private

Definition at line 653 of file DomainParticipantImpl.h.

Referenced by DomainParticipantImpl(), enable(), and get_dynamic_type().

---

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

• DomainParticipantImpl.h
• DomainParticipantImpl.cpp