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

#include <DomainParticipantFactoryImpl.h>

Inheritance diagram for OpenDDS::DCPS::DomainParticipantFactoryImpl:

[legend]

Collaboration diagram for OpenDDS::DCPS::DomainParticipantFactoryImpl:

[legend]

Public Member Functions
typedef	OPENDDS_SET (RcHandle< DomainParticipantImpl >) DPSet

typedef	OPENDDS_MAP (DDS::DomainId_t, DPSet) DPMap

	DomainParticipantFactoryImpl ()

virtual	~DomainParticipantFactoryImpl ()

virtual DDS::DomainParticipant_ptr	create_participant (DDS::DomainId_t domainId, const DDS::DomainParticipantQos &qos, DDS::DomainParticipantListener_ptr a_listener, DDS::StatusMask mask)

virtual DDS::ReturnCode_t	delete_participant (DDS::DomainParticipant_ptr a_participant)

virtual DDS::DomainParticipant_ptr	lookup_participant (DDS::DomainId_t domainId)

virtual DDS::ReturnCode_t	set_default_participant_qos (const DDS::DomainParticipantQos &qos)

virtual DDS::ReturnCode_t	get_default_participant_qos (DDS::DomainParticipantQos &qos)

virtual DDS::DomainParticipantFactory_ptr	get_instance ()

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

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

DPMap	participants () const
	Make a copy of the participants map for reading. More...

DDS::ReturnCode_t	delete_all_participants ()

size_t	participant_count () const

Public Member Functions inherited from DDS::DomainParticipantFactory
DomainParticipant	create_participant (in DomainId_t domainId, in DomainParticipantQos qos, in DomainParticipantListener a_listener, in StatusMask mask)

ReturnCode_t	delete_participant (in DomainParticipant a_participant)

DomainParticipant	lookup_participant (in DomainId_t domainId)

ReturnCode_t	set_default_participant_qos (in DomainParticipantQos qos)

ReturnCode_t	get_default_participant_qos (inout DomainParticipantQos qos)

ReturnCode_t	set_qos (in DomainParticipantFactoryQos qos)

ReturnCode_t	get_qos (inout DomainParticipantFactoryQos qos)

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

Private Attributes
DDS::DomainParticipantFactoryQos	qos_

DDS::DomainParticipantQos	default_participant_qos_
	The default qos value of DomainParticipant. More...

DPMap	participants_
	The collection of domain participants. More...

ACE_Recursive_Thread_Mutex	participants_protector_
	Protect the participant collection. More...

InstanceHandleGenerator	participant_handles_

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

typedef DDS::DomainParticipantFactory ::_var_type	_var_type

Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr	_ptr_type

typedef LocalObject_var	_var_type

typedef LocalObject_out	_out_type

Public Types inherited from CORBA::Object
typedef Object_ptr	_ptr_type

typedef Object_var	_var_type

typedef Object_out	_out_type

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DDS::DomainParticipantFactory >
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)

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

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

TAO::Object_Proxy_Broker *	proxy_broker () const

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

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

Detailed Description

Implements the OpenDDS::DCPS::DomainParticipantFactory interfaces.

This class acts as factory of the DomainParticipant.

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

Definition at line 41 of file DomainParticipantFactoryImpl.h.

Constructor & Destructor Documentation

◆ DomainParticipantFactoryImpl()

OpenDDS::DCPS::DomainParticipantFactoryImpl::DomainParticipantFactoryImpl ( )

Definition at line 26 of file DomainParticipantFactoryImpl.cpp.

   : qos_(TheServiceParticipant->initial_DomainParticipantFactoryQos()),
     default_participant_qos_(TheServiceParticipant->initial_DomainParticipantQos())
 {
 }

◆ ~DomainParticipantFactoryImpl()

OpenDDS::DCPS::DomainParticipantFactoryImpl::~DomainParticipantFactoryImpl ( )

