OpenDDS::DCPS::StaticParticipant Class Reference

#include <StaticDiscovery.h>

Inheritance diagram for OpenDDS::DCPS::StaticParticipant:

Collaboration diagram for OpenDDS::DCPS::StaticParticipant:

Classes
struct	DiscoveredParticipant

Public Member Functions
	StaticParticipant (GUID_t &guid, const DDS::DomainParticipantQos &qos, const EndpointRegistry &registry)
void	init_bit (const DDS::Subscriber_var &bit_subscriber)
void	fini_bit ()
void	shutdown ()
DDS::Subscriber_ptr	init_bit (DomainParticipantImpl *participant)
void	fini_bit (DCPS::DomainParticipantImpl *participant)
bool	attach_participant (DDS::DomainId_t domainId, const GUID_t &participantId)
bool	remove_domain_participant (DDS::DomainId_t domain_id, const GUID_t &participantId)
bool	ignore_domain_participant (DDS::DomainId_t domain, const GUID_t &myParticipantId, const GUID_t &ignoreId)
bool	update_domain_participant_qos (DDS::DomainId_t domain, const GUID_t &participant, const DDS::DomainParticipantQos &qos)
DCPS::TopicStatus	assert_topic (GUID_t &topicId, DDS::DomainId_t domainId, const GUID_t &participantId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, bool hasDcpsKey, DCPS::TopicCallbacks *topic_callbacks)
DCPS::TopicStatus	find_topic (DDS::DomainId_t domainId, const GUID_t &participantId, const char *topicName, CORBA::String_out dataTypeName, DDS::TopicQos_out qos, GUID_t &topicId)
DCPS::TopicStatus	remove_topic (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId)
bool	ignore_topic (DDS::DomainId_t domainId, const GUID_t &myParticipantId, const GUID_t &ignoreId)
bool	update_topic_qos (const GUID_t &topicId, DDS::DomainId_t domainId, const GUID_t &participantId, const DDS::TopicQos &qos)
GUID_t	add_publication (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId, DCPS::DataWriterCallbacks_rch publication, const DDS::DataWriterQos &qos, const DCPS::TransportLocatorSeq &transInfo, const DDS::PublisherQos &publisherQos, const XTypes::TypeInformation &type_info)
bool	remove_publication (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &publicationId)
bool	ignore_publication (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &ignoreId)
bool	update_publication_qos (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &dwId, const DDS::DataWriterQos &qos, const DDS::PublisherQos &publisherQos)
void	update_publication_locators (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &dwId, const DCPS::TransportLocatorSeq &transInfo)
GUID_t	add_subscription (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &topicId, DCPS::DataReaderCallbacks_rch subscription, const DDS::DataReaderQos &qos, const DCPS::TransportLocatorSeq &transInfo, const DDS::SubscriberQos &subscriberQos, const char *filterClassName, const char *filterExpr, const DDS::StringSeq &params, const XTypes::TypeInformation &type_info)
bool	remove_subscription (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &subscriptionId)
bool	ignore_subscription (DDS::DomainId_t domainId, const GUID_t &participantId, const GUID_t &ignoreId)
bool	update_subscription_qos (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &drId, const DDS::DataReaderQos &qos, const DDS::SubscriberQos &subQos)
bool	update_subscription_params (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &subId, const DDS::StringSeq &params)
void	update_subscription_locators (DDS::DomainId_t domainId, const GUID_t &partId, const GUID_t &subId, const DCPS::TransportLocatorSeq &transInfo)
void	ignore_domain_participant (const GUID_t &ignoreId)
virtual bool	announce_domain_participant_qos ()
bool	update_domain_participant_qos (const DDS::DomainParticipantQos &qos)
TopicStatus	assert_topic (GUID_t &topicId, const char *topicName, const char *dataTypeName, const DDS::TopicQos &qos, bool hasDcpsKey, TopicCallbacks *topic_callbacks)
TopicStatus	find_topic (const char *topicName, CORBA::String_out dataTypeName, DDS::TopicQos_out qos, GUID_t &topicId)
TopicStatus	remove_topic (const GUID_t &topicId)
void	ignore_topic (const GUID_t &ignoreId)
bool	update_topic_qos (const GUID_t &topicId, const DDS::TopicQos &qos)
GUID_t	add_publication (const GUID_t &topicId, DataWriterCallbacks_rch publication, const DDS::DataWriterQos &qos, const TransportLocatorSeq &transInfo, const DDS::PublisherQos &publisherQos, const XTypes::TypeInformation &type_info)
void	remove_publication (const GUID_t &publicationId)
void	ignore_publication (const GUID_t &ignoreId)
bool	update_publication_qos (const GUID_t &publicationId, const DDS::DataWriterQos &qos, const DDS::PublisherQos &publisherQos)
void	update_publication_locators (const GUID_t &publicationId, const TransportLocatorSeq &transInfo)
GUID_t	add_subscription (const GUID_t &topicId, DataReaderCallbacks_rch subscription, const DDS::DataReaderQos &qos, const TransportLocatorSeq &transInfo, const DDS::SubscriberQos &subscriberQos, const char *filterClassName, const char *filterExpr, const DDS::StringSeq &params, const XTypes::TypeInformation &type_info)
void	remove_subscription (const GUID_t &subscriptionId)
void	ignore_subscription (const GUID_t &ignoreId)
bool	update_subscription_qos (const GUID_t &subscriptionId, const DDS::DataReaderQos &qos, const DDS::SubscriberQos &subscriberQos)
bool	update_subscription_params (const GUID_t &subId, const DDS::StringSeq &params)
void	update_subscription_locators (const GUID_t &subId, const TransportLocatorSeq &transInfo)
DDS::Subscriber_var	bit_subscriber () const
void	type_lookup_service (const XTypes::TypeLookupService_rch type_lookup_service)
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Private Types
typedef DiscoveredParticipantMap::iterator	DiscoveredParticipantIter
typedef DiscoveredParticipantMap::const_iterator	DiscoveredParticipantConstIter

