OpenDDS::DCPS::CopyChainVisitor Class Reference

#include <CopyChainVisitor.h>

Inheritance diagram for OpenDDS::DCPS::CopyChainVisitor:

Collaboration diagram for OpenDDS::DCPS::CopyChainVisitor:

Public Member Functions
	CopyChainVisitor (BasicQueue< TransportQueueElement > &target, MessageBlockAllocator *mb_allocator, DataBlockAllocator *db_allocator, bool duplicate=false)
virtual	~CopyChainVisitor ()
virtual int	visit_element (TransportQueueElement *element)
int	status () const
	Access the status. More...
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
BasicQueue< TransportQueueElement > &	target_
	Target queue to fill with copied elements. More...
MessageBlockAllocator *	mb_allocator_
	Allocator to create copied elements. More...
DataBlockAllocator *	db_allocator_
int	status_
	Status of visitation. More...
bool	duplicate_

Detailed Description

Definition at line 26 of file CopyChainVisitor.h.

Constructor & Destructor Documentation

CopyChainVisitor()

ACE_INLINE OpenDDS::DCPS::CopyChainVisitor::CopyChainVisitor	(	BasicQueue< TransportQueueElement > &	target,
		MessageBlockAllocator *	mb_allocator,
		DataBlockAllocator *	db_allocator,
		bool	duplicate = false
	)

Definition at line 11 of file CopyChainVisitor.inl.

References ACE_INLINE, and DBG_ENTRY_LVL.

  : target_(target)
  , mb_allocator_(mb_allocator)
  , db_allocator_(db_allocator)
  , status_(0)
  , duplicate_(duplicate)
{
  DBG_ENTRY_LVL("CopyChainVisitor", "CopyChainVisitor", 6);
}

~CopyChainVisitor()

OpenDDS::DCPS::CopyChainVisitor::~CopyChainVisitor ( )

virtual

Definition at line 16 of file CopyChainVisitor.cpp.

References DBG_ENTRY_LVL.

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

Member Function Documentation

status()

ACE_INLINE int OpenDDS::DCPS::CopyChainVisitor::status

(

void

)

const

Access the status.

Definition at line 27 of file CopyChainVisitor.inl.

References status_.

{
  return status_;
}

visit_element()

int OpenDDS::DCPS::CopyChainVisitor::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 CopyChainVisitor.cpp.

References db_allocator_, DBG_ENTRY_LVL, duplicate_, OpenDDS::DCPS::TransportQueueElement::duplicate_msg(), mb_allocator_, OpenDDS::DCPS::TransportQueueElement::msg(), OpenDDS::DCPS::TransportQueueElement::publication_id(), OpenDDS::DCPS::BasicQueue< T >::put(), and target_.

{
  DBG_ENTRY_LVL("CopyChainVisitor", "visit_element", 6);

  TransportRetainedElement* copiedElement = 0;
  if (duplicate_) {
    // Create a new copy of the current element.
    copiedElement = new
      TransportRetainedElement(
        element->duplicate_msg(),
        element->publication_id()
      );
  } else {
    // Create a new copy of the current element.
    copiedElement = new
      TransportRetainedElement(
        element->msg(),
        element->publication_id(),
        mb_allocator_,
        db_allocator_
      );
  }

  // Add the copy to the target.
  target_.put(copiedElement);

  // Visit entire queue.
  return 1;
}

Member Data Documentation

db_allocator_

DataBlockAllocator* OpenDDS::DCPS::CopyChainVisitor::db_allocator_

private

Definition at line 49 of file CopyChainVisitor.h.

Referenced by visit_element().

duplicate_

bool OpenDDS::DCPS::CopyChainVisitor::duplicate_

private

Definition at line 53 of file CopyChainVisitor.h.

Referenced by visit_element().

mb_allocator_

MessageBlockAllocator* OpenDDS::DCPS::CopyChainVisitor::mb_allocator_

private

Allocator to create copied elements.

Definition at line 48 of file CopyChainVisitor.h.

Referenced by visit_element().

status_

int OpenDDS::DCPS::CopyChainVisitor::status_

private

Status of visitation.

Definition at line 52 of file CopyChainVisitor.h.

Referenced by status().

target_

BasicQueue<TransportQueueElement>& OpenDDS::DCPS::CopyChainVisitor::target_

private

Target queue to fill with copied elements.

Definition at line 45 of file CopyChainVisitor.h.

Referenced by visit_element().

---

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

• CopyChainVisitor.h
• CopyChainVisitor.cpp
• CopyChainVisitor.inl