#include <BuiltInTopicUtils.h>

Inheritance diagram for OpenDDS::DCPS::BitSubscriber:

Collaboration diagram for OpenDDS::DCPS::BitSubscriber:

[legend]

Public Member Functions
	BitSubscriber ()

	BitSubscriber (const DDS::Subscriber_var &bit_subscriber)

DDS::Subscriber_ptr	get () const

void	clear ()

DDS::InstanceHandle_t	add_participant (const DDS::ParticipantBuiltinTopicData &part, DDS::ViewStateKind view_state)

void	remove_participant (DDS::InstanceHandle_t part_ih, DDS::InstanceHandle_t loc_ih)

DDS::ReturnCode_t	get_discovered_participant_data (DDS::ParticipantBuiltinTopicData &participant_data, DDS::InstanceHandle_t participant_handle)

DDS::ReturnCode_t	get_discovered_topic_data (DDS::TopicBuiltinTopicData &topic_data, DDS::InstanceHandle_t topic_handle)

DDS::InstanceHandle_t	add_publication (const DDS::PublicationBuiltinTopicData &pub, DDS::ViewStateKind view_state)

void	remove_publication (DDS::InstanceHandle_t pub_ih)

DDS::InstanceHandle_t	add_subscription (const DDS::SubscriptionBuiltinTopicData &sub, DDS::ViewStateKind view_state)

void	remove_subscription (DDS::InstanceHandle_t sub_ih)

DDS::InstanceHandle_t	add_participant_location (const ParticipantLocationBuiltinTopicData &loc, DDS::ViewStateKind view_state)

DDS::InstanceHandle_t	add_connection_record (const ConnectionRecord &cr, DDS::ViewStateKind view_state)

void	remove_connection_record (const ConnectionRecord &cr)

DDS::InstanceHandle_t	add_thread_status (const InternalThreadBuiltinTopicData &ts, DDS::ViewStateKind view_state, const SystemTimePoint &timestamp)

void	remove_thread_status (const InternalThreadBuiltinTopicData &ts)

void	bit_pub_listener_hack (DomainParticipantImpl *participant)

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 Member Functions
template<typename DataReaderImpl , typename Sample >
DDS::InstanceHandle_t	add_i (const char *topic_name, const Sample &sample, DDS::ViewStateKind view_state)

void	remove_i (const char *topic_name, DDS::InstanceHandle_t ih)

Private Attributes
DDS::Subscriber_var	bit_subscriber_

ACE_Thread_Mutex	mutex_

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

Detailed Description

Definition at line 244 of file BuiltInTopicUtils.h.

Constructor & Destructor Documentation

◆ BitSubscriber() [1/2]

OpenDDS::DCPS::BitSubscriber::BitSubscriber ( )

inline

Definition at line 246 of file BuiltInTopicUtils.h.

247 {}

◆ BitSubscriber() [2/2]

OpenDDS::DCPS::BitSubscriber::BitSubscriber ( const DDS::Subscriber_var & bit_subscriber )

inlineexplicit

Definition at line 249 of file BuiltInTopicUtils.h.

250 : bit_subscriber_(bit_subscriber)

251 {}

OpenDDS::DCPS::BitSubscriber::bit_subscriber_

DDS::Subscriber_var bit_subscriber_

Definition: BuiltInTopicUtils.h:313

Member Function Documentation

◆ add_connection_record()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_connection_record	(	const ConnectionRecord &	cr,
		DDS::ViewStateKind	view_state
	)

Definition at line 168 of file BuiltInTopicUtils.cpp.

References OpenDDS::DCPS::BUILT_IN_CONNECTION_RECORD_TOPIC.

 {
   return add_i<ConnectionRecordDataReaderImpl>(BUILT_IN_CONNECTION_RECORD_TOPIC, cr, view_state);
 }

◆ add_i()

template<typename DataReaderImpl , typename Sample >

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_i	(	const char *	topic_name,
		const Sample &	sample,
		DDS::ViewStateKind	view_state
	)

private

Definition at line 290 of file BuiltInTopicUtils.cpp.

