OpenDDS::DCPS::MessageBlock Class Reference

#include <MessageBlock.h>

Collaboration diagram for OpenDDS::DCPS::MessageBlock:

Public Member Functions
	MessageBlock (const ACE_Message_Block &amb)
	construct a MessageBlock that references the existing amb's ACE_Data_Block More...
	MessageBlock (size_t size)
	construct a MessageBlock with 'size' bytes allocated but not used (wr_ptr_ is 0) More...
	MessageBlock (const char *data, size_t size)
	construct a MessageBlock that points to external data, doesn't allocate or copy More...
	~MessageBlock ()
	MessageBlock (const MessageBlock &rhs)
MessageBlock &	operator= (const MessageBlock &rhs)
void	swap (MessageBlock &rhs)
ACE_Data_Block *	duplicate_data () const
char *	base () const
char *	rd_ptr () const
void	read (size_t diff)
void	unread (size_t diff)
char *	wr_ptr () const
void	write (size_t diff)
void	unwrite (size_t diff)
size_t	len () const

Private Attributes
ACE_Data_Block *	data_
size_t	rd_ptr_
size_t	wr_ptr_

Detailed Description

Definition at line 19 of file MessageBlock.h.

Constructor & Destructor Documentation

MessageBlock() [1/4]

OpenDDS::DCPS::MessageBlock::MessageBlock ( const ACE_Message_Block &  amb )

explicit

construct a MessageBlock that references the existing amb's ACE_Data_Block

Definition at line 43 of file MessageBlock.cpp.

Referenced by operator=().

  : data_(amb.data_block()->duplicate())
  , rd_ptr_(amb.rd_ptr() - amb.base())
  , wr_ptr_(amb.wr_ptr() - amb.base())
{}

MessageBlock() [2/4]

OpenDDS::DCPS::MessageBlock::MessageBlock ( size_t  size )

explicit

construct a MessageBlock with 'size' bytes allocated but not used (wr_ptr_ is 0)

Definition at line 19 of file MessageBlock.cpp.

References ACE_NEW_MALLOC, data_, ACE_Allocator::instance(), ACE_Allocator::malloc(), and ACE_Message_Block::MB_DATA.

  : data_()
  , rd_ptr_()
  , wr_ptr_()
{
  ACE_Allocator* const alloc = ACE_Allocator::instance();
  ACE_NEW_MALLOC(data_,
    (ACE_Data_Block*) alloc->malloc(sizeof(ACE_Data_Block)),
    ACE_Data_Block(size, ACE_Message_Block::MB_DATA, 0, alloc, 0,
                   0, alloc));
}

MessageBlock() [3/4]

OpenDDS::DCPS::MessageBlock::MessageBlock	(	const char *	data,
		size_t	size
	)

construct a MessageBlock that points to external data, doesn't allocate or copy

Definition at line 31 of file MessageBlock.cpp.

References ACE_NEW_MALLOC, data_, ACE_Message_Block::DONT_DELETE, ACE_Allocator::instance(), ACE_Allocator::malloc(), and ACE_Message_Block::MB_DATA.

  : data_()
  , rd_ptr_()
  , wr_ptr_(size)
{
  ACE_Allocator* const alloc = ACE_Allocator::instance();
  ACE_NEW_MALLOC(data_,
    (ACE_Data_Block*) alloc->malloc(sizeof(ACE_Data_Block)),
    ACE_Data_Block(size, ACE_Message_Block::MB_DATA, data, alloc, 0,
                   ACE_Message_Block::DONT_DELETE, alloc));
}

~MessageBlock()

OpenDDS::DCPS::MessageBlock::~MessageBlock

(

)

Definition at line 55 of file MessageBlock.cpp.

References data_, and ACE_Data_Block::release().

{
  if (data_) {
    data_->release();
  }
}

MessageBlock() [4/4]

OpenDDS::DCPS::MessageBlock::MessageBlock

(

const MessageBlock &

rhs

)

Definition at line 49 of file MessageBlock.cpp.

  : data_(rhs.data_->duplicate())
  , rd_ptr_(rhs.rd_ptr_)
  , wr_ptr_(rhs.wr_ptr_)
{}