Private Member Functions
typedef	OPENDDS_MAP_CMP (GUID_t, DiscoveredParticipant, GUID_tKeyLessThan) DiscoveredParticipantMap
void	remove_discovered_participant (DiscoveredParticipantIter &iter)
virtual void	remove_discovered_participant_i (DiscoveredParticipantIter &)
ParticipantBuiltinTopicDataDataReaderImpl *	part_bit ()
ParticipantLocationBuiltinTopicDataDataReaderImpl *	part_loc_bit ()
ConnectionRecordDataReaderImpl *	connection_record_bit ()
InternalThreadBuiltinTopicDataDataReaderImpl *	internal_thread_bit ()
StaticEndpointManager &	endpoint_manager ()

Private Attributes
ACE_Thread_Mutex	lock_
DDS::Subscriber_var	bit_subscriber_
DDS::DomainParticipantQos	qos_
DiscoveredParticipantMap	participants_
RcHandle< StaticEndpointManager >	endpoint_manager_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 479 of file StaticDiscovery.h.

Member Typedef Documentation

DiscoveredParticipantConstIter

typedef DiscoveredParticipantMap::const_iterator OpenDDS::DCPS::StaticParticipant::DiscoveredParticipantConstIter

private

Definition at line 803 of file StaticDiscovery.h.

DiscoveredParticipantIter

typedef DiscoveredParticipantMap::iterator OpenDDS::DCPS::StaticParticipant::DiscoveredParticipantIter

private

Definition at line 801 of file StaticDiscovery.h.

Constructor & Destructor Documentation

StaticParticipant()

OpenDDS::DCPS::StaticParticipant::StaticParticipant ( GUID_t &  guid, const DDS::DomainParticipantQos &  qos, const EndpointRegistry &  registry  )

inline

Definition at line 481 of file StaticDiscovery.h.

    : qos_(qos)
    , endpoint_manager_(make_rch<StaticEndpointManager>(guid, ref(lock_), ref(registry), ref(*this)))
  {}

Member Function Documentation

add_publication() [1/2]

GUID_t OpenDDS::DCPS::StaticParticipant::add_publication	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	topicId,
		DCPS::DataWriterCallbacks_rch	publication,
		const DDS::DataWriterQos &	qos,
		const DCPS::TransportLocatorSeq &	transInfo,
		const DDS::PublisherQos &	publisherQos,
		const XTypes::TypeInformation &	type_info
	)