References ACE_DEBUG, ACE_GUARD_RETURN, bit_subscriber_, DDS::HANDLE_NIL, LM_DEBUG, OpenDDS::DCPS::log_bits, and mutex_.

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, DDS::HANDLE_NIL);
 
   if (!bit_subscriber_) {
     if (log_bits) {
       ACE_DEBUG((LM_DEBUG, "(%P|%t) DEBUG: BitSubscriber::add_i: %@ bit_subscriber_ is null for topic %C, returning nil\n", this, topic_name));
     }
     return DDS::HANDLE_NIL;
   }
 
   DDS::DataReader_var d = bit_subscriber_->lookup_datareader(topic_name);
   if (!d) {
     if (log_bits) {
       ACE_DEBUG((LM_DEBUG, "(%P|%t) DEBUG: BitSubscriber::add_i: %@ DataReader is null for topic %C, returning nil\n", this, topic_name));
     }
     return DDS::HANDLE_NIL;
   }
 
   DataReaderImpl* bit = dynamic_cast<DataReaderImpl*>(d.in());
   if (!bit) {
     if (log_bits) {
       ACE_DEBUG((LM_DEBUG, "(%P|%t) DEBUG: BitSubscriber::add_i: %@ dynamic_cast failed for topic %C, returning nil\n", this, topic_name));
     }
     return DDS::HANDLE_NIL;
   }
 
   const DDS::InstanceHandle_t ih = bit->store_synthetic_data(sample, view_state);
   if (log_bits) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) DEBUG: BitSubscriber::add_i: %@ returning instance handle %d for topic %C\n", this, ih, topic_name));
   }
   return ih;
 #else
   if (log_bits) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) DEBUG: BitSubscriber::add_i: %@ DDS_HAS_MINIMUM_BIT is not defined, returning nil\n", this, topic_name));
   }
   ACE_UNUSED_ARG(sample);
   ACE_UNUSED_ARG(view_state);
   return DDS::HANDLE_NIL;
 #endif /* DDS_HAS_MINIMUM_BIT */
 }

◆ add_participant()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_participant	(	const DDS::ParticipantBuiltinTopicData &	part,
		DDS::ViewStateKind	view_state
	)

Definition at line 42 of file BuiltInTopicUtils.cpp.

References OpenDDS::DCPS::BUILT_IN_PARTICIPANT_TOPIC.

 {
   return add_i<ParticipantBuiltinTopicDataDataReaderImpl>(BUILT_IN_PARTICIPANT_TOPIC, part, view_state);
 }

◆ add_participant_location()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_participant_location	(	const ParticipantLocationBuiltinTopicData &	loc,
		DDS::ViewStateKind	view_state
	)

Definition at line 162 of file BuiltInTopicUtils.cpp.

References OpenDDS::DCPS::BUILT_IN_PARTICIPANT_LOCATION_TOPIC.

 {
   return add_i<ParticipantLocationBuiltinTopicDataDataReaderImpl>(BUILT_IN_PARTICIPANT_LOCATION_TOPIC, loc, view_state);
 }

◆ add_publication()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_publication	(	const DDS::PublicationBuiltinTopicData &	pub,
		DDS::ViewStateKind	view_state
	)

Definition at line 140 of file BuiltInTopicUtils.cpp.

References OpenDDS::DCPS::BUILT_IN_PUBLICATION_TOPIC.

 {
   return add_i<PublicationBuiltinTopicDataDataReaderImpl>(BUILT_IN_PUBLICATION_TOPIC, pub, view_state);
 }

◆ add_subscription()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_subscription	(	const DDS::SubscriptionBuiltinTopicData &	sub,
		DDS::ViewStateKind	view_state
	)

Definition at line 151 of file BuiltInTopicUtils.cpp.

References OpenDDS::DCPS::BUILT_IN_SUBSCRIPTION_TOPIC.

 {
   return add_i<SubscriptionBuiltinTopicDataDataReaderImpl>(BUILT_IN_SUBSCRIPTION_TOPIC, sub, view_state);
 }

◆ add_thread_status()

DDS::InstanceHandle_t OpenDDS::DCPS::BitSubscriber::add_thread_status	(	const InternalThreadBuiltinTopicData &	ts,
		DDS::ViewStateKind	view_state,
		const SystemTimePoint &	timestamp
	)

Definition at line 200 of file BuiltInTopicUtils.cpp.

