OpenDDS::DCPS::Service_Participant Class Reference

Service entrypoint. More...

#include <Service_Participant.h>

Inheritance diagram for OpenDDS::DCPS::Service_Participant:

[legend]Collaboration diagram for OpenDDS::DCPS::Service_Participant:

[legend]List of all members.

Public Types
typedef int	RepoKey
	Key type for storing repository objects.
typedef std::map< ::DDS::DomainId_t, RepoKey >	DomainRepoMap
	The DomainId to RepoKey mapping.
typedef std::map< RepoKey, DCPSInfo_var >	RepoMap
typedef std::map< RepoKey, ACE_TString >	RepoTransportIpMap
	The builtin topic transport address.
typedef std::map< RepoKey, int >	RepoTransportPortMap
	The builtin topic transport port number.
typedef std::map< RepoKey, TransportImpl_rch >	RepoTransportMap
	The mapping from repository key to transport implementations.
	ANY_DOMAIN = -1
	DEFAULT_REPO = -1
enum	{ ANY_DOMAIN = -1 }
	Domain value for the default repository IOR. More...
enum	{ DEFAULT_REPO = -1 }
	Key value for the default repository IOR. More...
Public Member Functions
	Service_Participant ()
	Constructor.
	~Service_Participant ()
	Destructor.
virtual int	svc ()
	Launch a thread to run the orb.
int	set_ORB (CORBA::ORB_ptr orb)
CORBA::ORB_ptr	get_ORB ()
::DDS::DomainParticipantFactory_ptr	get_domain_participant_factory (int &argc=zero_argc, ACE_TCHAR *argv[]=0)
void	shutdown ()
PortableServer::POA_ptr	the_poa ()
DCPSInfo_ptr	get_repository (const ::DDS::DomainId_t domain)
	Accessor of the DCPSInfo object reference.
::DDS::UserDataQosPolicy	initial_UserDataQosPolicy () const
::DDS::TopicDataQosPolicy	initial_TopicDataQosPolicy () const
::DDS::GroupDataQosPolicy	initial_GroupDataQosPolicy () const
::DDS::TransportPriorityQosPolicy	initial_TransportPriorityQosPolicy () const
::DDS::LifespanQosPolicy	initial_LifespanQosPolicy () const
::DDS::DurabilityQosPolicy	initial_DurabilityQosPolicy () const
::DDS::DurabilityServiceQosPolicy	initial_DurabilityServiceQosPolicy () const
::DDS::PresentationQosPolicy	initial_PresentationQosPolicy () const
::DDS::DeadlineQosPolicy	initial_DeadlineQosPolicy () const
::DDS::LatencyBudgetQosPolicy	initial_LatencyBudgetQosPolicy () const
::DDS::OwnershipQosPolicy	initial_OwnershipQosPolicy () const
::DDS::OwnershipStrengthQosPolicy	initial_OwnershipStrengthQosPolicy () const
::DDS::LivelinessQosPolicy	initial_LivelinessQosPolicy () const
::DDS::TimeBasedFilterQosPolicy	initial_TimeBasedFilterQosPolicy () const
::DDS::PartitionQosPolicy	initial_PartitionQosPolicy () const
::DDS::ReliabilityQosPolicy	initial_ReliabilityQosPolicy () const
::DDS::DestinationOrderQosPolicy	initial_DestinationOrderQosPolicy () const
::DDS::HistoryQosPolicy	initial_HistoryQosPolicy () const
::DDS::ResourceLimitsQosPolicy	initial_ResourceLimitsQosPolicy () const
::DDS::EntityFactoryQosPolicy	initial_EntityFactoryQosPolicy () const
::DDS::WriterDataLifecycleQosPolicy	initial_WriterDataLifecycleQosPolicy () const
::DDS::ReaderDataLifecycleQosPolicy	initial_ReaderDataLifecycleQosPolicy () const
::DDS::DomainParticipantQos	initial_DomainParticipantQos () const
::DDS::TopicQos	initial_TopicQos () const
::DDS::DataWriterQos	initial_DataWriterQos () const
::DDS::PublisherQos	initial_PublisherQos () const
::DDS::DataReaderQos	initial_DataReaderQos () const
::DDS::SubscriberQos	initial_SubscriberQos () const
size_t	n_chunks () const
void	n_chunks (size_t chunks)
	Set the value returned by n_chunks() accessor.