virtual

Definition at line 32 of file DomainParticipantFactoryImpl.cpp.

References ACE_DEBUG, OpenDDS::DCPS::DCPS_debug_level, and LM_DEBUG.

 {
   if (DCPS_debug_level > 0) {
     ACE_DEBUG((LM_DEBUG,
                "(%P|%t) DomainParticipantFactoryImpl::"
                "~DomainParticipantFactoryImpl()\n"));
   }
 }

Member Function Documentation

◆ create_participant()

DDS::DomainParticipant_ptr OpenDDS::DCPS::DomainParticipantFactoryImpl::create_participant	(	DDS::DomainId_t	domainId,
		const DDS::DomainParticipantQos &	qos,
		DDS::DomainParticipantListener_ptr	a_listener,
		DDS::StatusMask	mask
	)

virtual

Definition at line 42 of file DomainParticipantFactoryImpl.cpp.

References OpenDDS::DCPS::RcHandle< T >::_retn(), ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, DDS::EntityFactoryQosPolicy::autoenable_created_entities, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::Qos_Helper::consistent(), OpenDDS::DCPS::DCPS_debug_level, DDS::DomainParticipantFactoryQos::entity_factory, get_default_participant_qos(), OpenDDS::DCPS::RcHandle< T >::in(), LM_ERROR, OPENDDS_STRING, participant_handles_, PARTICIPANT_QOS_DEFAULT, participants_, participants_protector_, qos_, OpenDDS::DCPS::ref(), DDS::RETCODE_OK, TheServiceParticipant, TheTransportRegistry, and OpenDDS::DCPS::Qos_Helper::valid().

 {
   DDS::DomainParticipantQos par_qos = qos;
 
   if (par_qos == PARTICIPANT_QOS_DEFAULT) {
     get_default_participant_qos(par_qos);
   }
 
   if (!Qos_Helper::valid(par_qos)) {
     if (DCPS_debug_level > 0) {
       ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantFactoryImpl::create_participant, ")
                 ACE_TEXT("invalid qos.\n")));
     }
     return DDS::DomainParticipant::_nil();
   }
 
   if (!Qos_Helper::consistent(par_qos)) {
     if (DCPS_debug_level > 0) {
       ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantFactoryImpl::create_participant, ")
                 ACE_TEXT("inconsistent qos.\n")));
     }
     return DDS::DomainParticipant::_nil();
   }
 
   RcHandle<DomainParticipantImpl> dp =
     make_rch<DomainParticipantImpl>(ref(participant_handles_), domainId, par_qos, a_listener, mask);
 
   if (qos_.entity_factory.autoenable_created_entities) {
     if (dp->enable() != DDS::RETCODE_OK) {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: ")
                   ACE_TEXT("DomainParticipantFactoryImpl::create_participant, ")
                   ACE_TEXT("unable to enable DomainParticipant.\n")));
       }
       return DDS::DomainParticipant::_nil();
     }
   }
 
   // if the specified transport is a transport template then create a new transport
   // instance for the new participant if per_participant is set (checked before creating instance).
   ACE_TString transport_base_config_name;
   TheServiceParticipant->get_transport_base_config_name(domainId, transport_base_config_name);
 
   if (TheTransportRegistry->config_has_transport_template(transport_base_config_name)) {
     OPENDDS_STRING transport_config_name = ACE_TEXT_ALWAYS_CHAR(transport_base_config_name.c_str());
     OPENDDS_STRING transport_instance_name = dp->get_unique_id();
 
     // unique config and instance names are returned in transport_config_name and transport_instance_name
     const bool ret = TheTransportRegistry->create_new_transport_instance_for_participant(domainId, transport_config_name, transport_instance_name);
 
     if (ret) {
       TheTransportRegistry->bind_config(transport_config_name, dp.in());
       TheTransportRegistry->update_config_template_instance_info(transport_config_name, transport_instance_name);
     } else {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: ")
                   ACE_TEXT("DomainParticipantFactoryImpl::create_participant, ")
                   ACE_TEXT("could not create new transport instance for participant.\n")));
       }
       return DDS::DomainParticipant::_nil();
     }
   }
 
   ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                    guard,
                    participants_protector_,
                    DDS::DomainParticipant::_nil());
 
   participants_[domainId].insert(dp);
   return dp._retn();
 }

