#include <DataSampleElement.h>

Inheritance diagram for OpenDDS::DCPS::DataSampleElement:

Collaboration diagram for OpenDDS::DCPS::DataSampleElement:

[legend]

Public Member Functions
	DataSampleElement (GUID_t publication_id, TransportSendListener *send_listener, PublicationInstance_rch handle)

	DataSampleElement (const DataSampleElement &elem)

DataSampleElement &	operator= (const DataSampleElement &elem)

	~DataSampleElement ()

const DataSampleHeader &	get_header () const

DataSampleHeader &	get_header ()

DataSample *	get_sample () const

DataSample *	get_sample ()

void	set_sample (Message_Block_Ptr sample)

GUID_t	get_pub_id () const

CORBA::ULong	get_num_subs () const

void	set_num_subs (CORBA::ULong num_subs)

const OpenDDS::DCPS::GUID_t *	get_sub_ids () const

OpenDDS::DCPS::GUID_t	get_sub_id (CORBA::ULong index) const

void	set_sub_id (CORBA::ULong index, OpenDDS::DCPS::GUID_t id)

TransportSendListener *	get_send_listener () const

TransportSendListener *	get_send_listener ()

PublicationInstance_rch	get_handle () const

typedef	OPENDDS_MAP (DataLinkIdType, GUIDSeq_var) DataLinkIdTypeGUIDMap

DataLinkIdTypeGUIDMap &	get_filter_per_link ()

void	set_filter_out (GUIDSeq *filter_out)

void	set_transaction_id (ACE_UINT64 transaction_id)

ACE_UINT64	transaction_id () const

Private Member Functions
DataSampleElement *	get_next_send_sample () const

void	set_next_send_sample (DataSampleElement *next_send_sample)

Private Attributes
ACE_UINT64	transaction_id_

DataSampleHeader	header_
	The OpenDDS DCPS header for this sample. More...

Message_Block_Ptr	sample_

GUID_t	publication_id_
	Publication Id used downstream. More...

CORBA::ULong	num_subs_

OpenDDS::DCPS::GUID_t	subscription_ids_ [OpenDDS::DCPS::MAX_READERS_PER_ELEM]

TransportSendListener *	send_listener_

PublicationInstance_rch	handle_

GUIDSeq_var	filter_out_
	tracking for Content-Filtering data More...

DataLinkIdTypeGUIDMap	filter_per_link_

DataSampleElement *	previous_writer_sample_
	Thread of all data within a DataWriter. More...

DataSampleElement *	next_writer_sample_

DataSampleElement *	next_instance_sample_
	Thread of data within the instance. More...

DataSampleElement *	previous_instance_sample_

DataSampleElement *	next_send_sample_
	Thread of data being unsent/sending/sent/released. More...

DataSampleElement *	previous_send_sample_

Friends
class	SendStateDataSampleList

class	WriterDataSampleList

class	InstanceDataSampleList

class	TransportClient

class	::DDS_TEST

class	SendStateDataSampleListIterator
	Iterators needs access to prev/next pointers for iteration. More...

class	SendStateDataSampleListConstIterator

Detailed Description

Wraps the marshaled message sample to be published, along with the publication Id and Instance handle for downstream processing.

Internally there are next/previous pointers that used for lists InstanceDataSampleList, SendStateDataSampleList, and WriterDataSampleList. These pointers are kept in this single element rather than having multiple smaller lists in order to allow us to allocate once which will minimize locking. Note that because the list pointers are stored within the element, the element can simultaneously be in at most one InstanceDataSampleList list, one SendStateDataSampleList list, and one WriterDataSampleList list.

Definition at line 54 of file DataSampleElement.h.

Constructor & Destructor Documentation

◆ DataSampleElement() [1/2]

OpenDDS::DCPS::DataSampleElement::DataSampleElement	(	GUID_t	publication_id,
		TransportSendListener *	send_listener,
		PublicationInstance_rch	handle
	)

Definition at line 22 of file DataSampleElement.cpp.