add_publication() [2/2]

GUID_t OpenDDS::DCPS::StaticParticipant::add_publication ( const GUID_t &  topicId, DataWriterCallbacks_rch  publication, const DDS::DataWriterQos &  qos, const TransportLocatorSeq &  transInfo, const DDS::PublisherQos &  publisherQos, const XTypes::TypeInformation &  type_info  )

inline

Definition at line 675 of file StaticDiscovery.h.

  {
    return endpoint_manager().add_publication(topicId, publication, qos,
                                              transInfo, publisherQos, type_info);
  }

add_subscription() [1/2]

GUID_t OpenDDS::DCPS::StaticParticipant::add_subscription	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	topicId,
		DCPS::DataReaderCallbacks_rch	subscription,
		const DDS::DataReaderQos &	qos,
		const DCPS::TransportLocatorSeq &	transInfo,
		const DDS::SubscriberQos &	subscriberQos,
		const char *	filterClassName,
		const char *	filterExpr,
		const DDS::StringSeq &	params,
		const XTypes::TypeInformation &	type_info
	)

add_subscription() [2/2]

GUID_t OpenDDS::DCPS::StaticParticipant::add_subscription ( const GUID_t &  topicId, DataReaderCallbacks_rch  subscription, const DDS::DataReaderQos &  qos, const TransportLocatorSeq &  transInfo, const DDS::SubscriberQos &  subscriberQos, const char *  filterClassName, const char *  filterExpr, const DDS::StringSeq &  params, const XTypes::TypeInformation &  type_info  )

inline

Definition at line 712 of file StaticDiscovery.h.

  {
    return endpoint_manager().add_subscription(topicId, subscription, qos, transInfo,
      subscriberQos, filterClassName, filterExpr, params, type_info);
  }

announce_domain_participant_qos()

virtual bool OpenDDS::DCPS::StaticParticipant::announce_domain_participant_qos ( )

inlinevirtual

Definition at line 622 of file StaticDiscovery.h.

  {
    return true;
  }

assert_topic() [1/2]

DCPS::TopicStatus OpenDDS::DCPS::StaticParticipant::assert_topic	(	GUID_t &	topicId,
		DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const char *	topicName,
		const char *	dataTypeName,
		const DDS::TopicQos &	qos,
		bool	hasDcpsKey,
		DCPS::TopicCallbacks *	topic_callbacks
	)

assert_topic() [2/2]

TopicStatus OpenDDS::DCPS::StaticParticipant::assert_topic ( GUID_t &  topicId, const char *  topicName, const char *  dataTypeName, const DDS::TopicQos &  qos, bool  hasDcpsKey, TopicCallbacks *  topic_callbacks  )

inline

Definition at line 634 of file StaticDiscovery.h.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, LM_ERROR, and OpenDDS::DCPS::PRECONDITION_NOT_MET.

  {
    if (std::strlen(topicName) > 256 || std::strlen(dataTypeName) > 256) {
      if (DCPS_debug_level) {
        ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR LocalParticipant::assert_topic() - ")
                   ACE_TEXT("topic or type name length limit (256) exceeded\n")));
      }
      return PRECONDITION_NOT_MET;
    }

    return endpoint_manager().assert_topic(topicId, topicName, dataTypeName, qos, hasDcpsKey, topic_callbacks);
  }

attach_participant()

bool OpenDDS::DCPS::StaticParticipant::attach_participant	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId
	)

bit_subscriber()

DDS::Subscriber_var OpenDDS::DCPS::StaticParticipant::bit_subscriber ( ) const

inline

Definition at line 756 of file StaticDiscovery.h.

Referenced by OpenDDS::DCPS::StaticEndpointManager::pub_bit(), and OpenDDS::DCPS::StaticEndpointManager::sub_bit().

  {
    return bit_subscriber_;
  }

connection_record_bit()

ConnectionRecordDataReaderImpl* OpenDDS::DCPS::StaticParticipant::connection_record_bit ( )

inlineprivate

Definition at line 832 of file StaticDiscovery.h.

