#include <BuildChainVisitor.h>

Inheritance diagram for OpenDDS::DCPS::BuildChainVisitor:

Collaboration diagram for OpenDDS::DCPS::BuildChainVisitor:

[legend]

Public Member Functions
	BuildChainVisitor ()

virtual	~BuildChainVisitor ()

virtual int	visit_element (TransportQueueElement *element)

ACE_Message_Block *	chain ()

Public Member Functions inherited from OpenDDS::DCPS::BasicQueueVisitor< TransportQueueElement >
	BasicQueueVisitor ()

virtual	~BasicQueueVisitor ()

virtual int	visit_element_remove (TransportQueueElement *element, int &remove)

virtual int	visit_element_ref (TransportQueueElement *&element)

Private Attributes
ACE_Message_Block *	head_

ACE_Message_Block *	tail_

Detailed Description

Definition at line 25 of file BuildChainVisitor.h.

Constructor & Destructor Documentation

◆ BuildChainVisitor()

ACE_INLINE OpenDDS::DCPS::BuildChainVisitor::BuildChainVisitor ( )

Definition at line 11 of file BuildChainVisitor.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

   : head_(0),
     tail_(0)
 {
   DBG_ENTRY_LVL("BuildChainVisitor", "BuildChainVisitor", 6);
 }

◆ ~BuildChainVisitor()

OpenDDS::DCPS::BuildChainVisitor::~BuildChainVisitor ( )

virtual

Definition at line 16 of file BuildChainVisitor.cpp.

References DBG_ENTRY_LVL.

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

Member Function Documentation

◆ chain()

ACE_INLINE ACE_Message_Block * OpenDDS::DCPS::BuildChainVisitor::chain ( )

Accessor to extract the chain, leaving the head_ and tail_ set to 0 as a result.

Definition at line 20 of file BuildChainVisitor.inl.

References DBG_ENTRY_LVL, head_, and tail_.

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

 {
   DBG_ENTRY_LVL("BuildChainVisitor", "chain", 6);
 
   ACE_Message_Block* head = head_;
   head_ = tail_ = 0;
   return head;
 }

◆ visit_element()

int OpenDDS::DCPS::BuildChainVisitor::visit_element ( TransportQueueElement * element )

virtual

This is the visit_element() method that will be called when the visitation method used is BasicQueue<T>::accept_visitor().

Return 0 if visiting should stop, return 1 to continue visiting.

Reimplemented from OpenDDS::DCPS::BasicQueueVisitor< TransportQueueElement >.

Definition at line 22 of file BuildChainVisitor.cpp.

References ACE_Message_Block::cont(), DBG_ENTRY_LVL, ACE_Message_Block::duplicate(), head_, OpenDDS::DCPS::TransportQueueElement::msg(), and tail_.

 {
   DBG_ENTRY_LVL("BuildChainVisitor", "visit_element", 6);
 
   if (head_ == 0) {
     // This is the first element that we have visited.
     head_ = element->msg()->duplicate();
     tail_ = head_;
 
     while (tail_->cont() != 0) {
       tail_ = tail_->cont();
     }
 
   } else {
     // This is not the first element that we have visited.
     tail_->cont(element->msg()->duplicate());
 
     while (tail_->cont() != 0) {
       tail_ = tail_->cont();
     }
   }
 
   // Visit entire queue.
   return 1;
 }

Member Data Documentation

◆ head_

ACE_Message_Block* OpenDDS::DCPS::BuildChainVisitor::head_

private

Definition at line 39 of file BuildChainVisitor.h.

Referenced by chain(), and visit_element().

◆ tail_

ACE_Message_Block* OpenDDS::DCPS::BuildChainVisitor::tail_