References OpenDDS::DCPS::GUID_UNKNOWN, OpenDDS::DCPS::MAX_READERS_PER_ELEM, and subscription_ids_.

   : transaction_id_(0),
     publication_id_(publication_id),
     num_subs_(0),
     send_listener_(send_listener),
     handle_(handle),
     previous_writer_sample_(0),
     next_writer_sample_(0),
     next_instance_sample_(0),
     previous_instance_sample_(0),
     next_send_sample_(0),
     previous_send_sample_(0)
 
 {
   std::fill(subscription_ids_,
     subscription_ids_ + OpenDDS::DCPS::MAX_READERS_PER_ELEM,
     GUID_UNKNOWN);
 }

◆ DataSampleElement() [2/2]

OpenDDS::DCPS::DataSampleElement::DataSampleElement ( const DataSampleElement & elem )

Definition at line 44 of file DataSampleElement.cpp.

References num_subs_, and subscription_ids_.

   : transaction_id_(elem.transaction_id_)
   , header_(elem.header_)
   , sample_(elem.sample_ ? elem.sample_->duplicate() : 0)
   , publication_id_(elem.publication_id_)
   , num_subs_(elem.num_subs_)
   , send_listener_(elem.send_listener_)
   , handle_(elem.handle_)
   , filter_out_(elem.filter_out_)
   , filter_per_link_(elem.filter_per_link_)
   , previous_writer_sample_(elem.previous_writer_sample_)
   , next_writer_sample_(elem.next_writer_sample_)
   , next_instance_sample_(elem.next_instance_sample_)
   , previous_instance_sample_(elem.previous_instance_sample_)
   , next_send_sample_(elem.next_send_sample_)
   , previous_send_sample_(elem.previous_send_sample_)
 
 {
   std::copy(elem.subscription_ids_,
             elem.subscription_ids_ + num_subs_,
             subscription_ids_);
 }

◆ ~DataSampleElement()

OpenDDS::DCPS::DataSampleElement::~DataSampleElement ( )

Definition at line 67 of file DataSampleElement.cpp.

68 {

69 }

Member Function Documentation

◆ get_filter_per_link()

ACE_INLINE DataSampleElement::DataLinkIdTypeGUIDMap & OpenDDS::DCPS::DataSampleElement::get_filter_per_link ( )

Definition at line 125 of file DataSampleElement.inl.

References ACE_INLINE, and filter_per_link_.

Referenced by OpenDDS::DCPS::DataLinkSet::send().

 {
   return filter_per_link_;
 }

◆ get_handle()

PublicationInstance_rch OpenDDS::DCPS::DataSampleElement::get_handle ( void ) const

Definition at line 99 of file DataSampleElement.cpp.

References handle_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::DCPS::WriteDataContainer::data_delivered().

 {
   return handle_;
 }

◆ get_header() [1/2]

ACE_INLINE const DataSampleHeader & OpenDDS::DCPS::DataSampleElement::get_header ( ) const

Definition at line 32 of file DataSampleElement.inl.

References ACE_INLINE, and header_.

 {
   return header_;
 }

◆ get_header() [2/2]

ACE_INLINE DataSampleHeader & OpenDDS::DCPS::DataSampleElement::get_header ( )

Definition at line 39 of file DataSampleElement.inl.

References ACE_INLINE, and get_header().

 {
   return const_cast<DataSampleHeader&>(static_cast<const DataSampleElement &>(*this).get_header());
 }

◆ get_next_send_sample()

ACE_INLINE DataSampleElement * OpenDDS::DCPS::DataSampleElement::get_next_send_sample ( ) const

private

Definition at line 18 of file DataSampleElement.inl.

References ACE_INLINE, and next_send_sample_.

Referenced by OpenDDS::DCPS::TransportClient::send_i().

 {
   return next_send_sample_;
 }

◆ get_num_subs()

ACE_INLINE CORBA::ULong OpenDDS::DCPS::DataSampleElement::get_num_subs ( ) const

Definition at line 75 of file DataSampleElement.inl.

References ACE_INLINE, and num_subs_.