References ACE_GUARD_RETURN, bit_subscriber_, DDS::HANDLE_NIL, mutex_, and OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_synthetic_data().

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, DDS::HANDLE_NIL);
 
   if (!bit_subscriber_) {
     return DDS::HANDLE_NIL;
   }
 
   DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_INTERNAL_THREAD_TOPIC);
   if (!d) {
     return DDS::HANDLE_NIL;
   }
 
   InternalThreadBuiltinTopicDataDataReaderImpl* bit = dynamic_cast<InternalThreadBuiltinTopicDataDataReaderImpl*>(d.in());
   if (!bit) {
     return DDS::HANDLE_NIL;
   }
 
   return bit->store_synthetic_data(ts, view_state, timestamp);
 #else
   ACE_UNUSED_ARG(ts);
   ACE_UNUSED_ARG(view_state);
   ACE_UNUSED_ARG(timestamp);
   return DDS::HANDLE_NIL;
 #endif /* DDS_HAS_MINIMUM_BIT */
 }

◆ bit_pub_listener_hack()

void OpenDDS::DCPS::BitSubscriber::bit_pub_listener_hack ( DomainParticipantImpl * participant )

Definition at line 256 of file BuiltInTopicUtils.cpp.

References ACE_GUARD, bit_subscriber_, DDS::DATA_AVAILABLE_STATUS, mutex_, OpenDDS::DCPS::rchandle_from(), and TheServiceParticipant.

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
   if (!bit_subscriber_) {
     return;
   }
 
   DDS::DataReader_var dr =
     bit_subscriber_->lookup_datareader(BUILT_IN_PUBLICATION_TOPIC);
   DDS::PublicationBuiltinTopicDataDataReader_var bit_pub_dr =
     DDS::PublicationBuiltinTopicDataDataReader::_narrow(dr);
 
   if (bit_pub_dr) {
     DDS::DataReaderListener_var listener = bit_pub_dr->get_listener();
     if (!listener) {
       DDS::DataReaderListener_var bit_pub_listener =
         new BitPubListenerImpl(participant);
       bit_pub_dr->set_listener(bit_pub_listener, DDS::DATA_AVAILABLE_STATUS);
       // Must call on_data_available when attaching a listener late - samples may be waiting
       DataReaderImpl* reader = dynamic_cast<DataReaderImpl*>(bit_pub_dr.in());
       if (!reader) {
         return;
       }
       TheServiceParticipant->job_queue()->enqueue(make_rch<DataReaderImpl::OnDataAvailable>(bit_pub_listener, rchandle_from(reader), true, false, false));
     }
   }
 #else
   ACE_UNUSED_ARG(participant);
 #endif
 }

◆ clear()

void OpenDDS::DCPS::BitSubscriber::clear ( void )

inline

Definition at line 259 of file BuiltInTopicUtils.h.

References ACE_GUARD, and timestamp().

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     bit_subscriber_ = 0;
   }

◆ get()

DDS::Subscriber_ptr OpenDDS::DCPS::BitSubscriber::get ( void ) const

inline

Definition at line 253 of file BuiltInTopicUtils.h.

References ACE_GUARD_RETURN.

   {
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, 0);
     return DDS::Subscriber::_duplicate(bit_subscriber_.in());
   }

◆ get_discovered_participant_data()

DDS::ReturnCode_t OpenDDS::DCPS::BitSubscriber::get_discovered_participant_data	(	DDS::ParticipantBuiltinTopicData &	participant_data,
		DDS::InstanceHandle_t	participant_handle
	)

Definition at line 60 of file BuiltInTopicUtils.cpp.

References ACE_GUARD_RETURN, DDS::ANY_INSTANCE_STATE, DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, bit_subscriber_, mutex_, DDS::RETCODE_NO_DATA, and DDS::RETCODE_OK.

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, DDS::RETCODE_NO_DATA);
 
   if (!bit_subscriber_) {
     return DDS::RETCODE_NO_DATA;
   }
 
   DDS::SampleInfoSeq info;
   DDS::ParticipantBuiltinTopicDataSeq data;
   DDS::DataReader_var dr = bit_subscriber_->lookup_datareader(BUILT_IN_PARTICIPANT_TOPIC);
   DDS::ParticipantBuiltinTopicDataDataReader_var bit_part_dr =
     DDS::ParticipantBuiltinTopicDataDataReader::_narrow(dr);
 
   const DDS::ReturnCode_t ret = bit_part_dr->read_instance(data,
                                                            info,
                                                            1,
                                                            participant_handle,
                                                            DDS::ANY_SAMPLE_STATE,
                                                            DDS::ANY_VIEW_STATE,
                                                            DDS::ANY_INSTANCE_STATE);
 
   if (ret == DDS::RETCODE_OK) {
     if (info[0].valid_data) {
       participant_data = data[0];
     } else {
       return DDS::RETCODE_NO_DATA;
     }
   }
 
   return ret;
 #else
   ACE_UNUSED_ARG(participant_data);
   ACE_UNUSED_ARG(participant_handle);
   return DDS::RETCODE_NO_DATA;
 #endif
 }