size_t	association_chunk_multiplier () const
void	association_chunk_multiplier (size_t multiplier)
void	liveliness_factor (int factor)
int	liveliness_factor () const
void	set_repo_ior (const ACE_TCHAR *ior, const RepoKey key=DEFAULT_REPO)
	Load DCPSInfoRepo IORs.
void	set_repo (DCPSInfo_ptr repo, const RepoKey key=DEFAULT_REPO)
	Load DCPSInfoRepo reference directly.
void	remap_domains (const RepoKey oldKey, const RepoKey newKey)
	Rebind a domain from one repository to another.
void	set_repo_domain (const ::DDS::DomainId_t domain, const RepoKey repo)
	Bind DCPSInfoRepo IORs to domains.
const RepoKey	domain_to_repo (const ::DDS::DomainId_t domain) const
	Convert domainId to repository key.
void	repository_lost (const RepoKey key)
	Failover to a new repository.
TransportImpl_rch	bit_transport_impl (::DDS::DomainId_t domain=ANY_DOMAIN)
	Accessor of the TransportImpl used by the builtin topics.
bool	get_BIT ()
void	set_BIT (bool b)
int	init_bit_transport_impl (RepoKey repo=DEFAULT_REPO)
	Create the TransportImpl for all builtin topics.
DataDurabilityCache *	get_data_durability_cache (::DDS::DurabilityQosPolicy const &durability)
int &	federation_recovery_duration ()
	Accessors for FederationRecoveryDuration in seconds.
int	federation_recovery_duration () const
	Accessors for FederationRecoveryDuration in seconds.
int &	federation_initial_backoff_seconds ()
	Accessors for FederationInitialBackoffSeconds.
int	federation_initial_backoff_seconds () const
	Accessors for FederationInitialBackoffSeconds.
int &	federation_backoff_multiplier ()
	Accessors for FederationBackoffMultiplier.
int	federation_backoff_multiplier () const
	Accessors for FederationBackoffMultiplier.
int &	federation_liveliness ()
	Accessors for FederationLivelinessDuration.
int	federation_liveliness () const
	Accessors for FederationLivelinessDuration.
int	bit_transport_port (RepoKey repo=DEFAULT_REPO) const
void	bit_transport_port (int port, RepoKey repo=DEFAULT_REPO)
int	bit_lookup_duration_msec () const
void	bit_lookup_duration_msec (int msec)
Static Public Member Functions
static Service_Participant *	instance (void)
	Return a singleton instance of this class.
Public Attributes
CORBA::ORB_var	orb_
int	orb_from_user_
	true if set_ORB() was called.
PortableServer::POA_var	root_poa_
	The root poa object reference.
DomainParticipantFactoryImpl *	dp_factory_servant_
	The domain participant factory servant.
::DDS::DomainParticipantFactory_var	dp_factory_
	The domain participant factory object reference.
DomainRepoMap	domainRepoMap_
RepoMap	repoMap_
TAO_SYNCH_MUTEX	factory_lock_
::DDS::UserDataQosPolicy	initial_UserDataQosPolicy_
	The initial values of qos policies.