Member Function Documentation

base()

char* OpenDDS::DCPS::MessageBlock::base ( void  ) const

inline

Definition at line 43 of file MessageBlock.h.

{ return data_->base(); }

duplicate_data()

ACE_Data_Block* OpenDDS::DCPS::MessageBlock::duplicate_data ( ) const

inline

Definition at line 41 of file MessageBlock.h.

References ACE_Data_Block::duplicate().

Referenced by OpenDDS::DCPS::ReceivedDataSample::data().

{ return data_->duplicate(); }

len()

size_t OpenDDS::DCPS::MessageBlock::len ( void  ) const

inline

Definition at line 53 of file MessageBlock.h.

Referenced by OpenDDS::DCPS::ReceivedDataSample::copy_data(), OpenDDS::DCPS::ReceivedDataSample::peek(), and OpenDDS::DCPS::ReceivedDataSample::write_data().

{ return wr_ptr_ - rd_ptr_; }

operator=()

MessageBlock & OpenDDS::DCPS::MessageBlock::operator=

(

const MessageBlock &

rhs

)

Definition at line 71 of file MessageBlock.cpp.

References copy(), data_, MessageBlock(), rd_ptr_, swap(), and wr_ptr_.

{
  if (&rhs != this) {
    MessageBlock copy(rhs);
    swap(copy);
  }
  return *this;
}

rd_ptr()

char* OpenDDS::DCPS::MessageBlock::rd_ptr ( void  ) const

inline

Definition at line 45 of file MessageBlock.h.

Referenced by OpenDDS::DCPS::ReceivedDataSample::copy_data(), OpenDDS::DCPS::ReceivedDataSample::data(), OpenDDS::DCPS::ReceivedDataSample::peek(), and OpenDDS::DCPS::ReceivedDataSample::write_data().

{ return base() + rd_ptr_; }

read()

void OpenDDS::DCPS::MessageBlock::read ( size_t  diff )

inline

Definition at line 46 of file MessageBlock.h.

{ rd_ptr_ += diff; }

swap()

void OpenDDS::DCPS::MessageBlock::swap

(

MessageBlock &

rhs

)

Definition at line 63 of file MessageBlock.cpp.

References data_, rd_ptr_, OpenDDS::DCPS::swap(), and wr_ptr_.

Referenced by operator=(), and OpenDDS::DCPS::swap().

{
  std::swap(data_, rhs.data_);
  std::swap(rd_ptr_, rhs.rd_ptr_);
  std::swap(wr_ptr_, rhs.wr_ptr_);
}

unread()

void OpenDDS::DCPS::MessageBlock::unread ( size_t  diff )

inline

Definition at line 47 of file MessageBlock.h.

{ rd_ptr_ -= diff; }

unwrite()

void OpenDDS::DCPS::MessageBlock::unwrite ( size_t  diff )

inline

Definition at line 51 of file MessageBlock.h.

{ wr_ptr_ -= diff; }

wr_ptr()

char* OpenDDS::DCPS::MessageBlock::wr_ptr ( void  ) const

inline

Definition at line 49 of file MessageBlock.h.

Referenced by OpenDDS::DCPS::ReceivedDataSample::data().

{ return base() + wr_ptr_; }

write()

void OpenDDS::DCPS::MessageBlock::write ( size_t  diff )

inline

Definition at line 50 of file MessageBlock.h.

{ wr_ptr_ += diff; }

Member Data Documentation

data_

ACE_Data_Block* OpenDDS::DCPS::MessageBlock::data_

private

Definition at line 56 of file MessageBlock.h.

Referenced by MessageBlock(), operator=(), swap(), and ~MessageBlock().

rd_ptr_

size_t OpenDDS::DCPS::MessageBlock::rd_ptr_

private

Definition at line 57 of file MessageBlock.h.

Referenced by operator=(), and swap().

wr_ptr_

size_t OpenDDS::DCPS::MessageBlock::wr_ptr_

private

Definition at line 58 of file MessageBlock.h.

Referenced by operator=(), and swap().

---

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

• MessageBlock.h
• MessageBlock.cpp