OpenDDS::DCPS::Service_Participant Class Reference

Service entrypoint. More...

#include <Service_Participant.h>

Collaboration diagram for OpenDDS::DCPS::Service_Participant:

Classes
struct	DiscoveryInfo
struct	DomainRange

Public Types
enum	{ ANY_DOMAIN = -1 }
	Domain value for the default repository IOR. More...
enum	TypeObjectEncoding { Encoding_Normal, Encoding_WriteOldFormat, Encoding_ReadOldFormat }

Public Member Functions
	Service_Participant ()
	~Service_Participant ()
const TimeSource &	time_source () const
ACE_Reactor_Timer_Interface *	timer ()
ACE_Reactor *	reactor ()
ACE_thread_t	reactor_owner () const
ReactorInterceptor_rch	interceptor () const
JobQueue_rch	job_queue () const
void	set_shutdown_listener (RcHandle< ShutdownListener > listener)
DDS::DomainParticipantFactory_ptr	get_domain_participant_factory (int &argc=zero_argc, ACE_TCHAR *argv[]=0)
DDS::ReturnCode_t	shutdown ()
bool	is_shut_down () const
	Accessor for if the participant has been shutdown. More...
Discovery_rch	get_discovery (const DDS::DomainId_t domain)
	Accessor of the Discovery object for a given domain. More...
const DDS::UserDataQosPolicy &	initial_UserDataQosPolicy () const
const DDS::TopicDataQosPolicy &	initial_TopicDataQosPolicy () const
const DDS::GroupDataQosPolicy &	initial_GroupDataQosPolicy () const
const DDS::TransportPriorityQosPolicy &	initial_TransportPriorityQosPolicy () const
const DDS::LifespanQosPolicy &	initial_LifespanQosPolicy () const
const DDS::DurabilityQosPolicy &	initial_DurabilityQosPolicy () const
const DDS::DurabilityServiceQosPolicy &	initial_DurabilityServiceQosPolicy () const
const DDS::PresentationQosPolicy &	initial_PresentationQosPolicy () const
const DDS::DeadlineQosPolicy &	initial_DeadlineQosPolicy () const
const DDS::LatencyBudgetQosPolicy &	initial_LatencyBudgetQosPolicy () const
const DDS::OwnershipQosPolicy &	initial_OwnershipQosPolicy () const
const DDS::OwnershipStrengthQosPolicy &	initial_OwnershipStrengthQosPolicy () const
const DDS::LivelinessQosPolicy &	initial_LivelinessQosPolicy () const
const DDS::TimeBasedFilterQosPolicy &	initial_TimeBasedFilterQosPolicy () const
const DDS::PartitionQosPolicy &	initial_PartitionQosPolicy () const
const DDS::ReliabilityQosPolicy &	initial_ReliabilityQosPolicy () const
const DDS::DestinationOrderQosPolicy &	initial_DestinationOrderQosPolicy () const
const DDS::HistoryQosPolicy &	initial_HistoryQosPolicy () const
const DDS::ResourceLimitsQosPolicy &	initial_ResourceLimitsQosPolicy () const
const DDS::EntityFactoryQosPolicy &	initial_EntityFactoryQosPolicy () const
const DDS::WriterDataLifecycleQosPolicy &	initial_WriterDataLifecycleQosPolicy () const
const DDS::ReaderDataLifecycleQosPolicy &	initial_ReaderDataLifecycleQosPolicy () const
const DDS::PropertyQosPolicy &	initial_PropertyQosPolicy () const
const DDS::DataRepresentationQosPolicy &	initial_DataRepresentationQosPolicy () const
const DDS::DomainParticipantFactoryQos &	initial_DomainParticipantFactoryQos () const
const DDS::DomainParticipantQos &	initial_DomainParticipantQos () const
const DDS::TopicQos &	initial_TopicQos () const
const DDS::DataWriterQos &	initial_DataWriterQos () const
const DDS::PublisherQos &	initial_PublisherQos () const
const DDS::DataReaderQos &	initial_DataReaderQos () const
const DDS::SubscriberQos &	initial_SubscriberQos () const
const DDS::TypeConsistencyEnforcementQosPolicy &	initial_TypeConsistencyEnforcementQosPolicy () const
size_t	n_chunks () const
void	n_chunks (size_t chunks)
	Set the value returned by n_chunks() accessor. More...
size_t	association_chunk_multiplier () const
void	association_chunk_multiplier (size_t multiplier)
void	liveliness_factor (int factor)
int	liveliness_factor () const
void	add_discovery (Discovery_rch discovery)
bool	set_repo_ior (const char *ior, Discovery::RepoKey key=Discovery::DEFAULT_REPO, bool attach_participant=true)
bool	use_bidir_giop () const
void	remap_domains (Discovery::RepoKey oldKey, Discovery::RepoKey newKey, bool attach_participant=true)
	Rebind a domain from one repository to another. More...
void	set_repo_domain (const DDS::DomainId_t domain, Discovery::RepoKey repo, bool attach_participant=true)
	Bind DCPSInfoRepo IORs to domains. More...
void	set_default_discovery (const Discovery::RepoKey &defaultDiscovery)
Discovery::RepoKey	get_default_discovery ()
Discovery::RepoKey	domain_to_repo (const DDS::DomainId_t domain) const
	Convert domainId to repository key. More...
void	repository_lost (Discovery::RepoKey key)
	Failover to a new repository. More...
MonotonicTimePoint	new_pending_timeout_deadline () const
	Get a new pending timeout deadline. More...
OPENDDS_STRING	bit_transport_ip () const
bool	get_security ()
void	set_security (bool b)
bool	get_BIT ()
void	set_BIT (bool b)
const NetworkAddress &	default_address () const
DataDurabilityCache *	get_data_durability_cache (DDS::DurabilityQosPolicy const &durability)
typedef	OPENDDS_MAP (Discovery::RepoKey, Discovery_rch) RepoKeyDiscoveryMap
	For internal OpenDDS Use (needed for monitor code) More...
const RepoKeyDiscoveryMap &	discoveryMap () const
typedef	OPENDDS_MAP (DDS::DomainId_t, Discovery::RepoKey) DomainRepoMap
const DomainRepoMap &	domainRepoMap () const
void	register_discovery_type (const char *section_name, Discovery::Config *cfg)
ACE_ARGV *	ORB_argv ()
Recorder_ptr	create_recorder (DDS::DomainParticipant_ptr participant, DDS::Topic_ptr a_topic, const DDS::SubscriberQos &subscriber_qos, const DDS::DataReaderQos &datareader_qos, const RecorderListener_rch &a_listener)
DDS::ReturnCode_t	delete_recorder (Recorder_ptr recorder)
Replayer_ptr	create_replayer (DDS::DomainParticipant_ptr participant, DDS::Topic_ptr a_topic, const DDS::PublisherQos &publisher_qos, const DDS::DataWriterQos &datawriter_qos, const ReplayerListener_rch &a_listener)
DDS::ReturnCode_t	delete_replayer (Replayer_ptr replayer)
DDS::Topic_ptr	create_typeless_topic (DDS::DomainParticipant_ptr participant, const char *topic_name, const char *type_name, bool type_has_keys, const DDS::TopicQos &qos, DDS::TopicListener_ptr a_listener=0, DDS::StatusMask mask=0)
int	load_configuration (ACE_Configuration_Heap &cf, const ACE_TCHAR *filename)
bool	belongs_to_domain_range (DDS::DomainId_t domainId) const
bool	get_transport_base_config_name (DDS::DomainId_t domainId, ACE_TString &name) const
void	default_configuration_file (const ACE_TCHAR *path)
DDS::Duration_t	bit_autopurge_nowriter_samples_delay () const
void	bit_autopurge_nowriter_samples_delay (const DDS::Duration_t &duration)
DDS::Duration_t	bit_autopurge_disposed_samples_delay () const
void	bit_autopurge_disposed_samples_delay (const DDS::Duration_t &duration)
XTypes::TypeInformation	get_type_information (DDS::DomainParticipant_ptr participant, const DDS::BuiltinTopicKey_t &key) const
DDS::ReturnCode_t	get_dynamic_type (DDS::DynamicType_var &type, DDS::DomainParticipant_ptr participant, const DDS::BuiltinTopicKey_t &key) const
XTypes::TypeObject	get_type_object (DDS::DomainParticipant_ptr participant, const XTypes::TypeIdentifier &ti) const
TypeObjectEncoding	type_object_encoding () const
void	type_object_encoding (TypeObjectEncoding encoding)
void	type_object_encoding (const char *encoding)
RcHandle< InternalTopic< NetworkInterfaceAddress > >	network_interface_address_topic () const
unsigned int	printer_value_writer_indent () const
void	printer_value_writer_indent (unsigned int value)
ACE_Thread_Mutex &	get_static_xtypes_lock ()
	getter for lock that protects the static initialization of XTypes related data structures More...
ThreadStatusManager &	get_thread_status_manager ()
	Get the service participant's thread status manager. More...
int &	federation_recovery_duration ()
	Accessors for FederationRecoveryDuration in seconds. More...
int	federation_recovery_duration () const
	Accessors for FederationRecoveryDuration in seconds. More...
int &	federation_initial_backoff_seconds ()
	Accessors for FederationInitialBackoffSeconds. More...
int	federation_initial_backoff_seconds () const
	Accessors for FederationInitialBackoffSeconds. More...
int &	federation_backoff_multiplier ()
	Accessors for FederationBackoffMultiplier. More...
int	federation_backoff_multiplier () const
	Accessors for FederationBackoffMultiplier. More...
int &	federation_liveliness ()
	Accessors for FederationLivelinessDuration. More...
int	federation_liveliness () const
	Accessors for FederationLivelinessDuration. More...
long &	scheduler ()
	Accessors for scheduling policy value. More...
long	scheduler () const
	Accessors for scheduling policy value. More...
bool &	publisher_content_filter ()
	Accessors for PublisherContentFilter. More...
bool	publisher_content_filter () const
	Accessors for PublisherContentFilter. More...
TimeDuration	pending_timeout () const
	Accessors for pending data timeout. More...
void	pending_timeout (const TimeDuration &value)
	Accessors for pending data timeout. More...
int	priority_min () const
	Accessors for priority extremums for the current scheduler. More...
int	priority_max () const
	Accessors for priority extremums for the current scheduler. More...
int	bit_transport_port () const
void	bit_transport_port (int port)
int	bit_lookup_duration_msec () const
void	bit_lookup_duration_msec (int msec)

Static Public Member Functions
static Service_Participant *	instance ()
	Return a singleton instance of this class. More...

Public Attributes
MonitorFactory *	monitor_factory_
unique_ptr< Monitor >	monitor_
	Pointer to the monitor object for this object. More...

Private Member Functions
void	initialize ()
	Initialize default qos. More...
void	initializeScheduling ()
	Initialize the thread scheduling and initial priority. More...
int	parse_args (int &argc, ACE_TCHAR *argv[])
int	load_configuration ()
int	load_common_configuration (ACE_Configuration_Heap &cf, const ACE_TCHAR *filename)
int	load_domain_configuration (ACE_Configuration_Heap &cf, const ACE_TCHAR *filename)
int	load_domain_ranges (ACE_Configuration_Heap &cf)
int	load_discovery_templates (ACE_Configuration_Heap &cf)
int	configure_domain_range_instance (DDS::DomainId_t domainId)
int	load_discovery_configuration (ACE_Configuration_Heap &cf, const ACE_TCHAR *section_name)
int	configure_discovery_template (DDS::DomainId_t domainId, const OPENDDS_STRING &discovery_name)
typedef	OPENDDS_MAP (OPENDDS_STRING, container_supported_unique_ptr< Discovery::Config >) DiscoveryTypes
	OPENDDS_MAP (DDS::DomainId_t, OPENDDS_STRING) domain_to_transport_name_map_
	OPENDDS_VECTOR (DomainRange) domain_ranges_
	OPENDDS_VECTOR (DiscoveryInfo) discovery_infos_
int	parse_domain_range (const OPENDDS_STRING &range, int &start, int &end)
bool	has_domain_range () const
bool	get_domain_range_info (DDS::DomainId_t id, DomainRange &inst)
bool	process_customizations (DDS::DomainId_t id, const OPENDDS_STRING &discovery_name, ValueMap &customs)
OpenDDS::DCPS::Discovery::RepoKey	get_discovery_template_instance_name (DDS::DomainId_t id)
bool	is_discovery_template (const OPENDDS_STRING &name)

Private Attributes
DiscoveryTypes	discovery_types_
ACE_ARGV	ORB_argv_
const TimeSource	time_source_
ReactorTask	reactor_task_
JobQueue_rch	job_queue_
RcHandle< DomainParticipantFactoryImpl >	dp_factory_servant_
RepoKeyDiscoveryMap	discoveryMap_
	The RepoKey to Discovery object mapping. More...
DomainRepoMap	domainRepoMap_
	The DomainId to RepoKey mapping. More...
Discovery::RepoKey	defaultDiscovery_
ACE_Thread_Mutex	factory_lock_
DDS::UserDataQosPolicy	initial_UserDataQosPolicy_
	The initial values of qos policies. More...
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::PropertyQosPolicy	initial_PropertyQosPolicy_
DDS::DataRepresentationQosPolicy	initial_DataRepresentationQosPolicy_
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::DomainParticipantFactoryQos	initial_DomainParticipantFactoryQos_
DDS::TypeConsistencyEnforcementQosPolicy	initial_TypeConsistencyEnforcementQosPolicy_
size_t	n_chunks_
size_t	association_chunk_multiplier_
int	liveliness_factor_
	The propagation delay factor. More...
ACE_TString	bit_transport_ip_
	The builtin topic transport address. More...
int	bit_transport_port_
	The builtin topic transport port number. More...
bool	bit_enabled_
bool	security_enabled_
int	bit_lookup_duration_msec_
NetworkAddress	default_address_
	The default network address to use. More...
ACE_TString	global_transport_config_
int	federation_recovery_duration_
	The FederationRecoveryDuration value in seconds. More...
int	federation_initial_backoff_seconds_
	The FederationInitialBackoffSeconds value. More...
int	federation_backoff_multiplier_
	This FederationBackoffMultiplier. More...
int	federation_liveliness_
	This FederationLivelinessDuration. More...
ACE_TString	schedulerString_
	Scheduling policy value from configuration file. More...
TimeDuration	schedulerQuantum_
	Scheduler time slice from configuration file. More...
long	scheduler_
	Scheduling policy value used for setting thread priorities. More...
int	priority_min_
	Minimum priority value for the current scheduling policy. More...
int	priority_max_
	Maximum priority value for the current scheduling policy. More...
bool	publisher_content_filter_
	Allow the publishing side to do content filtering? More...
unique_ptr< DataDurabilityCache >	transient_data_cache_
	The TRANSIENT data durability cache. More...
unique_ptr< DataDurabilityCache >	persistent_data_cache_
	The PERSISTENT data durability cache. More...
ACE_CString	persistent_data_dir_
	The PERSISTENT data durability directory. More...
TimeDuration	pending_timeout_
bool	bidir_giop_
	Enable TAO's Bidirectional GIOP? More...
ThreadStatusManager	thread_status_manager_
ACE_Thread_Mutex	xtypes_lock_
	Thread mutex used to protect the static initialization of XTypes data structures. More...
bool	monitor_enabled_
	Enable Monitor functionality. More...
AtomicBool	shut_down_
	Used to track state of service participant. More...
RcHandle< ShutdownListener >	shutdown_listener_
ACE_Recursive_Thread_Mutex	maps_lock_
	Guard access to the internal maps. More...
ACE_TString	default_configuration_file_
NetworkConfigMonitor_rch	network_config_monitor_
ACE_Thread_Mutex	network_config_monitor_lock_
DDS::Duration_t	bit_autopurge_nowriter_samples_delay_
DDS::Duration_t	bit_autopurge_disposed_samples_delay_
TypeObjectEncoding	type_object_encoding_
RcHandle< InternalTopic< NetworkInterfaceAddress > >	network_interface_address_topic_
unsigned int	printer_value_writer_indent_

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.

Note

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

Definition at line 70 of file Service_Participant.h.

Member Enumeration Documentation

anonymous enum

anonymous enum

Domain value for the default repository IOR.

Enumerator
ANY_DOMAIN

Definition at line 73 of file Service_Participant.h.

{ ANY_DOMAIN = -1 };

TypeObjectEncoding

enum OpenDDS::DCPS::Service_Participant::TypeObjectEncoding

Enumerator
Encoding_Normal
Encoding_WriteOldFormat
Encoding_ReadOldFormat

Definition at line 459 of file Service_Participant.h.

{ Encoding_Normal, Encoding_WriteOldFormat, Encoding_ReadOldFormat };

Constructor & Destructor Documentation

Service_Participant()

OpenDDS::DCPS::Service_Participant::Service_Participant

(

)

Definition at line 176 of file Service_Participant.cpp.

References ACE_TEXT(), if(), and initialize().

  :
#ifndef OPENDDS_SAFETY_PROFILE
  ORB_argv_(false /*substitute_env_args*/),
#endif
  time_source_()
  , reactor_task_(false)
  , defaultDiscovery_(DDS_DEFAULT_DISCOVERY_METHOD)
  , n_chunks_(DEFAULT_NUM_CHUNKS)
  , association_chunk_multiplier_(DEFAULT_CHUNK_MULTIPLIER)
  , liveliness_factor_(80)
  , bit_transport_port_(0)
  , bit_enabled_(
#ifdef DDS_HAS_MINIMUM_BIT
      false
#else
      true
#endif
    )
#ifdef OPENDDS_SECURITY
  , security_enabled_(false)
#endif
  , bit_lookup_duration_msec_(BIT_LOOKUP_DURATION_MSEC)
  , global_transport_config_(ACE_TEXT(""))
  , monitor_factory_(0)
  , federation_recovery_duration_(DEFAULT_FEDERATION_RECOVERY_DURATION)
  , federation_initial_backoff_seconds_(DEFAULT_FEDERATION_INITIAL_BACKOFF_SECONDS)
  , federation_backoff_multiplier_(DEFAULT_FEDERATION_BACKOFF_MULTIPLIER)
  , federation_liveliness_(DEFAULT_FEDERATION_LIVELINESS)
#if OPENDDS_POOL_ALLOCATOR
  , pool_size_(1024 * 1024 * 16)
  , pool_granularity_(8)
#endif
  , scheduler_(-1)
  , priority_min_(0)
  , priority_max_(0)
  , publisher_content_filter_(true)
#ifndef OPENDDS_NO_PERSISTENCE_PROFILE
  , persistent_data_dir_(DEFAULT_PERSISTENT_DATA_DIR)
#endif
  , bidir_giop_(true)
  , monitor_enabled_(false)
  , shut_down_(false)
  , default_configuration_file_(ACE_TEXT(""))
  , type_object_encoding_(Encoding_Normal)
  , network_interface_address_topic_(make_rch<InternalTopic<NetworkInterfaceAddress> >())
  , printer_value_writer_indent_(4)
{
  initialize();
}

~Service_Participant()

OpenDDS::DCPS::Service_Participant::~Service_Participant

(

)

Definition at line 227 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_GUARD, OpenDDS::DCPS::DCPS_debug_level, dp_factory_servant_, factory_lock_, LM_DEBUG, LM_WARNING, OpenDDS::DCPS::log_level, DDS::RETCODE_ALREADY_DELETED, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), shutdown(), and OpenDDS::DCPS::LogLevel::Warning.

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

  {
    ACE_GUARD(ACE_Thread_Mutex, guard, factory_lock_);
    if (dp_factory_servant_) {
      const size_t count = dp_factory_servant_->participant_count();
      if (count > 0 && log_level >= LogLevel::Warning) {
        ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: Service_Participant::~Service_Participant: "
          "There are %B remaining domain participant(s). "
          "It is recommended to delete them before shutdown.\n",
          count));
      }

      const DDS::ReturnCode_t cleanup_status = dp_factory_servant_->delete_all_participants();
      if (cleanup_status) {
        if (log_level >= LogLevel::Warning) {
          ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: Service_Participant::~Service_Participant: "
            "delete_all_participants returned %C\n",
            retcode_to_string(cleanup_status)));
        }
      }
    }
  }

  const DDS::ReturnCode_t shutdown_status = shutdown();
  if (shutdown_status != DDS::RETCODE_OK && shutdown_status != DDS::RETCODE_ALREADY_DELETED) {
    if (log_level >= LogLevel::Warning) {
      ACE_ERROR((LM_WARNING, "(%P|%t) WARNING: Service_Participant::~Service_Participant: "
        "shutdown returned %C\n",
        retcode_to_string(shutdown_status)));
    }
  }
}

Member Function Documentation

add_discovery()

void OpenDDS::DCPS::Service_Participant::add_discovery

(

Discovery_rch

discovery

)

Definition at line 2777 of file Service_Participant.cpp.

References ACE_GUARD, discoveryMap_, and maps_lock_.

Referenced by load_configuration().

{
  if (discovery) {
    ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, this->maps_lock_);
    this->discoveryMap_[discovery->key()] = discovery;
  }
}

association_chunk_multiplier() [1/2]

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 -DCPSChunkAssociationMultiplier option, or by n_association_chunk_multiplier() setter.

Definition at line 1476 of file Service_Participant.cpp.

References association_chunk_multiplier_.

{
  return association_chunk_multiplier_;
}

association_chunk_multiplier() [2/2]

void OpenDDS::DCPS::Service_Participant::association_chunk_multiplier

(

size_t

multiplier

)

Set the value returned by n_association_chunk_multiplier() accessor. See accessor description.

Definition at line 1482 of file Service_Participant.cpp.

References association_chunk_multiplier_.

{
  association_chunk_multiplier_ = multiplier;
  got_chunk_association_multiplier = true;
}

belongs_to_domain_range()

bool OpenDDS::DCPS::Service_Participant::belongs_to_domain_range

(

DDS::DomainId_t

domainId

)

const

Used by TransportRegistry to determine if a domain ID is part of a [DomainRange]

Definition at line 2336 of file Service_Participant.cpp.

References OPENDDS_VECTOR().

{
  for (OPENDDS_VECTOR(DomainRange)::const_iterator i = domain_ranges_.begin(); i != domain_ranges_.end(); ++i) {
    if (domainId >= i->range_start && domainId <= i->range_end) {
      return true;
    }
  }

  return false;
}

