Line data Source code
1 : /* 2 : * 3 : * 4 : * Distributed under the OpenDDS License. 5 : * See: http://www.opendds.org/license.html 6 : */ 7 : 8 : #include "DCPS/DdsDcps_pch.h" //Only the _pch include should start with DCPS/ 9 : #include "TransportRetainedElement.h" 10 : 11 : #if !defined (__ACE_INLINE__) 12 : #include "TransportRetainedElement.inl" 13 : #endif /* __ACE_INLINE__ */ 14 : 15 : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 16 : 17 4 : OpenDDS::DCPS::TransportRetainedElement::~TransportRetainedElement() 18 : { 19 : DBG_ENTRY_LVL("TransportRetainedElement", "~TransportRetainedElement", 6); 20 4 : } 21 : 22 : void 23 2 : OpenDDS::DCPS::TransportRetainedElement::release_element( 24 : bool /* dropped_by_transport */ 25 : ) 26 : { 27 : DBG_ENTRY_LVL("TransportRetainedElement", "release_element", 6); 28 2 : delete this; 29 2 : } 30 : 31 : OpenDDS::DCPS::GUID_t 32 0 : OpenDDS::DCPS::TransportRetainedElement::publication_id() const 33 : { 34 : DBG_ENTRY_LVL("TransportRetainedElement", "publication_id", 6); 35 0 : return publication_id_; 36 : } 37 : 38 : ACE_Message_Block* 39 0 : OpenDDS::DCPS::TransportRetainedElement::duplicate_msg() const 40 : { 41 : DBG_ENTRY_LVL("TransportRetainedElement", "duplicate_msg", 6); 42 0 : return msg_->duplicate(); 43 : } 44 : 45 : const ACE_Message_Block* 46 16 : OpenDDS::DCPS::TransportRetainedElement::msg() const 47 : { 48 : DBG_ENTRY_LVL("TransportRetainedElement", "msg", 6); 49 16 : return msg_.get(); 50 : } 51 : 52 : const ACE_Message_Block* 53 0 : OpenDDS::DCPS::TransportRetainedElement::msg_payload() const 54 : { 55 : DBG_ENTRY_LVL("TransportRetainedElement", "msg_payload", 6); 56 0 : return msg_->cont(); 57 : } 58 : 59 : OPENDDS_END_VERSIONED_NAMESPACE_DECL