◆ get_discovered_topic_data()

DDS::ReturnCode_t OpenDDS::DCPS::BitSubscriber::get_discovered_topic_data	(	DDS::TopicBuiltinTopicData &	topic_data,
		DDS::InstanceHandle_t	topic_handle
	)

Definition at line 100 of file BuiltInTopicUtils.cpp.

References ACE_GUARD_RETURN, DDS::ANY_INSTANCE_STATE, DDS::ANY_SAMPLE_STATE, DDS::ANY_VIEW_STATE, bit_subscriber_, mutex_, DDS::RETCODE_NO_DATA, and DDS::RETCODE_OK.

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, DDS::RETCODE_NO_DATA);
 
   if (!bit_subscriber_) {
     return DDS::RETCODE_NO_DATA;
   }
 
   DDS::SampleInfoSeq info;
   DDS::TopicBuiltinTopicDataSeq data;
   DDS::DataReader_var dr = bit_subscriber_->lookup_datareader(BUILT_IN_TOPIC_TOPIC);
   DDS::TopicBuiltinTopicDataDataReader_var bit_topic_dr =
     DDS::TopicBuiltinTopicDataDataReader::_narrow(dr);
 
   const DDS::ReturnCode_t ret = bit_topic_dr->read_instance(data,
                                                             info,
                                                             1,
                                                             topic_handle,
                                                             DDS::ANY_SAMPLE_STATE,
                                                             DDS::ANY_VIEW_STATE,
                                                             DDS::ANY_INSTANCE_STATE);
 
   if (ret == DDS::RETCODE_OK) {
     if (info[0].valid_data) {
       topic_data = data[0];
     } else {
       return DDS::RETCODE_NO_DATA;
     }
   }
 
   return ret;
 #else
   ACE_UNUSED_ARG(topic_data);
   ACE_UNUSED_ARG(topic_handle);
   return DDS::RETCODE_NO_DATA;
 #endif
 }

◆ remove_connection_record()

void OpenDDS::DCPS::BitSubscriber::remove_connection_record ( const ConnectionRecord & cr )

Definition at line 174 of file BuiltInTopicUtils.cpp.

References ACE_GUARD, bit_subscriber_, OpenDDS::DCPS::DataReaderImpl_T< MessageType >::lookup_instance(), mutex_, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE, and OpenDDS::DCPS::DataReaderImpl::set_instance_state().

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
   if (!bit_subscriber_) {
     return;
   }
 
   DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_CONNECTION_RECORD_TOPIC);
 
   if (!d) {
     return;
   }
 
   ConnectionRecordDataReaderImpl* bit = dynamic_cast<ConnectionRecordDataReaderImpl*>(d.in());
   if (!bit) {
     return;
   }
 
   bit->set_instance_state(bit->lookup_instance(cr), DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE);
 #else
   ACE_UNUSED_ARG(cr);
 #endif
 }

◆ remove_i()

void OpenDDS::DCPS::BitSubscriber::remove_i	(	const char *	topic_name,
		DDS::InstanceHandle_t	ih
	)

private

Definition at line 335 of file BuiltInTopicUtils.cpp.

References ACE_GUARD, bit_subscriber_, DDS::HANDLE_NIL, mutex_, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and OpenDDS::DCPS::DataReaderImpl::set_instance_state().