References OpenDDS::DCPS::BUILT_IN_CONNECTION_RECORD_TOPIC.

  {
    DDS::Subscriber_var bit_sub(bit_subscriber());
    if (!bit_sub.in())
      return 0;

    DDS::DataReader_var d =
      bit_sub->lookup_datareader(BUILT_IN_CONNECTION_RECORD_TOPIC);
    return dynamic_cast<ConnectionRecordDataReaderImpl*>(d.in());
  }

endpoint_manager()

StaticEndpointManager& OpenDDS::DCPS::StaticParticipant::endpoint_manager ( )

inlineprivate

Definition at line 855 of file StaticDiscovery.h.

{ return *endpoint_manager_; }

find_topic() [1/2]

DCPS::TopicStatus OpenDDS::DCPS::StaticParticipant::find_topic	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const char *	topicName,
		CORBA::String_out	dataTypeName,
		DDS::TopicQos_out	qos,
		GUID_t &	topicId
	)

find_topic() [2/2]

TopicStatus OpenDDS::DCPS::StaticParticipant::find_topic ( const char *  topicName, CORBA::String_out  dataTypeName, DDS::TopicQos_out  qos, GUID_t &  topicId  )

inline

Definition at line 650 of file StaticDiscovery.h.

  {
    return endpoint_manager().find_topic(topicName, dataTypeName, qos, topicId);
  }

fini_bit() [1/2]

void OpenDDS::DCPS::StaticParticipant::fini_bit ( )

inline

Definition at line 494 of file StaticDiscovery.h.

  {
    bit_subscriber_ = 0;
  }

fini_bit() [2/2]

void OpenDDS::DCPS::StaticParticipant::fini_bit

(

DCPS::DomainParticipantImpl *

participant

)

ignore_domain_participant() [1/2]

bool OpenDDS::DCPS::StaticParticipant::ignore_domain_participant	(	DDS::DomainId_t	domain,
		const GUID_t &	myParticipantId,
		const GUID_t &	ignoreId
	)

ignore_domain_participant() [2/2]

void OpenDDS::DCPS::StaticParticipant::ignore_domain_participant ( const GUID_t &  ignoreId )

inline

Definition at line 611 of file StaticDiscovery.h.

References ACE_GUARD, and lock_.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, lock_);
    endpoint_manager().ignore(ignoreId);

    DiscoveredParticipantIter iter = participants_.find(ignoreId);
    if (iter != participants_.end()) {
      remove_discovered_participant(iter);
    }
  }

ignore_publication() [1/2]

bool OpenDDS::DCPS::StaticParticipant::ignore_publication	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	ignoreId
	)

ignore_publication() [2/2]

void OpenDDS::DCPS::StaticParticipant::ignore_publication ( const GUID_t &  ignoreId )

inline

Definition at line 692 of file StaticDiscovery.h.

References ACE_GUARD, and lock_.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, lock_);
    return endpoint_manager().ignore(ignoreId);
  }

ignore_subscription() [1/2]

bool OpenDDS::DCPS::StaticParticipant::ignore_subscription	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	ignoreId
	)

ignore_subscription() [2/2]

void OpenDDS::DCPS::StaticParticipant::ignore_subscription ( const GUID_t &  ignoreId )

inline

Definition at line 732 of file StaticDiscovery.h.

References ACE_GUARD, and lock_.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, lock_);
    return endpoint_manager().ignore(ignoreId);
  }

ignore_topic() [1/2]

bool OpenDDS::DCPS::StaticParticipant::ignore_topic	(	DDS::DomainId_t	domainId,
		const GUID_t &	myParticipantId,
		const GUID_t &	ignoreId
	)

ignore_topic() [2/2]

void OpenDDS::DCPS::StaticParticipant::ignore_topic ( const GUID_t &  ignoreId )

inline

Definition at line 664 of file StaticDiscovery.h.

References ACE_GUARD, and lock_.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, lock_);
    endpoint_manager().ignore(ignoreId);
  }

init_bit() [1/2]

void OpenDDS::DCPS::StaticParticipant::init_bit ( const DDS::Subscriber_var &  bit_subscriber )

inline

Definition at line 488 of file StaticDiscovery.h.

  {
    bit_subscriber_ = bit_subscriber;
    endpoint_manager_->init_bit();
  }

init_bit() [2/2]

DDS::Subscriber_ptr OpenDDS::DCPS::StaticParticipant::init_bit

