Base wrapper class around a data/control sample to be sent. More...

#include <TransportQueueElement.h>

Inheritance diagram for OpenDDS::DCPS::TransportQueueElement:

[legend]

Collaboration diagram for OpenDDS::DCPS::TransportQueueElement:

[legend]

Classes
class	MatchCriteria

class	MatchOnDataPayload

class	MatchOnElement

class	MatchOnPubId

struct	OrderBySequenceNumber

Public Member Functions
virtual	~TransportQueueElement ()

bool	data_dropped (bool dropped_by_transport=false)

bool	data_delivered ()

void	increment_loan ()

virtual bool	requires_exclusive_packet () const
	Does the sample require an exclusive transport packet? More...

virtual GUID_t	publication_id () const =0
	Accessor for the publication id that sent the sample. More...

virtual GUID_t	subscription_id () const
	Accessor for the subscription id, if sent the sample is sent to 1 sub. More...

virtual SequenceNumber	sequence () const

virtual ACE_Message_Block *	duplicate_msg () const =0
	A reference-incremented duplicate of the marshalled sample (sample header + sample data) More...

virtual const ACE_Message_Block *	msg () const =0
	The marshalled sample (sample header + sample data) More...

virtual const ACE_Message_Block *	msg_payload () const =0
	The marshalled payload only (sample data) More...

virtual bool	is_control (GUID_t pub_id) const
	Is the element a "control" sample from the specified pub_id? More...

bool	released () const
	Is the listener get called ? More...

void	released (bool flag)

virtual bool	owned_by_transport ()=0
	Is the sample created by the transport? More...

virtual TqePair	fragment (size_t size)

virtual bool	is_fragment () const
	Is this QueueElement the result of fragmentation? More...

virtual bool	is_last_fragment () const
	Is this QueueElement the last result of fragmentation? More...

virtual bool	is_request_ack () const

virtual bool	is_retained_replaced () const

Static Public Member Functions
static ACE_Message_Block *	clone_mb (const ACE_Message_Block msg, MessageBlockAllocator mb_allocator, DataBlockAllocator *db_allocator)

Protected Member Functions
	TransportQueueElement (unsigned long initial_count)

virtual void	release_element (bool dropped_by_transport)=0
	Invoked when the counter reaches 0. More...

bool	was_dropped () const

Private Member Functions
bool	decision_made (bool dropped_by_transport)
	Common logic for data_dropped() and data_delivered(). More...

Private Attributes
Atomic< unsigned long >	sub_loan_count_
	Counts the number of outstanding sub-loans. More...

bool	dropped_
	Flag flipped to true if any DataLink dropped the sample. More...

bool	released_
	If the callback to DW is made. More...

Friends
class	TransportCustomizedElement

Detailed Description

Base wrapper class around a data/control sample to be sent.

This class serves as the base class for different types of samples that can be sent. For example, there are data samples and control samples. A subclass of TransportQueueElement exists for each of these types of samples.

This class maintains a counter that, when decremented to 0, will trigger some logic (defined in the subclass) that will "return the loan" of the sample. The sample is "loaned" to the transport via a send() or send_control() call on the TransportClient. This wrapper object will "return the loan" when all DataLinks have "returned" their sub-loans.

Definition at line 53 of file TransportQueueElement.h.

Constructor & Destructor Documentation

◆ ~TransportQueueElement()

OpenDDS::DCPS::TransportQueueElement::~TransportQueueElement ( )

virtual

Definition at line 25 of file TransportQueueElement.cpp.

References DBG_ENTRY_LVL.

 {
   DBG_ENTRY_LVL("TransportQueueElement", "~TransportQueueElement", 6);
 }

◆ TransportQueueElement()

ACE_INLINE OpenDDS::DCPS::TransportQueueElement::TransportQueueElement ( unsigned long initial_count )

explicitprotected

Ctor. The initial_count is the number of DataLinks to which this TransportQueueElement will be sent.