Referenced by OpenDDS::DCPS::WriteDataContainer::data_delivered(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::TransportClient::send_i(), and OpenDDS::DCPS::TransportSendElement::subscription_id().

 {
   return num_subs_;
 }

◆ get_pub_id()

ACE_INLINE GUID_t OpenDDS::DCPS::DataSampleElement::get_pub_id ( ) const

Definition at line 68 of file DataSampleElement.inl.

References ACE_INLINE, and publication_id_.

Referenced by OpenDDS::DCPS::ReplayerImpl::data_delivered(), OpenDDS::DCPS::DataWriterImpl::data_delivered(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::TransportSendElement::publication_id(), OpenDDS::DCPS::TransportSendStrategy::remove_sample(), OpenDDS::DCPS::RtpsUdpDataLink::remove_sample(), and OpenDDS::DCPS::TransportClient::send_i().

 {
   return publication_id_;
 }

◆ get_sample() [1/2]

ACE_INLINE DataSample * OpenDDS::DCPS::DataSampleElement::get_sample ( ) const

Definition at line 47 of file DataSampleElement.inl.

References ACE_INLINE, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), and sample_.

Referenced by OpenDDS::DCPS::WriteDataContainer::data_delivered(), OpenDDS::DCPS::TransportSendElement::duplicate_msg(), OpenDDS::DCPS::DataWriterImpl::filter_out(), OpenDDS::DCPS::DataDurabilityCache::insert(), OpenDDS::DCPS::TransportSendElement::msg(), OpenDDS::DCPS::TransportSendControlElement::msg(), OpenDDS::DCPS::TransportSendElement::msg_payload(), OpenDDS::DCPS::ThreadPerConnectionSendTask::remove_sample(), OpenDDS::DCPS::TransportSendStrategy::remove_sample(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::remove_sample(), OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_data_type(), OpenDDS::DCPS::DataLinkSet::send(), and OpenDDS::RTPS::Sedp::Writer::send_sample().

 {
   return sample_.get();
 }

◆ get_sample() [2/2]

ACE_INLINE DataSample * OpenDDS::DCPS::DataSampleElement::get_sample ( )

Definition at line 54 of file DataSampleElement.inl.

References ACE_INLINE, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), and sample_.

 {
   return sample_.get();
 }

◆ get_send_listener() [1/2]

ACE_INLINE TransportSendListener * OpenDDS::DCPS::DataSampleElement::get_send_listener ( ) const

Definition at line 110 of file DataSampleElement.inl.

References ACE_INLINE, and send_listener_.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), OpenDDS::DCPS::TransportSendElement::release_element(), OpenDDS::DCPS::TransportSendControlElement::requires_exclusive_packet(), OpenDDS::DCPS::DataLinkSet::send(), and OpenDDS::DCPS::TransportClient::send_i().

 {
   return send_listener_;
 }

◆ get_send_listener() [2/2]

ACE_INLINE TransportSendListener * OpenDDS::DCPS::DataSampleElement::get_send_listener ( )

Definition at line 117 of file DataSampleElement.inl.

References ACE_INLINE, and send_listener_.

 {
   return send_listener_;
 }

◆ get_sub_id()

ACE_INLINE OpenDDS::DCPS::GUID_t OpenDDS::DCPS::DataSampleElement::get_sub_id ( CORBA::ULong index ) const

Definition at line 96 of file DataSampleElement.inl.

References ACE_INLINE, and subscription_ids_.

Referenced by OpenDDS::DCPS::WriteDataContainer::data_delivered(), OpenDDS::DCPS::RtpsSampleHeader::populate_data_sample_submessages(), and OpenDDS::DCPS::TransportSendElement::subscription_id().

 {
   return subscription_ids_[index];
 }

◆ get_sub_ids()

ACE_INLINE const OpenDDS::DCPS::GUID_t * OpenDDS::DCPS::DataSampleElement::get_sub_ids ( ) const

Definition at line 89 of file DataSampleElement.inl.

References ACE_INLINE, and subscription_ids_.

Referenced by OpenDDS::DCPS::TransportClient::send_i().

 {
   return subscription_ids_;
 }

◆ OPENDDS_MAP()

typedef OpenDDS::DCPS::DataSampleElement::OPENDDS_MAP	(	DataLinkIdType	,
		GUIDSeq_var
	)

◆ operator=()

DataSampleElement & OpenDDS::DCPS::DataSampleElement::operator= ( const DataSampleElement & elem )

Definition at line 72 of file DataSampleElement.cpp.

