CopyChainVisitor.cpp

Go to the documentation of this file.

/*
 *
 *
 * Distributed under the OpenDDS License.
 * See: http://www.opendds.org/license.html
 */

#include "DCPS/DdsDcps_pch.h" //Only the _pch include should start with DCPS/
#include "CopyChainVisitor.h"
#include "TransportQueueElement.h"

#if !defined (__ACE_INLINE__)
#include "CopyChainVisitor.inl"
#endif /* __ACE_INLINE__ */

OpenDDS::DCPS::CopyChainVisitor::~CopyChainVisitor()
{
  DBG_ENTRY_LVL("CopyChainVisitor","~CopyChainVisitor",6);
}

int
OpenDDS::DCPS::CopyChainVisitor::visit_element(TransportQueueElement* element)
{
  DBG_ENTRY_LVL("CopyChainVisitor","visit_element",6);

  // Create a new copy of the current element.
  // fails.
  TransportRetainedElement* copiedElement = 0;
  ACE_NEW_MALLOC_NORETURN(
    copiedElement,
    (TransportRetainedElement*)this->allocator_->malloc(),
    TransportRetainedElement(
      element->msg(),
      element->publication_id(),
      this->allocator_,
      this->mb_allocator_,
      this->db_allocator_
    )
  );
  if( copiedElement) {
    // Add the copy to the target.
    this->target_.put( copiedElement);

    // Visit entire queue.
    return 1;

  } else {
    ACE_ERROR((LM_ERROR,
      ACE_TEXT("(%P|%t) ERROR: CopyChainVisitor::visit_element - ")
      ACE_TEXT("failed to allocate a new TransportRetainedElement.")
    ));
    this->status_ = -1;

    // Stop visitation.
    return 0;
  }


}

---