::DDS::TopicDataQosPolicy	initial_TopicDataQosPolicy_
::DDS::GroupDataQosPolicy	initial_GroupDataQosPolicy_
::DDS::TransportPriorityQosPolicy	initial_TransportPriorityQosPolicy_
::DDS::LifespanQosPolicy	initial_LifespanQosPolicy_
::DDS::DurabilityQosPolicy	initial_DurabilityQosPolicy_
::DDS::DurabilityServiceQosPolicy	initial_DurabilityServiceQosPolicy_
::DDS::PresentationQosPolicy	initial_PresentationQosPolicy_
::DDS::DeadlineQosPolicy	initial_DeadlineQosPolicy_
::DDS::LatencyBudgetQosPolicy	initial_LatencyBudgetQosPolicy_
::DDS::OwnershipQosPolicy	initial_OwnershipQosPolicy_
::DDS::OwnershipStrengthQosPolicy	initial_OwnershipStrengthQosPolicy_
::DDS::LivelinessQosPolicy	initial_LivelinessQosPolicy_
::DDS::TimeBasedFilterQosPolicy	initial_TimeBasedFilterQosPolicy_
::DDS::PartitionQosPolicy	initial_PartitionQosPolicy_
::DDS::ReliabilityQosPolicy	initial_ReliabilityQosPolicy_
::DDS::DestinationOrderQosPolicy	initial_DestinationOrderQosPolicy_
::DDS::HistoryQosPolicy	initial_HistoryQosPolicy_
::DDS::ResourceLimitsQosPolicy	initial_ResourceLimitsQosPolicy_
::DDS::EntityFactoryQosPolicy	initial_EntityFactoryQosPolicy_
::DDS::WriterDataLifecycleQosPolicy	initial_WriterDataLifecycleQosPolicy_
::DDS::ReaderDataLifecycleQosPolicy	initial_ReaderDataLifecycleQosPolicy_
::DDS::DomainParticipantQos	initial_DomainParticipantQos_
::DDS::TopicQos	initial_TopicQos_
::DDS::DataWriterQos	initial_DataWriterQos_
::DDS::PublisherQos	initial_PublisherQos_
::DDS::DataReaderQos	initial_DataReaderQos_
::DDS::SubscriberQos	initial_SubscriberQos_
::DDS::LivelinessLostStatus	initial_liveliness_lost_status_
::DDS::OfferedDeadlineMissedStatus	initial_offered_deadline_missed_status_
::DDS::OfferedIncompatibleQosStatus	initial_offered_incompatible_qos_status_
::DDS::PublicationMatchStatus	initial_publication_match_status_
size_t	n_chunks_
size_t	association_chunk_multiplier_
int	liveliness_factor_
	The propagation delay factor.
RepoTransportIpMap	bitTransportIpMap_
RepoTransportPortMap	bitTransportPortMap_
RepoTransportMap	bitTransportMap_
bool	bit_enabled_
int	bit_lookup_duration_msec_
ACE_Configuration_Heap	cf_
Private Member Functions
void	initialize ()
	Initalize default qos.
int	parse_args (int &argc, ACE_TCHAR *argv[])
int	load_configuration ()
int	load_common_configuration ()
int	load_domain_configuration ()
int	load_repo_configuration ()
Private Attributes
int	federation_recovery_duration_
	The FederationRecoveryDuration value in seconds.
int	federation_initial_backoff_seconds_
	The FederationInitialBackoffSeconds value.
int	federation_backoff_multiplier_
	This FederationBackoffMultiplier.
int	federation_liveliness_
	This FederationLivelinessDuration.
std::auto_ptr< DataDurabilityCache >	transient_data_cache_
	The TRANSIENT data durability cache.
std::auto_ptr< DataDurabilityCache >	persistent_data_cache_
	The PERSISTENT data durability cache.
Static Private Attributes
static int	zero_argc = 0

---

Detailed Description

Service entrypoint.

This class is a singleton that allows DDS client applications to configure OpenDDS. This includes running the ORB to support OpenDDS.

Note:

The client will either create an ORB and call set_ORB() before calling get_domain_particpant_factory() and will run the ORB *or* it will not call set_ORB() first and get_domain_particpant_factory() will automatically create an ORB to be used by OpenDDS and will run that ORB in a thread it creates.

This class may read a configuration file that will configure Transports as well as DCPS (e.g. number of ORB threads).

---

Member Typedef Documentation

typedef std::map< ::DDS::DomainId_t, RepoKey> OpenDDS::DCPS::Service_Participant::DomainRepoMap

The DomainId to RepoKey mapping.

typedef int OpenDDS::DCPS::Service_Participant::RepoKey

Key type for storing repository objects.

typedef std::map< RepoKey, DCPSInfo_var> OpenDDS::DCPS::Service_Participant::RepoMap

The DomainId to DCPSInfo/repository object references container.

typedef std::map< RepoKey, ACE_TString> OpenDDS::DCPS::Service_Participant::RepoTransportIpMap

The builtin topic transport address.

typedef std::map< RepoKey, TransportImpl_rch> OpenDDS::DCPS::Service_Participant::RepoTransportMap