References ACE_Message_Block::duplicate(), filter_out_, filter_per_link_, handle_, header_, next_instance_sample_, next_send_sample_, next_writer_sample_, num_subs_, previous_instance_sample_, previous_send_sample_, previous_writer_sample_, publication_id_, OpenDDS::DCPS::unique_ptr< T, Deleter >::reset(), sample_, send_listener_, subscription_ids_, and transaction_id_.

 {
   transaction_id_ = rhs.transaction_id_;
   header_ = rhs.header_;
   sample_.reset(rhs.sample_->duplicate());
   publication_id_ = rhs.publication_id_;
   num_subs_ = rhs.num_subs_;
 
   std::copy(rhs.subscription_ids_,
             rhs.subscription_ids_ + num_subs_,
             subscription_ids_);
 
   previous_writer_sample_ = rhs.previous_writer_sample_;
   next_writer_sample_ = rhs.next_writer_sample_;
   next_instance_sample_ = rhs.next_instance_sample_;
   previous_instance_sample_ = rhs.previous_instance_sample_;
   next_send_sample_ = rhs.next_send_sample_;
   previous_send_sample_ = rhs.previous_send_sample_;
   send_listener_ = rhs.send_listener_;
   handle_ = rhs.handle_;
   filter_out_ = rhs.filter_out_;
   filter_per_link_ = rhs.filter_per_link_;
 
   return *this;
 }

◆ set_filter_out()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_filter_out ( GUIDSeq * filter_out )

Definition at line 132 of file DataSampleElement.inl.

References ACE_INLINE, and filter_out_.

Referenced by OpenDDS::DCPS::DataWriterImpl::write().

 {
   filter_out_ = filter_out;
 }

◆ set_next_send_sample()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_next_send_sample ( DataSampleElement * next_send_sample )

private

Definition at line 25 of file DataSampleElement.inl.

References ACE_INLINE, and next_send_sample_.

 {
   next_send_sample_ = next_send_sample;
 }

◆ set_num_subs()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_num_subs ( CORBA::ULong num_subs )

Definition at line 82 of file DataSampleElement.inl.

References ACE_INLINE, and num_subs_.

Referenced by OpenDDS::DCPS::WriteDataContainer::copy_and_prepend(), OpenDDS::RTPS::Sedp::Writer::send_sample(), and OpenDDS::DCPS::ReplayerImpl::write().

 {
   num_subs_ = num_subs;
 }

◆ set_sample()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_sample ( Message_Block_Ptr sample )

Definition at line 61 of file DataSampleElement.inl.

References ACE_INLINE, OpenDDS::DCPS::unique_ptr< T, Deleter >::release(), OpenDDS::DCPS::unique_ptr< T, Deleter >::reset(), and sample_.

Referenced by OpenDDS::DCPS::DataWriterImpl::dispose(), OpenDDS::DCPS::DataWriterImpl::dispose_and_unregister(), OpenDDS::DCPS::DataWriterImpl::register_instance_i(), OpenDDS::DCPS::DataWriterImpl::send_request_ack(), OpenDDS::RTPS::Sedp::Writer::send_sample(), OpenDDS::DCPS::DataWriterImpl::unregister_instance_i(), OpenDDS::DCPS::ReplayerImpl::write(), and OpenDDS::DCPS::DataWriterImpl::write().

 {
   sample_.reset(sample.release());
 }

◆ set_sub_id()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_sub_id	(	CORBA::ULong	index,
		OpenDDS::DCPS::GUID_t	id
	)

Definition at line 103 of file DataSampleElement.inl.

References ACE_INLINE, and subscription_ids_.

Referenced by OpenDDS::DCPS::WriteDataContainer::copy_and_prepend(), OpenDDS::RTPS::Sedp::Writer::send_sample(), and OpenDDS::DCPS::ReplayerImpl::write().

 {
   subscription_ids_[index] = id;
 }

◆ set_transaction_id()

ACE_INLINE void OpenDDS::DCPS::DataSampleElement::set_transaction_id ( ACE_UINT64 transaction_id )

Definition at line 139 of file DataSampleElement.inl.

References ACE_INLINE, transaction_id(), and transaction_id_.

Referenced by OpenDDS::DCPS::WriteDataContainer::get_unsent_data().

 {
   transaction_id_ = transaction_id;
 }

◆ transaction_id()