bit_autopurge_disposed_samples_delay() [1/2]

DDS::Duration_t OpenDDS::DCPS::Service_Participant::bit_autopurge_disposed_samples_delay

(

)

const

Definition at line 2904 of file Service_Participant.cpp.

References bit_autopurge_disposed_samples_delay_.

{
  return bit_autopurge_disposed_samples_delay_;
}

bit_autopurge_disposed_samples_delay() [2/2]

void OpenDDS::DCPS::Service_Participant::bit_autopurge_disposed_samples_delay

(

const DDS::Duration_t &

duration

)

Definition at line 2910 of file Service_Participant.cpp.

References bit_autopurge_disposed_samples_delay_.

{
  bit_autopurge_disposed_samples_delay_ = duration;
}

bit_autopurge_nowriter_samples_delay() [1/2]

DDS::Duration_t OpenDDS::DCPS::Service_Participant::bit_autopurge_nowriter_samples_delay

(

)

const

Definition at line 2892 of file Service_Participant.cpp.

References bit_autopurge_nowriter_samples_delay_.

{
  return bit_autopurge_nowriter_samples_delay_;
}

bit_autopurge_nowriter_samples_delay() [2/2]

void OpenDDS::DCPS::Service_Participant::bit_autopurge_nowriter_samples_delay

(

const DDS::Duration_t &

duration

)

Definition at line 2898 of file Service_Participant.cpp.

References bit_autopurge_nowriter_samples_delay_.

{
  bit_autopurge_nowriter_samples_delay_ = duration;
}

bit_lookup_duration_msec() [1/2]

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.

Definition at line 1450 of file Service_Participant.cpp.

References bit_lookup_duration_msec_.

{
  return bit_lookup_duration_msec_;
}

bit_lookup_duration_msec() [2/2]

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.

Definition at line 1456 of file Service_Participant.cpp.

References bit_lookup_duration_msec_.

{
  bit_lookup_duration_msec_ = sec;
  got_bit_lookup_duration_msec = true;
}

bit_transport_ip()

OPENDDS_STRING OpenDDS::DCPS::Service_Participant::bit_transport_ip

(

)

const

Definition at line 1430 of file Service_Participant.cpp.

References ACE_TEXT_ALWAYS_CHAR, bit_transport_ip_, and ACE_String_Base< char >::c_str().

{
  return ACE_TEXT_ALWAYS_CHAR(this->bit_transport_ip_.c_str());
}

bit_transport_port() [1/2]

int OpenDDS::DCPS::Service_Participant::bit_transport_port

(

)

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.

Definition at line 1436 of file Service_Participant.cpp.

References bit_transport_port_.

{
  return this->bit_transport_port_;
}

bit_transport_port() [2/2]

void OpenDDS::DCPS::Service_Participant::bit_transport_port

(

int

port

)

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.

Definition at line 1442 of file Service_Participant.cpp.

References ACE_GUARD, bit_transport_port_, and maps_lock_.

{
  ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, this->maps_lock_);
  this->bit_transport_port_ = port;
  got_bit_transport_port = true;
}

configure_discovery_template()

int OpenDDS::DCPS::Service_Participant::configure_discovery_template ( DDS::DomainId_t  domainId, const OPENDDS_STRING &  discovery_name  )

private

Create and load a discovery config from a discovery template

Definition at line 2397 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, OpenDDS::DCPS::DCPS_debug_level, discoveryMap_, get_discovery_template_instance_name(), LM_DEBUG, LM_ERROR, load_discovery_configuration(), name, ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), process_customizations(), ACE_Configuration::root_section(), and ACE_Configuration_Heap::set_string_value().

Referenced by get_discovery().

{
  ValueMap discovery_settings;
  if (process_customizations(domainId, discovery_name, discovery_settings)) {
    Discovery::RepoKey name = get_discovery_template_instance_name(domainId);

    if (discoveryMap_.find(name) == discoveryMap_.end()) {
      ACE_Configuration_Heap dcf;
      dcf.open();
      const ACE_Configuration_Section_Key& root = dcf.root_section();

      //create discovery instance
      ACE_Configuration_Section_Key sect;
      dcf.open_section(root, RTPS_SECTION_NAME, true /* create */, sect);
      ACE_Configuration_Section_Key sub_sect;
      dcf.open_section(sect, ACE_TEXT_CHAR_TO_TCHAR(name.c_str()), true, sub_sect);

      for (ValueMap::const_iterator ds_it = discovery_settings.begin(); ds_it != discovery_settings.end(); ++ds_it) {
        dcf.set_string_value(sub_sect, ACE_TEXT_CHAR_TO_TCHAR(ds_it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(ds_it->second.c_str()));
        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::configure_discovery_template(): ")
                     ACE_TEXT("setting %C = %C\n"),
                     ds_it->first.c_str(), ds_it->second.c_str()));
        }
      }

      // load discovery
      int status = this->load_discovery_configuration(dcf, RTPS_SECTION_NAME);

      if (status != 0) {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::configure_discovery_template(): ")
                          ACE_TEXT("load_discovery_configuration() returned %d\n"),
                          status),
                         -1);
      }
    } else {
      // already configured. not necessarily an error
      if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Discovery config %C already exists\n"),
                     name.c_str()));
        }

    }
  } else {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::configure_discovery_template(): ")
                      ACE_TEXT("process_customizations() returned false\n")),
                     -1);
  }

  return 0;
}

configure_domain_range_instance()

int OpenDDS::DCPS::Service_Participant::configure_domain_range_instance ( DDS::DomainId_t  domainId )

private

Process the domain range template and activate the domain for the given domain ID

Definition at line 2220 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, OpenDDS::DCPS::TransportRegistry::create_transport_template_instance(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Service_Participant::DomainRange::discovery_template_name, discoveryMap_, OpenDDS::DCPS::Service_Participant::DomainRange::domain_info, OpenDDS::DCPS::TransportRegistry::get_config_instance_name(), get_discovery_template_instance_name(), get_domain_range_info(), get_transport_base_config_name(), OpenDDS::DCPS::TransportRegistry::instance(), LM_DEBUG, LM_ERROR, load_discovery_configuration(), load_domain_configuration(), name, ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, process_customizations(), ACE_Configuration::root_section(), ACE_Configuration_Heap::set_string_value(), OpenDDS::DCPS::to_dds_string(), and OpenDDS::DCPS::Service_Participant::DomainRange::transport_config_name.

Referenced by get_discovery().

{
  Discovery::RepoKey name = get_discovery_template_instance_name(domainId);

  if (discoveryMap_.find(name) == discoveryMap_.end()) {
    // create a cf that has [rtps_discovery/name+domainId]
    // copy sections adding customization
    DomainRange dr_inst;

    if (get_domain_range_info(domainId, dr_inst)) {
      ACE_Configuration_Heap dcf;
      dcf.open();
      const ACE_Configuration_Section_Key& root = dcf.root_section();

      // set the transport_config_name
      domain_to_transport_name_map_[domainId] = dr_inst.transport_config_name;

      // create domain instance
      ACE_Configuration_Section_Key dsect;
      dcf.open_section(root, DOMAIN_SECTION_NAME, true /* create */, dsect);
      ACE_Configuration_Section_Key dsub_sect;
      dcf.open_section(dsect, ACE_TEXT_CHAR_TO_TCHAR(to_dds_string(domainId).c_str()), true /* create */, dsub_sect);
      dcf.set_string_value(dsub_sect, ACE_TEXT("DiscoveryConfig"), ACE_TEXT_CHAR_TO_TCHAR(name.c_str()));
      for (ValueMap::const_iterator it = dr_inst.domain_info.begin();
           it != dr_inst.domain_info.end();
           ++it) {
        dcf.set_string_value(dsub_sect, ACE_TEXT_CHAR_TO_TCHAR(it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(it->second.c_str()));
        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::")
                     ACE_TEXT("configure_domain_range_instance(): adding %C=%C\n"),
                     it->first.c_str(), it->second.c_str()));
        }
      }

      ACE_TString cfg_name;
      if (get_transport_base_config_name(domainId, cfg_name)) {
        if (TransportRegistry::instance()->config_has_transport_template(cfg_name)) {
          // create transport instance add default transport config
          TransportRegistry::instance()->create_transport_template_instance(domainId, cfg_name);
          const OPENDDS_STRING config_instance_name = TransportRegistry::instance()->get_config_instance_name(domainId);
          dcf.set_string_value(dsub_sect, ACE_TEXT("DefaultTransportConfig"),
                               ACE_TEXT_CHAR_TO_TCHAR(config_instance_name.c_str()));
          if (DCPS_debug_level > 0) {
            ACE_DEBUG((LM_DEBUG,
                       ACE_TEXT("(%P|%t) Service_Participant::")
                       ACE_TEXT("configure_domain_range_instance(): setting DefaultTransportConfig=%C\n"),
                       config_instance_name.c_str()));
          }
        }
      } else {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                          ACE_TEXT("configure_domain_range_instance(): ")
                          ACE_TEXT("transport config not found for domain %d\n"),
                          domainId),
                         -1);
      }

      //create matching discovery instance
      ACE_Configuration_Section_Key sect;
      dcf.open_section(root, RTPS_SECTION_NAME, true /* create */, sect);
      ACE_Configuration_Section_Key sub_sect;
      dcf.open_section(sect, ACE_TEXT_CHAR_TO_TCHAR(name.c_str()), true, sub_sect);

      ValueMap discovery_settings;
      if (process_customizations(domainId, dr_inst.discovery_template_name, discovery_settings)) {
        for (ValueMap::const_iterator ds_it = discovery_settings.begin(); ds_it != discovery_settings.end(); ++ds_it) {
          dcf.set_string_value(sub_sect, ACE_TEXT_CHAR_TO_TCHAR(ds_it->first.c_str()), ACE_TEXT_CHAR_TO_TCHAR(ds_it->second.c_str()));
        }
      }

      // load discovery
      int status = this->load_discovery_configuration(dcf, RTPS_SECTION_NAME);

      if (status != 0) {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::configure_domain_range_instance(): ")
                          ACE_TEXT("load_discovery_configuration() returned %d\n"),
                          status),
                         -1);
      }

      // load domain config
      status = this->load_domain_configuration(dcf, 0);

      if (status != 0) {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::configure_domain_range_instance(): ")
                          ACE_TEXT("load_domain_configuration() returned %d\n"),
                          status),
                         -1);
      }

      if (DCPS_debug_level > 4) {
        ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) Service_Participant::configure_domain_range_instance(): ")
                 ACE_TEXT("configure domain %d.\n"),
                 domainId));
      }
    }

  } else {
    // > 9 to limit number of messages.
    if (DCPS_debug_level > 9) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) Service_Participant::configure_domain_range_instance(): ")
                 ACE_TEXT("domain %d already configured.\n"),
                 domainId));
    }
  }
  return 0;
}

create_recorder()

Recorder_ptr OpenDDS::DCPS::Service_Participant::create_recorder	(	DDS::DomainParticipant_ptr	participant,
		DDS::Topic_ptr	a_topic,
		const DDS::SubscriberQos &	subscriber_qos,
		const DDS::DataReaderQos &	datareader_qos,
		const RecorderListener_rch &	a_listener
	)

Create a Recorder object.

Definition at line 2804 of file Service_Participant.cpp.

References OpenDDS::DCPS::DomainParticipantImpl::create_recorder().

{
  DomainParticipantImpl* participant_servant = dynamic_cast<DomainParticipantImpl*>(participant);
  if (participant_servant)
    return participant_servant->create_recorder(a_topic, subscriber_qos, datareader_qos, a_listener, 0);
  return 0;
}

create_replayer()

Replayer_ptr OpenDDS::DCPS::Service_Participant::create_replayer	(	DDS::DomainParticipant_ptr	participant,
		DDS::Topic_ptr	a_topic,
		const DDS::PublisherQos &	publisher_qos,
		const DDS::DataWriterQos &	datawriter_qos,
		const ReplayerListener_rch &	a_listener
	)

Create a Replayer object

Definition at line 2829 of file Service_Participant.cpp.

References OpenDDS::DCPS::DomainParticipantImpl::create_replayer().

{
  DomainParticipantImpl* participant_servant = dynamic_cast<DomainParticipantImpl*>(participant);
  if (participant_servant)
    return participant_servant->create_replayer(a_topic, publisher_qos, datawriter_qos, a_listener, 0);
  return 0;
}

create_typeless_topic()

DDS::Topic_ptr OpenDDS::DCPS::Service_Participant::create_typeless_topic	(	DDS::DomainParticipant_ptr	participant,
		const char *	topic_name,
		const char *	type_name,
		bool	type_has_keys,
		const DDS::TopicQos &	qos,
		DDS::TopicListener_ptr	a_listener = 0,
		DDS::StatusMask	mask = 0
	)

Create a topic that does not have the data type registered.

Definition at line 2853 of file Service_Participant.cpp.

References OpenDDS::DCPS::DomainParticipantImpl::create_typeless_topic().

{
  DomainParticipantImpl* participant_servant = dynamic_cast<DomainParticipantImpl*>(participant);
  if (!participant_servant) {
    return 0;
  }
  return participant_servant->create_typeless_topic(topic_name, type_name, type_has_keys, qos, a_listener, mask);
}

default_address()

const NetworkAddress& OpenDDS::DCPS::Service_Participant::default_address ( ) const

inline

Definition at line 337 of file Service_Participant.h.

References OpenDDS::DCPS::OPENDDS_MAP().

{ return default_address_; }

default_configuration_file()

void OpenDDS::DCPS::Service_Participant::default_configuration_file

(

const ACE_TCHAR *

path

)

Set a configuration file to use if -DCPSConfigFile wasn't passed to TheParticipantFactoryWithArgs. Must be used before TheParticipantFactory*() functions are called.

Definition at line 2869 of file Service_Participant.cpp.

References default_configuration_file_.

{
  default_configuration_file_ = path;
}

delete_recorder()

DDS::ReturnCode_t OpenDDS::DCPS::Service_Participant::delete_recorder

(

Recorder_ptr

recorder

)

Delete an existing Recorder from its DomainParticipant.

Definition at line 2817 of file Service_Participant.cpp.

References OpenDDS::DCPS::RecorderImpl::cleanup(), OpenDDS::DCPS::DomainParticipantImpl::delete_recorder(), OpenDDS::DCPS::RecorderImpl::participant(), and DDS::RETCODE_ERROR.

{
  DDS::ReturnCode_t ret = DDS::RETCODE_ERROR;
  RecorderImpl* impl = dynamic_cast<RecorderImpl*>(recorder);
  if (impl){
    ret = impl->cleanup();
    impl->participant()->delete_recorder(recorder);
  }
  return ret;
}

delete_replayer()

DDS::ReturnCode_t OpenDDS::DCPS::Service_Participant::delete_replayer

(

Replayer_ptr

replayer

)

Delete an existing Replayer from its DomainParticipant.

Definition at line 2842 of file Service_Participant.cpp.

References OpenDDS::DCPS::ReplayerImpl::cleanup(), OpenDDS::DCPS::DomainParticipantImpl::delete_replayer(), OpenDDS::DCPS::ReplayerImpl::participant(), and DDS::RETCODE_ERROR.

{
  DDS::ReturnCode_t ret = DDS::RETCODE_ERROR;
  ReplayerImpl* impl = static_cast<ReplayerImpl*>(replayer);
  if (impl) {
    ret = impl->cleanup();
    impl->participant()->delete_replayer(replayer);
  }
  return ret;
}

discoveryMap()

const Service_Participant::RepoKeyDiscoveryMap & OpenDDS::DCPS::Service_Participant::discoveryMap

(

)

const

Definition at line 2792 of file Service_Participant.cpp.

References discoveryMap_.

{
  return this->discoveryMap_;
}

domain_to_repo()

ACE_INLINE Discovery::RepoKey OpenDDS::DCPS::Service_Participant::domain_to_repo

(

const DDS::DomainId_t

domain

)

const

Convert domainId to repository key.

Definition at line 15 of file Service_Participant.inl.

References ACE_INLINE, OpenDDS::DCPS::Discovery::DEFAULT_REPO, and domainRepoMap_.

{
  DomainRepoMap::const_iterator where = domainRepoMap_.find(domain);

  if (where == domainRepoMap_.end()) {
    return Discovery::DEFAULT_REPO;

  } else {
    return where->second;
  }
}

domainRepoMap()

const Service_Participant::DomainRepoMap & OpenDDS::DCPS::Service_Participant::domainRepoMap

(

)

const

Definition at line 2798 of file Service_Participant.cpp.

References domainRepoMap_.

{
  return this->domainRepoMap_;
}

federation_backoff_multiplier() [1/2]

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

(

)

Accessors for FederationBackoffMultiplier.

Definition at line 283 of file Service_Participant.inl.

References ACE_INLINE, and federation_backoff_multiplier_.

Referenced by repository_lost().

{
  return federation_backoff_multiplier_;
}

federation_backoff_multiplier() [2/2]

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

(

)

const

Accessors for FederationBackoffMultiplier.

Definition at line 290 of file Service_Participant.inl.

References ACE_INLINE, and federation_backoff_multiplier_.

{
  return federation_backoff_multiplier_;
}

federation_initial_backoff_seconds() [1/2]

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

(

)

Accessors for FederationInitialBackoffSeconds.

Definition at line 269 of file Service_Participant.inl.

References ACE_INLINE, and federation_initial_backoff_seconds_.

Referenced by repository_lost().

{
  return federation_initial_backoff_seconds_;
}

federation_initial_backoff_seconds() [2/2]

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

(

)

const

Accessors for FederationInitialBackoffSeconds.

Definition at line 276 of file Service_Participant.inl.

References ACE_INLINE, and federation_initial_backoff_seconds_.

{
  return federation_initial_backoff_seconds_;
}

federation_liveliness() [1/2]

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

(

)

Accessors for FederationLivelinessDuration.

Definition at line 297 of file Service_Participant.inl.

References ACE_INLINE, and federation_liveliness_.

{
  return federation_liveliness_;
}

federation_liveliness() [2/2]

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

(

)

const

Accessors for FederationLivelinessDuration.

Definition at line 304 of file Service_Participant.inl.

References ACE_INLINE, and federation_liveliness_.

{
  return federation_liveliness_;
}

federation_recovery_duration() [1/2]

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

(

)

Accessors for FederationRecoveryDuration in seconds.

Definition at line 255 of file Service_Participant.inl.

References ACE_INLINE, and federation_recovery_duration_.

Referenced by repository_lost().

{
  return federation_recovery_duration_;
}

federation_recovery_duration() [2/2]

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

(

)

const

Accessors for FederationRecoveryDuration in seconds.

Definition at line 262 of file Service_Participant.inl.

References ACE_INLINE, and federation_recovery_duration_.

{
  return federation_recovery_duration_;
}

get_BIT()

bool OpenDDS::DCPS::Service_Participant::get_BIT ( )

inline

Definition at line 329 of file Service_Participant.h.

                 {
    return bit_enabled_;
  }

get_data_durability_cache()

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.

Definition at line 2728 of file Service_Participant.cpp.

References ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, factory_lock_, DDS::DurabilityQosPolicy::kind, LM_WARNING, persistent_data_cache_, persistent_data_dir_, DDS::PERSISTENT_DURABILITY_QOS, transient_data_cache_, and DDS::TRANSIENT_DURABILITY_QOS.

{
  DDS::DurabilityQosPolicyKind const kind =
    durability.kind;

  DataDurabilityCache * cache = 0;

  if (kind == DDS::TRANSIENT_DURABILITY_QOS) {
    {
      ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, factory_lock_, 0);

      if (!this->transient_data_cache_) {
        this->transient_data_cache_.reset(new DataDurabilityCache(kind));
      }
    }

    cache = this->transient_data_cache_.get();

  } else if (kind == DDS::PERSISTENT_DURABILITY_QOS) {
    {
      ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, factory_lock_, 0);

      try {
        if (!this->persistent_data_cache_) {
          this->persistent_data_cache_.reset(new DataDurabilityCache(kind,
                                                                     this->persistent_data_dir_));
        }

      } catch (const std::exception& ex) {
        if (DCPS_debug_level > 0) {
          ACE_ERROR((LM_WARNING,
                     ACE_TEXT("(%P|%t) WARNING: Service_Participant::get_data_durability_cache ")
                     ACE_TEXT("failed to create PERSISTENT cache, falling back on ")
                     ACE_TEXT("TRANSIENT behavior: %C\n"), ex.what()));
        }

        this->persistent_data_cache_.reset(new DataDurabilityCache(DDS::TRANSIENT_DURABILITY_QOS));
      }
    }

    cache = this->persistent_data_cache_.get();
  }

  return cache;
}

get_default_discovery()

Discovery::RepoKey OpenDDS::DCPS::Service_Participant::get_default_discovery

(

)

Definition at line 1277 of file Service_Participant.cpp.

References defaultDiscovery_.

{
  return this->defaultDiscovery_;
}

get_discovery()

Discovery_rch OpenDDS::DCPS::Service_Participant::get_discovery

(

const DDS::DomainId_t

domain

)

Accessor of the Discovery object for a given domain.

