Inheritance diagram for OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer:

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer:

[legend]

Public Member Functions
	MultiSendBuffer (RtpsUdpDataLink *outer, size_t capacity)

void	insert (SequenceNumber sequence, TransportSendStrategy::QueueType queue, ACE_Message_Block chain)

Public Member Functions inherited from OpenDDS::DCPS::TransportSendBuffer
size_t	capacity () const

void	bind (TransportSendStrategy *strategy)

virtual void	retain_all (const GUID_t &pub_id)

LockType &	strategy_lock ()

Public Attributes
RtpsUdpDataLink *	outer_

Additional Inherited Members
Public Types inherited from OpenDDS::DCPS::TransportSendBuffer
typedef TransportSendStrategy::LockType	LockType

Protected Types inherited from OpenDDS::DCPS::TransportSendBuffer
typedef TransportSendStrategy::QueueType	QueueType

typedef std::pair< QueueType , ACE_Message_Block >	BufferType

Protected Member Functions inherited from OpenDDS::DCPS::TransportSendBuffer
	TransportSendBuffer (size_t capacity)

virtual	~TransportSendBuffer ()

void	resend_one (const BufferType &buffer)

Protected Attributes inherited from OpenDDS::DCPS::TransportSendBuffer
TransportSendStrategy *	strategy_

const size_t	capacity_

Detailed Description

Definition at line 322 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

◆ MultiSendBuffer()

OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::MultiSendBuffer	(	RtpsUdpDataLink *	outer,
		size_t	capacity
	)

inline

Definition at line 324 of file RtpsUdpDataLink.h.

References OpenDDS::DCPS::insert().

       : TransportSendBuffer(capacity)
       , outer_(outer)
     {}

Member Function Documentation

◆ insert()

void OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert	(	SequenceNumber	sequence,
		TransportSendStrategy::QueueType *	queue,
		ACE_Message_Block *	chain
	)

virtual

Implements OpenDDS::DCPS::TransportSendBuffer.

Definition at line 993 of file RtpsUdpDataLink.cpp.

References ACE_DEBUG, ACE_ERROR, OpenDDS::DCPS::SequenceNumber::getValue(), OpenDDS::DCPS::TransportQueueElement::is_fragment(), OpenDDS::DCPS::TransportCustomizedElement::is_last_fragment(), OpenDDS::DCPS::RcHandle< T >::is_nil(), OpenDDS::DCPS::RtpsCustomizedElement::last_fragment(), LM_DEBUG, LM_ERROR, OpenDDS::DCPS::BasicQueue< T >::peek(), OpenDDS::DCPS::TransportQueueElement::publication_id(), OpenDDS::DCPS::TransportQueueElement::sequence(), OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN(), and OpenDDS::DCPS::Transport_debug_level.

 {
   // Called from TransportSendStrategy::send_packet().
   // RtpsUdpDataLink is not locked at this point, and is only locked
   // to grab the appropriate writer send buffer via get_writer_send_buffer()
   const TransportQueueElement* const tqe = q->peek();
   const SequenceNumber seq = tqe->sequence();
   if (seq == SequenceNumber::SEQUENCENUMBER_UNKNOWN()) {
     return;
   }
 
   const GUID_t pub_id = tqe->publication_id();
 
   RcHandle<SingleSendBuffer> send_buff = outer_->get_writer_send_buffer(pub_id);
   if (send_buff.is_nil()) {
     return;
   }
 
   if (Transport_debug_level > 5) {
     ACE_DEBUG((LM_DEBUG, "(%P|%t) RtpsUdpDataLink::MultiSendBuffer::insert() - "
       "pub_id %C seq %q frag %d\n", LogGuid(pub_id).c_str(), seq.getValue(),
       (int)tqe->is_fragment()));
   }
 
   if (tqe->is_fragment()) {
     const RtpsCustomizedElement* const rce =
       dynamic_cast<const RtpsCustomizedElement*>(tqe);
     if (rce) {
       send_buff->insert_fragment(seq, rce->last_fragment(), rce->is_last_fragment(), q, chain);
     } else if (Transport_debug_level) {
       ACE_ERROR((LM_ERROR, "(%P|%t) RtpsUdpDataLink::MultiSendBuffer::insert()"
         " - ERROR: couldn't get fragment number for pub_id %C seq %q\n",
         LogGuid(pub_id).c_str(), seq.getValue()));
     }
   } else {
     send_buff->insert(seq, q, chain);
   }
 }

Member Data Documentation

◆ outer_

RtpsUdpDataLink* OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::outer_

Definition at line 333 of file RtpsUdpDataLink.h.

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

Public Member Functions

Public Attributes