(

DomainParticipantImpl *

participant

)

internal_thread_bit()

InternalThreadBuiltinTopicDataDataReaderImpl* OpenDDS::DCPS::StaticParticipant::internal_thread_bit ( )

inlineprivate

Definition at line 843 of file StaticDiscovery.h.

References OpenDDS::DCPS::BUILT_IN_INTERNAL_THREAD_TOPIC.

  {
    DDS::Subscriber_var bit_sub(bit_subscriber());
    if (!bit_sub.in())
      return 0;

    DDS::DataReader_var d =
      bit_sub->lookup_datareader(BUILT_IN_INTERNAL_THREAD_TOPIC);
    return dynamic_cast<InternalThreadBuiltinTopicDataDataReaderImpl*>(d.in());
  }

OPENDDS_MAP_CMP()

typedef OpenDDS::DCPS::StaticParticipant::OPENDDS_MAP_CMP ( GUID_t  , DiscoveredParticipant  , GUID_tKeyLessThan    )

private

part_bit()

ParticipantBuiltinTopicDataDataReaderImpl* OpenDDS::DCPS::StaticParticipant::part_bit ( )

inlineprivate

Definition at line 810 of file StaticDiscovery.h.

References OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC.

  {
    DDS::Subscriber_var bit_sub(bit_subscriber());
    if (!bit_sub.in())
      return 0;

    DDS::DataReader_var d =
      bit_sub->lookup_datareader(BUILT_IN_PARTICIPANT_TOPIC);
    return dynamic_cast<ParticipantBuiltinTopicDataDataReaderImpl*>(d.in());
  }

part_loc_bit()

ParticipantLocationBuiltinTopicDataDataReaderImpl* OpenDDS::DCPS::StaticParticipant::part_loc_bit ( )

inlineprivate

Definition at line 821 of file StaticDiscovery.h.

References OpenDDS::DCPS::BUILT_IN_PARTICIPANT_LOCATION_TOPIC.

  {
    DDS::Subscriber_var bit_sub(bit_subscriber());
    if (!bit_sub.in())
      return 0;

    DDS::DataReader_var d =
      bit_sub->lookup_datareader(BUILT_IN_PARTICIPANT_LOCATION_TOPIC);
    return dynamic_cast<ParticipantLocationBuiltinTopicDataDataReaderImpl*>(d.in());
  }

remove_discovered_participant()

void OpenDDS::DCPS::StaticParticipant::remove_discovered_participant ( DiscoveredParticipantIter &  iter )

private

Definition at line 3112 of file StaticDiscovery.cpp.

References ACE_DEBUG, ACE_GUARD, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, DDS::HANDLE_NIL, LM_INFO, OpenDDS::DCPS::StaticDiscovery::lock_, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::StaticDiscovery::participants_, and OpenDDS::DCPS::DataReaderImpl::set_instance_state().

{
  if (iter == participants_.end()) {
    return;
  }
  GUID_t part_id = iter->first;
  bool removed = endpoint_manager().disassociate();
  iter = participants_.find(part_id); // refresh iter after disassociate, which can unlock
  if (iter == participants_.end()) {
    return;
  }
  if (removed) {
#ifndef DDS_HAS_MINIMUM_BIT
    ParticipantBuiltinTopicDataDataReaderImpl* bit = part_bit();
    ParticipantLocationBuiltinTopicDataDataReaderImpl* loc_bit = part_loc_bit();
    // bit may be null if the DomainParticipant is shutting down
    if ((bit && iter->second.bit_ih_ != DDS::HANDLE_NIL) ||
        (loc_bit && iter->second.location_ih_ != DDS::HANDLE_NIL)) {
      {
        const DDS::InstanceHandle_t bit_ih = iter->second.bit_ih_;
        const DDS::InstanceHandle_t location_ih = iter->second.location_ih_;

        ACE_Reverse_Lock<ACE_Thread_Mutex> rev_lock(lock_);
        ACE_GUARD(ACE_Reverse_Lock<ACE_Thread_Mutex>, rg, rev_lock);
        if (bit && bit_ih != DDS::HANDLE_NIL) {
          bit->set_instance_state(bit_ih,
                                  DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE);
        }
        if (loc_bit && location_ih != DDS::HANDLE_NIL) {
          loc_bit->set_instance_state(location_ih,
                                      DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE);
        }
      }
      iter = participants_.find(part_id);
      if (iter == participants_.end()) {
        return;
      }
    }
#endif /* DDS_HAS_MINIMUM_BIT */
    if (DCPS_debug_level > 3) {
      ACE_DEBUG((LM_INFO, ACE_TEXT("(%P|%t) LocalParticipant::remove_discovered_participant")
                 ACE_TEXT(" - erasing %C (%B)\n"), LogGuid(iter->first).c_str(), participants_.size()));
    }

    remove_discovered_participant_i(iter);

    participants_.erase(iter);
  }
}

