RtpsCustomizedElement.h

Go to the documentation of this file.

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

#ifndef OPENDDS_DCPS_TRANSPORT_RTPS_UDP_RTPSCUSTOMIZEDELEMENT_H
#define OPENDDS_DCPS_TRANSPORT_RTPS_UDP_RTPSCUSTOMIZEDELEMENT_H

#include "Rtps_Udp_Export.h"

#include "dds/DCPS/transport/framework/TransportCustomizedElement.h"

#include "dds/DCPS/Dynamic_Cached_Allocator_With_Overflow_T.h"

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

namespace OpenDDS {
namespace DCPS {

class OpenDDS_Rtps_Udp_Export RtpsCustomizedElement
  : public TransportCustomizedElement {

public:

  RtpsCustomizedElement(TransportQueueElement* orig,
                        Message_Block_Ptr msg);

  SequenceNumber last_fragment() const;

private:

  virtual ~RtpsCustomizedElement();

  TqePair fragment(size_t size);
  const ACE_Message_Block* msg_payload() const;

  SequenceNumber last_frag_;
};

typedef Dynamic_Cached_Allocator_With_Overflow<ACE_Thread_Mutex>
  RtpsCustomizedElementAllocator;


} // namespace DCPS
} // namespace OpenDDS

OPENDDS_END_VERSIONED_NAMESPACE_DECL

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

#endif  /* OPENDDS_RTPSCUSTOMIZEDELEMENT_H */