Definition at line 17 of file TransportQueueElement.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

   : sub_loan_count_(initial_count),
     dropped_(false),
     released_(false)
 {
   DBG_ENTRY_LVL("TransportQueueElement", "TransportQueueElement", 6);
 }

Member Function Documentation

◆ clone_mb()

ACE_Message_Block * OpenDDS::DCPS::TransportQueueElement::clone_mb	(	const ACE_Message_Block *	msg,
		MessageBlockAllocator *	mb_allocator,
		DataBlockAllocator *	db_allocator
	)

static

Clone method with provided message block allocator and data block allocators.

Definition at line 62 of file TransportQueueElement.cpp.

References ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, ACE_NEW_MALLOC_RETURN, ACE_Message_Block::base(), ACE_Message_Block::capacity(), ACE_Message_Block::cont(), ACE_Message_Block::copy(), OpenDDS::DCPS::Cached_Allocator_With_Overflow< T, ACE_LOCK >::malloc(), ACE_Time_Value::max_time, ACE_Message_Block::MB_DATA, msg(), ACE_Message_Block::rd_ptr(), ACE_Message_Block::size(), ACE_Message_Block::wr_ptr(), and ACE_Time_Value::zero.

Referenced by OpenDDS::DCPS::SingleSendBuffer::retain_buffer().

 {
   ACE_Message_Block* cur_block = const_cast<ACE_Message_Block*>(msg);
   ACE_Message_Block* head_copy = 0;
   ACE_Message_Block* cur_copy  = 0;
   ACE_Message_Block* prev_copy = 0;
   // deep copy sample data
   while (cur_block != 0) {
     ACE_NEW_MALLOC_RETURN(cur_copy,
                           static_cast<ACE_Message_Block*>(
                           mb_allocator->malloc(sizeof(ACE_Message_Block))),
                           ACE_Message_Block(cur_block->capacity(),
                                             ACE_Message_Block::MB_DATA,
                                             0, //cont
                                             0, //data
                                             0, //alloc_strategy
                                             0, //locking_strategy
                                             ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY,
                                             ACE_Time_Value::zero,
                                             ACE_Time_Value::max_time,
                                             db_allocator,
                                             mb_allocator),
                           0);
 
     cur_copy->copy(cur_block->base(), cur_block->size());
     cur_copy->rd_ptr(cur_copy->base() +
                      (cur_block->rd_ptr() - cur_block->base()));
     cur_copy->wr_ptr(cur_copy->base() +
                      (cur_block->wr_ptr() - cur_block->base()));
 
     if (head_copy == 0) {
       head_copy = cur_copy;
     } else {
       prev_copy->cont(cur_copy);
     }
 
     prev_copy = cur_copy;
 
     cur_block = cur_block->cont();
   }
 
   return head_copy;
 }

◆ data_delivered()

ACE_INLINE bool OpenDDS::DCPS::TransportQueueElement::data_delivered ( )

Invoked when the sample has been sent by a DataLink. The return value indicates if this element is released.

Definition at line 36 of file TransportQueueElement.inl.

References ACE_INLINE, DBG_ENTRY_LVL, decision_made(), and dropped_.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::TransportSendStrategy::deliver_ack_request(), OpenDDS::DCPS::DataLink::handle_send_request_ack(), and OpenDDS::DCPS::TransportSendStrategy::send_delayed_notifications().

 {
   DBG_ENTRY_LVL("TransportQueueElement", "data_delivered", 6);
   // Decision made depend on dropped_ flag. If any link drops
   // the sample even other links deliver successfully, the
   // data dropped by transport will called back to writer.
   return decision_made(dropped_);
 }

◆ data_dropped()

ACE_INLINE bool OpenDDS::DCPS::TransportQueueElement::data_dropped ( bool dropped_by_transport = false )