remove_discovered_participant_i()

virtual void OpenDDS::DCPS::StaticParticipant::remove_discovered_participant_i ( DiscoveredParticipantIter &  )

inlineprivatevirtual

Definition at line 807 of file StaticDiscovery.h.

{}

remove_domain_participant()

bool OpenDDS::DCPS::StaticParticipant::remove_domain_participant	(	DDS::DomainId_t	domain_id,
		const GUID_t &	participantId
	)

remove_publication() [1/2]

bool OpenDDS::DCPS::StaticParticipant::remove_publication	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	publicationId
	)

remove_publication() [2/2]

void OpenDDS::DCPS::StaticParticipant::remove_publication ( const GUID_t &  publicationId )

inline

Definition at line 687 of file StaticDiscovery.h.

  {
    endpoint_manager().remove_publication(publicationId);
  }

remove_subscription() [1/2]

bool OpenDDS::DCPS::StaticParticipant::remove_subscription	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	subscriptionId
	)

remove_subscription() [2/2]

void OpenDDS::DCPS::StaticParticipant::remove_subscription ( const GUID_t &  subscriptionId )

inline

Definition at line 727 of file StaticDiscovery.h.

  {
    endpoint_manager().remove_subscription(subscriptionId);
  }

remove_topic() [1/2]

DCPS::TopicStatus OpenDDS::DCPS::StaticParticipant::remove_topic	(	DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const GUID_t &	topicId
	)

remove_topic() [2/2]

TopicStatus OpenDDS::DCPS::StaticParticipant::remove_topic ( const GUID_t &  topicId )

inline

Definition at line 659 of file StaticDiscovery.h.

  {
    return endpoint_manager().remove_topic(topicId);
  }

shutdown()

void OpenDDS::DCPS::StaticParticipant::shutdown ( void  )

inline

Definition at line 499 of file StaticDiscovery.h.

{}

type_lookup_service()

void OpenDDS::DCPS::StaticParticipant::type_lookup_service ( const XTypes::TypeLookupService_rch  type_lookup_service )

inline

Definition at line 761 of file StaticDiscovery.h.

  {
    endpoint_manager().type_lookup_service(type_lookup_service);
  }

update_domain_participant_qos() [1/2]

bool OpenDDS::DCPS::StaticParticipant::update_domain_participant_qos	(	DDS::DomainId_t	domain,
		const GUID_t &	participant,
		const DDS::DomainParticipantQos &	qos
	)

update_domain_participant_qos() [2/2]

bool OpenDDS::DCPS::StaticParticipant::update_domain_participant_qos ( const DDS::DomainParticipantQos &  qos )

inline

Definition at line 627 of file StaticDiscovery.h.

References ACE_GUARD_RETURN, and lock_.

  {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, g, lock_, false);
    qos_ = qos;
    return announce_domain_participant_qos();
  }

update_publication_locators() [1/2]

void OpenDDS::DCPS::StaticParticipant::update_publication_locators	(	DDS::DomainId_t	domainId,
		const GUID_t &	partId,
		const GUID_t &	dwId,
		const DCPS::TransportLocatorSeq &	transInfo
	)

update_publication_locators() [2/2]

void OpenDDS::DCPS::StaticParticipant::update_publication_locators ( const GUID_t &  publicationId, const TransportLocatorSeq &  transInfo  )

inline

Definition at line 706 of file StaticDiscovery.h.

  {
    endpoint_manager().update_publication_locators(publicationId, transInfo);
  }

update_publication_qos() [1/2]

