RtpsSampleHeader.cpp File Reference

#include "RtpsSampleHeader.h"
#include "RtpsUdpSendStrategy.h"
#include "dds/DCPS/Serializer.h"
#include "dds/DCPS/DataSampleElement.h"
#include "dds/DCPS/Marked_Default_Qos.h"
#include "dds/DCPS/Qos_Helper.h"
#include "dds/DCPS/Service_Participant.h"
#include "dds/DCPS/DisjointSequence.h"
#include "dds/DCPS/RTPS/RtpsCoreTypeSupportImpl.h"
#include "dds/DCPS/RTPS/MessageTypes.h"
#include "dds/DCPS/RTPS/BaseMessageTypes.h"
#include "dds/DCPS/transport/framework/ReceivedDataSample.h"
#include "dds/DCPS/transport/framework/TransportSendListener.h"
#include <cstring>
#include "RtpsSampleHeader.inl"

Include dependency graph for RtpsSampleHeader.cpp:

Go to the source code of this file.

Namespaces
namespace	OpenDDS
namespace	OpenDDS::RTPS
namespace	OpenDDS::DCPS
Defines
#define	CASE_SMKIND(kind, class, name)
#define	PROCESS_INLINE_QOS(QOS_NAME, DEFAULT_QOS, WRITER_QOS)
Enumerations
enum	{   FLAG_E = 1, FLAG_Q = 2, FLAG_D = 4, FLAG_K_IN_DATA = 8,   FLAG_K_IN_FRAG = 4 }
Functions
bool	OpenDDS::RTPS::operator== (const StatusInfo_t &lhs, const StatusInfo_t &rhs)
void	OpenDDS::DCPS::add_timestamp (RTPS::SubmessageSeq &subm, ACE_CDR::Octet flags, const DataSampleHeader &header)
void	OpenDDS::DCPS::add_key_hash (RTPS::ParameterList &plist, const ACE_Message_Block *data)
void	OpenDDS::DCPS::write (ACE_Message_Block *mb, ACE_CDR::UShort s, bool swap_bytes)
void	OpenDDS::DCPS::write (ACE_Message_Block *mb, ACE_CDR::ULong i, bool swap_bytes)
void	OpenDDS::DCPS::peek (ACE_CDR::UShort &target, const char *src, bool swap_bytes)
void	OpenDDS::DCPS::peek (ACE_CDR::ULong &target, const char *src, bool swap_bytes)
Variables
const OpenDDS::RTPS::StatusInfo_t	STATUS_INFO_REGISTER = { { 0, 0, 0, 0 } }
const OpenDDS::RTPS::StatusInfo_t	STATUS_INFO_DISPOSE = { { 0, 0, 0, 1 } }
const OpenDDS::RTPS::StatusInfo_t	STATUS_INFO_UNREGISTER = { { 0, 0, 0, 2 } }
const OpenDDS::RTPS::StatusInfo_t	STATUS_INFO_DISPOSE_UNREGISTER = { { 0, 0, 0, 3 } }
const size_t	OpenDDS::DCPS::FRAG_START_OFFSET = 24
const size_t	OpenDDS::DCPS::FRAG_SAMPLE_SIZE_OFFSET = 32

---

Define Documentation

#define CASE_SMKIND	(	kind,
		class,
		name		)

Value:

case kind: {               \
    class submessage;                                             \
    if (ser >> submessage) {                                      \
      octetsToNextHeader = submessage.smHeader.submessageLength;  \
      submessage_.name##_sm(submessage);                          \
      valid_ = true;                                              \
    }                                                             \
    break;                                                        \
  }

Referenced by OpenDDS::DCPS::RtpsSampleHeader::init().

#define PROCESS_INLINE_QOS	(	QOS_NAME,
		DEFAULT_QOS,
		WRITER_QOS		)

Value:

if (WRITER_QOS.QOS_NAME != DEFAULT_QOS.QOS_NAME) {          \
    const int qos_len = plist.length();                       \
    plist.length(qos_len + 1);                                \
    plist[qos_len].QOS_NAME(WRITER_QOS.QOS_NAME);             \
  }

Definition at line 503 of file RtpsSampleHeader.cpp.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_inline_qos().

---

Enumeration Type Documentation

anonymous enum

Enumerator:

FLAG_E
FLAG_Q
FLAG_D
FLAG_K_IN_DATA
FLAG_K_IN_FRAG

Definition at line 32 of file RtpsSampleHeader.cpp.

       { FLAG_E = 1, FLAG_Q = 2, FLAG_D = 4,
         FLAG_K_IN_DATA = 8, FLAG_K_IN_FRAG = 4 };

---

Variable Documentation

const OpenDDS::RTPS::StatusInfo_t STATUS_INFO_DISPOSE = { { 0, 0, 0, 1 } } [static]

Definition at line 36 of file RtpsSampleHeader.cpp.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

const OpenDDS::RTPS::StatusInfo_t STATUS_INFO_DISPOSE_UNREGISTER = { { 0, 0, 0, 3 } } [static]

Definition at line 38 of file RtpsSampleHeader.cpp.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

const OpenDDS::RTPS::StatusInfo_t STATUS_INFO_REGISTER = { { 0, 0, 0, 0 } } [static]

Definition at line 35 of file RtpsSampleHeader.cpp.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

const OpenDDS::RTPS::StatusInfo_t STATUS_INFO_UNREGISTER = { { 0, 0, 0, 2 } } [static]

Definition at line 37 of file RtpsSampleHeader.cpp.

Referenced by OpenDDS::DCPS::RtpsSampleHeader::populate_data_control_submessages(), and OpenDDS::DCPS::RtpsSampleHeader::process_iqos().

---