OpenDDS::RTPS::MessageParser Class Reference

#include <MessageParser.h>

Collaboration diagram for OpenDDS::RTPS::MessageParser:

Public Member Functions
	MessageParser (const ACE_Message_Block &in)
	MessageParser (const DDS::OctetSeq &in)
bool	parseHeader ()
bool	parseSubmessageHeader ()
bool	hasNextSubmessage () const
bool	skipToNextSubmessage ()
bool	skipSubmessageContent ()
const Header &	header () const
SubmessageHeader	submessageHeader () const
size_t	remaining () const
const char *	current () const
DCPS::Serializer &	serializer ()
template<typename T >
bool	operator>> (T &rhs)

Private Attributes
ACE_Message_Block	fromSeq_
DCPS::Message_Block_Ptr	in_
DCPS::Serializer	ser_
Header	header_
SubmessageHeader	sub_
size_t	smContentStart_

Detailed Description

Utility for iterating through a contiguous buffer (either really contiguous or virtually contiguous using message block chaining) of RTPS Submessages optionally prefixed by the RTPS Header

Definition at line 22 of file MessageParser.h.

Constructor & Destructor Documentation

MessageParser() [1/2]

OpenDDS::RTPS::MessageParser::MessageParser ( const ACE_Message_Block &  in )

explicit

Definition at line 19 of file MessageParser.cpp.

  : in_(in.duplicate())
  , ser_(in_.get(), encoding_plain_native)
  , header_()
  , sub_()
  , smContentStart_(0)
{}

MessageParser() [2/2]

OpenDDS::RTPS::MessageParser::MessageParser ( const DDS::OctetSeq &  in )

explicit

Definition at line 27 of file MessageParser.cpp.

References fromSeq_, ACE_Message_Block::size(), and ACE_Message_Block::wr_ptr().

  : fromSeq_(reinterpret_cast<const char*>(in.get_buffer()), in.length())
  , ser_(&fromSeq_, encoding_plain_native)
  , header_()
  , sub_()
  , smContentStart_(0)
{
  fromSeq_.wr_ptr(fromSeq_.size());
}

Member Function Documentation

current()

const char* OpenDDS::RTPS::MessageParser::current ( void  ) const

inline

Definition at line 36 of file MessageParser.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{ return ser_.pos_rd(); }

hasNextSubmessage()

bool OpenDDS::RTPS::MessageParser::hasNextSubmessage

(

)

const

Definition at line 57 of file MessageParser.cpp.

References OpenDDS::RTPS::INFO_TS, OpenDDS::DCPS::Serializer::length(), OpenDDS::RTPS::PAD, ser_, smContentStart_, sub_, OpenDDS::RTPS::SubmessageHeader::submessageId, and OpenDDS::RTPS::SubmessageHeader::submessageLength.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{
  if(sub_.submessageLength == 0) {
    if(sub_.submessageId != PAD && sub_.submessageId != INFO_TS) {
      return false;
    }
    return ser_.length();
  }
  return smContentStart_ > sub_.submessageLength;
}

header()

const Header& OpenDDS::RTPS::MessageParser::header ( void  ) const

inline

Definition at line 33 of file MessageParser.h.

{ return header_; }

operator>>()

template<typename T >

bool OpenDDS::RTPS::MessageParser::operator>> ( T &  rhs )

inline

Definition at line 41 of file MessageParser.h.

{ return ser_ >> rhs; }

parseHeader()

bool OpenDDS::RTPS::MessageParser::parseHeader

(

)

Definition at line 37 of file MessageParser.cpp.

References header_, and ser_.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{
  return ser_ >> header_;
}

parseSubmessageHeader()

bool OpenDDS::RTPS::MessageParser::parseSubmessageHeader

(

)

Definition at line 42 of file MessageParser.cpp.