Invoked when the sample is dropped from a DataLink due to a remove_sample() call. The dropped_by_transport flag true indicates the data dropping is initiated by transport when the transport send strategy is in a MODE_TERMINATED. The dropped_by_transport flag false indicates the dropping is initiated by the remove_sample and data_dropped() is a result of remove_sample(). The return value indicates if this element is released.

Definition at line 27 of file TransportQueueElement.inl.

References ACE_INLINE, DBG_ENTRY_LVL, decision_made(), and dropped_.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element_non_reliable_i(), OpenDDS::DCPS::TcpDataLink::handle_send_request_ack(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::remove_sample(), OpenDDS::DCPS::TransportSendStrategy::send(), OpenDDS::DCPS::DataLink::send(), OpenDDS::DCPS::TransportSendStrategy::send_delayed_notifications(), OpenDDS::DCPS::TcpDataLink::send_i(), OpenDDS::DCPS::DataLink::send_i(), OpenDDS::DCPS::PacketRemoveVisitor::visit_element_ref(), OpenDDS::DCPS::RemoveAllVisitor::visit_element_remove(), OpenDDS::DCPS::QueueRemoveVisitor::visit_element_remove(), and OpenDDS::DCPS::ThreadPerConRemoveVisitor::visit_element_remove().

 {
   DBG_ENTRY_LVL("TransportQueueElement", "data_dropped", 6);
   dropped_ = true;
   return decision_made(dropped_by_transport);
 }

◆ decision_made()

ACE_INLINE bool OpenDDS::DCPS::TransportQueueElement::decision_made ( bool dropped_by_transport )

private

Common logic for data_dropped() and data_delivered().

Definition at line 47 of file TransportQueueElement.inl.

References ACE_INLINE, DBG_ENTRY_LVL, OPENDDS_ASSERT, release_element(), and sub_loan_count_.

Referenced by data_delivered(), data_dropped(), and OpenDDS::DCPS::TransportCustomizedElement::release_element().

 {
   DBG_ENTRY_LVL("TransportQueueElement", "decision_made", 6);
 
   OPENDDS_ASSERT(sub_loan_count_);
 
   const unsigned long new_count = --sub_loan_count_;
   if (new_count == 0) {
     // All interested subscriptions have been satisfied.
 
     // The queue elements are released to its cached allocator
     // in release_element() call.
     // It's not necessary to set the released_ flag to true
     // as this element will be released anyway and not be
     // accessible. Note it can not be set after release_element
     // call.
     // released_ = true;
     release_element(dropped_by_transport);
     return true;
   }
 
   return false;
 }

◆ duplicate_msg()

virtual ACE_Message_Block* OpenDDS::DCPS::TransportQueueElement::duplicate_msg ( ) const

pure virtual

A reference-incremented duplicate of the marshalled sample (sample header + sample data)

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportControlElement, OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportReplacedElement, and OpenDDS::DCPS::TransportSendElement.

Referenced by OpenDDS::DCPS::CopyChainVisitor::visit_element().

◆ fragment()

TqePair OpenDDS::DCPS::TransportQueueElement::fragment ( size_t size )

virtual

Create two TransportQueueElements representing the same data payload as the current TransportQueueElement, with the first one (including its DataSampleHeader) fitting in "size" bytes. This method leaves the current TransportQueueElement alone (but can't be made const because the newly-created elements will need to invoke non-const methods on it). Each element in the pair will contain its own serialized modified DataSampleHeader.

If the fragmentation fails, a copy of null_tqe_pair is returned.

Reimplemented in OpenDDS::DCPS::RtpsCustomizedElement.

Definition at line 44 of file TransportQueueElement.cpp.

References OpenDDS::DCPS::move(), msg(), OpenDDS::DCPS::TransportCustomizedElement::set_fragment(), OpenDDS::DCPS::TransportCustomizedElement::set_msg(), OpenDDS::DCPS::DataSampleHeader::split(), and TransportCustomizedElement.

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

 {
   Message_Block_Ptr head;
   Message_Block_Ptr tail;
   DataSampleHeader::split(*msg(), size, head, tail);
 
   TransportCustomizedElement* frag = new TransportCustomizedElement(0);
   frag->set_fragment(this);
   frag->set_msg(move(head));
 
   TransportCustomizedElement* rest = new TransportCustomizedElement(this);
   rest->set_fragment(this);
   rest->set_msg(move(tail));
 
   return TqePair(frag, rest);
 }

◆ increment_loan()

void OpenDDS::DCPS::TransportQueueElement::increment_loan ( )

inline

Delay releasing the element by one decision (either a data_dropped or data_delivered).

Definition at line 115 of file TransportQueueElement.h.

Referenced by OpenDDS::DCPS::TransportSendStrategy::fragmentation_helper().

115 { ++sub_loan_count_; }

OpenDDS::DCPS::TransportQueueElement::sub_loan_count_

Atomic< unsigned long > sub_loan_count_

Counts the number of outstanding sub-loans.

Definition: TransportQueueElement.h:206

◆ is_control()

bool OpenDDS::DCPS::TransportQueueElement::is_control ( GUID_t pub_id ) const

virtual

Is the element a "control" sample from the specified pub_id?

Reimplemented in OpenDDS::DCPS::TransportSendControlElement.

Definition at line 38 of file TransportQueueElement.cpp.

References DBG_ENTRY_LVL.

 {
   DBG_ENTRY_LVL("TransportQueueElement", "is_control", 6);
   return false;
 }

◆ is_fragment()

virtual bool OpenDDS::DCPS::TransportQueueElement::is_fragment ( ) const

inlinevirtual

Is this QueueElement the result of fragmentation?

Reimplemented in OpenDDS::DCPS::TransportCustomizedElement.

Definition at line 169 of file TransportQueueElement.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::include_fragment(), and OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert().

169 { return false; }

◆ is_last_fragment()

virtual bool OpenDDS::DCPS::TransportQueueElement::is_last_fragment ( ) const

inlinevirtual

Is this QueueElement the last result of fragmentation?

Reimplemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportCustomizedElement, and OpenDDS::DCPS::TransportSendElement.

Definition at line 172 of file TransportQueueElement.h.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper().

172 { return false; }

◆ is_request_ack()

virtual bool OpenDDS::DCPS::TransportQueueElement::is_request_ack ( ) const

inlinevirtual

Reimplemented in OpenDDS::DCPS::TransportSendControlElement.

Definition at line 174 of file TransportQueueElement.h.

Referenced by OpenDDS::DCPS::TcpSendStrategy::add_delayed_notification(), and OpenDDS::DCPS::DataLink::send().

174 { return false; }

◆ is_retained_replaced()

virtual bool OpenDDS::DCPS::TransportQueueElement::is_retained_replaced ( ) const

inlinevirtual

Reimplemented in OpenDDS::DCPS::TransportRetainedElement, and OpenDDS::DCPS::TransportReplacedElement.

Definition at line 176 of file TransportQueueElement.h.

Referenced by OpenDDS::DCPS::PacketRemoveVisitor::visit_element_ref().

176 { return false; }

◆ msg()

virtual const ACE_Message_Block* OpenDDS::DCPS::TransportQueueElement::msg ( ) const

pure virtual

The marshalled sample (sample header + sample data)

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportControlElement, OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportReplacedElement, and OpenDDS::DCPS::TransportSendElement.

Referenced by OpenDDS::DCPS::TransportSendStrategy::adjust_packet_after_send(), clone_mb(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element_non_reliable_i(), fragment(), OpenDDS::DCPS::SingleSendBuffer::insert(), OpenDDS::DCPS::TransportSendStrategy::send(), OpenDDS::DCPS::TransportReplacedElement::TransportReplacedElement(), OpenDDS::DCPS::BuildChainVisitor::visit_element(), OpenDDS::DCPS::CopyChainVisitor::visit_element(), OpenDDS::DCPS::PacketRemoveVisitor::visit_element_ref(), OpenDDS::DCPS::RemoveAllVisitor::visit_element_remove(), and OpenDDS::DCPS::QueueRemoveVisitor::visit_element_remove().

◆ msg_payload()

virtual const ACE_Message_Block* OpenDDS::DCPS::TransportQueueElement::msg_payload ( ) const

pure virtual

The marshalled payload only (sample data)

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportControlElement, OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportReplacedElement, OpenDDS::DCPS::TransportSendElement, and OpenDDS::DCPS::RtpsCustomizedElement.

Referenced by OpenDDS::DCPS::TransportQueueElement::MatchOnDataPayload::matches(), and OpenDDS::DCPS::TransportCustomizedElement::msg_payload().

◆ owned_by_transport()

virtual bool OpenDDS::DCPS::TransportQueueElement::owned_by_transport ( )

pure virtual

Is the sample created by the transport?

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportSendElement, OpenDDS::DCPS::TransportReplacedElement, and OpenDDS::DCPS::TransportControlElement.

Referenced by OpenDDS::DCPS::TransportSendStrategy::send_delayed_notifications().

◆ publication_id()

virtual GUID_t OpenDDS::DCPS::TransportQueueElement::publication_id ( ) const

pure virtual

Accessor for the publication id that sent the sample.

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportControlElement, OpenDDS::DCPS::TransportReplacedElement, OpenDDS::DCPS::TransportCustomizedElement, and OpenDDS::DCPS::TransportSendElement.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::add_delayed_notification(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element_non_reliable_i(), OpenDDS::DCPS::RtpsUdpDataLink::durability_resend(), OpenDDS::DCPS::TcpDataLink::handle_send_request_ack(), OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert(), OpenDDS::DCPS::TransportQueueElement::MatchOnPubId::matches(), OpenDDS::DCPS::RtpsUdpSendStrategy::send_bytes_i_helper(), OpenDDS::DCPS::TcpDataLink::send_i(), OpenDDS::DCPS::TransportCustomizedElement::set_fragment(), OpenDDS::DCPS::TransportReplacedElement::TransportReplacedElement(), and OpenDDS::DCPS::CopyChainVisitor::visit_element().

◆ release_element()

virtual void OpenDDS::DCPS::TransportQueueElement::release_element ( bool dropped_by_transport )

protectedpure virtual

Invoked when the counter reaches 0.

Implemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportRetainedElement, OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportControlElement, OpenDDS::DCPS::TransportSendElement, and OpenDDS::DCPS::TransportReplacedElement.

Referenced by decision_made().

◆ released() [1/2]

ACE_INLINE bool OpenDDS::DCPS::TransportQueueElement::released ( ) const

Is the listener get called ?

Definition at line 80 of file TransportQueueElement.inl.

References ACE_INLINE, and released_.

 {
   return released_;
 }

◆ released() [2/2]

ACE_INLINE void OpenDDS::DCPS::TransportQueueElement::released ( bool flag )

Definition at line 87 of file TransportQueueElement.inl.

References ACE_INLINE, and released_.

 {
   released_ = flag;
 }

◆ requires_exclusive_packet()

bool OpenDDS::DCPS::TransportQueueElement::requires_exclusive_packet ( ) const

virtual

Does the sample require an exclusive transport packet?

Reimplemented in OpenDDS::DCPS::TransportCustomizedElement, OpenDDS::DCPS::TransportSendControlElement, and OpenDDS::DCPS::TransportControlElement.

Definition at line 31 of file TransportQueueElement.cpp.

References DBG_ENTRY_LVL.

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

 {
   DBG_ENTRY_LVL("TransportQueueElement", "requires_exclusive_packet", 6);
   return false;
 }

◆ sequence()

virtual SequenceNumber OpenDDS::DCPS::TransportQueueElement::sequence ( ) const

inlinevirtual

Reimplemented in OpenDDS::DCPS::TransportSendControlElement, OpenDDS::DCPS::TransportSendElement, and OpenDDS::DCPS::TransportCustomizedElement.

Definition at line 128 of file TransportQueueElement.h.

References OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN().

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::add_elem_awaiting_ack(), OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::durability_resend(), OpenDDS::DCPS::TcpDataLink::handle_send_request_ack(), OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert(), OpenDDS::DCPS::TransportQueueElement::OrderBySequenceNumber::operator()(), OpenDDS::DCPS::TransportCustomizedElement::sequence(), and OpenDDS::DCPS::TransportCustomizedElement::set_fragment().

                                           {
     return SequenceNumber::SEQUENCENUMBER_UNKNOWN();
   }

◆ subscription_id()

virtual GUID_t OpenDDS::DCPS::TransportQueueElement::subscription_id ( ) const

inlinevirtual

Accessor for the subscription id, if sent the sample is sent to 1 sub.

Reimplemented in OpenDDS::DCPS::TransportCustomizedElement, and OpenDDS::DCPS::TransportSendElement.

Definition at line 124 of file TransportQueueElement.h.

References OpenDDS::DCPS::GUID_UNKNOWN.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::customize_queue_element_helper(), OpenDDS::DCPS::RtpsUdpDataLink::durability_resend(), OpenDDS::DCPS::SingleSendBuffer::insert(), OpenDDS::DCPS::RtpsUdpSendStrategy::send_bytes_i_helper(), and OpenDDS::DCPS::TransportCustomizedElement::set_fragment().

                                          {
     return GUID_UNKNOWN;
   }

◆ was_dropped()

ACE_INLINE bool OpenDDS::DCPS::TransportQueueElement::was_dropped ( ) const

protected

May be used by subclass' implementation of release_element() to determine if any DataLinks dropped the data instead of delivering it.

Definition at line 73 of file TransportQueueElement.inl.

References ACE_INLINE, and dropped_.

Referenced by OpenDDS::DCPS::TransportSendElement::release_element(), and OpenDDS::DCPS::TransportSendControlElement::release_element().

 {
   return dropped_;
 }

Friends And Related Function Documentation

◆ TransportCustomizedElement

friend class TransportCustomizedElement

friend

Definition at line 203 of file TransportQueueElement.h.

Referenced by fragment().

Member Data Documentation

◆ dropped_

bool OpenDDS::DCPS::TransportQueueElement::dropped_

private

Flag flipped to true if any DataLink dropped the sample.

Definition at line 209 of file TransportQueueElement.h.

Referenced by data_delivered(), data_dropped(), and was_dropped().

◆ released_

bool OpenDDS::DCPS::TransportQueueElement::released_

private

If the callback to DW is made.

Definition at line 212 of file TransportQueueElement.h.

Referenced by released().

◆ sub_loan_count_

Atomic<unsigned long> OpenDDS::DCPS::TransportQueueElement::sub_loan_count_

private

Counts the number of outstanding sub-loans.

Definition at line 206 of file TransportQueueElement.h.

Referenced by decision_made().

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

Classes

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ ~TransportQueueElement()

◆ TransportQueueElement()

Member Function Documentation

◆ clone_mb()

◆ data_delivered()

◆ data_dropped()

◆ decision_made()

◆ duplicate_msg()

◆ fragment()

◆ increment_loan()

◆ is_control()

◆ is_fragment()

◆ is_last_fragment()

◆ is_request_ack()

◆ is_retained_replaced()

◆ msg()

◆ msg_payload()

◆ owned_by_transport()

◆ publication_id()

◆ release_element()

◆ released() [1/2]

◆ released() [2/2]

◆ requires_exclusive_packet()

◆ sequence()

◆ subscription_id()

◆ was_dropped()

Friends And Related Function Documentation

◆ TransportCustomizedElement

Member Data Documentation

◆ dropped_

◆ released_

◆ sub_loan_count_