OpenDDS::DCPS::DataDurabilityCache::sample_data_type Class Reference

Sample list data type for all samples. More...

#include <DataDurabilityCache.h>

Collaboration diagram for OpenDDS::DCPS::DataDurabilityCache::sample_data_type:

Public Member Functions
	sample_data_type ()
	sample_data_type (DataSampleElement &element, ACE_Allocator *allocator)
	sample_data_type (DDS::Time_t timestamp, const ACE_Message_Block &mb, ACE_Allocator *allocator)
	sample_data_type (sample_data_type const &rhs)
	~sample_data_type ()
sample_data_type &	operator= (sample_data_type const &rhs)
void	get_sample (char const *&s, size_t &len, DDS::Time_t &source_timestamp)
void	set_allocator (ACE_Allocator *allocator)

Private Member Functions
void	init (const ACE_Message_Block *data)

Private Attributes
size_t	length_
char *	sample_
DDS::Time_t	source_timestamp_
ACE_Allocator *	allocator_

Detailed Description

Sample list data type for all samples.

Definition at line 147 of file DataDurabilityCache.h.

Constructor & Destructor Documentation

sample_data_type() [1/4]

OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_data_type

(

)

Definition at line 170 of file DataDurabilityCache.cpp.

References DDS::Time_t::nanosec, DDS::Time_t::sec, and source_timestamp_.

  : length_(0)
  , sample_(0)
  , allocator_(0)
{
  this->source_timestamp_.sec = 0;
  this->source_timestamp_.nanosec = 0;
}

sample_data_type() [2/4]

OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_data_type	(	DataSampleElement &	element,
		ACE_Allocator *	allocator
	)

Definition at line 179 of file DataDurabilityCache.cpp.

References ACE_Message_Block::cont(), OpenDDS::DCPS::DataSampleElement::get_header(), OpenDDS::DCPS::DataSampleElement::get_sample(), init(), DDS::Time_t::nanosec, DDS::Time_t::sec, source_timestamp_, OpenDDS::DCPS::DataSampleHeader::source_timestamp_nanosec_, and OpenDDS::DCPS::DataSampleHeader::source_timestamp_sec_.

  : length_(0)
  , sample_(0)
  , allocator_(a)
{
  this->source_timestamp_.sec     = element.get_header().source_timestamp_sec_;
  this->source_timestamp_.nanosec = element.get_header().source_timestamp_nanosec_;

  // Only copy the data provided by the user.  The DataSampleHeader
  // will be reconstructed when the durable data is retrieved by a
  // DataWriterImpl instance.
  //
  // The user's data is stored in the first message block
  // continuation.
  ACE_Message_Block const * const data = element.get_sample()->cont();
  init(data);
}

sample_data_type() [3/4]

OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_data_type	(	DDS::Time_t	timestamp,
		const ACE_Message_Block &	mb,
		ACE_Allocator *	allocator
	)

Definition at line 199 of file DataDurabilityCache.cpp.

References init().

  : length_(0)
  , sample_(0)
  , source_timestamp_(timestamp)
  , allocator_(a)
{
  init(&mb);
}

sample_data_type() [4/4]

OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_data_type

(

sample_data_type const &

rhs

)

Definition at line 229 of file DataDurabilityCache.cpp.

References ACE_ALLOCATOR, allocator_, length_, ACE_Allocator::malloc(), ACE_OS::memcpy(), DDS::Time_t::nanosec, sample_, DDS::Time_t::sec, and source_timestamp_.

  : length_(rhs.length_)
  , sample_(0)
  , allocator_(rhs.allocator_)
{
  this->source_timestamp_.sec     = rhs.source_timestamp_.sec;
  this->source_timestamp_.nanosec = rhs.source_timestamp_.nanosec;

  if (this->allocator_) {
    ACE_ALLOCATOR(this->sample_,
                  static_cast<char *>(
                    this->allocator_->malloc(rhs.length_)));
    ACE_OS::memcpy(this->sample_, rhs.sample_, rhs.length_);
  }
}

~sample_data_type()

OpenDDS::DCPS::DataDurabilityCache::sample_data_type::~sample_data_type

