Line data    Source code

       1             : /*
       2             :  *
       3             :  *
       4             :  * Distributed under the OpenDDS License.
       5             :  * See: http://www.opendds.org/license.html
       6             :  */
       7             : 
       8             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
       9             : 
      10             : namespace OpenDDS {
      11             : namespace DCPS {
      12             : 
      13             : ACE_INLINE
      14             : Discovery::RepoKey
      15             : Service_Participant::domain_to_repo(const DDS::DomainId_t domain) const
      16             : {
      17             :   DomainRepoMap::const_iterator where = domainRepoMap_.find(domain);
      18             : 
      19             :   if (where == domainRepoMap_.end()) {
      20             :     return Discovery::DEFAULT_REPO;
      21             : 
      22             :   } else {
      23             :     return where->second;
      24             :   }
      25             : }
      26             : 
      27             : ACE_INLINE
      28             : const DDS::UserDataQosPolicy&
      29         181 : Service_Participant::initial_UserDataQosPolicy() const
      30             : {
      31         181 :   return initial_UserDataQosPolicy_;
      32             : }
      33             : 
      34             : ACE_INLINE
      35             : const DDS::TopicDataQosPolicy&
      36         143 : Service_Participant::initial_TopicDataQosPolicy() const
      37             : {
      38         143 :   return initial_TopicDataQosPolicy_;
      39             : }
      40             : 
      41             : ACE_INLINE
      42             : const DDS::GroupDataQosPolicy&
      43         143 : Service_Participant::initial_GroupDataQosPolicy() const
      44             : {
      45         143 :   return initial_GroupDataQosPolicy_;
      46             : }
      47             : 
      48             : ACE_INLINE
      49             : const DDS::TransportPriorityQosPolicy&
      50           0 : Service_Participant::initial_TransportPriorityQosPolicy() const
      51             : {
      52           0 :   return initial_TransportPriorityQosPolicy_;
      53             : }
      54             : 
      55             : ACE_INLINE
      56             : const DDS::LifespanQosPolicy&
      57          83 : Service_Participant::initial_LifespanQosPolicy() const
      58             : {
      59          83 :   return initial_LifespanQosPolicy_;
      60             : }
      61             : 
      62             : ACE_INLINE
      63             : const DDS::DurabilityQosPolicy&
      64         145 : Service_Participant::initial_DurabilityQosPolicy() const
      65             : {
      66         145 :   return initial_DurabilityQosPolicy_;
      67             : }
      68             : 
      69             : ACE_INLINE
      70             : const DDS::DurabilityServiceQosPolicy&
      71          83 : Service_Participant::initial_DurabilityServiceQosPolicy() const
      72             : {
      73          83 :   return initial_DurabilityServiceQosPolicy_;
      74             : }
      75             : 
      76             : ACE_INLINE
      77             : const DDS::PresentationQosPolicy&
      78         147 : Service_Participant::initial_PresentationQosPolicy() const
      79             : {
      80         147 :   return initial_PresentationQosPolicy_;
      81             : }
      82             : 
      83             : ACE_INLINE
      84             : const DDS::DeadlineQosPolicy&
      85         146 : Service_Participant::initial_DeadlineQosPolicy() const
      86             : {
      87         146 :   return initial_DeadlineQosPolicy_;
      88             : }
      89             : 
      90             : ACE_INLINE
      91             : const DDS::LatencyBudgetQosPolicy&
      92         146 : Service_Participant::initial_LatencyBudgetQosPolicy() const
      93             : {
      94         146 :   return initial_LatencyBudgetQosPolicy_;
      95             : }
      96             : 
      97             : ACE_INLINE
      98             : const DDS::OwnershipQosPolicy&
      99         145 : Service_Participant::initial_OwnershipQosPolicy() const
     100             : {
     101         145 :   return initial_OwnershipQosPolicy_;
     102             : }
     103             : 
     104             : #ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
     105             : ACE_INLINE
     106             : const DDS::OwnershipStrengthQosPolicy&
     107          83 : Service_Participant::initial_OwnershipStrengthQosPolicy() const
     108             : {
     109          83 :   return initial_OwnershipStrengthQosPolicy_;
     110             : }
     111             : #endif
     112             : 
     113             : ACE_INLINE
     114             : const DDS::LivelinessQosPolicy&
     115         147 : Service_Participant::initial_LivelinessQosPolicy() const
     116             : {
     117         147 :   return initial_LivelinessQosPolicy_;
     118             : }
     119             : 
     120             : ACE_INLINE
     121             : const DDS::TimeBasedFilterQosPolicy&
     122          63 : Service_Participant::initial_TimeBasedFilterQosPolicy() const
     123             : {
     124          63 :   return initial_TimeBasedFilterQosPolicy_;
     125             : }
     126             : 
     127             : ACE_INLINE
     128             : const DDS::PartitionQosPolicy&
     129         143 : Service_Participant::initial_PartitionQosPolicy() const
     130             : {
     131         143 :   return initial_PartitionQosPolicy_;
     132             : }
     133             : 
     134             : ACE_INLINE
     135             : const DDS::ReliabilityQosPolicy&
     136           2 : Service_Participant::initial_ReliabilityQosPolicy() const
     137             : {
     138           2 :   return initial_ReliabilityQosPolicy_;
     139             : }
     140             : 
     141             : ACE_INLINE
     142             : const DDS::DestinationOrderQosPolicy&
     143         145 : Service_Participant::initial_DestinationOrderQosPolicy() const
     144             : {
     145         145 :   return initial_DestinationOrderQosPolicy_;
     146             : }
     147             : 
     148             : ACE_INLINE
     149             : const DDS::HistoryQosPolicy&
     150           0 : Service_Participant::initial_HistoryQosPolicy() const
     151             : {
     152           0 :   return initial_HistoryQosPolicy_;
     153             : }
     154             : 
     155             : ACE_INLINE
     156             : const DDS::ResourceLimitsQosPolicy&
     157           0 : Service_Participant::initial_ResourceLimitsQosPolicy() const
     158             : {
     159           0 :   return initial_ResourceLimitsQosPolicy_;
     160             : }
     161             : 
     162             : ACE_INLINE
     163             : const DDS::EntityFactoryQosPolicy&
     164           0 : Service_Participant::initial_EntityFactoryQosPolicy() const
     165             : {
     166           0 :   return initial_EntityFactoryQosPolicy_;
     167             : }
     168             : 
     169             : ACE_INLINE
     170             : const DDS::WriterDataLifecycleQosPolicy&
     171           0 : Service_Participant::initial_WriterDataLifecycleQosPolicy() const
     172             : {
     173           0 :   return initial_WriterDataLifecycleQosPolicy_;
     174             : }
     175             : 
     176             : ACE_INLINE
     177             : const DDS::ReaderDataLifecycleQosPolicy&
     178           0 : Service_Participant::initial_ReaderDataLifecycleQosPolicy() const
     179             : {
     180           0 :   return initial_ReaderDataLifecycleQosPolicy_;
     181             : }
     182             : 
     183             : ACE_INLINE
     184             : const DDS::PropertyQosPolicy&
     185             : Service_Participant::initial_PropertyQosPolicy() const
     186             : {
     187             :   return initial_PropertyQosPolicy_;
     188             : }
     189             : 
     190             : ACE_INLINE
     191             : const DDS::DataRepresentationQosPolicy&
     192             : Service_Participant::initial_DataRepresentationQosPolicy() const
     193             : {
     194             :   return initial_DataRepresentationQosPolicy_;
     195             : }
     196             : 
     197             : ACE_INLINE
     198             : const DDS::DomainParticipantFactoryQos&
     199           9 : Service_Participant::initial_DomainParticipantFactoryQos() const
     200             : {
     201           9 :   return initial_DomainParticipantFactoryQos_;
     202             : }
     203             : 
     204             : ACE_INLINE
     205             : const DDS::DomainParticipantQos&
     206           9 : Service_Participant::initial_DomainParticipantQos() const
     207             : {
     208           9 :   return initial_DomainParticipantQos_;
     209             : }
     210             : 
     211             : ACE_INLINE
     212             : const DDS::TopicQos&
     213           0 : Service_Participant::initial_TopicQos() const
     214             : {
     215           0 :   return initial_TopicQos_;
     216             : }
     217             : 
     218             : ACE_INLINE
     219             : const DDS::DataWriterQos&
     220          41 : Service_Participant::initial_DataWriterQos() const
     221             : {
     222          41 :   return initial_DataWriterQos_;
     223             : }
     224             : 
     225             : ACE_INLINE
     226             : const DDS::PublisherQos&
     227           0 : Service_Participant::initial_PublisherQos() const
     228             : {
     229           0 :   return initial_PublisherQos_;
     230             : }
     231             : 
     232             : ACE_INLINE
     233             : const DDS::DataReaderQos&
     234          23 : Service_Participant::initial_DataReaderQos() const
     235             : {
     236          23 :   return initial_DataReaderQos_;
     237             : }
     238             : 
     239             : ACE_INLINE
     240             : const DDS::SubscriberQos&
     241           0 : Service_Participant::initial_SubscriberQos() const
     242             : {
     243           0 :   return initial_SubscriberQos_;
     244             : }
     245             : 
     246             : ACE_INLINE
     247             : const DDS::TypeConsistencyEnforcementQosPolicy&
     248          59 : Service_Participant::initial_TypeConsistencyEnforcementQosPolicy() const
     249             : {
     250          59 :   return initial_TypeConsistencyEnforcementQosPolicy_;
     251             : }
     252             : 
     253             : ACE_INLINE
     254             : int&
     255           0 : Service_Participant::federation_recovery_duration()
     256             : {
     257           0 :   return federation_recovery_duration_;
     258             : }
     259             : 
     260             : ACE_INLINE
     261             : int
     262             : Service_Participant::federation_recovery_duration() const
     263             : {
     264             :   return federation_recovery_duration_;
     265             : }
     266             : 
     267             : ACE_INLINE
     268             : int&
     269           0 : Service_Participant::federation_initial_backoff_seconds()
     270             : {
     271           0 :   return federation_initial_backoff_seconds_;
     272             : }
     273             : 
     274             : ACE_INLINE
     275             : int
     276             : Service_Participant::federation_initial_backoff_seconds() const
     277             : {
     278             :   return federation_initial_backoff_seconds_;
     279             : }
     280             : 
     281             : ACE_INLINE
     282             : int&
     283           0 : Service_Participant::federation_backoff_multiplier()
     284             : {
     285           0 :   return federation_backoff_multiplier_;
     286             : }
     287             : 
     288             : ACE_INLINE
     289             : int
     290             : Service_Participant::federation_backoff_multiplier() const
     291             : {
     292             :   return federation_backoff_multiplier_;
     293             : }
     294             : 
     295             : ACE_INLINE
     296             : int&
     297             : Service_Participant::federation_liveliness()
     298             : {
     299             :   return federation_liveliness_;
     300             : }
     301             : 
     302             : ACE_INLINE
     303             : int
     304             : Service_Participant::federation_liveliness() const
     305             : {
     306             :   return federation_liveliness_;
     307             : }
     308             : 
     309             : ACE_INLINE
     310             : long&
     311           0 : Service_Participant::scheduler()
     312             : {
     313           0 :   return scheduler_;
     314             : }
     315             : 
     316             : ACE_INLINE
     317             : long
     318             : Service_Participant::scheduler() const
     319             : {
     320             :   return scheduler_;
     321             : }
     322             : 
     323             : ACE_INLINE
     324             : TimeDuration
     325           3 : Service_Participant::pending_timeout() const
     326             : {
     327           3 :   return pending_timeout_;
     328             : }
     329             : 
     330             : ACE_INLINE
     331             : void Service_Participant::pending_timeout(const TimeDuration& value)
     332             : {
     333             :   pending_timeout_ = value;
     334             : }
     335             : 
     336             : ACE_INLINE
     337           0 : MonotonicTimePoint Service_Participant::new_pending_timeout_deadline() const
     338             : {
     339           0 :   return pending_timeout_.is_zero() ?
     340           0 :     MonotonicTimePoint() : MonotonicTimePoint::now() + pending_timeout_;
     341             : }
     342             : 
     343             : ACE_INLINE
     344             : int
     345           0 : Service_Participant::priority_min() const
     346             : {
     347           0 :   return priority_min_;
     348             : }
     349             : 
     350             : ACE_INLINE
     351             : int
     352           0 : Service_Participant::priority_max() const
     353             : {
     354           0 :   return priority_max_;
     355             : }
     356             : 
     357             : ACE_INLINE
     358             : bool&
     359           0 : Service_Participant::publisher_content_filter()
     360             : {
     361           0 :   return publisher_content_filter_;
     362             : }
     363             : 
     364             : ACE_INLINE
     365             : bool
     366             : Service_Participant::publisher_content_filter() const
     367             : {
     368             :   return publisher_content_filter_;
     369             : }
     370             : 
     371             : ACE_INLINE
     372             : bool
     373           0 : Service_Participant::is_shut_down() const
     374             : {
     375           0 :   return shut_down_;
     376             : }
     377             : 
     378             : ACE_INLINE
     379             : bool
     380             : Service_Participant::use_bidir_giop() const
     381             : {
     382             :   return bidir_giop_;
     383             : }
     384             : 
     385             : ACE_INLINE
     386             : Service_Participant::TypeObjectEncoding
     387         161 : Service_Participant::type_object_encoding() const
     388             : {
     389         161 :   return type_object_encoding_;
     390             : }
     391             : 
     392             : ACE_INLINE
     393           0 : void Service_Participant::type_object_encoding(TypeObjectEncoding encoding)
     394             : {
     395           0 :   type_object_encoding_ = encoding;
     396           0 : }
     397             : 
     398             : } // namespace DCPS
     399             : } // namespace OpenDDS
     400             : 
     401             : OPENDDS_END_VERSIONED_NAMESPACE_DECL