OpenDDS  Snapshot(2023/04/28-20:55)
Service_Participant.inl
Go to the documentation of this file.
1 /*
2  *
3  *
4  * Distributed under the OpenDDS License.
5  * See: http://www.opendds.org/license.html
6  */
7 
9 
10 namespace OpenDDS {
11 namespace DCPS {
12 
16 {
17  DomainRepoMap::const_iterator where = domainRepoMap_.find(domain);
18 
19  if (where == domainRepoMap_.end()) {
21 
22  } else {
23  return where->second;
24  }
25 }
26 
30 {
32 }
33 
37 {
39 }
40 
44 {
46 }
47 
51 {
53 }
54 
58 {
60 }
61 
65 {
67 }
68 
72 {
74 }
75 
79 {
81 }
82 
86 {
88 }
89 
93 {
95 }
96 
100 {
102 }
103 
104 #ifndef OPENDDS_NO_OWNERSHIP_KIND_EXCLUSIVE
108 {
110 }
111 #endif
112 
116 {
118 }
119 
123 {
125 }
126 
130 {
132 }
133 
137 {
139 }
140 
144 {
146 }
147 
151 {
153 }
154 
158 {
160 }
161 
165 {
167 }
168 
172 {
174 }
175 
179 {
181 }
182 
186 {
188 }
189 
193 {
195 }
196 
200 {
202 }
203 
207 {
209 }
210 
212 const DDS::TopicQos&
214 {
215  return initial_TopicQos_;
216 }
217 
219 const DDS::DataWriterQos&
221 {
222  return initial_DataWriterQos_;
223 }
224 
226 const DDS::PublisherQos&
228 {
229  return initial_PublisherQos_;
230 }
231 
233 const DDS::DataReaderQos&
235 {
236  return initial_DataReaderQos_;
237 }
238 
240 const DDS::SubscriberQos&
242 {
243  return initial_SubscriberQos_;
244 }
245 
249 {
251 }
252 
254 int&
256 {
258 }
259 
261 int
263 {
265 }
266 
268 int&
270 {
272 }
273 
275 int
277 {
279 }
280 
282 int&
284 {
286 }
287 
289 int
291 {
293 }
294 
296 int&
298 {
299  return federation_liveliness_;
300 }
301 
303 int
305 {
306  return federation_liveliness_;
307 }
308 
310 long&
312 {
313  return scheduler_;
314 }
315 
317 long
319 {
320  return scheduler_;
321 }
322 
326 {
327  return pending_timeout_;
328 }
329 
332 {
334 }
335 
338 {
339  return pending_timeout_.is_zero() ?
341 }
342 
344 int
346 {
347  return priority_min_;
348 }
349 
351 int
353 {
354  return priority_max_;
355 }
356 
358 bool&
360 {
362 }
363 
365 bool
367 {
369 }
370 
372 bool
374 {
375  return shut_down_;
376 }
377 
379 bool
381 {
382  return bidir_giop_;
383 }
384 
388 {
389  return type_object_encoding_;
390 }
391 
394 {
396 }
397 
398 } // namespace DCPS
399 } // namespace OpenDDS
400 
DDS::GroupDataQosPolicy initial_GroupDataQosPolicy_
const DDS::LatencyBudgetQosPolicy & initial_LatencyBudgetQosPolicy() const
TimeDuration pending_timeout() const
Accessors for pending data timeout.
DDS::ResourceLimitsQosPolicy initial_ResourceLimitsQosPolicy_
const DDS::PresentationQosPolicy & initial_PresentationQosPolicy() const
DDS::DataRepresentationQosPolicy initial_DataRepresentationQosPolicy_
static const char * DEFAULT_REPO
Key value for the default repository IOR.
Definition: Discovery.h:85
Discovery::RepoKey domain_to_repo(const DDS::DomainId_t domain) const
Convert domainId to repository key.
const LogLevel::Value value
Definition: debug.cpp:61
TypeObjectEncoding type_object_encoding() const
const DDS::SubscriberQos & initial_SubscriberQos() const
long scheduler_
Scheduling policy value used for setting thread priorities.
DDS::LatencyBudgetQosPolicy initial_LatencyBudgetQosPolicy_
int & federation_recovery_duration()
Accessors for FederationRecoveryDuration in seconds.
DDS::TopicDataQosPolicy initial_TopicDataQosPolicy_
DomainRepoMap domainRepoMap_
The DomainId to RepoKey mapping.
const DDS::DomainParticipantFactoryQos & initial_DomainParticipantFactoryQos() const
int priority_min_
Minimum priority value for the current scheduling policy.
const DDS::ReaderDataLifecycleQosPolicy & initial_ReaderDataLifecycleQosPolicy() const
DDS::TypeConsistencyEnforcementQosPolicy initial_TypeConsistencyEnforcementQosPolicy_
DDS::OwnershipQosPolicy initial_OwnershipQosPolicy_
DDS::LifespanQosPolicy initial_LifespanQosPolicy_
int & federation_initial_backoff_seconds()
Accessors for FederationInitialBackoffSeconds.
DDS::WriterDataLifecycleQosPolicy initial_WriterDataLifecycleQosPolicy_
const DDS::DataWriterQos & initial_DataWriterQos() const
int & federation_liveliness()
Accessors for FederationLivelinessDuration.
const DDS::HistoryQosPolicy & initial_HistoryQosPolicy() const
DDS::ReaderDataLifecycleQosPolicy initial_ReaderDataLifecycleQosPolicy_
const DDS::OwnershipStrengthQosPolicy & initial_OwnershipStrengthQosPolicy() const
int priority_max_
Maximum priority value for the current scheduling policy.
DDS::TransportPriorityQosPolicy initial_TransportPriorityQosPolicy_
const DDS::DestinationOrderQosPolicy & initial_DestinationOrderQosPolicy() const
int priority_min() const
Accessors for priority extremums for the current scheduler.
const DDS::DeadlineQosPolicy & initial_DeadlineQosPolicy() const
DDS::DurabilityQosPolicy initial_DurabilityQosPolicy_
const DDS::DataReaderQos & initial_DataReaderQos() const
DDS::LivelinessQosPolicy initial_LivelinessQosPolicy_
static TimePoint_T< MonotonicClock > now()
Definition: TimePoint_T.inl:41
DDS::DestinationOrderQosPolicy initial_DestinationOrderQosPolicy_
bool bidir_giop_
Enable TAO&#39;s Bidirectional GIOP?
const DDS::ReliabilityQosPolicy & initial_ReliabilityQosPolicy() const
DOMAINID_TYPE_NATIVE DomainId_t
const DDS::LivelinessQosPolicy & initial_LivelinessQosPolicy() const
int federation_recovery_duration_
The FederationRecoveryDuration value in seconds.
long & scheduler()
Accessors for scheduling policy value.
const DDS::DurabilityServiceQosPolicy & initial_DurabilityServiceQosPolicy() const
bool is_shut_down() const
Accessor for if the participant has been shutdown.
int federation_liveliness_
This FederationLivelinessDuration.
const DDS::GroupDataQosPolicy & initial_GroupDataQosPolicy() const
DDS::PropertyQosPolicy initial_PropertyQosPolicy_
DDS::DomainParticipantFactoryQos initial_DomainParticipantFactoryQos_
DDS::ReliabilityQosPolicy initial_ReliabilityQosPolicy_
TimePoint_T< MonotonicClock > MonotonicTimePoint
Definition: TimeTypes.h:51
const DDS::UserDataQosPolicy & initial_UserDataQosPolicy() const
const DDS::EntityFactoryQosPolicy & initial_EntityFactoryQosPolicy() const
bool & publisher_content_filter()
Accessors for PublisherContentFilter.
const DDS::TransportPriorityQosPolicy & initial_TransportPriorityQosPolicy() const
DDS::PartitionQosPolicy initial_PartitionQosPolicy_
const DDS::PropertyQosPolicy & initial_PropertyQosPolicy() const
const DDS::PublisherQos & initial_PublisherQos() const
DDS::HistoryQosPolicy initial_HistoryQosPolicy_
const DDS::WriterDataLifecycleQosPolicy & initial_WriterDataLifecycleQosPolicy() const
DDS::TimeBasedFilterQosPolicy initial_TimeBasedFilterQosPolicy_
const DDS::ResourceLimitsQosPolicy & initial_ResourceLimitsQosPolicy() const
const DDS::TimeBasedFilterQosPolicy & initial_TimeBasedFilterQosPolicy() const
DDS::DomainParticipantQos initial_DomainParticipantQos_
const DDS::DomainParticipantQos & initial_DomainParticipantQos() const
DDS::DeadlineQosPolicy initial_DeadlineQosPolicy_
DDS::EntityFactoryQosPolicy initial_EntityFactoryQosPolicy_
const DDS::TypeConsistencyEnforcementQosPolicy & initial_TypeConsistencyEnforcementQosPolicy() const
int federation_initial_backoff_seconds_
The FederationInitialBackoffSeconds value.
AtomicBool shut_down_
Used to track state of service participant.
int federation_backoff_multiplier_
This FederationBackoffMultiplier.
#define OPENDDS_END_VERSIONED_NAMESPACE_DECL
DDS::DurabilityServiceQosPolicy initial_DurabilityServiceQosPolicy_
const DDS::TopicQos & initial_TopicQos() const
#define ACE_INLINE
const DDS::DataRepresentationQosPolicy & initial_DataRepresentationQosPolicy() const
MonotonicTimePoint new_pending_timeout_deadline() const
Get a new pending timeout deadline.
const DDS::DurabilityQosPolicy & initial_DurabilityQosPolicy() const
int priority_max() const
Accessors for priority extremums for the current scheduler.
DDS::UserDataQosPolicy initial_UserDataQosPolicy_
The initial values of qos policies.
DDS::OwnershipStrengthQosPolicy initial_OwnershipStrengthQosPolicy_
const DDS::TopicDataQosPolicy & initial_TopicDataQosPolicy() const
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
DDS::PresentationQosPolicy initial_PresentationQosPolicy_
const DDS::LifespanQosPolicy & initial_LifespanQosPolicy() const
const DDS::OwnershipQosPolicy & initial_OwnershipQosPolicy() const
OPENDDS_STRING RepoKey
Definition: Discovery.h:80
const DDS::PartitionQosPolicy & initial_PartitionQosPolicy() const
The Internal API and Implementation of OpenDDS.
Definition: AddressCache.h:28
bool publisher_content_filter_
Allow the publishing side to do content filtering?
int & federation_backoff_multiplier()
Accessors for FederationBackoffMultiplier.