OpenDDS::DCPS::RtpsCustomizedElement Class Reference

#include <RtpsCustomizedElement.h>

Inheritance diagram for OpenDDS::DCPS::RtpsCustomizedElement:

[legend]

Collaboration diagram for OpenDDS::DCPS::RtpsCustomizedElement:

[legend]

List of all members.

Public Member Functions
	RtpsCustomizedElement (TransportQueueElement *orig, Message_Block_Ptr msg)
SequenceNumber	sequence () const
SequenceNumber	last_fragment () const
Private Member Functions
virtual	~RtpsCustomizedElement ()
ElementPair	fragment (size_t size)
const ACE_Message_Block *	msg_payload () const
	The marshalled payload only (sample data).
Private Attributes
SequenceNumber	seq_
SequenceNumber	last_frag_

---

Detailed Description

Definition at line 22 of file RtpsCustomizedElement.h.

---

Constructor & Destructor Documentation

ACE_INLINE OpenDDS::DCPS::RtpsCustomizedElement::RtpsCustomizedElement	(	TransportQueueElement *	orig,
		Message_Block_Ptr	msg
	)

Definition at line 14 of file RtpsCustomizedElement.inl.

References OpenDDS::DCPS::move(), OpenDDS::DCPS::TransportCustomizedElement::set_msg(), and OpenDDS::DCPS::TransportCustomizedElement::set_requires_exclusive().

Referenced by fragment().

  : TransportCustomizedElement(orig, false)
  , seq_(SequenceNumber::SEQUENCENUMBER_UNKNOWN())
{
  set_requires_exclusive();
  set_msg(move(msg));
}

Here is the call graph for this function:

Here is the caller graph for this function:

OpenDDS::DCPS::RtpsCustomizedElement::~RtpsCustomizedElement

(

)

[private, virtual]

Definition at line 20 of file RtpsCustomizedElement.cpp.

{}

---

Member Function Documentation

ElementPair OpenDDS::DCPS::RtpsCustomizedElement::fragment

(

size_t

size

)

[private, virtual]

Create two TransportQueueElements representing the same data payload as the current TransportQueueElement, with the first one (including its DataSampleHeader) fitting in "size" bytes. This method leaves the current TransportQueueElement alone (but can't be made const because the newly-created elements will need to invoke non-const methods on it). Each element in the pair will contain its own serialized modified DataSampleHeader.

Reimplemented from OpenDDS::DCPS::TransportQueueElement.

Definition at line 24 of file RtpsCustomizedElement.cpp.

References last_frag_, OpenDDS::DCPS::move(), OpenDDS::DCPS::TransportCustomizedElement::msg(), OpenDDS::DCPS::TransportCustomizedElement::publication_id(), RtpsCustomizedElement(), seq_, sequence(), OpenDDS::DCPS::TransportCustomizedElement::set_fragment(), OpenDDS::DCPS::TransportCustomizedElement::set_publication_id(), and OpenDDS::DCPS::RtpsSampleHeader::split().

{
  Message_Block_Ptr head;
  Message_Block_Ptr tail;
  const SequenceRange fragNumbers =
    RtpsSampleHeader::split(*msg(), size, head, tail);

  RtpsCustomizedElement* frag =
    new RtpsCustomizedElement(0, move(head));
  frag->set_publication_id(publication_id());
  frag->seq_ = sequence();
  frag->set_fragment();
  frag->last_frag_ = fragNumbers.first;

  RtpsCustomizedElement* rest =
    new RtpsCustomizedElement(this, move(tail));
  rest->set_fragment();
  rest->last_frag_ = fragNumbers.second;

  return ElementPair(frag, rest);
}

Here is the call graph for this function:

ACE_INLINE SequenceNumber OpenDDS::DCPS::RtpsCustomizedElement::last_fragment

(

)

const

Definition at line 34 of file RtpsCustomizedElement.inl.

References last_frag_.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::MultiSendBuffer::insert().

{
  return last_frag_;
}

Here is the caller graph for this function:

const ACE_Message_Block * OpenDDS::DCPS::RtpsCustomizedElement::msg_payload

(

)

const [private, virtual]

The marshalled payload only (sample data).

Reimplemented from OpenDDS::DCPS::TransportCustomizedElement.

Definition at line 47 of file RtpsCustomizedElement.cpp.

References ACE_Message_Block::cont(), and OpenDDS::DCPS::TransportCustomizedElement::msg().

{
  return msg() ? msg()->cont() : 0;
}

Here is the call graph for this function:

ACE_INLINE SequenceNumber OpenDDS::DCPS::RtpsCustomizedElement::sequence

(

)

const [virtual]

Reimplemented from OpenDDS::DCPS::TransportCustomizedElement.

Definition at line 26 of file RtpsCustomizedElement.inl.

References seq_, and OpenDDS::DCPS::SequenceNumber::SEQUENCENUMBER_UNKNOWN().

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::customize_queue_element(), and fragment().

{
  return (seq_ == SequenceNumber::SEQUENCENUMBER_UNKNOWN()) ?
    TransportCustomizedElement::sequence() : seq_;
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

Member Data Documentation

SequenceNumber OpenDDS::DCPS::RtpsCustomizedElement::last_frag_ [private]

Definition at line 40 of file RtpsCustomizedElement.h.

Referenced by fragment(), and last_fragment().

SequenceNumber OpenDDS::DCPS::RtpsCustomizedElement::seq_ [private]

Definition at line 40 of file RtpsCustomizedElement.h.

Referenced by fragment(), and sequence().

---

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

• RtpsCustomizedElement.h
• RtpsCustomizedElement.cpp
• RtpsCustomizedElement.inl