◆ delete_all_participants()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_all_participants ( )

Definition at line 326 of file DomainParticipantFactoryImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, copy(), OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities(), delete_participant(), LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::LogLevel::Notice, participants(), participants_, participants_protector_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_OUT_OF_RESOURCES, and OpenDDS::DCPS::retcode_to_string().

 {
   ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, participants_protector_,
     DDS::RETCODE_OUT_OF_RESOURCES);
 
   /*
    * Create a copy of the participants because we need to run
    * delete_participants on them, but delete_participants removes them from the
    * object's map.
    */
   DPMap copy = participants();
 
   DDS::ReturnCode_t rv = DDS::RETCODE_OK;
   DPMap::iterator itr;
   for (itr = copy.begin(); itr != copy.end(); ++itr) {
     DPSet& dp_set = itr->second;
     DPSet::iterator dp_set_itr;
     for (dp_set_itr = dp_set.begin(); dp_set_itr != dp_set.end(); ++dp_set_itr) {
       DomainParticipantImpl* const dp = &**dp_set_itr;
       DDS::ReturnCode_t tmp = dp->delete_contained_entities();
       if (tmp) {
         if (log_level >= LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: "
             "DomainParticipantFactoryImpl::delete_all_participants: "
             "delete_contained_entities returned %C\n",
             retcode_to_string(tmp)));
         }
         rv = DDS::RETCODE_ERROR;
       }
 
       tmp = delete_participant(dp);
       if (tmp) {
         if (log_level >= LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: "
             "DomainParticipantFactoryImpl::delete_all_participants: "
             "delete_participant returned %C\n",
             retcode_to_string(tmp)));
         }
         rv = DDS::RETCODE_ERROR;
       }
     }
   }
 
   // Remove Empty Domain Id Sets
   participants_.clear();
 
   return rv;
 }

◆ delete_participant()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::delete_participant ( DDS::DomainParticipant_ptr a_participant )

virtual

Definition at line 125 of file DomainParticipantFactoryImpl.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DomainParticipantImpl::delete_contained_entities(), OpenDDS::DCPS::DomainParticipantImpl::get_domain_id(), OpenDDS::DCPS::DomainParticipantImpl::get_id(), OpenDDS::DCPS::DomainParticipantImpl::is_clean(), CORBA::is_nil(), LM_ERROR, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::TransportConfig::name(), OpenDDS::DCPS::LogLevel::Notice, participants_, participants_protector_, OpenDDS::DCPS::rchandle_from(), DDS::RETCODE_BAD_PARAMETER, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_PRECONDITION_NOT_MET, TheServiceParticipant, and TheTransportRegistry.