Definition at line 1283 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), configure_discovery_template(), configure_domain_range_instance(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Discovery::DEFAULT_REPO, OpenDDS::DCPS::Discovery::DEFAULT_RTPS, defaultDiscovery_, discoveryMap_, domainRepoMap_, get_discovery_template_instance_name(), get_domain_range_info(), is_discovery_template(), LM_DEBUG, LM_ERROR, load_discovery_configuration(), maps_lock_, ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, ACE_Configuration::root_section(), OpenDDS::DCPS::RTPS_SECTION_NAME, and set_repo_ior().

Referenced by InfoRepo::init().

{
  ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, this->maps_lock_, Discovery_rch());

  // Default to the Default InfoRepo-based discovery unless the user has
  // changed defaultDiscovery_ using the API or config file
  Discovery::RepoKey repo = defaultDiscovery_;
  bool in_range = false;
  const Discovery::RepoKey instance_name = get_discovery_template_instance_name(domain);
  DomainRange dr_inst;

  RepoKeyDiscoveryMap::const_iterator location;

  // Find if this domain has a repo key (really a discovery key)
  // mapped to it.
  DomainRepoMap::const_iterator where = this->domainRepoMap_.find(domain);
  if (where != this->domainRepoMap_.end()) {
    repo = where->second;
  } else {
    // Is domain part of a DomainRange template?
    in_range = get_domain_range_info(domain, dr_inst);
  }

  // check to see if this domain has a discovery template
  // and if the template instance has already been loaded.
  if (!in_range && is_discovery_template(repo)) {
    location = this->discoveryMap_.find(instance_name);
    if (location == this->discoveryMap_.end()) {
      if (configure_discovery_template(domain, repo)) {
        repo = instance_name;
      }
    }
  }

  location = this->discoveryMap_.find(repo);

  if (location == this->discoveryMap_.end()) {
    if (in_range) {
      const int ret = configure_domain_range_instance(domain);

      // return the newly configured domain and return it
      if (!ret) {
        return this->discoveryMap_[instance_name];
      } else {
        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                     ACE_TEXT("failed attempt to set RTPS discovery for domain range %d.\n"),
                     domain));
        }

        return Discovery_rch();
      }
    } else if ((repo == Discovery::DEFAULT_REPO) ||
        (repo == "-1")) {
      // Set the default repository IOR if it hasn't already happened
      // by this point.  This is why this can't be const.
      bool ok = this->set_repo_ior(DEFAULT_REPO_IOR, Discovery::DEFAULT_REPO);

      if (!ok) {
        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                     ACE_TEXT("failed attempt to set default IOR for domain %d.\n"),
                     domain));
        }

      } else {
        // Found the default!
        if (DCPS_debug_level > 4) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                     ACE_TEXT("returning default repository for domain %d.\n"),
                     domain));
        }

      }
      return this->discoveryMap_[Discovery::DEFAULT_REPO];

    } else if (repo == Discovery::DEFAULT_RTPS) {

      ACE_Configuration_Heap cf;
      cf.open();
      ACE_Configuration_Section_Key k;
      cf.open_section(cf.root_section(), RTPS_SECTION_NAME, true /*create*/, k);

      int status = load_discovery_configuration(cf, RTPS_SECTION_NAME);

      if (status != 0) {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: Service_Participant::get_Discovery ")
                   ACE_TEXT("failed attempt to load default RTPS discovery for domain %d.\n"),
                   domain));

        return Discovery_rch();
      }

      // Try to find it again
      location = this->discoveryMap_.find(Discovery::DEFAULT_RTPS);

      if (location == this->discoveryMap_.end()) {
        // Unable to load DEFAULT_RTPS
        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                     ACE_TEXT("failed attempt to set default RTPS discovery for domain %d.\n"),
                     domain));
        }

        return Discovery_rch();

      } else {
        // Found the default!
        if (DCPS_debug_level > 4) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                     ACE_TEXT("returning default RTPS discovery for domain %d.\n"),
                     domain));
        }

        return location->second;
      }

    } else {
      // Non-default repositories _must_ be loaded by application.
      if (DCPS_debug_level > 4) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
                   ACE_TEXT("repository for domain %d was not set.\n"),
                   domain));
      }

      return Discovery_rch();
    }
  }

  if (DCPS_debug_level > 4) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) Service_Participant::get_discovery: ")
               ACE_TEXT("returning repository for domain %d, repo %C.\n"),
               domain, repo.c_str()));
  }

  return location->second;
}

get_discovery_template_instance_name()

Discovery::RepoKey OpenDDS::DCPS::Service_Participant::get_discovery_template_instance_name ( DDS::DomainId_t  id )

private

Definition at line 2695 of file Service_Participant.cpp.

References OpenDDS::DCPS::to_dds_string().

Referenced by configure_discovery_template(), configure_domain_range_instance(), and get_discovery().

{
  OpenDDS::DCPS::Discovery::RepoKey configured_name = "rtps_template_instance_";
  configured_name += to_dds_string(id);
  return configured_name;
}

get_domain_participant_factory()

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* and -ORB* options and their arguments.

: Move ORB initialization to after the configuration file is processed and the initial scheduling policy and priority are established.

Definition at line 405 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, ACE_TEXT(), ACE_VERSION, ACE_ARGV_T< CHAR_TYPE >::add(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::NetworkConfigMonitor::close(), ACE::compiler_beta_version(), ACE::compiler_major_version(), ACE::compiler_minor_version(), ACE::compiler_name(), OpenDDS::DCPS::config_fname, OpenDDS::DCPS::NetworkConfigMonitor::connect(), ACE_Arg_Shifter_T< class >::consume_arg(), OpenDDS::DCPS::MonitorFactory::create_sp_monitor(), ACE_Arg_Shifter_T< class >::cur_arg_strncasecmp(), OpenDDS::DCPS::DCPS_debug_level, default_configuration_file_, OpenDDS::DCPS::NetworkConfigMonitor::disconnect(), dp_factory_servant_, OpenDDS::DCPS::LogLevel::Error, factory_lock_, ACE_OS::fclose(), ACE_OS::fopen(), OpenDDS::DCPS::LogLevel::get_as_string(), ACE_Arg_Shifter_T< class >::get_current(), OpenDDS::DCPS::ReactorTask::get_reactor(), ACE_Arg_Shifter_T< class >::ignore_arg(), OpenDDS::DCPS::LogLevel::Info, OpenDDS::DCPS::MonitorFactory::initialize(), initializeScheduling(), ACE_Dynamic_Service< class >::instance(), OpenDDS::DCPS::ReactorTask::interceptor(), ACE_Arg_Shifter_T< class >::is_anything_left(), ACE_String_Base< char >::is_empty(), ACE_Arg_Shifter_T< class >::is_parameter_next(), job_queue_, LM_DEBUG, LM_ERROR, LM_INFO, LM_NOTICE, LM_WARNING, load_configuration(), OpenDDS::DCPS::log_level, monitor_, monitor_enabled_, monitor_factory_, network_config_monitor_, network_interface_address_topic_, OpenDDS::DCPS::NetworkConfigMonitor::open(), OpenDDS::DCPS::ReactorTask::open_reactor_task(), OPENDDS_VERSION, ORB_argv_, parse_args(), ACE_Service_Config::process_directive(), reactor_task_, OpenDDS::DCPS::RcHandle< T >::reset(), OpenDDS::DCPS::MonitorFactory::service_initialize(), shut_down_, thread_status_manager_, uname(), and ACE_OS::uname().

Referenced by shutdown().

{
  if (!dp_factory_servant_) {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, factory_lock_, 0);

    shut_down_ = false;

    if (!dp_factory_servant_) {
      // This used to be a call to ORB_init().  Since the ORB is now managed
      // by InfoRepoDiscovery, just save the -ORB* args for later use.
      // The exceptions are -ORBLogFile and -ORBVerboseLogging, which
      // are processed by the service participant. This allows log control
      // even if an ORB is not being used.
#ifndef OPENDDS_SAFETY_PROFILE
      ORB_argv_.add(ACE_TEXT("unused_arg_0"));
#endif
      /* NOTE ABOUT ADDING NEW OPTIONS HERE ==================================
       *
       * The argument parsing here is simple. It will match substrings of
       * options even if that isn't the whole option. For example; If
       * "-DCPSSecurity" is checked before "-DCPSSecurityDebug" and
       * "-DCPSSecurityDebug" is passed, it will match "-DCPSSecurity". Check
       * to make sure the order is correct.
       *
       * TODO/TBD: Create or make use of a stricter command line argument
       * parsing method/library. Something where we can define the format of
       * the argument and it will handle it better. Maybe could be integrated
       * into the config parsing, which has most of these options.
       */
      ACE_Arg_Shifter shifter(argc, argv);
      while (shifter.is_anything_left()) {
        if (shifter.cur_arg_strncasecmp(ACE_TEXT("-ORBLogFile")) == 0) {
          shifter.ignore_arg();
        } else if (shifter.cur_arg_strncasecmp(ACE_TEXT("-ORBVerboseLogging")) == 0) {
          shifter.ignore_arg();
        } else if (shifter.cur_arg_strncasecmp(ACE_TEXT("-ORB")) < 0) {
          shifter.ignore_arg();
        } else {
#ifndef OPENDDS_SAFETY_PROFILE
          ORB_argv_.add(shifter.get_current());
#endif
          shifter.consume_arg();
          if (shifter.is_parameter_next()) {
#ifndef OPENDDS_SAFETY_PROFILE
            ORB_argv_.add(shifter.get_current(), true /*quote_arg*/);
#endif
            shifter.consume_arg();
          }
        }
      }

      if (parse_args(argc, argv) != 0) {
        return DDS::DomainParticipantFactory::_nil();
      }

      if (config_fname.is_empty() && !default_configuration_file_.is_empty()) {
        config_fname = default_configuration_file_;
      }

      if (config_fname.is_empty()) {
        if (DCPS_debug_level) {
          ACE_DEBUG((LM_NOTICE,
                     ACE_TEXT("(%P|%t) NOTICE: not using file configuration - no configuration ")
                     ACE_TEXT("file specified.\n")));
        }

      } else {
        // Load configuration only if the configuration
        // file exists.
        FILE* in = ACE_OS::fopen(config_fname.c_str(),
                                 ACE_TEXT("r"));

        if (!in) {
          ACE_DEBUG((LM_WARNING,
                     ACE_TEXT("(%P|%t) WARNING: not using file configuration - ")
                     ACE_TEXT("can not open \"%s\" for reading. %p\n"),
                     config_fname.c_str(), ACE_TEXT("fopen")));

        } else {
          ACE_OS::fclose(in);

          if (DCPS_debug_level > 1) {
            ACE_DEBUG((LM_NOTICE,
                        ACE_TEXT("(%P|%t) NOTICE: Service_Participant::get_domain_participant_factory ")
                        ACE_TEXT("Going to load configuration from <%s>\n"),
                        config_fname.c_str()));
          }

          if (this->load_configuration() != 0) {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("(%P|%t) ERROR: Service_Participant::get_domain_participant_factory: ")
                       ACE_TEXT("load_configuration() failed.\n")));
            return DDS::DomainParticipantFactory::_nil();
          }
        }
      }
#if OPENDDS_POOL_ALLOCATOR
      // For non-FACE tests, configure pool
      configure_pool();
#endif

      if (log_level >= LogLevel::Info) {
        ACE_DEBUG((LM_INFO, "(%P|%t) Service_Participant::get_domain_participant_factory: "
          "This is OpenDDS " OPENDDS_VERSION " using ACE " ACE_VERSION "\n"));

        ACE_DEBUG((LM_INFO, "(%P|%t) Service_Participant::get_domain_participant_factory: "
          "log_level: %C DCPS_debug_level: %u\n", log_level.get_as_string(), DCPS_debug_level));

        ACE_utsname uname;
        if (ACE_OS::uname(&uname) != -1) {
          ACE_DEBUG((LM_INFO, "(%P|%t) Service_Participant::get_domain_participant_factory: "
            "machine: %C, %C platform: %C, %C, %C\n",
            uname.nodename, uname.machine, uname.sysname, uname.release, uname.version));
        }

        ACE_DEBUG((LM_INFO, "(%P|%t) Service_Participant::get_domain_participant_factory: "
          "compiler: %C version %d.%d.%d\n",
          ACE::compiler_name(), ACE::compiler_major_version(), ACE::compiler_minor_version(), ACE::compiler_beta_version()));
      }

      // Establish the default scheduling mechanism and
      // priority here.  Sadly, the ORB is already
      // initialized so we have no influence over its
      // scheduling or thread priority(ies).

      /// @TODO: Move ORB initialization to after the
      ///        configuration file is processed and the
      ///        initial scheduling policy and priority are
      ///        established.
      this->initializeScheduling();

      dp_factory_servant_ = make_rch<DomainParticipantFactoryImpl>();

      reactor_task_.open_reactor_task(0,
                                      &thread_status_manager_,
                                      "Service_Participant");

      job_queue_ = make_rch<JobQueue>(reactor_task_.get_reactor());

      if (this->monitor_enabled_) {
#if !defined(ACE_AS_STATIC_LIBS)
        ACE_TString directive = ACE_TEXT("dynamic OpenDDS_Monitor Service_Object * OpenDDS_monitor:_make_MonitorFactoryImpl()");
        ACE_Service_Config::process_directive(directive.c_str());
#endif
        this->monitor_factory_ =
          ACE_Dynamic_Service<MonitorFactory>::instance ("OpenDDS_Monitor");

        if (this->monitor_factory_ == 0) {
          if (this->monitor_enabled_) {
            ACE_ERROR((LM_ERROR,
                       ACE_TEXT("ERROR: Service_Participant::get_domain_participant_factory, ")
                       ACE_TEXT("Unable to enable monitor factory.\n")));
          }
        }
      }

      if (this->monitor_factory_ == 0) {
        // Use the stubbed factory
        MonitorFactory::service_initialize();
        this->monitor_factory_ =
          ACE_Dynamic_Service<MonitorFactory>::instance ("OpenDDS_Monitor_Default");
      }
      if (this->monitor_enabled_) {
        this->monitor_factory_->initialize();
      }

      this->monitor_.reset(this->monitor_factory_->create_sp_monitor(this));
    }

#if defined OPENDDS_LINUX_NETWORK_CONFIG_MONITOR
    if (DCPS_debug_level >= 1) {
      ACE_DEBUG((LM_DEBUG,
                 "(%P|%t) Service_Participant::get_domain_participant_factory: Creating LinuxNetworkConfigMonitor\n"));
    }
    network_config_monitor_ = make_rch<LinuxNetworkConfigMonitor>(reactor_task_.interceptor());
#elif defined(OPENDDS_NETWORK_CONFIG_MODIFIER)
    if (DCPS_debug_level >= 1) {
      ACE_DEBUG((LM_DEBUG,
                 "(%P|%t) Service_Participant::get_domain_participant_factory: Creating NetworkConfigModifier\n"));
    }
    network_config_monitor_ = make_rch<NetworkConfigModifier>();
#else
    if (DCPS_debug_level >= 1) {
      ACE_DEBUG((LM_DEBUG,
                 "(%P|%t) Service_Participant::get_domain_participant_factory: Creating DefaultNetworkConfigMonitor\n"));
    }
    network_config_monitor_ = make_rch<DefaultNetworkConfigMonitor>();
#endif

    network_config_monitor_->connect(network_interface_address_topic_);
    if (!network_config_monitor_->open()) {
      bool open_failed = false;
#ifdef OPENDDS_NETWORK_CONFIG_MODIFIER
      if (DCPS_debug_level >= 1) {
        ACE_DEBUG((LM_DEBUG,
                   "(%P|%t) Service_Participant::get_domain_participant_factory: Creating NetworkConfigModifier\n"));
      }
      network_config_monitor_->disconnect(network_interface_address_topic_);
      network_config_monitor_ = make_rch<NetworkConfigModifier>();
      network_config_monitor_->connect(network_interface_address_topic_);
      if (!network_config_monitor_->open()) {
        open_failed = true;
      }
#else
      open_failed = true;
#endif
      if (open_failed) {
        if (log_level >= LogLevel::Error) {
          ACE_ERROR((LM_ERROR,
                     "(%P|%t) ERROR: Service_Participant::get_domain_participant_factory: Could not open network config monitor\n"));
        }
        network_config_monitor_->close();
        network_config_monitor_->disconnect(network_interface_address_topic_);
        network_config_monitor_.reset();
      }
    }
  }

  return DDS::DomainParticipantFactory::_duplicate(dp_factory_servant_.in());
}

get_domain_range_info()

bool OpenDDS::DCPS::Service_Participant::get_domain_range_info ( DDS::DomainId_t  id, DomainRange &  inst  )

private

Definition at line 2609 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Service_Participant::DomainRange::discovery_template_name, OpenDDS::DCPS::Service_Participant::DomainRange::domain_info, has_domain_range(), LM_DEBUG, OPENDDS_VECTOR(), OpenDDS::DCPS::Service_Participant::DomainRange::range_end, OpenDDS::DCPS::Service_Participant::DomainRange::range_start, and OpenDDS::DCPS::Service_Participant::DomainRange::transport_config_name.

Referenced by configure_domain_range_instance(), and get_discovery().

{
  if (has_domain_range()) {
    for (OPENDDS_VECTOR(DomainRange)::iterator it = domain_ranges_.begin();
         it != domain_ranges_.end(); ++it) {
      if (id >= it->range_start && id <= it->range_end) {
        inst.range_start = it->range_start;
        inst.range_end = it->range_end;
        inst.discovery_template_name = it->discovery_template_name;
        inst.transport_config_name = it->transport_config_name;
        inst.domain_info = it->domain_info;

        if (DCPS_debug_level > 0) {
          ACE_DEBUG((LM_DEBUG,
                     ACE_TEXT("(%P|%t) Service_Participant::get_domain_range_info(): ")
                     ACE_TEXT("Domain %d is in [%s/%d-%d]\n"),
                     id, DOMAIN_RANGE_SECTION_NAME, it->range_start, it->range_end));
        }

        return true;
      }
    }
  }
  return false;
}

get_dynamic_type()

DDS::ReturnCode_t OpenDDS::DCPS::Service_Participant::get_dynamic_type	(	DDS::DynamicType_var &	type,
		DDS::DomainParticipant_ptr	participant,
		const DDS::BuiltinTopicKey_t &	key
	)		const

Definition at line 2931 of file Service_Participant.cpp.

{
  return dynamic_cast<DomainParticipantImpl*>(participant)->get_dynamic_type(type, key);
}

get_security()

bool OpenDDS::DCPS::Service_Participant::get_security ( )

inline

Definition at line 320 of file Service_Participant.h.

                      {
    return security_enabled_;
  }

get_static_xtypes_lock()

ACE_Thread_Mutex & OpenDDS::DCPS::Service_Participant::get_static_xtypes_lock

(

)

getter for lock that protects the static initialization of XTypes related data structures

Definition at line 2879 of file Service_Participant.cpp.

References OpenDDS::DCPS::RcHandle< T >::get(), network_config_monitor_, and xtypes_lock_.

{
  return xtypes_lock_;
}

get_thread_status_manager()

ThreadStatusManager & OpenDDS::DCPS::Service_Participant::get_thread_status_manager

(

)

Get the service participant's thread status manager.

Definition at line 2874 of file Service_Participant.cpp.

References thread_status_manager_.

{
  return thread_status_manager_;
}

get_transport_base_config_name()

bool OpenDDS::DCPS::Service_Participant::get_transport_base_config_name	(	DDS::DomainId_t	domainId,
		ACE_TString &	name
	)		const

Definition at line 2348 of file Service_Participant.cpp.

References ACE_TEXT(), ACE_TEXT_CHAR_TO_TCHAR, global_transport_config_, OPENDDS_MAP(), and OPENDDS_STRING.

Referenced by configure_domain_range_instance().

{
  OPENDDS_MAP(DDS::DomainId_t, OPENDDS_STRING)::const_iterator it = domain_to_transport_name_map_.find(domainId);
  if ( it != domain_to_transport_name_map_.end()) {
    name = ACE_TEXT_CHAR_TO_TCHAR(it->second.c_str());
    return true;
  } else if (global_transport_config_ != ACE_TEXT("")) {
    name = global_transport_config_;
    return true;
  } else {
    return false;
  }
}

get_type_information()

XTypes::TypeInformation OpenDDS::DCPS::Service_Participant::get_type_information	(	DDS::DomainParticipant_ptr	participant,
		const DDS::BuiltinTopicKey_t &	key
	)		const

Get TypeInformation of a remote entity given the corresponding BuiltinTopicKey_t.

Definition at line 2916 of file Service_Participant.cpp.

References OpenDDS::DCPS::DomainParticipantImpl::get_type_lookup_service().

{
  DomainParticipantImpl* participant_servant = dynamic_cast<DomainParticipantImpl*>(participant);
  if (participant_servant) {
    XTypes::TypeLookupService_rch tls = participant_servant->get_type_lookup_service();
    if (tls) {
      return tls->get_type_info(key);
    }
  }

  return XTypes::TypeInformation();
}

get_type_object()

XTypes::TypeObject OpenDDS::DCPS::Service_Participant::get_type_object	(	DDS::DomainParticipant_ptr	participant,
		const XTypes::TypeIdentifier &	ti
	)		const

Get TypeObject for a given TypeIdentifier.

Definition at line 2939 of file Service_Participant.cpp.

References OpenDDS::DCPS::DomainParticipantImpl::get_type_lookup_service().

{
  DomainParticipantImpl* participant_servant = dynamic_cast<DomainParticipantImpl*>(participant);
  if (participant_servant) {
    XTypes::TypeLookupService_rch tls = participant_servant->get_type_lookup_service();
    if (tls) {
      return tls->get_type_object(ti);
    }
  }

  return XTypes::TypeObject();
}

has_domain_range()

bool OpenDDS::DCPS::Service_Participant::has_domain_range ( ) const

private

Definition at line 2603 of file Service_Participant.cpp.

Referenced by get_domain_range_info().

{
  return !domain_ranges_.empty();
}

initial_DataReaderQos()

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

(

)

const

Definition at line 234 of file Service_Participant.inl.

References ACE_INLINE, and initial_DataReaderQos_.

{
  return initial_DataReaderQos_;
}

initial_DataRepresentationQosPolicy()

ACE_INLINE const DDS::DataRepresentationQosPolicy & OpenDDS::DCPS::Service_Participant::initial_DataRepresentationQosPolicy

(

)

const

Definition at line 192 of file Service_Participant.inl.

References ACE_INLINE, and initial_DataRepresentationQosPolicy_.

{
  return initial_DataRepresentationQosPolicy_;
}

initial_DataWriterQos()

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

(

)

const

Definition at line 220 of file Service_Participant.inl.

References ACE_INLINE, and initial_DataWriterQos_.

{
  return initial_DataWriterQos_;
}

initial_DeadlineQosPolicy()

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

(

)

const

Definition at line 85 of file Service_Participant.inl.

References ACE_INLINE, and initial_DeadlineQosPolicy_.

{
  return initial_DeadlineQosPolicy_;
}

initial_DestinationOrderQosPolicy()

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

(

)

const

Definition at line 143 of file Service_Participant.inl.

References ACE_INLINE, and initial_DestinationOrderQosPolicy_.

{
  return initial_DestinationOrderQosPolicy_;
}

initial_DomainParticipantFactoryQos()

ACE_INLINE const DDS::DomainParticipantFactoryQos & OpenDDS::DCPS::Service_Participant::initial_DomainParticipantFactoryQos

(

)

const

