TransportReplacedElement.inl

Go to the documentation of this file.
00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 #include "EntryExit.h"
00009 
00010 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
00011 
00012 ACE_INLINE
00013 OpenDDS::DCPS::TransportReplacedElement::TransportReplacedElement
00014 (TransportQueueElement* orig_elem,
00015  MessageBlockAllocator* mb_allocator,
00016  DataBlockAllocator* db_allocator)
00017   : TransportQueueElement(1)
00018   , mb_allocator_ (mb_allocator)
00019   , db_allocator_ (db_allocator)
00020 {
00021   DBG_ENTRY_LVL("TransportReplacedElement","TransportReplacedElement",6);
00022 
00023   // Obtain the publisher id.
00024   this->publisher_id_ = orig_elem->publication_id();
00025 
00026   this->msg_.reset(TransportQueueElement::clone_mb(orig_elem->msg(),
00027                                                this->mb_allocator_,
00028                                                this->db_allocator_));
00029 }
00030 
00031 ACE_INLINE
00032 OpenDDS::DCPS::RepoId
00033 OpenDDS::DCPS::TransportReplacedElement::publication_id() const
00034 {
00035   DBG_ENTRY_LVL("TransportReplacedElement","publication_id",6);
00036   return this->publisher_id_;
00037 }
00038 
00039 ACE_INLINE
00040 const ACE_Message_Block*
00041 OpenDDS::DCPS::TransportReplacedElement::msg() const
00042 {
00043   DBG_ENTRY_LVL("TransportReplacedElement","msg",6);
00044   return this->msg_.get();
00045 }
00046 
00047 ACE_INLINE
00048 const ACE_Message_Block*
00049 OpenDDS::DCPS::TransportReplacedElement::msg_payload() const
00050 {
00051   DBG_ENTRY_LVL("TransportReplacedElement", "msg_payload", 6);
00052   return this->msg_->cont();
00053 }
00054 
00055 ACE_INLINE
00056 bool
00057 OpenDDS::DCPS::TransportReplacedElement::owned_by_transport ()
00058 {
00059   return true;
00060 }
00061 
00062 OPENDDS_END_VERSIONED_NAMESPACE_DECL