OpenDDS::DCPS::GroupRakeData Class Reference

#include <GroupRakeData.h>

Classes
class	SortedSetCmp

Public Member Functions
	GroupRakeData ()
bool	insert_sample (ReceivedDataElement *sample, ReceivedDataElementList *rdel, SubscriptionInstance_rch i, size_t index_in_instance)
void	get_datareaders (DDS::DataReaderSeq &readers)
bool	copy_to_user ()
void	reset ()
RakeData	get_data ()

Private Member Functions
	GroupRakeData (const GroupRakeData &)
GroupRakeData &	operator= (const GroupRakeData &)
typedef	OPENDDS_MULTISET_CMP (RakeData, SortedSetCmp) SortedSet

Private Attributes
SortedSet	sorted_
SortedSet::iterator	current_sample_

Detailed Description

Rake is an abbreviation for "read or take". This class manages the results from a read() or take() operation, which are the received_data and the info_seq sequences passed in by-reference from the user.

Definition at line 33 of file GroupRakeData.h.

Constructor & Destructor Documentation

GroupRakeData() [1/2]

OpenDDS::DCPS::GroupRakeData::GroupRakeData

(

)

Definition at line 19 of file GroupRakeData.cpp.

{
}

GroupRakeData() [2/2]

OpenDDS::DCPS::GroupRakeData::GroupRakeData ( const GroupRakeData &  )

private

Member Function Documentation

copy_to_user()

bool OpenDDS::DCPS::GroupRakeData::copy_to_user

(

)

get_data()

RakeData OpenDDS::DCPS::GroupRakeData::get_data

(

)

Definition at line 71 of file GroupRakeData.cpp.

References current_sample_, and OPENDDS_END_VERSIONED_NAMESPACE_DECL.

{
  RakeData data = *this->current_sample_;
  ++this->current_sample_;
  return data;
}

get_datareaders()

void OpenDDS::DCPS::GroupRakeData::get_datareaders

(

DDS::DataReaderSeq &

readers

)

Definition at line 44 of file GroupRakeData.cpp.

References OpenDDS::DCPS::RcHandle< T >::in(), and sorted_.

Referenced by OpenDDS::DCPS::SubscriberImpl::get_datareaders().

{
  ACE_UNUSED_ARG(readers);
#ifndef OPENDDS_NO_OBJECT_MODEL_PROFILE
  readers.length(static_cast<CORBA::ULong>(this->sorted_.size()));
  CORBA::ULong i = 0;
  SortedSet::iterator itEnd = this->sorted_.end();
  for (SortedSet::iterator it = this->sorted_.begin(); it != itEnd; ++it) {
    RcHandle<DDS::DataReader> reader = it->si_->instance_state_->data_reader().lock();
    if (reader) {
      readers[i++] = DDS::DataReader::_duplicate(reader.in());
    } else {
      readers.length(readers.length() - 1);
    }
  }
#endif
}

insert_sample()

bool OpenDDS::DCPS::GroupRakeData::insert_sample	(	ReceivedDataElement *	sample,
		ReceivedDataElementList *	rdel,
		SubscriptionInstance_rch	i,
		size_t	index_in_instance
	)

Returns false if the sample will definitely not be part of the resulting dataset, however if this returns true it still may be excluded (due to sorting and max_samples).

Definition at line 24 of file GroupRakeData.cpp.

References current_sample_, sorted_, and OpenDDS::DCPS::ReceivedDataElement::valid_data_.

Referenced by OpenDDS::DCPS::DataReaderImpl::get_ordered_data().

{
  // Ignore DISPOSE and UNREGISTER messages in case they are sent
  // in the group coherent changes, but it shouldn't.
  if (!sample->valid_data_) {
    return false;
  }

  RakeData rd = {sample, rdel, instance, index_in_instance};
  this->sorted_.insert(rd);

  this->current_sample_ = this->sorted_.begin();
  return true;
}

OPENDDS_MULTISET_CMP()

typedef OpenDDS::DCPS::GroupRakeData::OPENDDS_MULTISET_CMP ( RakeData  , SortedSetCmp    )

private

operator=()

GroupRakeData& OpenDDS::DCPS::GroupRakeData::operator= ( const GroupRakeData &  )

private

reset()

void OpenDDS::DCPS::GroupRakeData::reset

(

void

)

Definition at line 64 of file GroupRakeData.cpp.

References sorted_.

{
  this->sorted_.clear();
}

Member Data Documentation

current_sample_

SortedSet::iterator OpenDDS::DCPS::GroupRakeData::current_sample_

private

Definition at line 82 of file GroupRakeData.h.

Referenced by get_data(), and insert_sample().

sorted_

SortedSet OpenDDS::DCPS::GroupRakeData::sorted_

private

Definition at line 80 of file GroupRakeData.h.

Referenced by get_datareaders(), insert_sample(), and reset().

---

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

• GroupRakeData.h
• GroupRakeData.cpp