OpenDDS::DCPS::TransportRetainedElement Class Reference

#include <TransportRetainedElement.h>

Inheritance diagram for OpenDDS::DCPS::TransportRetainedElement:

[legend]

Collaboration diagram for OpenDDS::DCPS::TransportRetainedElement:

[legend]

List of all members.

Public Member Functions
	TransportRetainedElement (const ACE_Message_Block *message, const RepoId &pubId, MessageBlockAllocator *mb_allocator_=0, DataBlockAllocator *db_allocator_=0)
	Construct with message block chain and Id values.
	TransportRetainedElement (const TransportRetainedElement &source)
	Copy constructor.
virtual	~TransportRetainedElement ()
TransportQueueElement methods
{
Message_Block_Ptr	msg_
	}
RepoId	publication_id_
	Originating publication Id, if any.
MessageBlockAllocator *	mb_allocator_
	Cached allocator for DataSampleHeader message block.
DataBlockAllocator *	db_allocator_
	Cached allocator for DataSampleHeader data block.
virtual RepoId	publication_id () const
	}
virtual const ACE_Message_Block *	msg () const
	}
virtual const ACE_Message_Block *	msg_payload () const
	}
virtual bool	owned_by_transport ()
	}
virtual void	release_element (bool dropped_by_transport)
	}

---

Detailed Description

Definition at line 23 of file TransportRetainedElement.h.

---

Constructor & Destructor Documentation

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL ACE_INLINE OpenDDS::DCPS::TransportRetainedElement::TransportRetainedElement	(	const ACE_Message_Block *	message,
		const RepoId &	pubId,
		MessageBlockAllocator *	mb_allocator_ = 0,
		DataBlockAllocator *	db_allocator_ = 0
	)

Construct with message block chain and Id values.

Definition at line 13 of file TransportRetainedElement.inl.

References OpenDDS::DCPS::TransportQueueElement::clone_mb(), db_allocator_, mb_allocator_, msg_, and OpenDDS::DCPS::unique_ptr< T, Deleter >::reset().

  : TransportQueueElement(1),
    publication_id_( pubId),
    mb_allocator_( mb_allocator),
    db_allocator_( db_allocator)
{
  if (message != 0) {
    msg_.reset(TransportQueueElement::clone_mb(message,
                                           this->mb_allocator_,
                                           this->db_allocator_));
  }
}

Here is the call graph for this function:

ACE_INLINE OpenDDS::DCPS::TransportRetainedElement::TransportRetainedElement

(

const TransportRetainedElement &

source

)

Copy constructor.

Definition at line 31 of file TransportRetainedElement.inl.

References DBG_ENTRY_LVL.

  : TransportQueueElement(1),
    msg_( ACE_Message_Block::duplicate( source.msg())),
    publication_id_( source.publication_id()),
    mb_allocator_( source.mb_allocator_),
    db_allocator_( source.db_allocator_)
{
  DBG_ENTRY_LVL("TransportRetainedElement","TransportRetainedElement",6);
}

OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL OpenDDS::DCPS::TransportRetainedElement::~TransportRetainedElement

(

)

[virtual]

Definition at line 17 of file TransportRetainedElement.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TransportRetainedElement","~TransportRetainedElement",6);
}

---

Member Function Documentation

const ACE_Message_Block * OpenDDS::DCPS::TransportRetainedElement::msg

(

void

)

const [virtual]

}

Sample data, if any.

Implements OpenDDS::DCPS::TransportQueueElement.

Definition at line 39 of file TransportRetainedElement.cpp.

References DBG_ENTRY_LVL, OpenDDS::DCPS::unique_ptr< T, Deleter >::get(), and msg_.

{
  DBG_ENTRY_LVL("TransportRetainedElement","msg",6);
  return this->msg_.get();
}

Here is the call graph for this function:

const ACE_Message_Block * OpenDDS::DCPS::TransportRetainedElement::msg_payload

(

)

const [virtual]

}

Sample data, if any.

Implements OpenDDS::DCPS::TransportQueueElement.

Definition at line 46 of file TransportRetainedElement.cpp.

References DBG_ENTRY_LVL, and msg_.

{
  DBG_ENTRY_LVL("TransportRetainedElement", "msg_payload", 6);
  return this->msg_->cont();
}

ACE_INLINE bool OpenDDS::DCPS::TransportRetainedElement::owned_by_transport

(

)

[virtual]

}

Sample data, if any.

Implements OpenDDS::DCPS::TransportQueueElement.

Definition at line 45 of file TransportRetainedElement.inl.

{
  return true;
}

OpenDDS::DCPS::RepoId OpenDDS::DCPS::TransportRetainedElement::publication_id

(

)

const [virtual]

}

Sample data, if any.

Implements OpenDDS::DCPS::TransportQueueElement.

Definition at line 32 of file TransportRetainedElement.cpp.

References DBG_ENTRY_LVL, and publication_id_.

{
  DBG_ENTRY_LVL("TransportRetainedElement","publication_id",6);
  return this->publication_id_;
}

void OpenDDS::DCPS::TransportRetainedElement::release_element

(

bool

dropped_by_transport

)

[protected, virtual]

}

Sample data, if any.

Implements OpenDDS::DCPS::TransportQueueElement.

Definition at line 23 of file TransportRetainedElement.cpp.

References DBG_ENTRY_LVL.

{
  DBG_ENTRY_LVL("TransportRetainedElement","release_element",6);
  delete this;
}

---

Member Data Documentation

DataBlockAllocator* OpenDDS::DCPS::TransportRetainedElement::db_allocator_ [private]

Cached allocator for DataSampleHeader data block.

Definition at line 63 of file TransportRetainedElement.h.

Referenced by TransportRetainedElement().

MessageBlockAllocator* OpenDDS::DCPS::TransportRetainedElement::mb_allocator_ [private]

Cached allocator for DataSampleHeader message block.

Definition at line 61 of file TransportRetainedElement.h.

Referenced by TransportRetainedElement().

Message_Block_Ptr OpenDDS::DCPS::TransportRetainedElement::msg_ [private]

}

Sample data, if any.

Definition at line 55 of file TransportRetainedElement.h.

Referenced by msg(), msg_payload(), and TransportRetainedElement().

RepoId OpenDDS::DCPS::TransportRetainedElement::publication_id_ [private]

Originating publication Id, if any.

Definition at line 58 of file TransportRetainedElement.h.

Referenced by publication_id().

---

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

• TransportRetainedElement.h
• TransportRetainedElement.cpp
• TransportRetainedElement.inl