The mapping from repository key to transport implementations.

typedef std::map< RepoKey, int> OpenDDS::DCPS::Service_Participant::RepoTransportPortMap

The builtin topic transport port number.

---

Member Enumeration Documentation

anonymous enum

Domain value for the default repository IOR.

Enumerator:

ANY_DOMAIN

anonymous enum

Key value for the default repository IOR.

Enumerator:

DEFAULT_REPO

---

Constructor & Destructor Documentation

OpenDDS::DCPS::Service_Participant::Service_Participant

(

)

Constructor.

OpenDDS::DCPS::Service_Participant::~Service_Participant

(

)

Destructor.

---

Member Function Documentation

void OpenDDS::DCPS::Service_Participant::association_chunk_multiplier

(

size_t

multiplier

)

See accessor description.

size_t OpenDDS::DCPS::Service_Participant::association_chunk_multiplier

(

)

const

This accessor is to provide the multiplier for allocators that have resources used on a per association basis. Has a default, can be set by the -DCPSChunkAssociationMutltiplier option, or by n_association_chunk_multiplier() setter.

void OpenDDS::DCPS::Service_Participant::bit_lookup_duration_msec

(

int

msec

)

Accessor for bit_lookup_duration_msec_. The accessor is used for client application to configure the timeout for lookup data from the builtin topic datareader. Value is in milliseconds.

int OpenDDS::DCPS::Service_Participant::bit_lookup_duration_msec

(

)

const

Accessor for bit_lookup_duration_msec_. The accessor is used for client application to configure the timeout for lookup data from the builtin topic datareader. Value is in milliseconds.

TransportImpl_rch OpenDDS::DCPS::Service_Participant::bit_transport_impl

(

::DDS::DomainId_t

domain = ANY_DOMAIN

)

Accessor of the TransportImpl used by the builtin topics.

void OpenDDS::DCPS::Service_Participant::bit_transport_port	(	int	port,
		RepoKey	repo = DEFAULT_REPO
	)

Accessors for bit_transport_port_.

The accessor is used for client application to configure the local transport listening port number.

Note:

The default port is INVALID. The user needs call this function to setup the desired port number.

int OpenDDS::DCPS::Service_Participant::bit_transport_port

(

RepoKey

repo = DEFAULT_REPO

)

const

Accessors for bit_transport_port_.

The accessor is used for client application to configure the local transport listening port number.

Note:

The default port is INVALID. The user needs call this function to setup the desired port number.

ACE_INLINE const Service_Participant::RepoKey OpenDDS::DCPS::Service_Participant::domain_to_repo

(

const ::DDS::DomainId_t

domain

)

const

Convert domainId to repository key.

ACE_INLINE int OpenDDS::DCPS::Service_Participant::federation_backoff_multiplier

(

)

const

Accessors for FederationBackoffMultiplier.

ACE_INLINE int & OpenDDS::DCPS::Service_Participant::federation_backoff_multiplier

(

)

Accessors for FederationBackoffMultiplier.

ACE_INLINE int OpenDDS::DCPS::Service_Participant::federation_initial_backoff_seconds

(

)

const

Accessors for FederationInitialBackoffSeconds.

ACE_INLINE int & OpenDDS::DCPS::Service_Participant::federation_initial_backoff_seconds

(

)

Accessors for FederationInitialBackoffSeconds.

ACE_INLINE int OpenDDS::DCPS::Service_Participant::federation_liveliness

(

)

const

Accessors for FederationLivelinessDuration.

ACE_INLINE int & OpenDDS::DCPS::Service_Participant::federation_liveliness

(

)

Accessors for FederationLivelinessDuration.

ACE_INLINE int OpenDDS::DCPS::Service_Participant::federation_recovery_duration

(

)

const

Accessors for FederationRecoveryDuration in seconds.

ACE_INLINE int & OpenDDS::DCPS::Service_Participant::federation_recovery_duration

(

)

Accessors for FederationRecoveryDuration in seconds.

bool OpenDDS::DCPS::Service_Participant::get_BIT

(

)

[inline]

DataDurabilityCache * OpenDDS::DCPS::Service_Participant::get_data_durability_cache

(

::DDS::DurabilityQosPolicy const &

durability

)