Definition at line 199 of file Service_Participant.inl.

References ACE_INLINE, and initial_DomainParticipantFactoryQos_.

{
  return initial_DomainParticipantFactoryQos_;
}

initial_DomainParticipantQos()

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

(

)

const

Definition at line 206 of file Service_Participant.inl.

References ACE_INLINE, and initial_DomainParticipantQos_.

{
  return initial_DomainParticipantQos_;
}

initial_DurabilityQosPolicy()

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

(

)

const

Definition at line 64 of file Service_Participant.inl.

References ACE_INLINE, and initial_DurabilityQosPolicy_.

{
  return initial_DurabilityQosPolicy_;
}

initial_DurabilityServiceQosPolicy()

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

(

)

const

Definition at line 71 of file Service_Participant.inl.

References ACE_INLINE, and initial_DurabilityServiceQosPolicy_.

{
  return initial_DurabilityServiceQosPolicy_;
}

initial_EntityFactoryQosPolicy()

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

(

)

const

Definition at line 164 of file Service_Participant.inl.

References ACE_INLINE, and initial_EntityFactoryQosPolicy_.

{
  return initial_EntityFactoryQosPolicy_;
}

initial_GroupDataQosPolicy()

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

(

)

const

Definition at line 43 of file Service_Participant.inl.

References ACE_INLINE, and initial_GroupDataQosPolicy_.

{
  return initial_GroupDataQosPolicy_;
}

initial_HistoryQosPolicy()

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

(

)

const

Definition at line 150 of file Service_Participant.inl.

References ACE_INLINE, and initial_HistoryQosPolicy_.

{
  return initial_HistoryQosPolicy_;
}

initial_LatencyBudgetQosPolicy()

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

(

)

const

Definition at line 92 of file Service_Participant.inl.

References ACE_INLINE, and initial_LatencyBudgetQosPolicy_.

{
  return initial_LatencyBudgetQosPolicy_;
}

initial_LifespanQosPolicy()

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

(

)

const

Definition at line 57 of file Service_Participant.inl.

References ACE_INLINE, and initial_LifespanQosPolicy_.

{
  return initial_LifespanQosPolicy_;
}

initial_LivelinessQosPolicy()

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

(

)

const

Definition at line 115 of file Service_Participant.inl.

References ACE_INLINE, and initial_LivelinessQosPolicy_.

{
  return initial_LivelinessQosPolicy_;
}

initial_OwnershipQosPolicy()

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

(

)

const

Definition at line 99 of file Service_Participant.inl.

References ACE_INLINE, and initial_OwnershipQosPolicy_.

{
  return initial_OwnershipQosPolicy_;
}

initial_OwnershipStrengthQosPolicy()

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

(

)

const

Definition at line 107 of file Service_Participant.inl.

References ACE_INLINE, and initial_OwnershipStrengthQosPolicy_.

{
  return initial_OwnershipStrengthQosPolicy_;
}

initial_PartitionQosPolicy()

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

(

)

const

Definition at line 129 of file Service_Participant.inl.

References ACE_INLINE, and initial_PartitionQosPolicy_.

{
  return initial_PartitionQosPolicy_;
}

initial_PresentationQosPolicy()

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

(

)

const

Definition at line 78 of file Service_Participant.inl.

References ACE_INLINE, and initial_PresentationQosPolicy_.

{
  return initial_PresentationQosPolicy_;
}

initial_PropertyQosPolicy()

ACE_INLINE const DDS::PropertyQosPolicy & OpenDDS::DCPS::Service_Participant::initial_PropertyQosPolicy

(

)

const

Definition at line 185 of file Service_Participant.inl.

References ACE_INLINE, and initial_PropertyQosPolicy_.

{
  return initial_PropertyQosPolicy_;
}

initial_PublisherQos()

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

(

)

const

Definition at line 227 of file Service_Participant.inl.

References ACE_INLINE, and initial_PublisherQos_.

{
  return initial_PublisherQos_;
}

initial_ReaderDataLifecycleQosPolicy()

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

(

)

const

Definition at line 178 of file Service_Participant.inl.

References ACE_INLINE, and initial_ReaderDataLifecycleQosPolicy_.

{
  return initial_ReaderDataLifecycleQosPolicy_;
}

initial_ReliabilityQosPolicy()

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

(

)

const

Definition at line 136 of file Service_Participant.inl.

References ACE_INLINE, and initial_ReliabilityQosPolicy_.

{
  return initial_ReliabilityQosPolicy_;
}

initial_ResourceLimitsQosPolicy()

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

(

)

const

Definition at line 157 of file Service_Participant.inl.

References ACE_INLINE, and initial_ResourceLimitsQosPolicy_.

{
  return initial_ResourceLimitsQosPolicy_;
}

initial_SubscriberQos()

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

(

)

const

Definition at line 241 of file Service_Participant.inl.

References ACE_INLINE, and initial_SubscriberQos_.

{
  return initial_SubscriberQos_;
}

initial_TimeBasedFilterQosPolicy()

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

(

)

const

Definition at line 122 of file Service_Participant.inl.

References ACE_INLINE, and initial_TimeBasedFilterQosPolicy_.

{
  return initial_TimeBasedFilterQosPolicy_;
}

initial_TopicDataQosPolicy()

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

(

)

const

Definition at line 36 of file Service_Participant.inl.

References ACE_INLINE, and initial_TopicDataQosPolicy_.

{
  return initial_TopicDataQosPolicy_;
}

initial_TopicQos()

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

(

)

const

Definition at line 213 of file Service_Participant.inl.

References ACE_INLINE, and initial_TopicQos_.

{
  return initial_TopicQos_;
}

initial_TransportPriorityQosPolicy()

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

(

)

const

Definition at line 50 of file Service_Participant.inl.

References ACE_INLINE, and initial_TransportPriorityQosPolicy_.

{
  return initial_TransportPriorityQosPolicy_;
}

initial_TypeConsistencyEnforcementQosPolicy()

ACE_INLINE const DDS::TypeConsistencyEnforcementQosPolicy & OpenDDS::DCPS::Service_Participant::initial_TypeConsistencyEnforcementQosPolicy

(

)

const

Definition at line 248 of file Service_Participant.inl.

References ACE_INLINE, and initial_TypeConsistencyEnforcementQosPolicy_.

{
  return initial_TypeConsistencyEnforcementQosPolicy_;
}

initial_UserDataQosPolicy()

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

(

)

const

Accessors of the qos policy initial values.

Definition at line 29 of file Service_Participant.inl.

References ACE_INLINE, and initial_UserDataQosPolicy_.

{
  return initial_UserDataQosPolicy_;
}

initial_WriterDataLifecycleQosPolicy()

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

(

)

const

Definition at line 171 of file Service_Participant.inl.

References ACE_INLINE, and initial_WriterDataLifecycleQosPolicy_.

{
  return initial_WriterDataLifecycleQosPolicy_;
}

initialize()

void OpenDDS::DCPS::Service_Participant::initialize ( void  )

private

Initialize default qos.

Definition at line 833 of file Service_Participant.cpp.

References DDS::PresentationQosPolicy::access_scope, DDS::EntityFactoryQosPolicy::autoenable_created_entities, bit_autopurge_disposed_samples_delay_, bit_autopurge_nowriter_samples_delay_, DDS::PresentationQosPolicy::coherent_access, DDS::DURATION_INFINITE_NSEC, DDS::DURATION_INFINITE_SEC, DDS::PublisherQos::entity_factory, DDS::SubscriberQos::entity_factory, DDS::DomainParticipantFactoryQos::entity_factory, DDS::DomainParticipantQos::entity_factory, DDS::PublisherQos::group_data, DDS::SubscriberQos::group_data, initial_DataReaderQos_, initial_DataRepresentationQosPolicy_, initial_DataWriterQos_, initial_DeadlineQosPolicy_, initial_DestinationOrderQosPolicy_, initial_DomainParticipantFactoryQos_, initial_DomainParticipantQos_, initial_DurabilityQosPolicy_, initial_DurabilityServiceQosPolicy_, initial_EntityFactoryQosPolicy_, initial_GroupDataQosPolicy_, initial_HistoryQosPolicy_, initial_LatencyBudgetQosPolicy_, initial_LifespanQosPolicy_, initial_LivelinessQosPolicy_, initial_OwnershipQosPolicy_, initial_OwnershipStrengthQosPolicy_, initial_PartitionQosPolicy_, initial_PresentationQosPolicy_, initial_PublisherQos_, initial_ReaderDataLifecycleQosPolicy_, initial_ReliabilityQosPolicy_, initial_ResourceLimitsQosPolicy_, initial_SubscriberQos_, initial_TimeBasedFilterQosPolicy_, initial_TopicQos_, initial_TransportPriorityQosPolicy_, initial_TypeConsistencyEnforcementQosPolicy_, initial_UserDataQosPolicy_, initial_WriterDataLifecycleQosPolicy_, DDS::INSTANCE_PRESENTATION_QOS, DDS::Duration_t::nanosec, DDS::PresentationQosPolicy::ordered_access, DDS::PublisherQos::partition, DDS::SubscriberQos::partition, DDS::PublisherQos::presentation, DDS::SubscriberQos::presentation, DDS::Duration_t::sec, DDS::DomainParticipantQos::user_data, and DDS::DataRepresentationQosPolicy::value.

Referenced by Service_Participant().

{
  initial_TransportPriorityQosPolicy_ = TransportPriorityQosPolicyBuilder();
  initial_LifespanQosPolicy_ = LifespanQosPolicyBuilder();

  initial_DurabilityQosPolicy_ = DurabilityQosPolicyBuilder();

  initial_DurabilityServiceQosPolicy_ = DurabilityServiceQosPolicyBuilder();

  initial_PresentationQosPolicy_.access_scope = DDS::INSTANCE_PRESENTATION_QOS;
  initial_PresentationQosPolicy_.coherent_access = false;
  initial_PresentationQosPolicy_.ordered_access = false;

  initial_DeadlineQosPolicy_ = DeadlineQosPolicyBuilder();

  initial_LatencyBudgetQosPolicy_ = LatencyBudgetQosPolicyBuilder();

  initial_OwnershipQosPolicy_ = OwnershipQosPolicyBuilder();
  initial_OwnershipStrengthQosPolicy_ = OwnershipStrengthQosPolicyBuilder();

  initial_LivelinessQosPolicy_ = LivelinessQosPolicyBuilder();

  initial_TimeBasedFilterQosPolicy_ = TimeBasedFilterQosPolicyBuilder();

  initial_ReliabilityQosPolicy_ = ReliabilityQosPolicyBuilder();

  initial_DestinationOrderQosPolicy_ = DestinationOrderQosPolicyBuilder();

  initial_HistoryQosPolicy_ = HistoryQosPolicyBuilder();

  initial_ResourceLimitsQosPolicy_ = ResourceLimitsQosPolicyBuilder();

  initial_EntityFactoryQosPolicy_.autoenable_created_entities = true;

  initial_WriterDataLifecycleQosPolicy_ = WriterDataLifecycleQosPolicyBuilder();

  // Will get interpreted based on how the type was annotated.
  initial_DataRepresentationQosPolicy_.value.length(0);

  initial_ReaderDataLifecycleQosPolicy_ = ReaderDataLifecycleQosPolicyBuilder();

  initial_TypeConsistencyEnforcementQosPolicy_ = TypeConsistencyEnforcementQosPolicyBuilder();

  initial_DomainParticipantQos_.user_data = initial_UserDataQosPolicy_;
  initial_DomainParticipantQos_.entity_factory = initial_EntityFactoryQosPolicy_;
  initial_DomainParticipantFactoryQos_.entity_factory = initial_EntityFactoryQosPolicy_;

  initial_TopicQos_ = TopicQosBuilder();

  initial_DataWriterQos_ = DataWriterQosBuilder();

  initial_PublisherQos_.presentation = initial_PresentationQosPolicy_;
  initial_PublisherQos_.partition = initial_PartitionQosPolicy_;
  initial_PublisherQos_.group_data = initial_GroupDataQosPolicy_;
  initial_PublisherQos_.entity_factory = initial_EntityFactoryQosPolicy_;

  initial_DataReaderQos_ = DataReaderQosBuilder();

  initial_SubscriberQos_.presentation = initial_PresentationQosPolicy_;
  initial_SubscriberQos_.partition = initial_PartitionQosPolicy_;
  initial_SubscriberQos_.group_data = initial_GroupDataQosPolicy_;
  initial_SubscriberQos_.entity_factory = initial_EntityFactoryQosPolicy_;

  bit_autopurge_nowriter_samples_delay_.sec = DDS::DURATION_INFINITE_SEC;
  bit_autopurge_nowriter_samples_delay_.nanosec = DDS::DURATION_INFINITE_NSEC;
  bit_autopurge_disposed_samples_delay_.sec = DDS::DURATION_INFINITE_SEC;
  bit_autopurge_disposed_samples_delay_.nanosec = DDS::DURATION_INFINITE_NSEC;
}

initializeScheduling()

void OpenDDS::DCPS::Service_Participant::initializeScheduling ( )

private

Initialize the thread scheduling and initial priority.

Definition at line 903 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_SCHED_FIFO, ACE_SCHED_OTHER, ACE_SCHED_RR, ACE_SCOPE_THREAD, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, EPERM, ACE_OS::last_error(), ACE_String_Base< char >::length(), LM_DEBUG, LM_ERROR, LM_NOTICE, LM_WARNING, ACE_Sched_Params::priority_max(), priority_max_, ACE_Sched_Params::priority_min(), priority_min_, ACE_OS::sched_params(), scheduler_, schedulerQuantum_, schedulerString_, set_repo_ior(), and OpenDDS::DCPS::TimeDuration::value().

Referenced by get_domain_participant_factory().

{
  //
  // Establish the scheduler if specified.
  //
  if (this->schedulerString_.length() == 0) {
    if (DCPS_debug_level > 0) {
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: Service_Participant::intializeScheduling() - ")
                 ACE_TEXT("no scheduling policy specified, not setting policy.\n")));
    }

  } else {
    //
    // Translate the scheduling policy to a usable value.
    //
    int ace_scheduler = ACE_SCHED_OTHER;
    this->scheduler_  = THR_SCHED_DEFAULT;

    if (this->schedulerString_ == ACE_TEXT("SCHED_RR")) {
      this->scheduler_ = THR_SCHED_RR;
      ace_scheduler    = ACE_SCHED_RR;

    } else if (this->schedulerString_ == ACE_TEXT("SCHED_FIFO")) {
      this->scheduler_ = THR_SCHED_FIFO;
      ace_scheduler    = ACE_SCHED_FIFO;

    } else if (this->schedulerString_ == ACE_TEXT("SCHED_OTHER")) {
      this->scheduler_ = THR_SCHED_DEFAULT;
      ace_scheduler    = ACE_SCHED_OTHER;

    } else {
      ACE_DEBUG((LM_WARNING,
                 ACE_TEXT("(%P|%t) WARNING: Service_Participant::initializeScheduling() - ")
                 ACE_TEXT("unrecognized scheduling policy: %s, set to SCHED_OTHER.\n"),
                 this->schedulerString_.c_str()));
    }

    //
    // Attempt to set the scheduling policy.
    //
#ifdef ACE_WIN32
    ACE_DEBUG((LM_NOTICE,
               ACE_TEXT("(%P|%t) NOTICE: Service_Participant::initializeScheduling() - ")
               ACE_TEXT("scheduling is not implemented on Win32.\n")));
    ACE_UNUSED_ARG(ace_scheduler);
#else
    ACE_Sched_Params params(
      ace_scheduler,
      ACE_Sched_Params::priority_min(ace_scheduler),
      ACE_SCOPE_THREAD,
      schedulerQuantum_.value());

    if (ACE_OS::sched_params(params) != 0) {
      if (ACE_OS::last_error() == EPERM) {
        ACE_DEBUG((LM_WARNING,
                   ACE_TEXT("(%P|%t) WARNING: Service_Participant::initializeScheduling() - ")
                   ACE_TEXT("user is not superuser, requested scheduler not set.\n")));

      } else {
        ACE_ERROR((LM_ERROR,
                   ACE_TEXT("(%P|%t) ERROR: Service_Participant::initializeScheduling() - ")
                   ACE_TEXT("sched_params failed: %m.\n")));
      }

      // Reset the scheduler value(s) if we did not succeed.
      this->scheduler_ = -1;
      ace_scheduler    = ACE_SCHED_OTHER;

    } else if (DCPS_debug_level > 0) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) Service_Participant::initializeScheduling() - ")
                 ACE_TEXT("scheduling policy set to %s(%d).\n"),
                 this->schedulerString_.c_str()));
    }

    //
    // Setup some scheduler specific information for later use.
    //
    this->priority_min_ = ACE_Sched_Params::priority_min(ace_scheduler, ACE_SCOPE_THREAD);
    this->priority_max_ = ACE_Sched_Params::priority_max(ace_scheduler, ACE_SCOPE_THREAD);
#endif // ACE_WIN32
  }
}

instance()

Service_Participant * OpenDDS::DCPS::Service_Participant::instance ( void  )

static

Return a singleton instance of this class.

Definition at line 266 of file Service_Participant.cpp.

References ACE_Singleton< TYPE, ACE_LOCK >::instance().

{
  // Hide the template instantiation to prevent multiple instances
  // from being created.

  return ACE_Singleton<Service_Participant, ACE_SYNCH_MUTEX>::instance();
}

interceptor()

ReactorInterceptor_rch OpenDDS::DCPS::Service_Participant::interceptor

(

)

const

Definition at line 299 of file Service_Participant.cpp.

References OpenDDS::DCPS::ReactorTask::interceptor(), and reactor_task_.

{
  return reactor_task_.interceptor();
}

is_discovery_template()

bool OpenDDS::DCPS::Service_Participant::is_discovery_template ( const OPENDDS_STRING &  name )

private

Definition at line 2703 of file Service_Participant.cpp.

References ACE_Allocator::instance(), and OPENDDS_VECTOR().

Referenced by get_discovery().

{
  OPENDDS_VECTOR(DiscoveryInfo)::const_iterator i;
  for (i = discovery_infos_.begin(); i != discovery_infos_.end(); ++i) {
    if (i->discovery_name == name && !i->customizations.empty()) {
      return true;
    }
  }

  return false;
}

is_shut_down()

ACE_INLINE bool OpenDDS::DCPS::Service_Participant::is_shut_down

(

)

const

Accessor for if the participant has been shutdown.

Definition at line 373 of file Service_Participant.inl.

References ACE_INLINE, and shut_down_.

{
  return shut_down_;
}

job_queue()

JobQueue_rch OpenDDS::DCPS::Service_Participant::job_queue

(

)

const

Definition at line 305 of file Service_Participant.cpp.

References job_queue_.

{
  return job_queue_;
}

liveliness_factor() [1/2]

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.

Definition at line 1489 of file Service_Participant.cpp.

References liveliness_factor_.

{
  liveliness_factor_ = factor;
  got_liveliness_factor = true;
}

liveliness_factor() [2/2]

int OpenDDS::DCPS::Service_Participant::liveliness_factor

(

)

const

Accessor of the Liveliness propagation delay factor.

Returns

% of lease period before sending a liveliness message.

Definition at line 1496 of file Service_Participant.cpp.

References liveliness_factor_.

{
  return liveliness_factor_;
}

load_common_configuration()

int OpenDDS::DCPS::Service_Participant::load_common_configuration ( ACE_Configuration_Heap &  cf, const ACE_TCHAR *  filename  )

private

Load the common configuration to the Service_Participant singleton.

Note

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

Definition at line 1681 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, association_chunk_multiplier_, ACE_OS::atoi(), bidir_giop_, bit_enabled_, bit_lookup_duration_msec_, bit_transport_ip_, bit_transport_port_, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, default_address_, OpenDDS::DCPS::Discovery::DEFAULT_REPO, defaultDiscovery_, ACE_String_Base< char >::empty(), OpenDDS::DCPS::SecurityDebug::fake_encryption, federation_backoff_multiplier_, federation_initial_backoff_seconds_, federation_liveliness_, federation_recovery_duration_, ACE_Configuration_Heap::find_value(), GET_CONFIG_STRING_VALUE, GET_CONFIG_TSTRING_VALUE, GET_CONFIG_VALUE, ACE_Configuration_Heap::get_string_value(), global_transport_config_, liveliness_factor_, LM_ERROR, LM_NOTICE, LM_WARNING, OpenDDS::DCPS::log_bits, OpenDDS::DCPS::log_level, monitor_enabled_, n_chunks_, ACE_Configuration_Heap::open_section(), OPENDDS_STRING, OpenDDS::DCPS::SecurityDebug::parse_flags(), pending_timeout_, persistent_data_dir_, publisher_content_filter_, ACE_Configuration::root_section(), schedulerQuantum_, schedulerString_, OpenDDS::DCPS::security_debug, security_enabled_, ACE_INET_Addr::set(), OpenDDS::DCPS::SecurityDebug::set_debug_level(), OpenDDS::DCPS::LogLevel::set_from_string(), set_repo_ior(), OpenDDS::DCPS::ThreadStatusManager::thread_status_interval(), thread_status_manager_, OpenDDS::DCPS::Transport_debug_level, type_object_encoding(), and value.

Referenced by load_configuration().