Referenced by delete_all_participants().

 {
   if (CORBA::is_nil(a_participant)) {
     if (DCPS_debug_level > 0) {
       ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: ")
                 ACE_TEXT("DomainParticipantFactoryImpl::delete_participant, ")
                 ACE_TEXT("Nil participant.\n")));
     }
     return DDS::RETCODE_BAD_PARAMETER;
   }
 
   // The servant's ref count should be 2 at this point, one referenced
   // by the poa and the other referenced by the map.
   DomainParticipantImpl* the_servant = dynamic_cast<DomainParticipantImpl*>(a_participant);
   if (!the_servant) {
     if (DCPS_debug_level > 0) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: ")
         ACE_TEXT("DomainParticipantFactoryImpl::delete_participant: ")
         ACE_TEXT("failed to obtain the DomainParticipantImpl.\n")));
     }
     return DDS::RETCODE_ERROR;
   }
 
   RcHandle<DomainParticipantImpl> servant_rch = rchandle_from(the_servant);
 
   TransportConfig_rch tr_cfg = servant_rch->transport_config();
   if (tr_cfg) {
     // check for and remove tranport template instance
     TheTransportRegistry->remove_transport_template_instance(tr_cfg->name());
   }
 
   //xxx servant rc = 4 (servant::DP::Entity::ServantBase::ref_count_
   String leftover_entities;
   if (!the_servant->is_clean(&leftover_entities)) {
     if (log_level >= LogLevel::Notice) {
       ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: "
                 "DomainParticipantFactoryImpl::delete_participant: "
                 "the participant %C is not empty. %C leftover\n",
                 LogGuid(the_servant->get_id()).c_str(), leftover_entities.c_str()));
     }
     return DDS::RETCODE_PRECONDITION_NOT_MET;
   }
 
   const DDS::DomainId_t domain_id = the_servant->get_domain_id();
   const GUID_t dp_id = the_servant->get_id();
 
   {
     ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                      guard,
                      participants_protector_,
                      DDS::RETCODE_ERROR);
 
     DPMap::iterator pos = participants_.find(domain_id);
     if (pos == participants_.end()) {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: ")
                    ACE_TEXT("DomainParticipantFactoryImpl::delete_participant: ")
                    ACE_TEXT("%p domain_id=%d dp_id=%C.\n"),
                    ACE_TEXT("find"),
                    domain_id,
                    LogGuid(dp_id).c_str()));
       }
       return DDS::RETCODE_ERROR;
     }
 
     if (pos->second.erase(servant_rch) == 0) {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: ")
                    ACE_TEXT("DomainParticipantFactoryImpl::delete_participant, ")
                    ACE_TEXT(" %p.\n"),
                    ACE_TEXT("remove")));
       }
       return DDS::RETCODE_ERROR;
     }
 
     if (pos->second.empty() && participants_.erase(domain_id) == 0) {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: ")
                    ACE_TEXT("DomainParticipantFactoryImpl::delete_participant, ")
                    ACE_TEXT(" %p.\n"),
                    ACE_TEXT("unbind")));
       }
       return DDS::RETCODE_ERROR;
     }
 
     guard.release();
 
     const DDS::ReturnCode_t result = the_servant->delete_contained_entities();
     if (result != DDS::RETCODE_OK) {
       return result;
     }
   }
 
   Discovery_rch disco = TheServiceParticipant->get_discovery(domain_id);
   if (disco) {
     if (!disco->remove_domain_participant(domain_id, dp_id)) {
       if (DCPS_debug_level > 0) {
         ACE_ERROR((LM_ERROR,
                    ACE_TEXT("(%P|%t) ERROR: ")
                    ACE_TEXT("could not remove domain participant.\n")));
       }
       return DDS::RETCODE_ERROR;
     }
   }
   return DDS::RETCODE_OK;
 }

◆ get_default_participant_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::get_default_participant_qos ( DDS::DomainParticipantQos & qos )

virtual

Definition at line 282 of file DomainParticipantFactoryImpl.cpp.

References default_participant_qos_, and DDS::RETCODE_OK.

Referenced by create_participant().

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

◆ get_instance()

DDS::DomainParticipantFactory_ptr OpenDDS::DCPS::DomainParticipantFactoryImpl::get_instance ( )

virtual

Implements DDS::DomainParticipantFactory.

Definition at line 290 of file DomainParticipantFactoryImpl.cpp.

References TheParticipantFactory.

 {
   return TheParticipantFactory;
 }

◆ get_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::get_qos ( DDS::DomainParticipantFactoryQos & qos )

virtual

Definition at line 311 of file DomainParticipantFactoryImpl.cpp.

