00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00009 00010 namespace OpenDDS { 00011 namespace DCPS { 00012 00013 ACE_INLINE 00014 RtpsCustomizedElement::RtpsCustomizedElement(TransportQueueElement* orig, 00015 Message_Block_Ptr msg) 00016 : TransportCustomizedElement(orig, false) 00017 , seq_(SequenceNumber::SEQUENCENUMBER_UNKNOWN()) 00018 { 00019 set_requires_exclusive(); 00020 set_msg(move(msg)); 00021 } 00022 00023 00024 ACE_INLINE 00025 SequenceNumber 00026 RtpsCustomizedElement::sequence() const 00027 { 00028 return (seq_ == SequenceNumber::SEQUENCENUMBER_UNKNOWN()) ? 00029 TransportCustomizedElement::sequence() : seq_; 00030 } 00031 00032 ACE_INLINE 00033 SequenceNumber 00034 RtpsCustomizedElement::last_fragment() const 00035 { 00036 return last_frag_; 00037 } 00038 00039 } 00040 } 00041 00042 OPENDDS_END_VERSIONED_NAMESPACE_DECL