TransportSendControlElement.inl

Go to the documentation of this file.

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

#include "EntryExit.h"
#include "dds/DCPS/DataSampleElement.h"

namespace OpenDDS {
namespace DCPS {

ACE_INLINE
TransportSendControlElement::TransportSendControlElement(int initial_count,
                                                         const RepoId& publisher_id,
                                                         TransportSendListener* listener,
                                                         const DataSampleHeader& header,
                                                         ACE_Message_Block* msg_block,
                                                         TransportSendControlElementAllocator* allocator)
  : TransportQueueElement(initial_count),
    publisher_id_(publisher_id),
    listener_(listener),
    header_(header),
    msg_(msg_block),
    dcps_elem_(0),
    allocator_(allocator)
{
  DBG_ENTRY_LVL("TransportSendControlElement","TransportSendControlElement",6);
}

ACE_INLINE
TransportSendControlElement::TransportSendControlElement(int initial_count,
                                                         const DataSampleElement* dcps_elem,
                                                         TransportSendControlElementAllocator* allocator)
  : TransportQueueElement(initial_count)
  , publisher_id_(dcps_elem->get_pub_id())
  , listener_(dcps_elem->get_send_listener())
  , header_(dcps_elem->get_header())
  , msg_(dcps_elem->get_sample())
  , dcps_elem_(dcps_elem)
  , allocator_(allocator)
{
  DBG_ENTRY_LVL("TransportSendControlElement", "TransportSendControlElement", 6);
}

ACE_INLINE /*static*/
TransportSendControlElement*
TransportSendControlElement::alloc(int initial_count,
                                   const RepoId& publisher_id,
                                   TransportSendListener* listener,
                                   const DataSampleHeader& header,
                                   ACE_Message_Block* message,
                                   TransportSendControlElementAllocator* allocator)
{
  TransportSendControlElement* ret;
  ACE_NEW_MALLOC_RETURN(ret,
    static_cast<TransportSendControlElement*>(allocator->malloc()),
    TransportSendControlElement(initial_count, publisher_id, listener, header,
                                message, allocator),
    0);
  return ret;
}

ACE_INLINE /*static*/
TransportSendControlElement*
TransportSendControlElement::alloc(int initial_count,
                                   const DataSampleElement* dcps_elem,
                                   TransportSendControlElementAllocator* allocator)
{
  TransportSendControlElement* ret;
  ACE_NEW_MALLOC_RETURN(ret,
    static_cast<TransportSendControlElement*>(allocator->malloc()),
    TransportSendControlElement(initial_count, dcps_elem, allocator),
    0);
  return ret;
}

ACE_INLINE
bool
TransportSendControlElement::owned_by_transport()
{
  return false;
}

ACE_INLINE
SequenceNumber
TransportSendControlElement::sequence() const
{
  return this->header_.sequence_;
}

}
}

---