TransportHeader.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 "TransportHeader.h"
#include "dds/DCPS/Serializer.h"
#include "EntryExit.h"

const ACE_CDR::Octet
OpenDDS::DCPS::TransportHeader::DCPS_PROTOCOL[] =
  { 0x44, 0x43, 0x50, 0x53, 0x02, 0x00 };
//   D     C     P     S     |     |__ minor version
//                           |________ major version

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

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL

namespace OpenDDS {
namespace DCPS {

bool operator<<(ACE_Message_Block& buffer, const TransportHeader& value)
{
  Serializer writer(&buffer, Encoding::KIND_UNALIGNED_CDR);

  if (!writer.write_octet_array(value.protocol_, sizeof(value.protocol_)))
    return false;

  const ACE_CDR::Octet flags =
    (value.byte_order_ << TransportHeader::BYTE_ORDER_FLAG) |
    (value.first_fragment_ << TransportHeader::FIRST_FRAGMENT_FLAG) |
    (value.last_fragment_ << TransportHeader::LAST_FRAGMENT_FLAG);

  return (writer << ACE_OutputCDR::from_octet(flags)) &&
         (writer << ACE_OutputCDR::from_octet(value.reserved_)) &&
         (writer << value.length_) &&
         (writer << value.sequence_) &&
         (writer << value.source_);
}

/*static*/
ACE_UINT32
TransportHeader::get_length(const char* marshaled_header)
{
  const TransportHeader* hdr = 0;
  static const unsigned int OFFSET = sizeof(hdr->protocol_) +
                                     1 /*flags*/ +
                                     sizeof(hdr->reserved_);
  return *reinterpret_cast<const ACE_UINT32*>(marshaled_header + OFFSET);
}

}
}

OPENDDS_END_VERSIONED_NAMESPACE_DECL