ACE_INLINE ACE_UINT64 OpenDDS::DCPS::DataSampleElement::transaction_id ( ) const

Definition at line 146 of file DataSampleElement.inl.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL, and transaction_id_.

Referenced by OpenDDS::DCPS::TransportClient::send_i(), and set_transaction_id().

 {
   return transaction_id_;
 }

Friends And Related Function Documentation

◆ ::DDS_TEST

friend class ::DDS_TEST

friend

Definition at line 144 of file DataSampleElement.h.

◆ InstanceDataSampleList

friend class InstanceDataSampleList

friend

Definition at line 142 of file DataSampleElement.h.

◆ SendStateDataSampleList

friend class SendStateDataSampleList

friend

*DataSampleList(s) is in charge of managing list placement therefore needs access to pointers

Definition at line 140 of file DataSampleElement.h.

◆ SendStateDataSampleListConstIterator

friend class SendStateDataSampleListConstIterator

friend

Definition at line 147 of file DataSampleElement.h.

◆ SendStateDataSampleListIterator

friend class SendStateDataSampleListIterator

friend

Iterators needs access to prev/next pointers for iteration.

Definition at line 146 of file DataSampleElement.h.

◆ TransportClient

friend class TransportClient

friend

Definition at line 143 of file DataSampleElement.h.

◆ WriterDataSampleList

friend class WriterDataSampleList

friend

Definition at line 141 of file DataSampleElement.h.

Member Data Documentation

◆ filter_out_

GUIDSeq_var OpenDDS::DCPS::DataSampleElement::filter_out_

private

tracking for Content-Filtering data

Definition at line 130 of file DataSampleElement.h.

Referenced by operator=(), OpenDDS::DCPS::TransportClient::send_i(), and set_filter_out().

◆ filter_per_link_

DataLinkIdTypeGUIDMap OpenDDS::DCPS::DataSampleElement::filter_per_link_

private

Definition at line 131 of file DataSampleElement.h.

Referenced by get_filter_per_link(), operator=(), and OpenDDS::DCPS::TransportClient::send_i().

◆ handle_

PublicationInstance_rch OpenDDS::DCPS::DataSampleElement::handle_

private

The pointer to the object that contains the instance information and data sample list. The client holds this as an InstanceHandle_t.

Definition at line 126 of file DataSampleElement.h.

Referenced by get_handle(), OpenDDS::DCPS::InstanceDataSampleList::on_some_list(), and operator=().

◆ header_

DataSampleHeader OpenDDS::DCPS::DataSampleElement::header_

private

The OpenDDS DCPS header for this sample.

Definition at line 105 of file DataSampleElement.h.

Referenced by get_header(), and operator=().

◆ next_instance_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::next_instance_sample_

mutableprivate

Thread of data within the instance.

Definition at line 158 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::InstanceDataSampleList::dequeue(), OpenDDS::DCPS::InstanceDataSampleList::dequeue_head(), OpenDDS::DCPS::InstanceDataSampleList::enqueue_tail(), OpenDDS::DCPS::InstanceDataSampleList::next(), OpenDDS::DCPS::InstanceDataSampleList::on_some_list(), and operator=().

◆ next_send_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::next_send_sample_

mutableprivate

Thread of data being unsent/sending/sent/released.

Definition at line 162 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::SendStateDataSampleList::dequeue(), OpenDDS::DCPS::SendStateDataSampleList::dequeue_head(), OpenDDS::DCPS::SendStateDataSampleList::enqueue_head(), OpenDDS::DCPS::SendStateDataSampleList::enqueue_tail(), get_next_send_sample(), OpenDDS::DCPS::SendStateDataSampleListIterator::operator++(), OpenDDS::DCPS::SendStateDataSampleListConstIterator::operator++(), operator=(), OpenDDS::DCPS::SendStateDataSampleList::remove(), and set_next_send_sample().

◆ next_writer_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::next_writer_sample_

mutableprivate

Definition at line 155 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::WriterDataSampleList::dequeue(), OpenDDS::DCPS::WriterDataSampleList::dequeue_head(), OpenDDS::DCPS::WriterDataSampleList::enqueue_tail(), and operator=().

◆ num_subs_

CORBA::ULong OpenDDS::DCPS::DataSampleElement::num_subs_

private