{
  const ACE_Configuration_Section_Key &root = cf.root_section();
  ACE_Configuration_Section_Key sect;

  if (cf.open_section(root, COMMON_SECTION_NAME, false, sect) != 0) {
    if (DCPS_debug_level > 0) {
      // This is not an error if the configuration file does not have
      // a common section. The code default configuration will be used.
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: Service_Participant::load_common_configuration ")
                 ACE_TEXT("failed to open section %s\n"),
                 COMMON_SECTION_NAME));
    }

    return 0;

  } else {
    const ACE_TCHAR* message =
      ACE_TEXT("(%P|%t) NOTICE: using %s value from command option (overrides value if it's in config file)\n");

    if (got_debug_level) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSDebugLevel")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSDebugLevel"), DCPS_debug_level, int)
    }

    if (got_info) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSInfoRepo")));
    } else {
      ACE_TString value;
      GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DCPSInfoRepo"), value)
      if (!value.empty()) {
        this->set_repo_ior(value.c_str(), Discovery::DEFAULT_REPO);
      }
    }

    if (got_use_rti_serialization) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSRTISerialization")));
    } else {
      bool should_use = true;
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSRTISerialization"), should_use, bool)
      if (!should_use) {
        ACE_ERROR((LM_WARNING,
          ACE_TEXT("(%P|%t) WARNING: Service_Participant::load_common_configuration ")
          ACE_TEXT("Argument ignored: DCPSRTISerialization is required to be enabled\n")));
      }
    }

    if (got_chunks) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSChunks")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSChunks"), this->n_chunks_, size_t)
    }

    if (got_chunk_association_multiplier) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSChunkAssociationMultiplier")));
    } else {
      // This is legacy support for a misspelling of the config option.
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSChunkAssociationMutltiplier"), this->association_chunk_multiplier_, size_t)
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSChunkAssociationMultiplier"), this->association_chunk_multiplier_, size_t)
    }

    if (got_bit_transport_port) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSBitTransportPort")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSBitTransportPort"), this->bit_transport_port_, int)
    }

    if (got_bit_transport_ip) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSBitTransportIPAddress")));
    } else {
      GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DCPSBitTransportIPAddress"), this->bit_transport_ip_)
    }

    if (got_liveliness_factor) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSLivelinessFactor")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSLivelinessFactor"), this->liveliness_factor_, int)
    }

    if (got_bit_lookup_duration_msec) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSBitLookupDurationMsec")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSBitLookupDurationMsec"), this->bit_lookup_duration_msec_, int)
    }

    if (got_global_transport_config) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSGlobalTransportConfig")));
    } else {
      GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DCPSGlobalTransportConfig"), this->global_transport_config_);
      if (this->global_transport_config_ == ACE_TEXT("$file")) {
        // When the special string of "$file" is used, substitute the file name
        this->global_transport_config_ = filename;
      }
    }

    if (got_bit_flag) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSBit")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSBit"), this->bit_enabled_, int)
    }

    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSLogBits"), log_bits, bool);

#if defined(OPENDDS_SECURITY)
    if (got_security_flag) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSSecurity")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSSecurity"), this->security_enabled_, int)
    }

    if (got_security_debug) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSSecurityDebug or DCPSSecurityDebugLevel")));
    } else {
      const ACE_TCHAR* debug_name = ACE_TEXT("DCPSSecurityDebug");
      const ACE_TCHAR* debug_level_name = ACE_TEXT("DCPSSecurityDebugLevel");
      bool got_value = false;
      ACE_TString debug_level_value;
      if (cf.get_string_value(sect, debug_level_name, debug_level_value) == -1) {
        ACE_TString debug_value;
        if (cf.get_string_value(sect, debug_name, debug_value) != -1) {
          if (debug_value != ACE_TEXT("")) {
            got_value = true;
            security_debug.parse_flags(debug_value.c_str());
          }
        }
      } else if (debug_level_value != ACE_TEXT("")) {
        got_value = true;
        security_debug.set_debug_level(ACE_OS::atoi(debug_level_value.c_str()));
      }
      if (!got_value && OpenDDS::DCPS::Transport_debug_level > 0) {
        ACE_DEBUG((LM_NOTICE,
          ACE_TEXT("(%P|%t) NOTICE: DCPSSecurityDebug and DCPSSecurityDebugLevel ")
          ACE_TEXT("are not defined in config file or are blank - using code default.\n")));
      }
    }

    if (got_security_fake_encryption) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSSecurityFakeEncryption")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSSecurityFakeEncryption"), security_debug.fake_encryption, int)
    }
#endif

    if (got_transport_debug_level) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSTransportDebugLevel")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSTransportDebugLevel"), OpenDDS::DCPS::Transport_debug_level, int)
    }

#ifndef OPENDDS_NO_PERSISTENCE_PROFILE
    if (got_persistent_data_dir) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSPersistentDataDir")));
    } else {
      ACE_TString value;
      GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DCPSPersistentDataDir"), value)
      this->persistent_data_dir_ = ACE_TEXT_ALWAYS_CHAR(value.c_str());
    }
#endif

    if (got_pending_timeout) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSPendingTimeout")));
    } else {
      int timeout = 0;
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSPendingTimeout"), timeout, int)
      pending_timeout_ = TimeDuration(timeout);
    }

    if (got_publisher_content_filter) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSPublisherContentFilter")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSPublisherContentFilter"),
        this->publisher_content_filter_, bool)
    }

    if (got_default_discovery) {
      ACE_Configuration::VALUETYPE type;
      if (cf.find_value(sect, ACE_TEXT("DCPSDefaultDiscovery"), type) != -1) {
        ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSDefaultDiscovery")));
      }
    } else {
      GET_CONFIG_STRING_VALUE(cf, sect, ACE_TEXT("DCPSDefaultDiscovery"),
        this->defaultDiscovery_);
    }

    if (got_bidir_giop) {
      ACE_Configuration::VALUETYPE type;
      if (cf.find_value(sect, ACE_TEXT("DCPSBidirGIOP"), type) != -1) {
        ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSBidirGIOP")));
      }
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSBidirGIOP"), bidir_giop_, bool)
    }

    if (got_thread_status_interval) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSThreadStatusInterval")));
    } else {
      int interval = 0;
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSThreadStatusInterval"), interval, int);
      thread_status_manager_.thread_status_interval(TimeDuration(interval));
    }

    ACE_Configuration::VALUETYPE type;
    if (got_log_fname) {
      if (cf.find_value(sect, ACE_TEXT("ORBLogFile"), type) != -1) {
        ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("ORBLogFile")));
      }
    } else {
      OPENDDS_STRING log_fname;
      GET_CONFIG_STRING_VALUE(cf, sect, ACE_TEXT("ORBLogFile"), log_fname);
      if (!log_fname.empty()) {
        set_log_file_name(log_fname.c_str());
      }
    }

    if (got_log_verbose) {
      if (cf.find_value(sect, ACE_TEXT("ORBVerboseLogging"), type) != -1) {
        ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("ORBVerboseLogging")));
      }
    } else {
      unsigned long verbose_logging = 0;
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("ORBVerboseLogging"), verbose_logging, unsigned long);
      set_log_verbose(verbose_logging);
    }

    if (got_default_address) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSDefaultAddress")));
    } else {
      ACE_TString default_address_str;
      GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("DCPSDefaultAddress"), default_address_str);
      ACE_INET_Addr addr;
      if (!default_address_str.empty() &&
          addr.set(u_short(0), default_address_str.c_str())) {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_common_configuration: ")
                          ACE_TEXT("failed to parse default address %C\n"),
                          default_address_str.c_str()),
                         -1);
      }
      default_address_ = NetworkAddress(addr);
    }

    if (got_monitor) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSMonitor")));
    } else {
      GET_CONFIG_VALUE(cf, sect, ACE_TEXT("DCPSMonitor"), monitor_enabled_, bool)
    }

    if (got_type_object_encoding) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSTypeObjectEncoding")));
    } else {
      String str;
      GET_CONFIG_STRING_VALUE(cf, sect, ACE_TEXT("DCPSTypeObjectEncoding"), str);
      if (!str.empty()) {
        type_object_encoding(str.c_str());
      }
    }

    if (got_log_level) {
      ACE_DEBUG((LM_NOTICE, message, ACE_TEXT("DCPSLogLevel")));
    } else {
      String str;
      GET_CONFIG_STRING_VALUE(cf, sect, ACE_TEXT("DCPSLogLevel"), str);
      if (!str.empty()) {
        log_level.set_from_string(str.c_str());
      }
    }

    // These are not handled on the command line.
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("FederationRecoveryDuration"), this->federation_recovery_duration_, int)
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("FederationInitialBackoffSeconds"), this->federation_initial_backoff_seconds_, int)
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("FederationBackoffMultiplier"), this->federation_backoff_multiplier_, int)
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("FederationLivelinessDuration"), this->federation_liveliness_, int)

#if OPENDDS_POOL_ALLOCATOR
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("pool_size"), pool_size_, size_t)
    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("pool_granularity"), pool_granularity_, size_t)
#endif

    //
    // Establish the scheduler if specified.
    //
    GET_CONFIG_TSTRING_VALUE(cf, sect, ACE_TEXT("scheduler"), this->schedulerString_)

    suseconds_t usec(0);

    GET_CONFIG_VALUE(cf, sect, ACE_TEXT("scheduler_slice"), usec, suseconds_t)

    if (usec > 0) {
      schedulerQuantum_ = TimeDuration(0, usec);
    }
  }

  return 0;
}

load_configuration() [1/2]

int OpenDDS::DCPS::Service_Participant::load_configuration	(	ACE_Configuration_Heap &	cf,
		const ACE_TCHAR *	filename
	)

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 TransportRegistry singleton.

Definition at line 1538 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, add_discovery(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::TransportRegistry::get_config(), OpenDDS::DCPS::TransportRegistry::global_config(), global_transport_config_, OpenDDS::DCPS::TransportRegistry::instance(), OpenDDS::DCPS::StaticDiscovery::instance(), LM_ERROR, LM_NOTICE, load_common_configuration(), load_discovery_configuration(), load_discovery_templates(), load_domain_configuration(), load_domain_ranges(), OpenDDS::DCPS::TransportRegistry::load_transport_configuration(), OpenDDS::DCPS::TransportRegistry::load_transport_templates(), and TheTransportRegistry.

{
  // Domain config is loaded after Discovery (see below). Since the domain
  // could be a domain_range that specifies the DiscoveryTemplate, check
  // for config templates before loading any config information.
  ACE_TString section_name;

  int status = this->load_common_configuration(config, filename);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_common_configuration () returned %d\n"),
                      status),
                     -1);
  }

  // Register static discovery.
  this->add_discovery(static_rchandle_cast<Discovery>(StaticDiscovery::instance()));

  // load any discovery configuration templates before rtps discovery
  // this will populate the domain_range_templates_
  status = this->load_domain_ranges(config);

  // load any rtps_discovery templates
  status = this->load_discovery_templates(config);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_domain_range_configuration() returned %d\n"),
                      status),
                     -1);
  }

  status = this->load_discovery_configuration(config, RTPS_SECTION_NAME);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_discovery_configuration() returned %d\n"),
                      status),
                     -1);
  }

  status = this->load_discovery_configuration(config, REPO_SECTION_NAME);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_discovery_configuration() returned %d\n"),
                      status),
                     -1);
  }

  // load any transport configuration templates before the transport config
  status = TransportRegistry::instance()->load_transport_templates(config);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_transport_templates() returned %d\n"),
                      status),
                     -1);
  }

  status = TransportRegistry::instance()->load_transport_configuration(
             ACE_TEXT_ALWAYS_CHAR(filename), config);
  if (this->global_transport_config_ != ACE_TEXT("")) {
    TransportConfig_rch config = TransportRegistry::instance()->get_config(
      ACE_TEXT_ALWAYS_CHAR(this->global_transport_config_.c_str()));
    if (config) {
      TransportRegistry::instance()->global_config(config);
    } else if (TheTransportRegistry->config_has_transport_template(global_transport_config_)) {
      if (DCPS_debug_level > 0) {
        // This is not an error.
        ACE_DEBUG((LM_NOTICE,
                   ACE_TEXT("(%P|%t) NOTICE: Service_Participant::load_configuration ")
                   ACE_TEXT("DCPSGlobalTransportConfig %C is a transport_template\n"),
                   this->global_transport_config_.c_str()));
      }
    } else {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                        ACE_TEXT("Unable to locate specified global transport config: %C\n"),
                        this->global_transport_config_.c_str()),
                       -1);
    }
  }

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_transport_configuration () returned %d\n"),
                      status),
                     -1);
  }

  // Needs to be loaded after the [rtps_discovery/*] and [repository/*]
  // sections to allow error reporting on bad discovery config names.
  // Also loaded after the transport configuration so that
  // DefaultTransportConfig within [domain/*] can use TransportConfig objects.
  status = this->load_domain_configuration(config, filename);

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_domain_configuration () returned %d\n"),
                      status),
                     -1);
  }

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("load_domain_configuration () returned %d\n"),
                      status),
                     -1);
  }

  // Needs to be loaded after transport configs and instances and domains.
  try {
    status = StaticDiscovery::instance()->load_configuration(config);

    if (status != 0) {
      ACE_ERROR_RETURN((LM_ERROR,
        ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
        ACE_TEXT("load_discovery_configuration() returned %d\n"),
        status),
        -1);
    }
  } catch (const CORBA::BAD_PARAM& ex) {
    ex._tao_print_exception("Exception caught in Service_Participant::load_configuration: "
      "trying to load_discovery_configuration()");
    return -1;
  }

  return 0;
}

load_configuration() [2/2]

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 TransportRegistry singleton.

Definition at line 1509 of file Service_Participant.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), ACE_String_Base< char >::c_str(), OpenDDS::DCPS::config_fname, ACE_Ini_ImpExp::import_config(), LM_ERROR, and ACE_Configuration_Heap::open().

Referenced by get_domain_participant_factory().

{
  ACE_Configuration_Heap cf;
  int status = 0;

  if ((status = cf.open()) != 0)
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("open() returned %d\n"),
                      status),
                     -1);

  ACE_Ini_ImpExp import(cf);
  status = import.import_config(config_fname.c_str());

  if (status != 0) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) ERROR: Service_Participant::load_configuration ")
                      ACE_TEXT("import_config () returned %d\n"),
                      status),
                     -1);
  } else {
    status = this->load_configuration(cf, config_fname.c_str());
  }

  return status;
}

load_discovery_configuration()

int OpenDDS::DCPS::Service_Participant::load_discovery_configuration ( ACE_Configuration_Heap &  cf, const ACE_TCHAR *  section_name  )

private

Load the discovery configuration to the Service_Participant singleton.

Definition at line 2363 of file Service_Participant.cpp.

References ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, discovery_types_, LM_ERROR, ACE_Configuration_Heap::open_section(), OPENDDS_STRING, ACE_Configuration::root_section(), and TheTransportRegistry.

Referenced by configure_discovery_template(), configure_domain_range_instance(), get_discovery(), and load_configuration().

{
  const ACE_Configuration_Section_Key &root = cf.root_section();
  ACE_Configuration_Section_Key sect;
  if (cf.open_section(root, section_name, false, sect) == 0) {

    const OPENDDS_STRING sect_name = ACE_TEXT_ALWAYS_CHAR(section_name);
    DiscoveryTypes::iterator iter =
      this->discovery_types_.find(sect_name);

    if (iter == this->discovery_types_.end()) {
      // See if we can dynamically load the required libraries
      TheTransportRegistry->load_transport_lib(sect_name);
      iter = this->discovery_types_.find(sect_name);
    }

    if (iter != this->discovery_types_.end()) {
      // discovery code is loaded, process options
      return iter->second->discovery_config(cf);
    } else {
      // No discovery code can be loaded, report an error
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                        ACE_TEXT("load_discovery_configuration(): ")
                        ACE_TEXT("Unable to load libraries for %s\n"),
                        section_name),
                       -1);
    }
  }
  return 0;
}

load_discovery_templates()

int OpenDDS::DCPS::Service_Participant::load_discovery_templates ( ACE_Configuration_Heap &  cf )

private

Load the discovery template information

Definition at line 2455 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, OpenDDS::DCPS::CUSTOMIZATION_SECTION_NAME, OpenDDS::DCPS::Service_Participant::DiscoveryInfo::customizations, OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Service_Participant::DiscoveryInfo::disc_info, OpenDDS::DCPS::Service_Participant::DiscoveryInfo::discovery_name, LM_DEBUG, LM_ERROR, ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, OpenDDS::DCPS::processSections(), OpenDDS::DCPS::pullValues(), and ACE_Configuration::root_section().

Referenced by load_configuration().

{
  // open the rtps_discovery config sections
  cf.open();
  const ACE_Configuration_Section_Key& root = cf.root_section();
  ACE_Configuration_Section_Key rtps_sect;

  if (cf.open_section(root, RTPS_SECTION_NAME, false, rtps_sect) == 0) {
    ValueMap vm;
    if (pullValues(cf, rtps_sect, vm) > 0) {
    // There are values inside [rtps_discovery]
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) Service_Participant::load_discovery_templates(): ")
                      ACE_TEXT("rtps_discovery sections must have a subsection name\n")),
                     -1);
    }

    // Process the subsections of this section (the individual domains)
    KeyList keys;
    if (processSections(cf, rtps_sect, keys) != 0) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) Service_Participant::load_discovery_templates(): ")
                        ACE_TEXT("too many nesting layers in the [rtps_discovery] section.\n")),
                       -1);
    }

    // store the discovery information
    for (KeyList::const_iterator disc_it = keys.begin(); disc_it != keys.end(); ++disc_it) {
      DiscoveryInfo dinfo;
      dinfo.discovery_name = disc_it->first;

      ValueMap values;
      if (pullValues(cf, disc_it->second, values) > 0) {
        for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
          // check for customizations
          if (it->first == ACE_TEXT_ALWAYS_CHAR(CUSTOMIZATION_SECTION_NAME)) {
            OPENDDS_STRING customization = it->second;
            if (DCPS_debug_level > 0) {
              ACE_DEBUG((LM_DEBUG,
                         ACE_TEXT("(%P|%t) Service_Participant::load_discovery_templates(): ")
                         ACE_TEXT("loading customizations [%s/%C]\n"),
                         CUSTOMIZATION_SECTION_NAME,
                         customization.c_str()));
            }

            ACE_Configuration_Section_Key custom_sect;
            if (cf.open_section(root, CUSTOMIZATION_SECTION_NAME, false, custom_sect) == 0) {
              ValueMap vcm;
              if (pullValues(cf, custom_sect, vcm) > 0) {
                ACE_ERROR_RETURN((LM_ERROR,
                                  ACE_TEXT("(%P|%t) Service_Participant::load_discovery_templates(): ")
                                  ACE_TEXT("%s sections must have a subsection name\n"),
                                  CUSTOMIZATION_SECTION_NAME),
                                 -1);
              }

              // Process the subsections of the custom section
              KeyList keys;
              if (processSections(cf, custom_sect, keys) != 0) {
                ACE_ERROR_RETURN((LM_ERROR,
                                  ACE_TEXT("(%P|%t) Service_Participant::load_discovery_templates(): ")
                                  ACE_TEXT("too many nesting layers in the [%s] section.\n"),
                                  CUSTOMIZATION_SECTION_NAME),
                                 -1);
              }

              // add customizations to domain range
              for (KeyList::const_iterator iter = keys.begin(); iter != keys.end(); ++iter) {
                if (customization == iter->first) {
                  ValueMap values;
                  pullValues(cf, iter->second, values);
                  for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
                    dinfo.customizations[it->first] = it->second;
                  }
                }
              }
            }
          } else {
              dinfo.disc_info[it->first] = it->second;
          }
        }
      }

      discovery_infos_.push_back(dinfo);
    }
  }

  // return 0 even if no templates were loaded
  return 0;
}

load_domain_configuration()

int OpenDDS::DCPS::Service_Participant::load_domain_configuration ( ACE_Configuration_Heap &  cf, const ACE_TCHAR *  filename  )

private

Load the domain configuration to the Service_Participant singleton.

Definition at line 1980 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, OpenDDS::DCPS::convertToInteger(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Discovery::DEFAULT_REPO, OpenDDS::DCPS::Discovery::DEFAULT_RTPS, OpenDDS::DCPS::Discovery::DEFAULT_STATIC, discoveryMap_, OpenDDS::DCPS::TransportRegistry::domain_default_config(), OpenDDS::DCPS::TransportRegistry::get_config(), OpenDDS::DCPS::TransportRegistry::instance(), OpenDDS::DCPS::RcHandle< T >::is_nil(), LM_DEBUG, LM_ERROR, LM_NOTICE, name, ACE_Configuration_Heap::open_section(), OPENDDS_STRING, OpenDDS::DCPS::processSections(), OpenDDS::DCPS::pullValues(), ACE_Configuration::root_section(), and set_repo_domain().

Referenced by configure_domain_range_instance(), and load_configuration().

{
  const ACE_Configuration_Section_Key& root = cf.root_section();
  ACE_Configuration_Section_Key domain_sect;

  if (cf.open_section(root, DOMAIN_SECTION_NAME, false, domain_sect) != 0) {
    if (DCPS_debug_level > 0) {
      // This is not an error if the configuration file does not have
      // any domain (sub)section. The code default configuration will be used.
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: Service_Participant::load_domain_configuration(): ")
                 ACE_TEXT("failed to open [%s] section - using code default.\n"),
                 DOMAIN_SECTION_NAME));
    }

    return 0;

  } else {
    // Ensure there are no properties in this section
    ValueMap vm;
    if (pullValues(cf, domain_sect, vm) > 0) {
      // There are values inside [domain]
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                        ACE_TEXT("domain sections must have a subsection name\n")),
                       -1);
    }
    // Process the subsections of this section (the individual domains)
    KeyList keys;
    if (processSections(cf, domain_sect, keys) != 0) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                        ACE_TEXT("too many nesting layers in the [domain] section.\n")),
                       -1);
    }

    // Loop through the [domain/*] sections
    for (KeyList::const_iterator it = keys.begin(); it != keys.end(); ++it) {
      OPENDDS_STRING domain_name = it->first;

      ValueMap values;
      pullValues(cf, it->second, values);
      DDS::DomainId_t domainId = -1;
      Discovery::RepoKey repoKey;
      OPENDDS_STRING perDomainDefaultTportConfig;
      for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
        OPENDDS_STRING name = it->first;
        if (name == "DomainId") {
          OPENDDS_STRING value = it->second;
          if (!convertToInteger(value, domainId)) {
            ACE_ERROR_RETURN((LM_ERROR,
                              ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                              ACE_TEXT("Illegal integer value for DomainId (%C) in [domain/%C] section.\n"),
                              value.c_str(), domain_name.c_str()),
                             -1);
          }
          if (DCPS_debug_level > 0) {
            ACE_DEBUG((LM_DEBUG,
                       ACE_TEXT("(%P|%t) [domain/%C]: DomainId == %d\n"),
                       domain_name.c_str(), domainId));
          }
        } else if (name == "DomainRepoKey") {
          // We will still process this for backward compatibility, but
          // it can now be replaced by "DiscoveryConfig=REPO:<key>"
          repoKey = it->second;
          if (repoKey == "-1") {
            repoKey = Discovery::DEFAULT_REPO;
          }

          if (DCPS_debug_level > 0) {
            ACE_DEBUG((LM_DEBUG,
                       ACE_TEXT("(%P|%t) [domain/%C]: DomainRepoKey == %C\n"),
                       domain_name.c_str(), repoKey.c_str()));
          }
        } else if (name == "DiscoveryConfig") {
           repoKey = it->second;
        } else if (name == "DefaultTransportConfig") {
          if (it->second == "$file") {
            // When the special string of "$file" is used, substitute the file name
            perDomainDefaultTportConfig = ACE_TEXT_ALWAYS_CHAR(filename);

          } else {
            perDomainDefaultTportConfig = it->second;
          }

        } else {
          ACE_ERROR_RETURN((LM_ERROR,
                            ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                            ACE_TEXT("Unexpected entry (%C) in [domain/%C] section.\n"),
                            name.c_str(), domain_name.c_str()),
                           -1);
        }
      }

      if (domainId == -1) {
        // DomainId parameter is not set, try using the domain name as an ID
        if (!convertToInteger(domain_name, domainId)) {
          ACE_ERROR_RETURN((LM_ERROR,
                            ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                            ACE_TEXT("Missing DomainId value in [domain/%C] section.\n"),
                            domain_name.c_str()),
                           -1);
        }
      }

      if (!perDomainDefaultTportConfig.empty()) {
        TransportRegistry* const reg = TransportRegistry::instance();
        TransportConfig_rch tc = reg->get_config(perDomainDefaultTportConfig);
        if (tc.is_nil()) {
          ACE_ERROR_RETURN((LM_ERROR,
            ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
            ACE_TEXT("Unknown transport config %C in [domain/%C] section.\n"),
            perDomainDefaultTportConfig.c_str(), domain_name.c_str()), -1);
        } else {
          reg->domain_default_config(domainId, tc);
        }
      }

      // Check to see if the specified discovery configuration has been defined
      if (!repoKey.empty()) {
        if ((repoKey != Discovery::DEFAULT_REPO) &&
            (repoKey != Discovery::DEFAULT_RTPS) &&
            (repoKey != Discovery::DEFAULT_STATIC) &&
            (this->discoveryMap_.find(repoKey) == this->discoveryMap_.end())) {
          ACE_ERROR_RETURN((LM_ERROR,
                            ACE_TEXT("(%P|%t) Service_Participant::load_domain_configuration(): ")
                            ACE_TEXT("Specified configuration (%C) not found.  Referenced in [domain/%C] section.\n"),
                            repoKey.c_str(), domain_name.c_str()),
                           -1);
        }
        this->set_repo_domain(domainId, repoKey);
      }
    }
  }

  return 0;
}

