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
SequenceNumber	sequence () const
SequenceNumber	last_fragment () const
Static Public Member Functions
static RtpsCustomizedElement *	alloc (TransportQueueElement *orig, ACE_Message_Block *msg, ACE_Allocator *allocator=0)
Private Member Functions
	RtpsCustomizedElement (TransportQueueElement *orig, ACE_Message_Block *msg, ACE_Allocator *allocator)
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 20 of file RtpsCustomizedElement.h.

---

Constructor & Destructor Documentation

ACE_INLINE OpenDDS::DCPS::RtpsCustomizedElement::RtpsCustomizedElement	(	TransportQueueElement *	orig,
		ACE_Message_Block *	msg,
		ACE_Allocator *	allocator
	)			[private]

Definition at line 12 of file RtpsCustomizedElement.inl.

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

Referenced by alloc().

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

OpenDDS::DCPS::RtpsCustomizedElement::~RtpsCustomizedElement

(

)

[private, virtual]

Definition at line 18 of file RtpsCustomizedElement.cpp.

{}

---

Member Function Documentation

ACE_INLINE RtpsCustomizedElement * OpenDDS::DCPS::RtpsCustomizedElement::alloc	(	TransportQueueElement *	orig,
		ACE_Message_Block *	msg,
		ACE_Allocator *	allocator = 0
	)			[static]

Definition at line 24 of file RtpsCustomizedElement.inl.

References OpenDDS::DCPS::TransportCustomizedElement::allocator(), and RtpsCustomizedElement().

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

{
  if (allocator) {
    RtpsCustomizedElement* ret;
    ACE_NEW_MALLOC_RETURN(ret,
      static_cast<RtpsCustomizedElement*>(allocator->malloc(0)),
      RtpsCustomizedElement(orig, msg, allocator),
      0);
    return ret;
  } else {
    return new RtpsCustomizedElement(orig, msg, 0);
  }
}

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 22 of file RtpsCustomizedElement.cpp.

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

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

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

  RtpsCustomizedElement* rest =
    RtpsCustomizedElement::alloc(this, tail, allocator());
  rest->set_fragment();
  rest->last_frag_ = fragNumbers.second;

  return ElementPair(frag, rest);
}

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

(

)

const

Definition at line 50 of file RtpsCustomizedElement.inl.

References last_frag_.

{
  return last_frag_;
}

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 45 of file RtpsCustomizedElement.cpp.

References OpenDDS::DCPS::TransportCustomizedElement::msg().

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

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

(

)

const [virtual]

Reimplemented from OpenDDS::DCPS::TransportCustomizedElement.

Definition at line 42 of file RtpsCustomizedElement.inl.

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

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

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

---

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

---