bool OpenDDS::DCPS::StaticParticipant::update_publication_qos	(	DDS::DomainId_t	domainId,
		const GUID_t &	partId,
		const GUID_t &	dwId,
		const DDS::DataWriterQos &	qos,
		const DDS::PublisherQos &	publisherQos
	)

update_publication_qos() [2/2]

bool OpenDDS::DCPS::StaticParticipant::update_publication_qos ( const GUID_t &  publicationId, const DDS::DataWriterQos &  qos, const DDS::PublisherQos &  publisherQos  )

inline

Definition at line 698 of file StaticDiscovery.h.

  {
    return endpoint_manager().update_publication_qos(publicationId, qos, publisherQos);
  }

update_subscription_locators() [1/2]

void OpenDDS::DCPS::StaticParticipant::update_subscription_locators	(	DDS::DomainId_t	domainId,
		const GUID_t &	partId,
		const GUID_t &	subId,
		const DCPS::TransportLocatorSeq &	transInfo
	)

update_subscription_locators() [2/2]

void OpenDDS::DCPS::StaticParticipant::update_subscription_locators ( const GUID_t &  subId, const TransportLocatorSeq &  transInfo  )

inline

Definition at line 751 of file StaticDiscovery.h.

  {
    endpoint_manager().update_subscription_locators(subId, transInfo);
  }

update_subscription_params() [1/2]

bool OpenDDS::DCPS::StaticParticipant::update_subscription_params	(	DDS::DomainId_t	domainId,
		const GUID_t &	partId,
		const GUID_t &	subId,
		const DDS::StringSeq &	params
	)

update_subscription_params() [2/2]

bool OpenDDS::DCPS::StaticParticipant::update_subscription_params ( const GUID_t &  subId, const DDS::StringSeq &  params  )

inline

Definition at line 746 of file StaticDiscovery.h.

  {
    return endpoint_manager().update_subscription_params(subId, params);
  }

update_subscription_qos() [1/2]

bool OpenDDS::DCPS::StaticParticipant::update_subscription_qos	(	DDS::DomainId_t	domainId,
		const GUID_t &	partId,
		const GUID_t &	drId,
		const DDS::DataReaderQos &	qos,
		const DDS::SubscriberQos &	subQos
	)

update_subscription_qos() [2/2]

bool OpenDDS::DCPS::StaticParticipant::update_subscription_qos ( const GUID_t &  subscriptionId, const DDS::DataReaderQos &  qos, const DDS::SubscriberQos &  subscriberQos  )

inline

Definition at line 738 of file StaticDiscovery.h.

  {
    return endpoint_manager().update_subscription_qos(subscriptionId, qos, subscriberQos);
  }

update_topic_qos() [1/2]

bool OpenDDS::DCPS::StaticParticipant::update_topic_qos	(	const GUID_t &	topicId,
		DDS::DomainId_t	domainId,
		const GUID_t &	participantId,
		const DDS::TopicQos &	qos
	)

update_topic_qos() [2/2]

bool OpenDDS::DCPS::StaticParticipant::update_topic_qos ( const GUID_t &  topicId, const DDS::TopicQos &  qos  )

inline

Definition at line 670 of file StaticDiscovery.h.

  {
    return endpoint_manager().update_topic_qos(topicId, qos);
  }

Member Data Documentation

bit_subscriber_

DDS::Subscriber_var OpenDDS::DCPS::StaticParticipant::bit_subscriber_

private

Definition at line 858 of file StaticDiscovery.h.

endpoint_manager_

RcHandle<StaticEndpointManager> OpenDDS::DCPS::StaticParticipant::endpoint_manager_

private

Definition at line 862 of file StaticDiscovery.h.

lock_

ACE_Thread_Mutex OpenDDS::DCPS::StaticParticipant::lock_

mutableprivate

Definition at line 857 of file StaticDiscovery.h.

participants_

DiscoveredParticipantMap OpenDDS::DCPS::StaticParticipant::participants_

private

Definition at line 860 of file StaticDiscovery.h.

qos_

DDS::DomainParticipantQos OpenDDS::DCPS::StaticParticipant::qos_

private

Definition at line 859 of file StaticDiscovery.h.

---

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

• StaticDiscovery.h
• StaticDiscovery.cpp