load_domain_ranges()

int OpenDDS::DCPS::Service_Participant::load_domain_ranges ( ACE_Configuration_Heap &  cf )

private

Load the domain range template configuration prior to discovery and domain configuration

Definition at line 2120 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Service_Participant::DomainRange::discovery_template_name, OpenDDS::DCPS::Service_Participant::DomainRange::domain_info, global_transport_config_, LM_DEBUG, LM_ERROR, LM_NOTICE, name, ACE_Configuration_Heap::open_section(), OPENDDS_STRING, parse_domain_range(), OpenDDS::DCPS::processSections(), OpenDDS::DCPS::pullValues(), OpenDDS::DCPS::Service_Participant::DomainRange::range_end, OpenDDS::DCPS::Service_Participant::DomainRange::range_start, ACE_Configuration::root_section(), and OpenDDS::DCPS::Service_Participant::DomainRange::transport_config_name.

Referenced by load_configuration().

{
  const ACE_Configuration_Section_Key& root = cf.root_section();
  ACE_Configuration_Section_Key domain_range_sect;

  if (cf.open_section(root, DOMAIN_RANGE_SECTION_NAME, false, domain_range_sect) != 0) {
    if (DCPS_debug_level > 0) {
      // This is not an error if the configuration file does not have
      // any domain range (sub)section.
      ACE_DEBUG((LM_NOTICE,
                 ACE_TEXT("(%P|%t) NOTICE: Service_Participant::load_domain_ranges(): ")
                 ACE_TEXT("config does not have a [%s] section.\n"),
                 DOMAIN_RANGE_SECTION_NAME));
    }

    return 0;

  } else {
    if (DCPS_debug_level > 0) {
      ACE_DEBUG((LM_NOTICE,
                   ACE_TEXT("(%P|%t) NOTICE: Service_Participant::load_domain_ranges(): ")
                   ACE_TEXT("config has %s sections.\n"),
                   DOMAIN_RANGE_SECTION_NAME));
    }

    // Ensure there are no properties in this section
    ValueMap vm;
    if (pullValues(cf, domain_range_sect, vm) > 0) {
      // There are values inside [DomainRange]
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) Service_Participant::load_domain_ranges(): ")
                        ACE_TEXT("[%s] sections must have a subsection range\n"),
                        DOMAIN_RANGE_SECTION_NAME),
                       -1);
    }

    // Process the subsections of this section (the ranges, m-n)
    KeyList keys;
    if (processSections(cf, domain_range_sect, keys) != 0) {
      ACE_ERROR_RETURN((LM_ERROR,
                        ACE_TEXT("(%P|%t) Service_Participant::load_domain_ranges(): ")
                        ACE_TEXT("too many nesting layers in the [%s] section.\n"),
                        DOMAIN_RANGE_SECTION_NAME),
                       -1);
    }

    // Loop through the [DomainRange/*] sections
    for (KeyList::const_iterator it = keys.begin(); it != keys.end(); ++it) {
      OPENDDS_STRING domain_range = it->first;

      DomainRange range_element;

      int range_start = -1;
      int range_end = -1;

      if (parse_domain_range(domain_range, range_start, range_end) != 0) {
          ACE_ERROR_RETURN((LM_ERROR,
                            ACE_TEXT("(%P|%t) Service_Participant::load_domain_ranges(): ")
                            ACE_TEXT("Error parsing [%s/%C] section.\n"),
                            DOMAIN_RANGE_SECTION_NAME,
                            domain_range.c_str()),
                           -1);
      }

      range_element.range_start = range_start;
      range_element.range_end = range_end;

      ValueMap values;
      if (pullValues(cf, it->second, values) > 0) {
        OPENDDS_STRING dt_name;

        for (ValueMap::const_iterator it = values.begin(); it != values.end(); ++it) {
          OPENDDS_STRING name = it->first;
          if (name == "DiscoveryTemplate") {
            dt_name = it->second;
            if (DCPS_debug_level > 0) {
              ACE_DEBUG((LM_DEBUG,
                         ACE_TEXT("(%P|%t) [%s/%C]: DiscoveryTemplate name == %C\n"),
                         DOMAIN_RANGE_SECTION_NAME, domain_range.c_str(), dt_name.c_str()));
            }
            range_element.discovery_template_name = dt_name;
          } else if (name == "DefaultTransportConfig") {
            range_element.transport_config_name = dt_name;
            range_element.domain_info[it->first] = it->second;
          } else {
            // key=val domain config option
            range_element.domain_info[it->first] = it->second;
          }
        }
      }
      if (this->global_transport_config_ != ACE_TEXT("")) {
        range_element.transport_config_name = ACE_TEXT_ALWAYS_CHAR(this->global_transport_config_.c_str());
      }
      domain_ranges_.push_back(range_element);
    }
  }

  return 0;
}

n_chunks() [1/2]

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.

Definition at line 1463 of file Service_Participant.cpp.

References n_chunks_.

{
  return n_chunks_;
}

n_chunks() [2/2]

void OpenDDS::DCPS::Service_Participant::n_chunks

(

size_t

chunks

)

Set the value returned by n_chunks() accessor.

See also

Accessor description.

Definition at line 1469 of file Service_Participant.cpp.

References n_chunks_.

{
  n_chunks_ = chunks;
  got_chunks = true;
}

network_interface_address_topic()

RcHandle<InternalTopic<NetworkInterfaceAddress> > OpenDDS::DCPS::Service_Participant::network_interface_address_topic ( ) const

inline

Definition at line 464 of file Service_Participant.h.

  {
    return network_interface_address_topic_;
  }

new_pending_timeout_deadline()

ACE_INLINE MonotonicTimePoint OpenDDS::DCPS::Service_Participant::new_pending_timeout_deadline

(

)

const

Get a new pending timeout deadline.

Definition at line 337 of file Service_Participant.inl.

References ACE_INLINE, OpenDDS::DCPS::TimeDuration::is_zero(), OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), and pending_timeout_.

{
  return pending_timeout_.is_zero() ?
    MonotonicTimePoint() : MonotonicTimePoint::now() + pending_timeout_;
}

OPENDDS_MAP() [1/4]

typedef OpenDDS::DCPS::Service_Participant::OPENDDS_MAP	(	Discovery::RepoKey	,
		Discovery_rch
	)

For internal OpenDDS Use (needed for monitor code)

Referenced by get_transport_base_config_name().

OPENDDS_MAP() [2/4]

typedef OpenDDS::DCPS::Service_Participant::OPENDDS_MAP	(	DDS::DomainId_t	,
		Discovery::RepoKey
	)

OPENDDS_MAP() [3/4]

typedef OpenDDS::DCPS::Service_Participant::OPENDDS_MAP ( OPENDDS_STRING  , container_supported_unique_ptr< Discovery::Config >    )

private

OPENDDS_MAP() [4/4]

OpenDDS::DCPS::Service_Participant::OPENDDS_MAP ( DDS::DomainId_t  , OPENDDS_STRING    )

private

OPENDDS_VECTOR() [1/2]

OpenDDS::DCPS::Service_Participant::OPENDDS_VECTOR ( DomainRange  )

private

Referenced by belongs_to_domain_range(), get_domain_range_info(), is_discovery_template(), process_customizations(), remap_domains(), and set_repo_domain().

OPENDDS_VECTOR() [2/2]

OpenDDS::DCPS::Service_Participant::OPENDDS_VECTOR ( DiscoveryInfo  )

private

ORB_argv()

ACE_ARGV* OpenDDS::DCPS::Service_Participant::ORB_argv ( )

inline

Definition at line 356 of file Service_Participant.h.

References name.

{ return &ORB_argv_; }

parse_args()

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

private

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

No need to guard this insertion as we are still single threaded here.

No need to guard this insertion as we are still single threaded here.

Definition at line 627 of file Service_Participant.cpp.

References ACE_ERROR, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, association_chunk_multiplier_, ACE_OS::atoi(), bidir_giop_, bit_enabled_, bit_lookup_duration_msec_, bit_transport_ip_, bit_transport_port_, OpenDDS::DCPS::config_fname, ACE_Arg_Shifter_T< class >::consume_arg(), default_address_, OpenDDS::DCPS::Discovery::DEFAULT_REPO, defaultDiscovery_, OpenDDS::DCPS::SecurityDebug::fake_encryption, federation_backoff_multiplier_, federation_initial_backoff_seconds_, federation_liveliness_, federation_recovery_duration_, ACE_Arg_Shifter_T< class >::get_the_parameter(), global_transport_config_, ACE_Arg_Shifter_T< class >::ignore_arg(), ACE_Arg_Shifter_T< class >::is_anything_left(), liveliness_factor_, LM_ERROR, LM_WARNING, OpenDDS::DCPS::log_level, monitor_enabled_, n_chunks_, OpenDDS::DCPS::SecurityDebug::parse_flags(), pending_timeout_, persistent_data_dir_, publisher_content_filter_, OpenDDS::DCPS::security_debug, security_enabled_, ACE_INET_Addr::set(), OpenDDS::DCPS::set_DCPS_debug_level(), OpenDDS::DCPS::SecurityDebug::set_debug_level(), OpenDDS::DCPS::LogLevel::set_from_string(), set_repo_ior(), OpenDDS::DCPS::ThreadStatusManager::thread_status_interval(), thread_status_manager_, OpenDDS::DCPS::Transport_debug_level, and type_object_encoding().

Referenced by get_domain_participant_factory().

{
  // Process logging options first, so they are in effect if we need to log
  // while processing other options.
  ACE_Arg_Shifter log_arg_shifter(argc, argv);
  while (log_arg_shifter.is_anything_left()) {
    const ACE_TCHAR* currentArg = 0;

    if ((currentArg = log_arg_shifter.get_the_parameter(ACE_TEXT("-ORBLogFile"))) != 0) {
      set_log_file_name(ACE_TEXT_ALWAYS_CHAR(currentArg));
      log_arg_shifter.consume_arg();
      got_log_fname = true;

    } else if ((currentArg = log_arg_shifter.get_the_parameter(ACE_TEXT("-ORBVerboseLogging"))) != 0) {
      set_log_verbose(ACE_OS::atoi(currentArg));
      log_arg_shifter.consume_arg();
      got_log_verbose = true;

    } else {
      log_arg_shifter.ignore_arg();
    }
  }

  ACE_Arg_Shifter arg_shifter(argc, argv);
  while (arg_shifter.is_anything_left()) {
    const ACE_TCHAR* currentArg = 0;

    if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSDebugLevel"))) != 0) {
      set_DCPS_debug_level(ACE_OS::atoi(currentArg));
      arg_shifter.consume_arg();
      got_debug_level = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSInfoRepo"))) != 0) {
      this->set_repo_ior(currentArg, Discovery::DEFAULT_REPO);
      arg_shifter.consume_arg();
      got_info = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSRTISerialization"))) != 0) {
      if (ACE_OS::atoi(currentArg) == 0) {
        ACE_ERROR((LM_WARNING,
          ACE_TEXT("(%P|%t) WARNING: Service_Participant::parse_args ")
          ACE_TEXT("Argument ignored: DCPSRTISerialization is required to be enabled\n")));
      }
      arg_shifter.consume_arg();
      got_use_rti_serialization = true;
    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSChunks"))) != 0) {
      n_chunks_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_chunks = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSChunkAssociationMultiplier"))) != 0) {
      association_chunk_multiplier_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_chunk_association_multiplier = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSConfigFile"))) != 0) {
      config_fname = currentArg;
      arg_shifter.consume_arg();

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSLivelinessFactor"))) != 0) {
      liveliness_factor_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_liveliness_factor = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSBitTransportPort"))) != 0) {
      /// No need to guard this insertion as we are still single
      /// threaded here.
      this->bit_transport_port_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_bit_transport_port = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSBitTransportIPAddress"))) != 0) {
      /// No need to guard this insertion as we are still single
      /// threaded here.
      this->bit_transport_ip_ = currentArg;
      arg_shifter.consume_arg();
      got_bit_transport_ip = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSBitLookupDurationMsec"))) != 0) {
      bit_lookup_duration_msec_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_bit_lookup_duration_msec = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSGlobalTransportConfig"))) != 0) {
      global_transport_config_ = currentArg;
      arg_shifter.consume_arg();
      got_global_transport_config = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSBit"))) != 0) {
      bit_enabled_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_bit_flag = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSTransportDebugLevel"))) != 0) {
      OpenDDS::DCPS::Transport_debug_level = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_transport_debug_level = true;

#ifndef OPENDDS_NO_PERSISTENCE_PROFILE
    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSPersistentDataDir"))) != 0) {
      this->persistent_data_dir_ = ACE_TEXT_ALWAYS_CHAR(currentArg);
      arg_shifter.consume_arg();
      got_persistent_data_dir = true;
#endif

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSPendingTimeout"))) != 0) {
      pending_timeout_ = TimeDuration(ACE_OS::atoi(currentArg));
      arg_shifter.consume_arg();
      got_pending_timeout = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSPublisherContentFilter"))) != 0) {
      this->publisher_content_filter_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_publisher_content_filter = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSDefaultDiscovery"))) != 0) {
      this->defaultDiscovery_ = ACE_TEXT_ALWAYS_CHAR(currentArg);
      arg_shifter.consume_arg();
      got_default_discovery = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSBidirGIOP"))) != 0) {
      bidir_giop_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_bidir_giop = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSThreadStatusInterval"))) != 0) {
      thread_status_manager_.thread_status_interval(TimeDuration(ACE_OS::atoi(currentArg)));
      arg_shifter.consume_arg();
      got_thread_status_interval = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-FederationRecoveryDuration"))) != 0) {
      this->federation_recovery_duration_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-FederationInitialBackoffSeconds"))) != 0) {
      this->federation_initial_backoff_seconds_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-FederationBackoffMultiplier"))) != 0) {
      this->federation_backoff_multiplier_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-FederationLivelinessDuration"))) != 0) {
      this->federation_liveliness_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSDefaultAddress"))) != 0) {
      ACE_INET_Addr addr;
      if (addr.set(u_short(0), currentArg)) {
        ACE_ERROR_RETURN((LM_ERROR,
                          ACE_TEXT("(%P|%t) ERROR: Service_Participant::parse_args: ")
                          ACE_TEXT("failed to parse default address %C\n"),
                          currentArg),
                         -1);
      }
      default_address_ = NetworkAddress(addr);
      arg_shifter.consume_arg();
      got_default_address = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSMonitor"))) != 0) {
      this->monitor_enabled_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_monitor = true;

#if defined(OPENDDS_SECURITY)
    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSSecurityDebugLevel"))) != 0) {
      security_debug.set_debug_level(ACE_OS::atoi(currentArg));
      arg_shifter.consume_arg();
      got_security_debug = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSSecurityDebug"))) != 0) {
      security_debug.parse_flags(currentArg);
      arg_shifter.consume_arg();
      got_security_debug = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSSecurityFakeEncryption"))) != 0) {
      security_debug.fake_encryption = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_security_fake_encryption = true;

    // Must be last "-DCPSSecurity*" option, see comment above this arg parsing loop
    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSSecurity"))) != 0) {
      security_enabled_ = ACE_OS::atoi(currentArg);
      arg_shifter.consume_arg();
      got_security_flag = true;

#endif
    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSTypeObjectEncoding"))) != 0) {
      type_object_encoding(ACE_TEXT_ALWAYS_CHAR(currentArg));
      arg_shifter.consume_arg();
      got_type_object_encoding = true;

    } else if ((currentArg = arg_shifter.get_the_parameter(ACE_TEXT("-DCPSLogLevel"))) != 0) {
      log_level.set_from_string(ACE_TEXT_ALWAYS_CHAR(currentArg));
      arg_shifter.consume_arg();
      got_log_level = true;

    } else {
      arg_shifter.ignore_arg();
    }
  }
  // Indicates successful parsing of the command line
  return 0;
}

parse_domain_range()

int OpenDDS::DCPS::Service_Participant::parse_domain_range ( const OPENDDS_STRING &  range, int &  start, int &  end  )

private

Definition at line 2546 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::convertToInteger(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DOMAIN_RANGE_SECTION_NAME, LM_DEBUG, and LM_ERROR.

Referenced by load_domain_ranges().

                                                                                             {
  const std::size_t dash_pos = range.find("-", 0);

  if (dash_pos == std::string::npos || dash_pos == range.length() - 1) {
    start = end = -1;
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
                      ACE_TEXT("%s missing '-' in [%s/%C] section.\n"),
                      DOMAIN_RANGE_SECTION_NAME, DOMAIN_RANGE_SECTION_NAME, range.c_str()),
                     -1);
  }

  if (!convertToInteger(range.substr(0, dash_pos), start)) {
    start = end = -1;
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
                      ACE_TEXT("Illegal integer value for start %s (%C) in [%s/%C] section.\n"),
                      DOMAIN_RANGE_SECTION_NAME, range.substr(0, dash_pos).c_str(),
                      DOMAIN_RANGE_SECTION_NAME, range.c_str()),
                     -1);
  }
  if (DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
               ACE_TEXT("(%P|%t) [%s/%C]: range_start == %d\n"),
               DOMAIN_RANGE_SECTION_NAME,
               range.c_str(), start));
  }

  if (!convertToInteger(range.substr(dash_pos + 1), end)) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
                      ACE_TEXT("Illegal integer value for end %s (%C) in [%s/%C] section.\n"),
                      DOMAIN_RANGE_SECTION_NAME, range.substr(0, dash_pos).c_str(),
                      DOMAIN_RANGE_SECTION_NAME, range.c_str()),
                     -1);
  }

  if (DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
               ACE_TEXT("(%P|%t) [%s/%C]: range_end == %d\n"),
               DOMAIN_RANGE_SECTION_NAME, range.c_str(), end));
  }

  if (end < start) {
    ACE_ERROR_RETURN((LM_ERROR,
                      ACE_TEXT("(%P|%t) Service_Participant::parse_domain_range(): ")
                      ACE_TEXT("Range End %d is less than range start %d in [%s/%C] section.\n"),
                      end, start, DOMAIN_RANGE_SECTION_NAME, range.c_str()),
                     -1);
  }

  return 0;
}

pending_timeout() [1/2]

ACE_INLINE TimeDuration OpenDDS::DCPS::Service_Participant::pending_timeout

(

)

const

Accessors for pending data timeout.

Definition at line 325 of file Service_Participant.inl.

References ACE_INLINE, and pending_timeout_.

{
  return pending_timeout_;
}

pending_timeout() [2/2]

ACE_INLINE void OpenDDS::DCPS::Service_Participant::pending_timeout

(

const TimeDuration &

value

)

Accessors for pending data timeout.

Definition at line 331 of file Service_Participant.inl.

References ACE_INLINE, pending_timeout_, and value.

{
  pending_timeout_ = value;
}

printer_value_writer_indent() [1/2]

unsigned int OpenDDS::DCPS::Service_Participant::printer_value_writer_indent ( ) const

inline

Definition at line 469 of file Service_Participant.h.

  {
    return printer_value_writer_indent_;
  }

printer_value_writer_indent() [2/2]

void OpenDDS::DCPS::Service_Participant::printer_value_writer_indent ( unsigned int  value )

inline

Definition at line 474 of file Service_Participant.h.

References OpenDDS::DCPS::OPENDDS_MAP(), OPENDDS_STRING, and value.

  {
    printer_value_writer_indent_ = value;
  }

priority_max()

ACE_INLINE int OpenDDS::DCPS::Service_Participant::priority_max

(

)

const

Accessors for priority extremums for the current scheduler.

Definition at line 352 of file Service_Participant.inl.

References ACE_INLINE, and priority_max_.

{
  return priority_max_;
}

priority_min()

ACE_INLINE int OpenDDS::DCPS::Service_Participant::priority_min

(

)

const

Accessors for priority extremums for the current scheduler.

Definition at line 345 of file Service_Participant.inl.

References ACE_INLINE, and priority_min_.