References ACE_CDR_BYTE_ORDER, OpenDDS::RTPS::FLAG_E, OpenDDS::RTPS::SubmessageHeader::flags, OpenDDS::DCPS::Serializer::length(), ser_, smContentStart_, sub_, OpenDDS::RTPS::SubmessageHeader::submessageId, OpenDDS::RTPS::SubmessageHeader::submessageLength, and OpenDDS::DCPS::Serializer::swap_bytes().

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{
  if(!(ser_ >> ACE_InputCDR::to_octet(sub_.submessageId)) ||
    !(ser_ >> ACE_InputCDR::to_octet(sub_.flags))) {
    return false;
  }

  ser_.swap_bytes(ACE_CDR_BYTE_ORDER != (sub_.flags & FLAG_E));
  if(!(ser_ >> sub_.submessageLength)) {
    return false;
  }
  smContentStart_ = ser_.length();
  return sub_.submessageLength <= ser_.length();
}

remaining()

size_t OpenDDS::RTPS::MessageParser::remaining ( ) const

inline

Definition at line 35 of file MessageParser.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{ return in_ ? in_->total_length() : fromSeq_.length(); }

serializer()

DCPS::Serializer& OpenDDS::RTPS::MessageParser::serializer ( )

inline

Definition at line 38 of file MessageParser.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{ return ser_; }

skipSubmessageContent()

bool OpenDDS::RTPS::MessageParser::skipSubmessageContent

(

)

Definition at line 74 of file MessageParser.cpp.

References OpenDDS::RTPS::INFO_TS, OpenDDS::DCPS::Serializer::length(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::RTPS::PAD, read(), ser_, OpenDDS::DCPS::Serializer::skip(), smContentStart_, sub_, OpenDDS::RTPS::SubmessageHeader::submessageId, and OpenDDS::RTPS::SubmessageHeader::submessageLength.

{
  if(sub_.submessageLength) {
    const size_t read = smContentStart_ - ser_.length();
    return ser_.skip(static_cast<unsigned short>(sub_.submessageLength - read));
  } else if (sub_.submessageId == PAD || sub_.submessageId == INFO_TS) {
    return true;
  } else {
    return ser_.skip(static_cast<unsigned short>(ser_.length()));
  }
}

skipToNextSubmessage()

bool OpenDDS::RTPS::MessageParser::skipToNextSubmessage

(

)

Definition at line 68 of file MessageParser.cpp.

References OpenDDS::DCPS::Serializer::length(), read(), ser_, OpenDDS::DCPS::Serializer::skip(), smContentStart_, sub_, and OpenDDS::RTPS::SubmessageHeader::submessageLength.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::authtag(), OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{
  const size_t read = smContentStart_ - ser_.length();
  return ser_.skip(static_cast<unsigned short>(sub_.submessageLength - read));
}

submessageHeader()

SubmessageHeader OpenDDS::RTPS::MessageParser::submessageHeader ( ) const

inline

Definition at line 34 of file MessageParser.h.

Referenced by OpenDDS::Security::CryptoBuiltInImpl::decode_rtps_message(), and OpenDDS::DCPS::RtpsUdpSendStrategy::encode_submessages().

{ return sub_; }

Member Data Documentation

fromSeq_

ACE_Message_Block OpenDDS::RTPS::MessageParser::fromSeq_

private

Definition at line 44 of file MessageParser.h.

Referenced by MessageParser().

header_

Header OpenDDS::RTPS::MessageParser::header_

private

Definition at line 47 of file MessageParser.h.

Referenced by parseHeader().

in_

DCPS::Message_Block_Ptr OpenDDS::RTPS::MessageParser::in_

private

Definition at line 45 of file MessageParser.h.

ser_

DCPS::Serializer OpenDDS::RTPS::MessageParser::ser_

private

Definition at line 46 of file MessageParser.h.

Referenced by hasNextSubmessage(), parseHeader(), parseSubmessageHeader(), skipSubmessageContent(), and skipToNextSubmessage().

smContentStart_

size_t OpenDDS::RTPS::MessageParser::smContentStart_

private

Definition at line 49 of file MessageParser.h.

Referenced by hasNextSubmessage(), parseSubmessageHeader(), skipSubmessageContent(), and skipToNextSubmessage().

sub_

SubmessageHeader OpenDDS::RTPS::MessageParser::sub_

private

Definition at line 48 of file MessageParser.h.

Referenced by hasNextSubmessage(), parseSubmessageHeader(), skipSubmessageContent(), and skipToNextSubmessage().

---

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

• MessageParser.h
• MessageParser.cpp