Get the data durability cache corresponding to the given DurabilityQosPolicy and sample list depth.

DDS::DomainParticipantFactory_ptr OpenDDS::DCPS::Service_Participant::get_domain_participant_factory	(	int &	argc = zero_argc,
		ACE_TCHAR *	argv[] = 0
	)

Initialize the DDS client environment and get the DomainParticipantFactory.

This method consumes -DCPS* options and thier arguments. Unless the client/application code calls other methods to define how the ORB is run, calling this method will initiallize the ORB and then run it in a separate thread.

CORBA::ORB_ptr OpenDDS::DCPS::Service_Participant::get_ORB

(

)

Get the ORB used by OpenDDS.

Only valid after set_ORB() or get_domain_participant_factory() called.

DCPSInfo_ptr OpenDDS::DCPS::Service_Participant::get_repository

(

const ::DDS::DomainId_t

domain

)

Accessor of the DCPSInfo object reference.

int OpenDDS::DCPS::Service_Participant::init_bit_transport_impl

(

RepoKey

repo = DEFAULT_REPO

)

Create the TransportImpl for all builtin topics.

ACE_INLINE::DDS::DataReaderQos OpenDDS::DCPS::Service_Participant::initial_DataReaderQos

(

)

const

ACE_INLINE::DDS::DataWriterQos OpenDDS::DCPS::Service_Participant::initial_DataWriterQos

(

)

const

ACE_INLINE::DDS::DeadlineQosPolicy OpenDDS::DCPS::Service_Participant::initial_DeadlineQosPolicy

(

)

const

ACE_INLINE::DDS::DestinationOrderQosPolicy OpenDDS::DCPS::Service_Participant::initial_DestinationOrderQosPolicy

(

)

const

ACE_INLINE::DDS::DomainParticipantQos OpenDDS::DCPS::Service_Participant::initial_DomainParticipantQos

(

)

const

ACE_INLINE::DDS::DurabilityQosPolicy OpenDDS::DCPS::Service_Participant::initial_DurabilityQosPolicy

(

)

const

ACE_INLINE::DDS::DurabilityServiceQosPolicy OpenDDS::DCPS::Service_Participant::initial_DurabilityServiceQosPolicy

(

)

const

ACE_INLINE::DDS::EntityFactoryQosPolicy OpenDDS::DCPS::Service_Participant::initial_EntityFactoryQosPolicy

(

)

const

ACE_INLINE::DDS::GroupDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_GroupDataQosPolicy

(

)

const

ACE_INLINE::DDS::HistoryQosPolicy OpenDDS::DCPS::Service_Participant::initial_HistoryQosPolicy

(

)

const

ACE_INLINE::DDS::LatencyBudgetQosPolicy OpenDDS::DCPS::Service_Participant::initial_LatencyBudgetQosPolicy

(

)

const

ACE_INLINE::DDS::LifespanQosPolicy OpenDDS::DCPS::Service_Participant::initial_LifespanQosPolicy

(

)

const

ACE_INLINE::DDS::LivelinessQosPolicy OpenDDS::DCPS::Service_Participant::initial_LivelinessQosPolicy

(

)

const

ACE_INLINE::DDS::OwnershipQosPolicy OpenDDS::DCPS::Service_Participant::initial_OwnershipQosPolicy

(

)

const

ACE_INLINE::DDS::OwnershipStrengthQosPolicy OpenDDS::DCPS::Service_Participant::initial_OwnershipStrengthQosPolicy

(

)

const

ACE_INLINE::DDS::PartitionQosPolicy OpenDDS::DCPS::Service_Participant::initial_PartitionQosPolicy

(

)

const

ACE_INLINE::DDS::PresentationQosPolicy OpenDDS::DCPS::Service_Participant::initial_PresentationQosPolicy

(

)

const

ACE_INLINE::DDS::PublisherQos OpenDDS::DCPS::Service_Participant::initial_PublisherQos

(

)

const

ACE_INLINE::DDS::ReaderDataLifecycleQosPolicy OpenDDS::DCPS::Service_Participant::initial_ReaderDataLifecycleQosPolicy

(

)

const