{
  return priority_min_;
}

process_customizations()

bool OpenDDS::DCPS::Service_Participant::process_customizations ( DDS::DomainId_t  id, const OPENDDS_STRING &  discovery_name, ValueMap &  customs  )

private

Definition at line 2636 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), OpenDDS::DCPS::convertToInteger(), OpenDDS::DCPS::DCPS_debug_level, LM_DEBUG, LM_ERROR, OPENDDS_STRING, OPENDDS_VECTOR(), and OpenDDS::DCPS::to_dds_string().

Referenced by configure_discovery_template(), and configure_domain_range_instance().

{
  // get the discovery info
  OPENDDS_VECTOR(DiscoveryInfo)::const_iterator dit;
  for (dit = discovery_infos_.begin(); dit != discovery_infos_.end(); ++dit) {
    if (discovery_name == dit->discovery_name) {
      break;
    }
  }

  if (dit != discovery_infos_.end()) {
    // add discovery info to customs
    for (ValueMap::const_iterator i = dit->disc_info.begin(); i != dit->disc_info.end(); ++i) {
      customs[i->first] = i->second;
      if (DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) Service_Participant::")
                   ACE_TEXT("process_customizations(): adding config %C=%C\n"),
                   i->first.c_str(), i->second.c_str()));
      }
    }

    // update customs valuemap with any customizations
    for (ValueMap::const_iterator i = dit->customizations.begin(); i != dit->customizations.end(); ++i) {
      if (i->first == "InteropMulticastOverride" && i->second == "AddDomainId") {
        OPENDDS_STRING addr = customs["InteropMulticastOverride"];
        size_t pos = addr.find_last_of(".");
        if (pos != OPENDDS_STRING::npos) {
          OPENDDS_STRING custom = addr.substr(pos + 1);
          int val = 0;
          if (!convertToInteger(custom, val)) {
            ACE_ERROR_RETURN((LM_ERROR,
                              ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                              ACE_TEXT("process_customizations(): ")
                              ACE_TEXT("could not convert %C to integer\n"),
                              custom.c_str()),
                             false);
          }
          val += id;
          addr = addr.substr(0, pos);
          addr += "." + to_dds_string(val);
        } else {
          ACE_ERROR_RETURN((LM_ERROR,
                            ACE_TEXT("(%P|%t) ERROR: Service_Participant::")
                            ACE_TEXT("process_customizations(): ")
                            ACE_TEXT("could not AddDomainId for %s\n"),
                            customs["InteropMulticastOverride"].c_str()),
                           false);
        }

        customs["InteropMulticastOverride"] = addr;
      }
    }
  }

  return true;
}

publisher_content_filter() [1/2]

ACE_INLINE bool & OpenDDS::DCPS::Service_Participant::publisher_content_filter

(

)

Accessors for PublisherContentFilter.

Definition at line 359 of file Service_Participant.inl.

References ACE_INLINE, and publisher_content_filter_.

{
  return publisher_content_filter_;
}

publisher_content_filter() [2/2]

ACE_INLINE bool OpenDDS::DCPS::Service_Participant::publisher_content_filter

(

)

const

Accessors for PublisherContentFilter.

Definition at line 366 of file Service_Participant.inl.

References ACE_INLINE, and publisher_content_filter_.

{
  return publisher_content_filter_;
}

reactor()

ACE_Reactor * OpenDDS::DCPS::Service_Participant::reactor

(

void

)

Definition at line 287 of file Service_Participant.cpp.

References OpenDDS::DCPS::ReactorTask::get_reactor(), and reactor_task_.

{
  return reactor_task_.get_reactor();
}

reactor_owner()

ACE_thread_t OpenDDS::DCPS::Service_Participant::reactor_owner

(

)

const

Definition at line 293 of file Service_Participant.cpp.

References OpenDDS::DCPS::ReactorTask::get_reactor_owner(), and reactor_task_.

{
  return reactor_task_.get_reactor_owner();
}

register_discovery_type()

void OpenDDS::DCPS::Service_Participant::register_discovery_type	(	const char *	section_name,
		Discovery::Config *	cfg
	)

Definition at line 1502 of file Service_Participant.cpp.

References discovery_types_.

{
  discovery_types_[section_name].reset(cfg);
}

remap_domains()

void OpenDDS::DCPS::Service_Participant::remap_domains	(	Discovery::RepoKey	oldKey,
		Discovery::RepoKey	newKey,
		bool	attach_participant = true
	)

Rebind a domain from one repository to another.

Definition at line 1049 of file Service_Participant.cpp.

References ACE_GUARD, domainRepoMap_, maps_lock_, OPENDDS_VECTOR(), and set_repo_domain().

Referenced by repository_lost(), and set_repo_ior().

{
  // Search the mappings for any domains mapped to this repository.
  OPENDDS_VECTOR(DDS::DomainId_t) domainList;
  {
    ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, this->maps_lock_);

    for (DomainRepoMap::const_iterator current = this->domainRepoMap_.begin();
         current != this->domainRepoMap_.end();
         ++current) {
      if (current->second == oldKey) {
        domainList.push_back(current->first);
      }
    }
  }

  // Remap the domains that were attached to this repository.
  for (unsigned int index = 0; index < domainList.size(); ++index) {
    // For mapped domains, attach their participants by setting the
    // mapping again.
    this->set_repo_domain(domainList[ index], newKey, attach_participant);
  }
}

repository_lost()

void OpenDDS::DCPS::Service_Participant::repository_lost

(

Discovery::RepoKey

key

)

Failover to a new repository.

Definition at line 1176 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, discoveryMap_, federation_backoff_multiplier(), federation_initial_backoff_seconds(), federation_recovery_duration(), OpenDDS::DCPS::TimePoint_T< AceClock >::is_zero(), LM_DEBUG, LM_WARNING, OpenDDS::DCPS::TimePoint_T< MonotonicClock >::now(), OPENDDS_ASSERT, remap_domains(), and ACE_OS::sleep().

{
  // Find the lost repository.
  RepoKeyDiscoveryMap::iterator initialLocation = this->discoveryMap_.find(key);
  RepoKeyDiscoveryMap::iterator current         = initialLocation;

  if (current == this->discoveryMap_.end()) {
    ACE_DEBUG((LM_WARNING,
               ACE_TEXT("(%P|%t) WARNING: Service_Participant::repository_lost: ")
               ACE_TEXT("lost repository %C was not present, ")
               ACE_TEXT("finding another anyway.\n"),
               key.c_str()));

  } else {
    // Start with the repository *after* the lost one.
    ++current;
  }

  // Calculate the bounding end time for attempts.
  const TimeDuration td(federation_recovery_duration());
  const MonotonicTimePoint recoveryFailedTime(MonotonicTimePoint::now() + td);

  // Backoff delay.
  int backoff = this->federation_initial_backoff_seconds();

  // Keep trying until the total recovery time specified is exceeded.
  while (recoveryFailedTime > MonotonicTimePoint::now()) {

    // Wrap to the beginning at the end of the list.
    if (current == this->discoveryMap_.end()) {
      // Continue to traverse the list.
      current = this->discoveryMap_.begin();
    }

    // Handle reaching the lost repository by waiting before trying
    // again.
    if (current == initialLocation) {
      if (DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) Service_Participant::repository_lost: ")
                   ACE_TEXT("waiting %d seconds to traverse the ")
                   ACE_TEXT("repository list another time ")
                   ACE_TEXT("for lost key %C.\n"),
                   backoff,
                   key.c_str()));
      }

      // Wait to traverse the list and try again.
      ACE_OS::sleep(backoff);

      // Exponentially backoff delay.
      backoff *= this->federation_backoff_multiplier();

      // Don't increment current to allow us to reattach to the
      // original repository if it is restarted.
    }

    // Check the availability of the current repository.
    if (current->second->active()) {

      if (DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) Service_Participant::repository_lost: ")
                   ACE_TEXT("replacing repository %C with %C.\n"),
                   key.c_str(),
                   current->first.c_str()));
      }

      // If we reach here, the validate_connection() call succeeded
      // and the repository is reachable.
      this->remap_domains(key, current->first);

      // Now we are done.  This is the only non-failure exit from
      // this method.
      return;

    } else {
      ACE_DEBUG((LM_WARNING,
                 ACE_TEXT("(%P|%t) WARNING: Service_Participant::repository_lost: ")
                 ACE_TEXT("repository %C was not available to replace %C, ")
                 ACE_TEXT("looking for another.\n"),
                 current->first.c_str(),
                 key.c_str()));
    }

    // Move to the next candidate repository.
    ++current;
  }

  // If we reach here, we have exceeded the total recovery time
  // specified.
  OPENDDS_ASSERT(recoveryFailedTime.is_zero());
}

scheduler() [1/2]

ACE_INLINE long & OpenDDS::DCPS::Service_Participant::scheduler

(

void

)

Accessors for scheduling policy value.

Definition at line 311 of file Service_Participant.inl.

References ACE_INLINE, and scheduler_.

{
  return scheduler_;
}

scheduler() [2/2]

ACE_INLINE long OpenDDS::DCPS::Service_Participant::scheduler

(

void

)

const

Accessors for scheduling policy value.

Definition at line 318 of file Service_Participant.inl.

References ACE_INLINE, and scheduler_.

{
  return scheduler_;
}

set_BIT()

void OpenDDS::DCPS::Service_Participant::set_BIT ( bool  b )

inline

Definition at line 333 of file Service_Participant.h.

                       {
    bit_enabled_ = b;
  }

set_default_discovery()

void OpenDDS::DCPS::Service_Participant::set_default_discovery

(

const Discovery::RepoKey &

defaultDiscovery

)

Definition at line 1271 of file Service_Participant.cpp.

References defaultDiscovery_.

{
  this->defaultDiscovery_ = key;
}

set_repo_domain()

void OpenDDS::DCPS::Service_Participant::set_repo_domain	(	const DDS::DomainId_t	domain,
		Discovery::RepoKey	repo,
		bool	attach_participant = true
	)

Bind DCPSInfoRepo IORs to domains.

Definition at line 1076 of file Service_Participant.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Discovery::DEFAULT_REPO, discoveryMap_, domainRepoMap_, dp_factory_servant_, LM_DEBUG, maps_lock_, and OPENDDS_VECTOR().

Referenced by load_domain_configuration(), and remap_domains().

{
  typedef std::pair<Discovery_rch, GUID_t> DiscRepoPair;
  OPENDDS_VECTOR(DiscRepoPair) repoList;
  {
    ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, this->maps_lock_);
    DomainRepoMap::const_iterator where = this->domainRepoMap_.find(domain);

    if (key == "-1") {
      key = Discovery::DEFAULT_REPO;
    }

    if ((where == this->domainRepoMap_.end()) || (where->second != key)) {
      // Only assign entries into the map when they change the
      // contents.
      this->domainRepoMap_[ domain] = key;

      if (DCPS_debug_level > 0) {
        ACE_DEBUG((LM_DEBUG,
                   ACE_TEXT("(%P|%t) Service_Participant::set_repo_domain: ")
                   ACE_TEXT("Domain[ %d] = Repo[ %C].\n"),
                   domain, key.c_str()));
      }
    }

    //
    // Make sure that we mark each DomainParticipant for this domain
    // using this repository as attached to this repository.
    //
    // @TODO: Move this note into user documentation.
    // N.B. Calling set_repo() or set_repo_ior() will result in this
    //      code executing again with the new repository.  It is best
    //      to call those routines first when making changes.
    //

    // No servant means no participant.  No worries.
    if (this->dp_factory_servant_) {
      // Map of domains to sets of participants.
      const DomainParticipantFactoryImpl::DPMap& participants
      = this->dp_factory_servant_->participants();

      // Extract the set of participants for the current domain.
      DomainParticipantFactoryImpl::DPMap::const_iterator
      which  = participants.find(domain);

      if (which != participants.end()) {
        // Extract the repository to attach this domain to.
        RepoKeyDiscoveryMap::const_iterator disc_iter = this->discoveryMap_.find(key);

        if (disc_iter != this->discoveryMap_.end()) {
          for (DomainParticipantFactoryImpl::DPSet::const_iterator
               current  = which->second.begin();
               current != which->second.end();
               ++current) {
            try {
              // Attach each DomainParticipant in this domain to this
              // repository.
              GUID_t id = (*current)->get_id();
              repoList.push_back(std::make_pair(disc_iter->second, id));

              if (DCPS_debug_level > 0) {
                ACE_DEBUG((LM_DEBUG,
                           ACE_TEXT("(%P|%t) Service_Participant::set_repo_domain: ")
                           ACE_TEXT("participant %C attached to Repo[ %C].\n"),
                           LogGuid(id).c_str(),
                           key.c_str()));
              }

            } catch (const CORBA::Exception& ex) {
              ex._tao_print_exception(
                "ERROR: Service_Participant::set_repo_domain: failed to attach repository - ");
              return;
            }
          }
        }
      }
    }
  } // End of GUARD scope.

  // Make all of the remote calls after releasing the lock.
  for (unsigned int index = 0; index < repoList.size(); ++index) {
    if (DCPS_debug_level > 0) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) Service_Participant::set_repo_domain: ")
                 ACE_TEXT("(%d of %d) attaching domain %d participant %C to Repo[ %C].\n"),
                 (1+index), repoList.size(), domain,
                 LogGuid(repoList[ index].second).c_str(),
                 key.c_str()));
    }

    if (attach_participant)
    {
      repoList[ index].first->attach_participant(domain, repoList[ index].second);
    }
  }
}

set_repo_ior()

bool OpenDDS::DCPS::Service_Participant::set_repo_ior	(	const char *	ior,
		Discovery::RepoKey	key = Discovery::DEFAULT_REPO,
		bool	attach_participant = true
	)

Definition at line 999 of file Service_Participant.cpp.

References ACE_DEBUG, ACE_ERROR_RETURN, ACE_TEXT(), ACE_TEXT_ALWAYS_CHAR, ACE_TEXT_CHAR_TO_TCHAR, ACE_String_Base< char >::c_str(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::Discovery::DEFAULT_REPO, discovery_types_, LM_DEBUG, LM_ERROR, ACE_Configuration_Heap::open(), ACE_Configuration_Heap::open_section(), OPENDDS_STRING, remap_domains(), OpenDDS::DCPS::REPO_SECTION_NAME, ACE_Configuration::root_section(), ACE_Configuration_Heap::set_string_value(), and TheTransportRegistry.

Referenced by get_discovery(), InfoRepo::init(), initializeScheduling(), load_common_configuration(), and parse_args().

{
  if (DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) Service_Participant::set_repo_ior: Repo[%C] == %C\n"),
               key.c_str(), ior));
  }

  // This is a global used for the bizarre commandline/configfile
  // processing done for this class.
  got_info = true;

  if (key == "-1") {
    key = Discovery::DEFAULT_REPO;
  }

  const OPENDDS_STRING repo_type = ACE_TEXT_ALWAYS_CHAR(REPO_SECTION_NAME);
  if (!discovery_types_.count(repo_type)) {
    // Re-use a transport registry function to attempt a dynamic load of the
    // library that implements the 'repo_type' (InfoRepoDiscovery)
    TheTransportRegistry->load_transport_lib(repo_type);
  }

  if (discovery_types_.count(repo_type)) {
    ACE_Configuration_Heap cf;
    cf.open();
    ACE_Configuration_Section_Key sect_key;
    ACE_TString section = REPO_SECTION_NAME;
    section += ACE_TEXT('\\');
    section += ACE_TEXT_CHAR_TO_TCHAR(key.c_str());
    cf.open_section(cf.root_section(), section.c_str(), true /*create*/, sect_key);
    cf.set_string_value(sect_key, ACE_TEXT("RepositoryIor"),
                        ACE_TEXT_CHAR_TO_TCHAR(ior));

    discovery_types_[repo_type]->discovery_config(cf);

    this->remap_domains(key, key, attach_participant);
    return true;
  }

  ACE_ERROR_RETURN((LM_ERROR,
                    ACE_TEXT("(%P|%t) Service_Participant::set_repo_ior ")
                    ACE_TEXT("ERROR - no discovery type registered for ")
                    ACE_TEXT("InfoRepoDiscovery\n")),
                   false);
}

set_security()

void OpenDDS::DCPS::Service_Participant::set_security ( bool  b )

inline

Definition at line 324 of file Service_Participant.h.

                            {
    security_enabled_ = b;
  }

set_shutdown_listener()

void OpenDDS::DCPS::Service_Participant::set_shutdown_listener

(

RcHandle< ShutdownListener >

listener

)

Definition at line 2786 of file Service_Participant.cpp.

References shutdown_listener_.

{
  shutdown_listener_ = listener;
}

shutdown()

DDS::ReturnCode_t OpenDDS::DCPS::Service_Participant::shutdown

(

void

)

Stop being a participant in the service.

Note

All Domain Participants have to be deleted before calling or DDS::RETCODE_PRECONDITION_NOT_MET is returned.

If the Service Participant has already been shutdown then DDS::RETCODE_ALREADY_DELETED will be returned.

Definition at line 310 of file Service_Participant.cpp.

References CORBA::Exception::_tao_print_exception(), ACE_DEBUG, ACE_ERROR, ACE_GUARD_RETURN, OpenDDS::Security::SecurityRegistry::close(), OpenDDS::DCPS::TransportRegistry::close(), OpenDDS::DCPS::NetworkConfigMonitor::close(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::MonitorFactory::deinitialize(), OpenDDS::DCPS::NetworkConfigMonitor::disconnect(), discovery_types_, discoveryMap_, domainRepoMap_, dp_factory_servant_, OpenDDS::DCPS::LogLevel::Error, factory_lock_, ACE_Argv_Type_Converter::get_argc(), get_domain_participant_factory(), ACE_Argv_Type_Converter::get_TCHAR_argv(), OpenDDS::DCPS::TransportRegistry::instance(), LM_DEBUG, LM_NOTICE, OpenDDS::DCPS::log_level, monitor_factory_, network_config_monitor_, network_config_monitor_lock_, network_interface_address_topic_, OpenDDS::DCPS::LogLevel::Notice, persistent_data_cache_, reactor_task_, OpenDDS::DCPS::TransportRegistry::release(), OpenDDS::DCPS::RcHandle< T >::reset(), DDS::RETCODE_ALREADY_DELETED, DDS::RETCODE_ERROR, DDS::RETCODE_OK, DDS::RETCODE_OUT_OF_RESOURCES, DDS::RETCODE_PRECONDITION_NOT_MET, shut_down_, shutdown_listener_, OpenDDS::DCPS::ReactorTask::stop(), and transient_data_cache_.

Referenced by ~Service_Participant().

{
  if (DCPS_debug_level >= 1) {
    ACE_DEBUG((LM_DEBUG, "(%P|%t) Service_Participant::shutdown\n"));
  }

  if (shut_down_) {
    return DDS::RETCODE_ALREADY_DELETED;
  }

  if (monitor_factory_) {
    monitor_factory_->deinitialize();
    monitor_factory_ = 0;
  }

  {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, factory_lock_, DDS::RETCODE_OUT_OF_RESOURCES);
    if (dp_factory_servant_) {
      const size_t count = dp_factory_servant_->participant_count();
      if (count > 0) {
        if (log_level >= LogLevel::Notice) {
          ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: Service_Participant::shutdown: "
            "there are %B domain participant(s) that must be deleted before shutdown can occur\n",
            count));
        }
        return DDS::RETCODE_PRECONDITION_NOT_MET;
      }
    }
  }

  if (shutdown_listener_) {
    shutdown_listener_->notify_shutdown();
  }

  DDS::ReturnCode_t rc = DDS::RETCODE_OK;
  try {
    TransportRegistry::instance()->release();
    {
      ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, factory_lock_, DDS::RETCODE_OUT_OF_RESOURCES);

      shut_down_ = true;

      dp_factory_servant_.reset();

      domainRepoMap_.clear();

      {
        ACE_GUARD_RETURN(ACE_Thread_Mutex, guard, network_config_monitor_lock_,
          DDS::RETCODE_OUT_OF_RESOURCES);
        if (network_config_monitor_) {
          network_config_monitor_->close();
          network_config_monitor_->disconnect(network_interface_address_topic_);
          network_config_monitor_.reset();
        }
      }

      domain_ranges_.clear();

      reactor_task_.stop();

      discoveryMap_.clear();

#ifndef OPENDDS_NO_PERSISTENCE_PROFILE
      transient_data_cache_.reset();
      persistent_data_cache_.reset();
#endif

      discovery_types_.clear();
    }
    TransportRegistry::close();
#ifdef OPENDDS_SECURITY
    OpenDDS::Security::SecurityRegistry::close();
#endif
  } catch (const CORBA::Exception& ex) {
    if (log_level >= LogLevel::Error) {
      ex._tao_print_exception("ERROR: Service_Participant::shutdown");
    }
    rc = DDS::RETCODE_ERROR;
  }

  return rc;
}

time_source()

const TimeSource & OpenDDS::DCPS::Service_Participant::time_source

(

)

const

Definition at line 275 of file Service_Participant.cpp.

References time_source_.

{
  return time_source_;
}

timer()

ACE_Reactor_Timer_Interface * OpenDDS::DCPS::Service_Participant::timer

(

void

)

Get the common timer interface. Intended for use by OpenDDS internals only.

Definition at line 281 of file Service_Participant.cpp.

References OpenDDS::DCPS::ReactorTask::get_reactor(), and reactor_task_.

{
  return reactor_task_.get_reactor();
}

type_object_encoding() [1/3]

ACE_INLINE Service_Participant::TypeObjectEncoding OpenDDS::DCPS::Service_Participant::type_object_encoding

(

)

const

Definition at line 387 of file Service_Participant.inl.

References ACE_INLINE, and type_object_encoding_.

Referenced by load_common_configuration(), parse_args(), and type_object_encoding().

{
  return type_object_encoding_;
}

type_object_encoding() [2/3]

ACE_INLINE void OpenDDS::DCPS::Service_Participant::type_object_encoding

(

TypeObjectEncoding

encoding

)

Definition at line 393 of file Service_Participant.inl.