Referenced by remove_participant(), remove_publication(), and remove_subscription().

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   if (ih != DDS::HANDLE_NIL) {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (!bit_subscriber_) {
       return;
     }
 
     DDS::DataReader_var d = bit_subscriber_->lookup_datareader(topic_name);
     if (!d) {
       return;
     }
 
     DataReaderImpl* bit = dynamic_cast<DataReaderImpl*>(d.in());
     if (!bit) {
       return;
     }
     bit->set_instance_state(ih, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE);
   }
 #else
   ACE_UNUSED_ARG(topic_name);
   ACE_UNUSED_ARG(ih);
 #endif
 }

◆ remove_participant()

void OpenDDS::DCPS::BitSubscriber::remove_participant	(	DDS::InstanceHandle_t	part_ih,
		DDS::InstanceHandle_t	loc_ih
	)

Definition at line 48 of file BuiltInTopicUtils.cpp.

References remove_i().

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   remove_i(BUILT_IN_PARTICIPANT_TOPIC, part_ih);
   remove_i(BUILT_IN_PARTICIPANT_LOCATION_TOPIC, loc_ih);
 #else
   ACE_UNUSED_ARG(part_ih);
   ACE_UNUSED_ARG(loc_ih);
 #endif
 }

◆ remove_publication()

void OpenDDS::DCPS::BitSubscriber::remove_publication ( DDS::InstanceHandle_t pub_ih )

Definition at line 146 of file BuiltInTopicUtils.cpp.

References remove_i().

 {
   remove_i(BUILT_IN_PUBLICATION_TOPIC, pub_ih);
 }

◆ remove_subscription()

void OpenDDS::DCPS::BitSubscriber::remove_subscription ( DDS::InstanceHandle_t sub_ih )

Definition at line 157 of file BuiltInTopicUtils.cpp.

References remove_i().

 {
   remove_i(BUILT_IN_SUBSCRIPTION_TOPIC, sub_ih);
 }

◆ remove_thread_status()

void OpenDDS::DCPS::BitSubscriber::remove_thread_status ( const InternalThreadBuiltinTopicData & ts )

Definition at line 230 of file BuiltInTopicUtils.cpp.

References ACE_GUARD, bit_subscriber_, OpenDDS::DCPS::DataReaderImpl_T< MessageType >::lookup_instance(), mutex_, DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE, and OpenDDS::DCPS::DataReaderImpl::set_instance_state().

 {
 #ifndef DDS_HAS_MINIMUM_BIT
   ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
   if (!bit_subscriber_) {
     return;
   }
 
   DDS::DataReader_var d = bit_subscriber_->lookup_datareader(BUILT_IN_INTERNAL_THREAD_TOPIC);
 
   if (!d) {
     return;
   }
 
   InternalThreadBuiltinTopicDataDataReaderImpl* bit = dynamic_cast<InternalThreadBuiltinTopicDataDataReaderImpl*>(d.in());
   if (!bit) {
     return;
   }
 
   bit->set_instance_state(bit->lookup_instance(ts), DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE);
 #else
   ACE_UNUSED_ARG(ts);
 #endif
 }

Member Data Documentation

◆ bit_subscriber_

DDS::Subscriber_var OpenDDS::DCPS::BitSubscriber::bit_subscriber_

private

Definition at line 313 of file BuiltInTopicUtils.h.

Referenced by add_i(), add_thread_status(), bit_pub_listener_hack(), get_discovered_participant_data(), get_discovered_topic_data(), remove_connection_record(), remove_i(), and remove_thread_status().

◆ mutex_

ACE_Thread_Mutex OpenDDS::DCPS::BitSubscriber::mutex_

mutableprivate

Definition at line 314 of file BuiltInTopicUtils.h.

Referenced by add_i(), add_thread_status(), bit_pub_listener_hack(), get_discovered_participant_data(), get_discovered_topic_data(), remove_connection_record(), remove_i(), and remove_thread_status().

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

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ BitSubscriber() [1/2]

◆ BitSubscriber() [2/2]

Member Function Documentation

◆ add_connection_record()

◆ add_i()

◆ add_participant()

◆ add_participant_location()

◆ add_publication()

◆ add_subscription()

◆ add_thread_status()

◆ bit_pub_listener_hack()

◆ clear()

◆ get()

◆ get_discovered_participant_data()

◆ get_discovered_topic_data()

◆ remove_connection_record()

◆ remove_i()

◆ remove_participant()

◆ remove_publication()

◆ remove_subscription()

◆ remove_thread_status()

Member Data Documentation

◆ bit_subscriber_

◆ mutex_