ACE_INLINE::DDS::ReliabilityQosPolicy OpenDDS::DCPS::Service_Participant::initial_ReliabilityQosPolicy

(

)

const

ACE_INLINE::DDS::ResourceLimitsQosPolicy OpenDDS::DCPS::Service_Participant::initial_ResourceLimitsQosPolicy

(

)

const

ACE_INLINE::DDS::SubscriberQos OpenDDS::DCPS::Service_Participant::initial_SubscriberQos

(

)

const

ACE_INLINE::DDS::TimeBasedFilterQosPolicy OpenDDS::DCPS::Service_Participant::initial_TimeBasedFilterQosPolicy

(

)

const

ACE_INLINE::DDS::TopicDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_TopicDataQosPolicy

(

)

const

ACE_INLINE::DDS::TopicQos OpenDDS::DCPS::Service_Participant::initial_TopicQos

(

)

const

ACE_INLINE::DDS::TransportPriorityQosPolicy OpenDDS::DCPS::Service_Participant::initial_TransportPriorityQosPolicy

(

)

const

ACE_INLINE::DDS::UserDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_UserDataQosPolicy

(

)

const

Accessors of the qos policy initial values.

ACE_INLINE::DDS::WriterDataLifecycleQosPolicy OpenDDS::DCPS::Service_Participant::initial_WriterDataLifecycleQosPolicy

(

)

const

void OpenDDS::DCPS::Service_Participant::initialize

(

)

[private]

Initalize default qos.

Service_Participant * OpenDDS::DCPS::Service_Participant::instance

(

void

)

[static]

Return a singleton instance of this class.

int OpenDDS::DCPS::Service_Participant::liveliness_factor

(

)

const

Accessor of the Liveliness propagation delay factor.

Returns:

% of lease period before sending a liveliness message.

void OpenDDS::DCPS::Service_Participant::liveliness_factor

(

int

factor

)

Set the Liveliness propagation delay factor.

Parameters:

factor

% of lease period before sending a liveliness message.

int OpenDDS::DCPS::Service_Participant::load_common_configuration

(

)

[private]

Load the common configuration to the Service_Participant singleton.

Note:

The values from command line can overwrite the values in configuration file.

int OpenDDS::DCPS::Service_Participant::load_configuration

(

)

[private]

Import the configuration file to the ACE_Configuration_Heap object and load common section configuration to the Service_Participant singleton and load the factory and transport section configuration to the TransportFactory singleton.

int OpenDDS::DCPS::Service_Participant::load_domain_configuration

(

)

[private]

Load the domain configuration to the Service_Participant singleton.

: Check this conversion.

: Check this conversion.

int OpenDDS::DCPS::Service_Participant::load_repo_configuration

(

)

[private]

Load the repository configuration to the Service_Participant singleton.

: Check this conversion.

void OpenDDS::DCPS::Service_Participant::n_chunks

(

size_t

chunks

)

Set the value returned by n_chunks() accessor.

See also:

Accessor description.

size_t OpenDDS::DCPS::Service_Participant::n_chunks

(

)

const

This accessor is to provide the configurable number of chunks that a DataWriter's cached allocator need to allocate when the resource limits are infinite. Has a default, can be set by the -DCPSChunks option, or by n_chunks() setter.

int OpenDDS::DCPS::Service_Participant::parse_args	(	int &	argc,
		ACE_TCHAR *	argv[]
	)			[private]

Parse the command line for user options. e.g. "-DCPSInfo <iorfile>". It consumes -DCPS* options and thier arguments

void OpenDDS::DCPS::Service_Participant::remap_domains	(	const RepoKey	oldKey,
		const RepoKey	newKey
	)

Rebind a domain from one repository to another.

void OpenDDS::DCPS::Service_Participant::repository_lost

(

const RepoKey

key

)

Failover to a new repository.

void OpenDDS::DCPS::Service_Participant::set_BIT

(

bool

b

)

[inline]

int OpenDDS::DCPS::Service_Participant::set_ORB

(

CORBA::ORB_ptr

orb

)

Client provides an ORB for the OpenDDS client to use.

Note:

The user is responsible for running the ORB.

void OpenDDS::DCPS::Service_Participant::set_repo	(	DCPSInfo_ptr	repo,
		const RepoKey	key = DEFAULT_REPO
	)