References OpenDDS::STUN::encoding(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and type_object_encoding_.

{
  type_object_encoding_ = encoding;
}

type_object_encoding() [3/3]

void OpenDDS::DCPS::Service_Participant::type_object_encoding

(

const char *

encoding

)

Definition at line 2954 of file Service_Participant.cpp.

References ACE_ERROR, Encoding_Normal, Encoding_ReadOldFormat, Encoding_WriteOldFormat, LM_ERROR, name, OPENDDS_END_VERSIONED_NAMESPACE_DECL, type_object_encoding(), and value.

{
  struct NameValue {
    const char* name;
    TypeObjectEncoding value;
  };
  static const NameValue entries[] = {
    {"Normal", Encoding_Normal},
    {"WriteOldFormat", Encoding_WriteOldFormat},
    {"ReadOldFormat", Encoding_ReadOldFormat},
  };
  for (size_t i = 0; i < sizeof entries / sizeof entries[0]; ++i) {
    if (0 == std::strcmp(entries[i].name, encoding)) {
      type_object_encoding(entries[i].value);
      return;
    }
  }
  ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: Service_Participant::type_object_encoding: "
             "invalid encoding %C\n", encoding));
}

use_bidir_giop()

ACE_INLINE bool OpenDDS::DCPS::Service_Participant::use_bidir_giop

(

)

const

Definition at line 380 of file Service_Participant.inl.

References ACE_INLINE, and bidir_giop_.

{
  return bidir_giop_;
}

Member Data Documentation

association_chunk_multiplier_

size_t OpenDDS::DCPS::Service_Participant::association_chunk_multiplier_

private

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.

Definition at line 616 of file Service_Participant.h.

Referenced by association_chunk_multiplier(), load_common_configuration(), and parse_args().

bidir_giop_

bool OpenDDS::DCPS::Service_Participant::bidir_giop_

private

Enable TAO's Bidirectional GIOP?

Definition at line 753 of file Service_Participant.h.

Referenced by load_common_configuration(), parse_args(), and use_bidir_giop().

bit_autopurge_disposed_samples_delay_

DDS::Duration_t OpenDDS::DCPS::Service_Participant::bit_autopurge_disposed_samples_delay_

private

Definition at line 783 of file Service_Participant.h.

Referenced by bit_autopurge_disposed_samples_delay(), and initialize().

bit_autopurge_nowriter_samples_delay_

DDS::Duration_t OpenDDS::DCPS::Service_Participant::bit_autopurge_nowriter_samples_delay_

private

Definition at line 782 of file Service_Participant.h.

Referenced by bit_autopurge_nowriter_samples_delay(), and initialize().

bit_enabled_

bool OpenDDS::DCPS::Service_Participant::bit_enabled_

private

Definition at line 627 of file Service_Participant.h.

Referenced by load_common_configuration(), and parse_args().

bit_lookup_duration_msec_

int OpenDDS::DCPS::Service_Participant::bit_lookup_duration_msec_

private

The timeout for lookup data from the builtin topic DataReader.

Definition at line 635 of file Service_Participant.h.

Referenced by bit_lookup_duration_msec(), load_common_configuration(), and parse_args().

bit_transport_ip_

ACE_TString OpenDDS::DCPS::Service_Participant::bit_transport_ip_

private

The builtin topic transport address.

Definition at line 622 of file Service_Participant.h.

Referenced by bit_transport_ip(), load_common_configuration(), and parse_args().

bit_transport_port_

int OpenDDS::DCPS::Service_Participant::bit_transport_port_

private

The builtin topic transport port number.

Definition at line 625 of file Service_Participant.h.

Referenced by bit_transport_port(), load_common_configuration(), and parse_args().

default_address_

NetworkAddress OpenDDS::DCPS::Service_Participant::default_address_

private

The default network address to use.

Definition at line 638 of file Service_Participant.h.

Referenced by load_common_configuration(), and parse_args().

default_configuration_file_

ACE_TString OpenDDS::DCPS::Service_Participant::default_configuration_file_

private

If set before TheParticipantFactoryWithArgs and -DCPSConfigFile is not passed, use this as the configuration file.

Definition at line 777 of file Service_Participant.h.

Referenced by default_configuration_file(), and get_domain_participant_factory().

defaultDiscovery_

Discovery::RepoKey OpenDDS::DCPS::Service_Participant::defaultDiscovery_

private

Definition at line 568 of file Service_Participant.h.

Referenced by get_default_discovery(), get_discovery(), load_common_configuration(), parse_args(), and set_default_discovery().

discovery_types_

DiscoveryTypes OpenDDS::DCPS::Service_Participant::discovery_types_

private

Definition at line 550 of file Service_Participant.h.

Referenced by load_discovery_configuration(), register_discovery_type(), set_repo_ior(), and shutdown().

discoveryMap_

RepoKeyDiscoveryMap OpenDDS::DCPS::Service_Participant::discoveryMap_

private

The RepoKey to Discovery object mapping.

Definition at line 563 of file Service_Participant.h.

Referenced by add_discovery(), configure_discovery_template(), configure_domain_range_instance(), discoveryMap(), get_discovery(), load_domain_configuration(), repository_lost(), set_repo_domain(), and shutdown().

domainRepoMap_

DomainRepoMap OpenDDS::DCPS::Service_Participant::domainRepoMap_

private

The DomainId to RepoKey mapping.

Definition at line 566 of file Service_Participant.h.

Referenced by domain_to_repo(), domainRepoMap(), get_discovery(), remap_domains(), set_repo_domain(), and shutdown().

dp_factory_servant_

RcHandle<DomainParticipantFactoryImpl> OpenDDS::DCPS::Service_Participant::dp_factory_servant_

private

Definition at line 560 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), set_repo_domain(), shutdown(), and ~Service_Participant().

factory_lock_

ACE_Thread_Mutex OpenDDS::DCPS::Service_Participant::factory_lock_

mutableprivate

The lock to serialize DomainParticipantFactory singleton creation and shutdown.

Definition at line 572 of file Service_Participant.h.

Referenced by get_data_durability_cache(), get_domain_participant_factory(), shutdown(), and ~Service_Participant().

federation_backoff_multiplier_

int OpenDDS::DCPS::Service_Participant::federation_backoff_multiplier_

private

This FederationBackoffMultiplier.

Definition at line 704 of file Service_Participant.h.

Referenced by federation_backoff_multiplier(), load_common_configuration(), and parse_args().

federation_initial_backoff_seconds_

int OpenDDS::DCPS::Service_Participant::federation_initial_backoff_seconds_

private

The FederationInitialBackoffSeconds value.

Definition at line 701 of file Service_Participant.h.

Referenced by federation_initial_backoff_seconds(), load_common_configuration(), and parse_args().

federation_liveliness_

int OpenDDS::DCPS::Service_Participant::federation_liveliness_

private

This FederationLivelinessDuration.

Definition at line 707 of file Service_Participant.h.

Referenced by federation_liveliness(), load_common_configuration(), and parse_args().

federation_recovery_duration_

int OpenDDS::DCPS::Service_Participant::federation_recovery_duration_

private

The FederationRecoveryDuration value in seconds.

Definition at line 698 of file Service_Participant.h.

Referenced by federation_recovery_duration(), load_common_configuration(), and parse_args().

global_transport_config_

ACE_TString OpenDDS::DCPS::Service_Participant::global_transport_config_

private

Specifies the name of the transport configuration that is used when the entity tree does not specify one. If not set, the default transport configuration is used.

Definition at line 643 of file Service_Participant.h.

Referenced by get_transport_base_config_name(), load_common_configuration(), load_configuration(), load_domain_ranges(), and parse_args().

initial_DataReaderQos_

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

private

Definition at line 604 of file Service_Participant.h.

Referenced by initial_DataReaderQos(), and initialize().

initial_DataRepresentationQosPolicy_

DDS::DataRepresentationQosPolicy OpenDDS::DCPS::Service_Participant::initial_DataRepresentationQosPolicy_

private

Definition at line 598 of file Service_Participant.h.

Referenced by initial_DataRepresentationQosPolicy(), and initialize().

initial_DataWriterQos_

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

private

Definition at line 602 of file Service_Participant.h.

Referenced by initial_DataWriterQos(), and initialize().

initial_DeadlineQosPolicy_

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

private

Definition at line 583 of file Service_Participant.h.

Referenced by initial_DeadlineQosPolicy(), and initialize().

initial_DestinationOrderQosPolicy_

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

private

Definition at line 591 of file Service_Participant.h.

Referenced by initial_DestinationOrderQosPolicy(), and initialize().

initial_DomainParticipantFactoryQos_

DDS::DomainParticipantFactoryQos OpenDDS::DCPS::Service_Participant::initial_DomainParticipantFactoryQos_

private

Definition at line 606 of file Service_Participant.h.

Referenced by initial_DomainParticipantFactoryQos(), and initialize().

initial_DomainParticipantQos_

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

private

Definition at line 600 of file Service_Participant.h.

Referenced by initial_DomainParticipantQos(), and initialize().

initial_DurabilityQosPolicy_

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

private

Definition at line 580 of file Service_Participant.h.

Referenced by initial_DurabilityQosPolicy(), and initialize().

initial_DurabilityServiceQosPolicy_

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

private

Definition at line 581 of file Service_Participant.h.

Referenced by initial_DurabilityServiceQosPolicy(), and initialize().

initial_EntityFactoryQosPolicy_

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

private

Definition at line 594 of file Service_Participant.h.

Referenced by initial_EntityFactoryQosPolicy(), and initialize().

initial_GroupDataQosPolicy_

DDS::GroupDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_GroupDataQosPolicy_

private

Definition at line 577 of file Service_Participant.h.

Referenced by initial_GroupDataQosPolicy(), and initialize().

initial_HistoryQosPolicy_

DDS::HistoryQosPolicy OpenDDS::DCPS::Service_Participant::initial_HistoryQosPolicy_

private

Definition at line 592 of file Service_Participant.h.

Referenced by initial_HistoryQosPolicy(), and initialize().

initial_LatencyBudgetQosPolicy_

DDS::LatencyBudgetQosPolicy OpenDDS::DCPS::Service_Participant::initial_LatencyBudgetQosPolicy_

private

Definition at line 584 of file Service_Participant.h.

Referenced by initial_LatencyBudgetQosPolicy(), and initialize().

initial_LifespanQosPolicy_

DDS::LifespanQosPolicy OpenDDS::DCPS::Service_Participant::initial_LifespanQosPolicy_

private

Definition at line 579 of file Service_Participant.h.

Referenced by initial_LifespanQosPolicy(), and initialize().

initial_LivelinessQosPolicy_

DDS::LivelinessQosPolicy OpenDDS::DCPS::Service_Participant::initial_LivelinessQosPolicy_

private

Definition at line 587 of file Service_Participant.h.

Referenced by initial_LivelinessQosPolicy(), and initialize().

initial_OwnershipQosPolicy_

DDS::OwnershipQosPolicy OpenDDS::DCPS::Service_Participant::initial_OwnershipQosPolicy_

private

Definition at line 585 of file Service_Participant.h.

Referenced by initial_OwnershipQosPolicy(), and initialize().

initial_OwnershipStrengthQosPolicy_

DDS::OwnershipStrengthQosPolicy OpenDDS::DCPS::Service_Participant::initial_OwnershipStrengthQosPolicy_

private

Definition at line 586 of file Service_Participant.h.

Referenced by initial_OwnershipStrengthQosPolicy(), and initialize().

initial_PartitionQosPolicy_

DDS::PartitionQosPolicy OpenDDS::DCPS::Service_Participant::initial_PartitionQosPolicy_

private

Definition at line 589 of file Service_Participant.h.

Referenced by initial_PartitionQosPolicy(), and initialize().

initial_PresentationQosPolicy_

DDS::PresentationQosPolicy OpenDDS::DCPS::Service_Participant::initial_PresentationQosPolicy_

private

Definition at line 582 of file Service_Participant.h.

Referenced by initial_PresentationQosPolicy(), and initialize().

initial_PropertyQosPolicy_

DDS::PropertyQosPolicy OpenDDS::DCPS::Service_Participant::initial_PropertyQosPolicy_

private

Definition at line 597 of file Service_Participant.h.

Referenced by initial_PropertyQosPolicy().

initial_PublisherQos_

DDS::PublisherQos OpenDDS::DCPS::Service_Participant::initial_PublisherQos_

private

Definition at line 603 of file Service_Participant.h.

Referenced by initial_PublisherQos(), and initialize().

initial_ReaderDataLifecycleQosPolicy_

DDS::ReaderDataLifecycleQosPolicy OpenDDS::DCPS::Service_Participant::initial_ReaderDataLifecycleQosPolicy_

private

Definition at line 596 of file Service_Participant.h.

Referenced by initial_ReaderDataLifecycleQosPolicy(), and initialize().

initial_ReliabilityQosPolicy_

DDS::ReliabilityQosPolicy OpenDDS::DCPS::Service_Participant::initial_ReliabilityQosPolicy_

private

Definition at line 590 of file Service_Participant.h.

Referenced by initial_ReliabilityQosPolicy(), and initialize().

initial_ResourceLimitsQosPolicy_

DDS::ResourceLimitsQosPolicy OpenDDS::DCPS::Service_Participant::initial_ResourceLimitsQosPolicy_

private

Definition at line 593 of file Service_Participant.h.

Referenced by initial_ResourceLimitsQosPolicy(), and initialize().

initial_SubscriberQos_

DDS::SubscriberQos OpenDDS::DCPS::Service_Participant::initial_SubscriberQos_

private

Definition at line 605 of file Service_Participant.h.

Referenced by initial_SubscriberQos(), and initialize().

initial_TimeBasedFilterQosPolicy_

DDS::TimeBasedFilterQosPolicy OpenDDS::DCPS::Service_Participant::initial_TimeBasedFilterQosPolicy_

private

Definition at line 588 of file Service_Participant.h.

Referenced by initial_TimeBasedFilterQosPolicy(), and initialize().

initial_TopicDataQosPolicy_

DDS::TopicDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_TopicDataQosPolicy_

private

Definition at line 576 of file Service_Participant.h.

Referenced by initial_TopicDataQosPolicy().

initial_TopicQos_

DDS::TopicQos OpenDDS::DCPS::Service_Participant::initial_TopicQos_

private

Definition at line 601 of file Service_Participant.h.

Referenced by initial_TopicQos(), and initialize().

initial_TransportPriorityQosPolicy_

DDS::TransportPriorityQosPolicy OpenDDS::DCPS::Service_Participant::initial_TransportPriorityQosPolicy_

private

Definition at line 578 of file Service_Participant.h.

Referenced by initial_TransportPriorityQosPolicy(), and initialize().

initial_TypeConsistencyEnforcementQosPolicy_

DDS::TypeConsistencyEnforcementQosPolicy OpenDDS::DCPS::Service_Participant::initial_TypeConsistencyEnforcementQosPolicy_

private

Definition at line 607 of file Service_Participant.h.

Referenced by initial_TypeConsistencyEnforcementQosPolicy(), and initialize().

initial_UserDataQosPolicy_

DDS::UserDataQosPolicy OpenDDS::DCPS::Service_Participant::initial_UserDataQosPolicy_

private

The initial values of qos policies.

Definition at line 575 of file Service_Participant.h.

Referenced by initial_UserDataQosPolicy(), and initialize().

initial_WriterDataLifecycleQosPolicy_

DDS::WriterDataLifecycleQosPolicy OpenDDS::DCPS::Service_Participant::initial_WriterDataLifecycleQosPolicy_

private

Definition at line 595 of file Service_Participant.h.

Referenced by initial_WriterDataLifecycleQosPolicy(), and initialize().

job_queue_

JobQueue_rch OpenDDS::DCPS::Service_Participant::job_queue_

private

Definition at line 558 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), and job_queue().

liveliness_factor_

int OpenDDS::DCPS::Service_Participant::liveliness_factor_

private

The propagation delay factor.

Definition at line 619 of file Service_Participant.h.

Referenced by liveliness_factor(), load_common_configuration(), and parse_args().

maps_lock_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::Service_Participant::maps_lock_

private

Guard access to the internal maps.

Definition at line 769 of file Service_Participant.h.

Referenced by add_discovery(), bit_transport_port(), get_discovery(), remap_domains(), and set_repo_domain().

monitor_

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

Pointer to the monitor object for this object.

Definition at line 694 of file Service_Participant.h.

Referenced by get_domain_participant_factory().

monitor_enabled_

bool OpenDDS::DCPS::Service_Participant::monitor_enabled_

private

Enable Monitor functionality.

Definition at line 761 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), load_common_configuration(), and parse_args().

monitor_factory_

MonitorFactory* OpenDDS::DCPS::Service_Participant::monitor_factory_

Pointer to the monitor factory that is used to create monitor objects.

Definition at line 691 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), and shutdown().

n_chunks_

size_t OpenDDS::DCPS::Service_Participant::n_chunks_

private

The configurable value of the number chunks that the DataWriter's cached allocator can allocate.

Definition at line 611 of file Service_Participant.h.

Referenced by load_common_configuration(), n_chunks(), and parse_args().

network_config_monitor_

NetworkConfigMonitor_rch OpenDDS::DCPS::Service_Participant::network_config_monitor_

private

Definition at line 779 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), get_static_xtypes_lock(), and shutdown().

network_config_monitor_lock_

ACE_Thread_Mutex OpenDDS::DCPS::Service_Participant::network_config_monitor_lock_

mutableprivate

Definition at line 780 of file Service_Participant.h.

Referenced by shutdown().

network_interface_address_topic_

RcHandle<InternalTopic<NetworkInterfaceAddress> > OpenDDS::DCPS::Service_Participant::network_interface_address_topic_

private

Definition at line 787 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), and shutdown().

ORB_argv_

ACE_ARGV OpenDDS::DCPS::Service_Participant::ORB_argv_

private

Definition at line 553 of file Service_Participant.h.

Referenced by get_domain_participant_factory().

pending_timeout_

TimeDuration OpenDDS::DCPS::Service_Participant::pending_timeout_

private

Number of seconds to wait on pending samples to be sent or dropped.

Definition at line 750 of file Service_Participant.h.

Referenced by load_common_configuration(), new_pending_timeout_deadline(), parse_args(), and pending_timeout().

persistent_data_cache_

unique_ptr<DataDurabilityCache> OpenDDS::DCPS::Service_Participant::persistent_data_cache_

private

The PERSISTENT data durability cache.

Definition at line 741 of file Service_Participant.h.

Referenced by get_data_durability_cache(), and shutdown().

persistent_data_dir_

ACE_CString OpenDDS::DCPS::Service_Participant::persistent_data_dir_

private

The PERSISTENT data durability directory.

Definition at line 744 of file Service_Participant.h.

Referenced by get_data_durability_cache(), load_common_configuration(), and parse_args().

printer_value_writer_indent_

unsigned int OpenDDS::DCPS::Service_Participant::printer_value_writer_indent_

private

Definition at line 789 of file Service_Participant.h.

priority_max_

int OpenDDS::DCPS::Service_Participant::priority_max_

private

Maximum priority value for the current scheduling policy.

Definition at line 730 of file Service_Participant.h.

Referenced by initializeScheduling(), and priority_max().

priority_min_

int OpenDDS::DCPS::Service_Participant::priority_min_

private

Minimum priority value for the current scheduling policy.

Definition at line 727 of file Service_Participant.h.

Referenced by initializeScheduling(), and priority_min().

publisher_content_filter_

bool OpenDDS::DCPS::Service_Participant::publisher_content_filter_

private

Allow the publishing side to do content filtering?

Definition at line 733 of file Service_Participant.h.

Referenced by load_common_configuration(), parse_args(), and publisher_content_filter().

reactor_task_

ReactorTask OpenDDS::DCPS::Service_Participant::reactor_task_

private

Definition at line 557 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), interceptor(), reactor(), reactor_owner(), shutdown(), and timer().

scheduler_

long OpenDDS::DCPS::Service_Participant::scheduler_

private

Scheduling policy value used for setting thread priorities.

Definition at line 724 of file Service_Participant.h.

Referenced by initializeScheduling(), and scheduler().

schedulerQuantum_

TimeDuration OpenDDS::DCPS::Service_Participant::schedulerQuantum_

private

Scheduler time slice from configuration file.

Definition at line 713 of file Service_Participant.h.

Referenced by initializeScheduling(), and load_common_configuration().

schedulerString_

ACE_TString OpenDDS::DCPS::Service_Participant::schedulerString_

private

Scheduling policy value from configuration file.

Definition at line 710 of file Service_Participant.h.

Referenced by initializeScheduling(), and load_common_configuration().

security_enabled_

bool OpenDDS::DCPS::Service_Participant::security_enabled_

private

Definition at line 630 of file Service_Participant.h.

Referenced by load_common_configuration(), and parse_args().

shut_down_

AtomicBool OpenDDS::DCPS::Service_Participant::shut_down_

private

Used to track state of service participant.

Definition at line 764 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), is_shut_down(), and shutdown().

shutdown_listener_

RcHandle<ShutdownListener> OpenDDS::DCPS::Service_Participant::shutdown_listener_

private

Definition at line 766 of file Service_Participant.h.

Referenced by set_shutdown_listener(), and shutdown().

thread_status_manager_

ThreadStatusManager OpenDDS::DCPS::Service_Participant::thread_status_manager_

private

Definition at line 755 of file Service_Participant.h.

Referenced by get_domain_participant_factory(), get_thread_status_manager(), load_common_configuration(), and parse_args().

time_source_

const TimeSource OpenDDS::DCPS::Service_Participant::time_source_

private

Definition at line 556 of file Service_Participant.h.

Referenced by time_source().

transient_data_cache_

unique_ptr<DataDurabilityCache> OpenDDS::DCPS::Service_Participant::transient_data_cache_

private

The TRANSIENT data durability cache.

Definition at line 738 of file Service_Participant.h.

Referenced by get_data_durability_cache(), and shutdown().

type_object_encoding_

TypeObjectEncoding OpenDDS::DCPS::Service_Participant::type_object_encoding_

private

Definition at line 785 of file Service_Participant.h.

Referenced by type_object_encoding().

xtypes_lock_

ACE_Thread_Mutex OpenDDS::DCPS::Service_Participant::xtypes_lock_

private

Thread mutex used to protect the static initialization of XTypes data structures.

Definition at line 758 of file Service_Participant.h.

Referenced by get_static_xtypes_lock().

zero_argc

int OpenDDS::DCPS::Service_Participant::zero_argc = 0

staticprivate

Definition at line 771 of file Service_Participant.h.

---

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

• Service_Participant.h
• Service_Participant.cpp
• Service_Participant.inl