References qos_, and DDS::RETCODE_OK.

 {
   qos = this->qos_;
   return DDS::RETCODE_OK;
 }

◆ lookup_participant()

DDS::DomainParticipant_ptr OpenDDS::DCPS::DomainParticipantFactoryImpl::lookup_participant ( DDS::DomainId_t domainId )

virtual

Definition at line 238 of file DomainParticipantFactoryImpl.cpp.

References ACE_DEBUG, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::find(), LM_DEBUG, participants_, and participants_protector_.

 {
   ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex,
                    guard,
                    participants_protector_,
                    DDS::DomainParticipant::_nil());
 
   DPSet* entry = 0;
 
   if (find(participants_, domainId, entry) == -1) {
     if (DCPS_debug_level >= 1) {
       ACE_DEBUG((LM_DEBUG,
                  ACE_TEXT("(%P|%t) ")
                  ACE_TEXT("DomainParticipantFactoryImpl::lookup_participant, ")
                  ACE_TEXT(" not found for domain %d.\n"),
                  domainId));
     }
 
     return DDS::DomainParticipant::_nil();
 
   } else {
     // No specification about which participant will return. We just return the first
     // object.
     // Note: We are not duplicate the object ref, so a delete call is not needed.
     return DDS::DomainParticipant::_duplicate(entry->begin()->in());
   }
 }

◆ OPENDDS_MAP()

typedef OpenDDS::DCPS::DomainParticipantFactoryImpl::OPENDDS_MAP	(	DDS::DomainId_t	,
		DPSet
	)

◆ OPENDDS_SET()

typedef OpenDDS::DCPS::DomainParticipantFactoryImpl::OPENDDS_SET ( RcHandle< DomainParticipantImpl > )

◆ participant_count()

size_t OpenDDS::DCPS::DomainParticipantFactoryImpl::participant_count ( ) const

Definition at line 375 of file DomainParticipantFactoryImpl.cpp.

References ACE_GUARD_RETURN, OPENDDS_END_VERSIONED_NAMESPACE_DECL, participants_, and participants_protector_.

 {
   ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, participants_protector_, 0);
   size_t count = 0;
   for (DPMap::const_iterator it = participants_.begin(); it != participants_.end(); ++it) {
     count += it->second.size();
   }
   return count;
 }

◆ participants()

DomainParticipantFactoryImpl::DPMap OpenDDS::DCPS::DomainParticipantFactoryImpl::participants ( ) const

Make a copy of the participants map for reading.

Definition at line 319 of file DomainParticipantFactoryImpl.cpp.

References ACE_GUARD_RETURN, participants_, and participants_protector_.

Referenced by delete_all_participants(), and OpenDDS::DCPS::SPMonitorImpl::report().

 {
   ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, participants_protector_, DPMap());
 
   return participants_;
 }

◆ set_default_participant_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::set_default_participant_qos ( const DDS::DomainParticipantQos & qos )

virtual

Definition at line 268 of file DomainParticipantFactoryImpl.cpp.

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

 {
   if (Qos_Helper::valid(qos)
       && Qos_Helper::consistent(qos)) {
     default_participant_qos_ = qos;
     return DDS::RETCODE_OK;
 
   } else {
     return DDS::RETCODE_INCONSISTENT_POLICY;
   }
 }

◆ set_qos()

DDS::ReturnCode_t OpenDDS::DCPS::DomainParticipantFactoryImpl::set_qos ( const DDS::DomainParticipantFactoryQos & qos )

virtual

Definition at line 296 of file DomainParticipantFactoryImpl.cpp.

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

 {
   if (Qos_Helper::valid(qos) && Qos_Helper::consistent(qos)) {
     if (!(qos_ == qos) && Qos_Helper::changeable(qos_, qos))
       qos_ = qos;
 
     return DDS::RETCODE_OK;
 
   } else {
     return DDS::RETCODE_INCONSISTENT_POLICY;
   }
 }