Load DCPSInfoRepo reference directly.

void OpenDDS::DCPS::Service_Participant::set_repo_domain	(	const ::DDS::DomainId_t	domain,
		const RepoKey	repo
	)

Bind DCPSInfoRepo IORs to domains.

void OpenDDS::DCPS::Service_Participant::set_repo_ior	(	const ACE_TCHAR *	ior,
		const RepoKey	key = DEFAULT_REPO
	)

Load DCPSInfoRepo IORs.

void OpenDDS::DCPS::Service_Participant::shutdown

(

)

Stop being a participant in the service.

Will shutdown the ORB unless it was given via set_ORB().

Note:

Required Precondition: all DomainParticipants have been deleted.

int OpenDDS::DCPS::Service_Participant::svc

(

)

[virtual]

Launch a thread to run the orb.

PortableServer::POA_ptr OpenDDS::DCPS::Service_Participant::the_poa

(

)

Accessor of the poa that application used.

Todo:

Currently this method return the rootpoa. We might create our own poa.

---

Member Data Documentation

size_t OpenDDS::DCPS::Service_Participant::association_chunk_multiplier_

The configurable value of maximum number of expected associations for publishers and subscribers. This is used to pre allocate enough memory and reduce heap allocations.

bool OpenDDS::DCPS::Service_Participant::bit_enabled_

int OpenDDS::DCPS::Service_Participant::bit_lookup_duration_msec_

The timeout for lookup data from the builtin topic DataReader.

RepoTransportIpMap OpenDDS::DCPS::Service_Participant::bitTransportIpMap_

RepoTransportMap OpenDDS::DCPS::Service_Participant::bitTransportMap_

RepoTransportPortMap OpenDDS::DCPS::Service_Participant::bitTransportPortMap_

ACE_Configuration_Heap OpenDDS::DCPS::Service_Participant::cf_

The configuration object that imports the configuration file.

DomainRepoMap OpenDDS::DCPS::Service_Participant::domainRepoMap_

::DDS::DomainParticipantFactory_var OpenDDS::DCPS::Service_Participant::dp_factory_

The domain participant factory object reference.

DomainParticipantFactoryImpl* OpenDDS::DCPS::Service_Participant::dp_factory_servant_

The domain participant factory servant.

Allocate the factory on the heap to avoid the circular dependency since the OpenDDS::DCPS::DomainParticipantFactoryImpl constructor calls the OpenDDS::DCPS::Service_Participant singleton.

TAO_SYNCH_MUTEX OpenDDS::DCPS::Service_Participant::factory_lock_

The lock to serialize DomainParticipantFactory singleton creation and shutdown.

int OpenDDS::DCPS::Service_Participant::federation_backoff_multiplier_ [private]

This FederationBackoffMultiplier.

int OpenDDS::DCPS::Service_Participant::federation_initial_backoff_seconds_ [private]

The FederationInitialBackoffSeconds value.

int OpenDDS::DCPS::Service_Participant::federation_liveliness_ [private]

This FederationLivelinessDuration.

int OpenDDS::DCPS::Service_Participant::federation_recovery_duration_ [private]

The FederationRecoveryDuration value in seconds.

::DDS::DataReaderQos OpenDDS::DCPS::Service_Participant::initial_DataReaderQos_

::DDS::DataWriterQos OpenDDS::DCPS::Service_Participant::initial_DataWriterQos_

::DDS::DeadlineQosPolicy OpenDDS::DCPS::Service_Participant::initial_DeadlineQosPolicy_

::DDS::DestinationOrderQosPolicy OpenDDS::DCPS::Service_Participant::initial_DestinationOrderQosPolicy_

::DDS::DomainParticipantQos OpenDDS::DCPS::Service_Participant::initial_DomainParticipantQos_

::DDS::DurabilityQosPolicy OpenDDS::DCPS::Service_Participant::initial_DurabilityQosPolicy_

::DDS::DurabilityServiceQosPolicy OpenDDS::DCPS::Service_Participant::initial_DurabilityServiceQosPolicy_

::DDS::EntityFactoryQosPolicy OpenDDS::DCPS::Service_Participant::initial_EntityFactoryQosPolicy_