Definition at line 114 of file DataSampleElement.h.

Referenced by DataSampleElement(), get_num_subs(), operator=(), and set_num_subs().

◆ previous_instance_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::previous_instance_sample_

mutableprivate

Definition at line 159 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::InstanceDataSampleList::dequeue(), OpenDDS::DCPS::InstanceDataSampleList::dequeue_head(), OpenDDS::DCPS::InstanceDataSampleList::enqueue_tail(), OpenDDS::DCPS::InstanceDataSampleList::on_some_list(), operator=(), and OpenDDS::DCPS::InstanceDataSampleList::prev().

◆ previous_send_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::previous_send_sample_

mutableprivate

Definition at line 163 of file DataSampleElement.h.

◆ previous_writer_sample_

DataSampleElement* OpenDDS::DCPS::DataSampleElement::previous_writer_sample_

mutableprivate

Thread of all data within a DataWriter.

Used to make removal from the container much more efficient.

Definition at line 154 of file DataSampleElement.h.

Referenced by OpenDDS::DCPS::WriterDataSampleList::dequeue(), OpenDDS::DCPS::WriterDataSampleList::dequeue_head(), OpenDDS::DCPS::WriterDataSampleList::enqueue_tail(), and operator=().

◆ publication_id_

GUID_t OpenDDS::DCPS::DataSampleElement::publication_id_

private

Publication Id used downstream.

Definition at line 112 of file DataSampleElement.h.

Referenced by get_pub_id(), and operator=().

◆ sample_

Message_Block_Ptr OpenDDS::DCPS::DataSampleElement::sample_

private

Message being sent which includes the DataSampleHeader message block and DataSample message block.

Definition at line 109 of file DataSampleElement.h.

Referenced by get_sample(), operator=(), and set_sample().

◆ send_listener_

TransportSendListener* OpenDDS::DCPS::DataSampleElement::send_listener_

private

Pointer to object that will be informed when the data has been delivered. This needs to be set prior to using the TransportClient to send().

Definition at line 121 of file DataSampleElement.h.

Referenced by get_send_listener(), and operator=().

◆ subscription_ids_

OpenDDS::DCPS::GUID_t OpenDDS::DCPS::DataSampleElement::subscription_ids_[OpenDDS::DCPS::MAX_READERS_PER_ELEM]

private

Definition at line 116 of file DataSampleElement.h.

Referenced by DataSampleElement(), get_sub_id(), get_sub_ids(), operator=(), and set_sub_id().

◆ transaction_id_

ACE_UINT64 OpenDDS::DCPS::DataSampleElement::transaction_id_

private

Definition at line 102 of file DataSampleElement.h.

Referenced by operator=(), set_transaction_id(), and transaction_id().

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

Public Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ DataSampleElement() [1/2]

◆ DataSampleElement() [2/2]

◆ ~DataSampleElement()

Member Function Documentation

◆ get_filter_per_link()

◆ get_handle()

◆ get_header() [1/2]

◆ get_header() [2/2]

◆ get_next_send_sample()

◆ get_num_subs()

◆ get_pub_id()

◆ get_sample() [1/2]

◆ get_sample() [2/2]

◆ get_send_listener() [1/2]

◆ get_send_listener() [2/2]

◆ get_sub_id()

◆ get_sub_ids()

◆ OPENDDS_MAP()

◆ operator=()

◆ set_filter_out()

◆ set_next_send_sample()

◆ set_num_subs()

◆ set_sample()

◆ set_sub_id()

◆ set_transaction_id()

◆ transaction_id()

Friends And Related Function Documentation

◆ ::DDS_TEST

◆ InstanceDataSampleList

◆ SendStateDataSampleList

◆ SendStateDataSampleListConstIterator

◆ SendStateDataSampleListIterator

◆ TransportClient

◆ WriterDataSampleList

Member Data Documentation

◆ filter_out_

◆ filter_per_link_

◆ handle_

◆ header_

◆ next_instance_sample_

◆ next_send_sample_

◆ next_writer_sample_

◆ num_subs_

◆ previous_instance_sample_

◆ previous_send_sample_

◆ previous_writer_sample_

◆ publication_id_

◆ sample_

◆ send_listener_

◆ subscription_ids_

◆ transaction_id_