(

)

Definition at line 246 of file DataDurabilityCache.cpp.

References allocator_, ACE_Allocator::free(), and sample_.

{
  if (this->allocator_)
    this->allocator_->free(this->sample_);
}

Member Function Documentation

get_sample()

void OpenDDS::DCPS::DataDurabilityCache::sample_data_type::get_sample	(	char const *&	s,
		size_t &	len,
		DDS::Time_t &	source_timestamp
	)

Definition at line 269 of file DataDurabilityCache.cpp.

References length_, DDS::Time_t::nanosec, sample_, DDS::Time_t::sec, and source_timestamp_.

Referenced by OpenDDS::DCPS::DataDurabilityCache::get_data(), and OpenDDS::DCPS::DataDurabilityCache::insert().

{
  s = this->sample_;
  len = this->length_;
  source_timestamp.sec     = this->source_timestamp_.sec;
  source_timestamp.nanosec = this->source_timestamp_.nanosec;
}

init()

void OpenDDS::DCPS::DataDurabilityCache::sample_data_type::init ( const ACE_Message_Block *  data )

private

Definition at line 211 of file DataDurabilityCache.cpp.

References ACE_ALLOCATOR, allocator_, ACE_Message_Block::cont(), length_, ACE_Allocator::malloc(), ACE_OS::memcpy(), sample_, and ACE_Message_Block::total_length().

Referenced by sample_data_type().

{
  this->length_ = data->total_length();

  ACE_ALLOCATOR(this->sample_,
                static_cast<char *>(
                  this->allocator_->malloc(this->length_)));

  char * buf = this->sample_;

  for (ACE_Message_Block const * i = data;
       i != 0;
       i = i->cont()) {
    ACE_OS::memcpy(buf, i->rd_ptr(), i->length());
    buf += i->length();
  }
}

operator=()

OpenDDS::DCPS::DataDurabilityCache::sample_data_type & OpenDDS::DCPS::DataDurabilityCache::sample_data_type::operator=

(

sample_data_type const &

rhs

)

Definition at line 253 of file DataDurabilityCache.cpp.

References allocator_, length_, DDS::Time_t::nanosec, sample_, DDS::Time_t::sec, source_timestamp_, and OpenDDS::DCPS::swap().

{
  // Strongly exception-safe copy assignment.
  sample_data_type tmp(rhs);
  std::swap(this->length_, tmp.length_);
  std::swap(this->sample_, tmp.sample_);
  std::swap(this->allocator_, tmp.allocator_);

  this->source_timestamp_.sec     = rhs.source_timestamp_.sec;
  this->source_timestamp_.nanosec = rhs.source_timestamp_.nanosec;

  return *this;
}

set_allocator()

void OpenDDS::DCPS::DataDurabilityCache::sample_data_type::set_allocator

(

ACE_Allocator *

allocator

)

Definition at line 281 of file DataDurabilityCache.cpp.

References allocator_.

{
  this->allocator_ = allocator;
}

Member Data Documentation

allocator_

ACE_Allocator* OpenDDS::DCPS::DataDurabilityCache::sample_data_type::allocator_

private

Definition at line 174 of file DataDurabilityCache.h.

Referenced by init(), operator=(), sample_data_type(), set_allocator(), and ~sample_data_type().

length_

size_t OpenDDS::DCPS::DataDurabilityCache::sample_data_type::length_

private

Definition at line 171 of file DataDurabilityCache.h.

Referenced by get_sample(), init(), operator=(), and sample_data_type().

sample_

char* OpenDDS::DCPS::DataDurabilityCache::sample_data_type::sample_

private

Definition at line 172 of file DataDurabilityCache.h.

Referenced by get_sample(), init(), operator=(), sample_data_type(), and ~sample_data_type().

source_timestamp_

DDS::Time_t OpenDDS::DCPS::DataDurabilityCache::sample_data_type::source_timestamp_

private

Definition at line 173 of file DataDurabilityCache.h.

Referenced by get_sample(), operator=(), and sample_data_type().

---

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

• DataDurabilityCache.h
• DataDurabilityCache.cpp